Home
last modified time | relevance | path

Searched refs:Long (Results 1 – 11 of 11) sorted by relevance

/unit/src/java/nginx/unit/websocket/
H A DAsyncChannelWrapperSecure.java113 WrapperFuture<Long,Void> inner = new WrapperFuture<>(); in write()
132 CompletionHandler<Long,B> handler) { in write() argument
134 WrapperFuture<Long,B> future = in write()
174 private final WrapperFuture<Long,?> future;
177 WrapperFuture<Long,?> future) { in WriteTask() argument
233 future.complete(Long.valueOf(written)); in run()
519 private final Future<Long> wrapped;
521 public LongToIntegerFuture(Future<Long> wrapped) { in LongToIntegerFuture()
542 Long result = wrapped.get(); in get()
554 Long result = wrapped.get(timeout, unit); in get()
H A DWsFrameBase.java224 Integer.toString(rsv), Integer.toString(opCode), Long.toString(payloadLength))); in processInitialHeader()
269 sm.getString("wsFrame.controlPayloadTooBig", Long.valueOf(payloadLength)))); in processRemainingHeader()
382 Long.valueOf(messageBufferText.remaining()), in sendMessageText()
383 Long.valueOf(maxMessageSize)))); in sendMessageText()
518 Long.valueOf(payloadLength))); in processDataBinary()
572 Long.valueOf(msg.remaining()), in sendMessageBinary()
573 Long.valueOf(maxMessageSize)))); in sendMessageBinary()
668 throw new IOException(sm.getString("wsFrame.byteToLongFail", Long.valueOf(len))); in byteArrayToLong()
H A DAsyncChannelWrapper.java42 CompletionHandler<Long,B> handler); in write() argument
H A DWsRemoteEndpointImplClient.java51 timeout = Long.MAX_VALUE; in doWrite()
H A DFutureToSendHandler.java105 Long.valueOf(timeout), unit.toString().toLowerCase())); in get()
H A DAsyncChannelWrapperNonSecure.java63 CompletionHandler<Long,B> handler) { in write() argument
H A DAsyncChannelGroupUtil.java89 Long.MAX_VALUE, TimeUnit.MILLISECONDS, in createAsynchronousChannelGroup()
H A DUtil.java299 clazz.equals(Long.class) || in isPrimitive()
322 } else if (type.equals(long.class) || type.equals(Long.class)) { in coerceToType()
323 return Long.valueOf(value); in coerceToType()
H A DWsRemoteEndpointImplBase.java272 return Long.MAX_VALUE; in getTimeoutExpiry()
471 Long userTimeout = null; in getBlockingSendTimeout()
472 if (obj instanceof Long) { in getBlockingSendTimeout()
473 userTimeout = (Long) obj; in getBlockingSendTimeout()
H A DWsSession.java197 this.id = Long.toHexString(ids.getAndIncrement()); in WsSession()
H A DWsWebSocketContainer.java291 timeout = Long.valueOf(timeoutValue).intValue(); in connectToServerRecursive()