Home
last modified time | relevance | path

Searched refs:Constants (Results 1 – 19 of 19) sorted by relevance

/unit/src/java/nginx/unit/websocket/
H A DWsWebSocketContainer.java269 if (Constants.DEFAULT_ORIGIN_HEADER_VALUE != null in connectToServerRecursive()
288 long timeout = Constants.IO_TIMEOUT_MS_DEFAULT; in connectToServerRecursive()
444 Constants.WS_PROTOCOL_HEADER_NAME); in connectToServerRecursive()
458 Constants.WS_EXTENSIONS_HEADER_NAME); in connectToServerRecursive()
547 case Constants.MULTIPLE_CHOICES: in isRedirectStatus()
548 case Constants.MOVED_PERMANENTLY: in isRedirectStatus()
549 case Constants.FOUND: in isRedirectStatus()
550 case Constants.SEE_OTHER: in isRedirectStatus()
551 case Constants.USE_PROXY: in isRedirectStatus()
552 case Constants.TEMPORARY_REDIRECT: in isRedirectStatus()
[all …]
H A DWsRemoteEndpointImplBase.java134 sendMessageBlock(Constants.OPCODE_BINARY, data, true); in sendBytes()
155 startMessage(Constants.OPCODE_BINARY, data, true, sush); in sendBytesByCompletion()
278 private byte currentOpCode = Constants.OPCODE_CONTINUATION;
285 opCode = Constants.OPCODE_CONTINUATION; in sendMessageBlock()
290 if (!last && opCode != Constants.OPCODE_CONTINUATION) { in sendMessageBlock()
294 if (last && opCode == Constants.OPCODE_CONTINUATION) { in sendMessageBlock()
295 currentOpCode = Constants.OPCODE_CONTINUATION; in sendMessageBlock()
397 if (Constants.INTERNAL_OPCODE_FLUSH == mp.getOpCode()) { in writeMessagePart()
413 if (mp.getOpCode() == Constants.OPCODE_CLOSE) { in writeMessagePart()
476 return Constants.DEFAULT_BLOCKING_SEND_TIMEOUT; in getBlockingSendTimeout()
[all …]
H A DBasicAuthenticator.java36 String userName = (String) userProperties.get(Constants.WS_AUTHENTICATION_USER_NAME); in getAuthorization()
37 String password = (String) userProperties.get(Constants.WS_AUTHENTICATION_PASSWORD); in getAuthorization()
H A DConstants.java28 public class Constants { class
155 private Constants() { in Constants() method in Constants
H A DWsSession.java109 private volatile int maxTextMessageBufferSize = Constants.DEFAULT_BUFFER_SIZE;
116 private byte startOpCode = Constants.OPCODE_CONTINUATION;
370 return Constants.WS_VERSION_HEADER_VALUE; in getProtocolVersion()
822 if (opCode == Constants.OPCODE_CONTINUATION) { in processFrame()
831 if (!last && (opCode == Constants.OPCODE_BINARY || in processFrame()
832 opCode == Constants.OPCODE_TEXT)) { in processFrame()
842 startOpCode = Constants.OPCODE_CONTINUATION; in processFrame()
845 if (opCode == Constants.OPCODE_PONG) { in processFrame()
860 if (opCode == Constants.OPCODE_CLOSE) { in processFrame()
877 if (opCode == Constants.OPCODE_BINARY) { in processFrame()
[all …]
H A DWsFrameBase.java93 inputBuffer = ByteBuffer.allocate(Constants.DEFAULT_BUFFER_SIZE); in WsFrameBase()
165 if (opCode != Constants.OPCODE_PING && in processInitialHeader()
166 opCode != Constants.OPCODE_PONG && in processInitialHeader()
167 opCode != Constants.OPCODE_CLOSE) { in processInitialHeader()
181 if (opCode == Constants.OPCODE_BINARY) { in processInitialHeader()
190 } else if (opCode == Constants.OPCODE_TEXT) { in processInitialHeader()
316 if (opCode == Constants.OPCODE_CLOSE) { in processDataControl()
347 } else if (opCode == Constants.OPCODE_PING) { in processDataControl()
351 } else if (opCode == Constants.OPCODE_PONG) { in processDataControl()
H A DTransformationFactory.java44 if (Constants.ALLOW_UNSUPPORTED_EXTENSIONS) { in create()
H A DDigestAuthenticator.java41 String userName = (String) userProperties.get(Constants.WS_AUTHENTICATION_USER_NAME); in getAuthorization()
42 String password = (String) userProperties.get(Constants.WS_AUTHENTICATION_PASSWORD); in getAuthorization()
H A DPerMessageDeflate.java53 private final ByteBuffer readBuffer = ByteBuffer.allocate(Constants.DEFAULT_BUFFER_SIZE);
59 private volatile ByteBuffer writeBuffer = ByteBuffer.allocate(Constants.DEFAULT_BUFFER_SIZE);
365 writeBuffer = ByteBuffer.allocate(Constants.DEFAULT_BUFFER_SIZE); in sendMessagePart()
H A DUtil.java77 return opCode == Constants.OPCODE_TEXT; in isText()
82 return opCode == Constants.OPCODE_CONTINUATION; in isContinuation()
/unit/src/java/nginx/unit/websocket/pojo/
H A DConstants.java22 public class Constants { class
29 private Constants() { in Constants() method in Constants
H A DPojoEndpointServer.java56 Constants.POJO_PATH_PARAM_KEY); in onOpen()
61 Constants.POJO_METHOD_MAPPING_KEY); in onOpen()
/unit/src/java/nginx/unit/websocket/server/
H A DConstants.java22 public class Constants { class
35 private Constants() { in Constants() method in Constants
H A DWsContextListener.java38 if (sc.getAttribute(Constants.SERVER_CONTAINER_SERVLET_CONTEXT_ATTRIBUTE) == null) { in contextInitialized()
46 Object obj = sc.getAttribute(Constants.SERVER_CONTAINER_SERVLET_CONTEXT_ATTRIBUTE); in contextDestroyed()
H A DUpgradeUtil.java44 import nginx.unit.websocket.Constants;
95 String origin = req.getHeader(Constants.ORIGIN_HEADER_NAME); in doUpgrade()
103 Constants.WS_PROTOCOL_HEADER_NAME); in doUpgrade()
111 Enumeration<String> extHeaders = req.getHeaders(Constants.WS_EXTENSIONS_HEADER_NAME); in doUpgrade()
121 installedExtensions = Constants.INSTALLED_EXTENSIONS; in doUpgrade()
125 installedExtensions.addAll(Constants.INSTALLED_EXTENSIONS); in doUpgrade()
175 nginx.unit.websocket.pojo.Constants.POJO_PATH_PARAM_KEY, pathParams); in doUpgrade()
H A DWsServerContainer.java78 nginx.unit.websocket.Constants.STRICT_SPEC_COMPLIANCE;
90 Constants.BINARY_BUFFER_SIZE_SERVLET_CONTEXT_INIT_PARAM); in WsServerContainer()
96 Constants.TEXT_BUFFER_SIZE_SERVLET_CONTEXT_INIT_PARAM); in WsServerContainer()
102 Constants.ENFORCE_NO_ADD_AFTER_HANDSHAKE_CONTEXT_INIT_PARAM); in WsServerContainer()
147 sec.getUserProperties().put(nginx.unit.websocket.pojo.Constants.POJO_METHOD_MAPPING_KEY, in addEndpoint()
H A DWsFilter.java42 Constants.SERVER_CONTAINER_SERVLET_CONTEXT_ATTRIBUTE); in init()
H A DWsSci.java134 Constants.SERVER_CONTAINER_SERVLET_CONTEXT_ATTRIBUTE, sc); in init()
/unit/auto/modules/
H A Djava417 src/java/nginx/unit/websocket/Constants.java \
446 src/java/nginx/unit/websocket/pojo/Constants.java \
461 src/java/nginx/unit/websocket/server/Constants.java \