/unit/auto/modules/ |
H A D | java | 417 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 \
|
/unit/src/java/nginx/unit/websocket/ |
H A D | BasicAuthenticator.java | 36 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 D | Constants.java | 28 public class Constants { class 155 private Constants() { in Constants() method in Constants
|
H A D | DigestAuthenticator.java | 41 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 D | PerMessageDeflate.java | 53 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 D | TransformationFactory.java | 44 if (Constants.ALLOW_UNSUPPORTED_EXTENSIONS) { in create()
|
H A D | Util.java | 77 return opCode == Constants.OPCODE_TEXT; in isText() 82 return opCode == Constants.OPCODE_CONTINUATION; in isContinuation()
|
H A D | WsFrameBase.java | 93 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 D | WsRemoteEndpointImplBase.java | 134 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 D | WsSession.java | 109 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 D | WsWebSocketContainer.java | 269 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 …]
|
/unit/src/java/nginx/unit/websocket/pojo/ |
H A D | Constants.java | 22 public class Constants { class 29 private Constants() { in Constants() method in Constants
|
H A D | PojoEndpointServer.java | 56 Constants.POJO_PATH_PARAM_KEY); in onOpen() 61 Constants.POJO_METHOD_MAPPING_KEY); in onOpen()
|
/unit/src/java/nginx/unit/websocket/server/ |
H A D | Constants.java | 22 public class Constants { class 35 private Constants() { in Constants() method in Constants
|
H A D | UpgradeUtil.java | 44 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 D | WsContextListener.java | 38 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 D | WsFilter.java | 42 Constants.SERVER_CONTAINER_SERVLET_CONTEXT_ATTRIBUTE); in init()
|
H A D | WsSci.java | 134 Constants.SERVER_CONTAINER_SERVLET_CONTEXT_ATTRIBUTE, sc); in init()
|
H A D | WsServerContainer.java | 78 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()
|