Searched refs:Long (Results 1 – 11 of 11) sorted by relevance
/unit/src/java/nginx/unit/websocket/ |
H A D | AsyncChannelWrapperSecure.java | 113 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 D | WsFrameBase.java | 224 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 D | AsyncChannelWrapper.java | 42 CompletionHandler<Long,B> handler); in write() argument
|
H A D | WsRemoteEndpointImplClient.java | 51 timeout = Long.MAX_VALUE; in doWrite()
|
H A D | FutureToSendHandler.java | 105 Long.valueOf(timeout), unit.toString().toLowerCase())); in get()
|
H A D | AsyncChannelWrapperNonSecure.java | 63 CompletionHandler<Long,B> handler) { in write() argument
|
H A D | AsyncChannelGroupUtil.java | 89 Long.MAX_VALUE, TimeUnit.MILLISECONDS, in createAsynchronousChannelGroup()
|
H A D | Util.java | 299 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 D | WsRemoteEndpointImplBase.java | 272 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 D | WsSession.java | 197 this.id = Long.toHexString(ids.getAndIncrement()); in WsSession()
|
H A D | WsWebSocketContainer.java | 291 timeout = Long.valueOf(timeoutValue).intValue(); in connectToServerRecursive()
|