/unit/src/java/ |
H A D | README.JSR-340 | 3 This version of Unit code is made available in support of the open source 5 testing purposes only. This Unit code is untested and presumed incompatible 7 write to this code. You should instead deploy and write production
|
/unit/src/java/javax/websocket/ |
H A D | CloseReason.java | 65 private int code; field in CloseReason.CloseCodes 67 CloseCodes(int code) { in CloseCodes() argument 68 this.code = code; in CloseCodes() 71 public static CloseCode getCloseCode(final int code) { in getCloseCode() argument 72 if (code > 2999 && code < 5000) { in getCloseCode() 76 return code; in getCloseCode() 80 switch (code) { in getCloseCode() 113 "Invalid close code: [" + code + "]"); in getCloseCode() 119 return code; in getCode()
|
/unit/src/java/nginx/unit/ |
H A D | Context.java | 973 Object code = req.getAttribute(RequestDispatcher.ERROR_STATUS_CODE); in service() local 974 if (code != null && code instanceof Integer) { in service() 975 handleStatusCode((Integer) code, req, resp); in service() 1046 private void handleStatusCode(int code, Request req, Response resp) in handleStatusCode() argument 1051 location = error2location_.get(code); in handleStatusCode() 1054 trace("Status " + code + " matched. Error page location: " + location); in handleStatusCode() 1408 Integer code = Integer.parseInt(child_node.getTextContent().trim()); in processWebXml() local 1410 error2location_.put(code, location); in processWebXml() 1411 trace("error-page: code " + code + " -> " + location); in processWebXml()
|
/unit/src/java/nginx/unit/websocket/ |
H A D | LocalStrings.properties | 141 ….proxyConnectFail=Failed to connect to the configured Proxy [{0}]. The HTTP response code was [{1}] 143 wsWebSocketContainer.missingLocationHeader=Failed to handle HTTP response code [{0}]. Missing Locat… 145 wsWebSocketContainer.unsupportedAuthScheme=Failed to handle HTTP response code [{0}]. Unsupported A… 146 wsWebSocketContainer.failedAuthentication=Failed to handle HTTP response code [{0}]. Authentication… 147 wsWebSocketContainer.missingWWWAuthenticateHeader=Failed to handle HTTP response code [{0}]. Missin…
|
H A D | Util.java | 86 static CloseCode getCloseCode(int code) { in getCloseCode() argument 87 if (code > 2999 && code < 5000) { in getCloseCode() 88 return CloseCodes.getCloseCode(code); in getCloseCode() 90 switch (code) { in getCloseCode()
|
H A D | WsFrameBase.java | 319 int code = CloseCodes.NORMAL_CLOSURE.getCode(); in processDataControl() local 328 code = controlBufferBinary.getShort(); in processDataControl() 346 wsSession.onClose(new CloseReason(Util.getCloseCode(code), reason)); in processDataControl()
|
/unit/src/nodejs/unit-http/ |
H A D | websocket_connection.js | 136 function validateCloseReason(code) { argument 137 if (code < 1000) { 141 if (code >= 1000 && code <= 2999) { 144 …turn [1000, 1001, 1002, 1003, 1007, 1008, 1009, 1010, 1011, 1012, 1013, 1014].indexOf(code) !== -1; 146 if (code >= 3000 && code <= 3999) { 152 if (code >= 4000 && code <= 4999) { 157 if (code >= 5000) { 178 this.closeDescription = 'Socket Error: ' + error.syscall + ' ' + error.code;
|
/unit/src/ |
H A D | nxt_h1proto_websocket.c | 14 uint16_t code; member 404 uint16_t code; in nxt_h1p_conn_ws_frame_process() local 422 code = ((p[0] ^ mask[0]) << 8) + (p[1] ^ mask[1]); in nxt_h1p_conn_ws_frame_process() 424 if (nxt_slow_path(code < 1000 || code >= 5000 in nxt_h1p_conn_ws_frame_process() 425 || (code > 1003 && code < 1007) in nxt_h1p_conn_ws_frame_process() 426 || (code > 1014 && code < 3000))) in nxt_h1p_conn_ws_frame_process() 429 code); in nxt_h1p_conn_ws_frame_process() 603 out = nxt_http_buf_mem(task, r, 2 + sizeof(err->code) + desc.length); in hxt_h1p_send_ws_error() 613 p = nxt_websocket_frame_init(wsh, sizeof(err->code) + desc.length); in hxt_h1p_send_ws_error() 618 *p++ = (err->code >> 8) & 0xFF; in hxt_h1p_send_ws_error() [all …]
|
H A D | nxt_pcre.c | 12 pcre *code; member 60 re->code = pcre_compile(pattern, 0, &err->msg, &erroffset, NULL); in nxt_regex_compile() 61 if (nxt_fast_path(re->code != NULL)) { in nxt_regex_compile() 63 re->extra = pcre_study(re->code, PCRE_STUDY_JIT_COMPILE, &err->msg); in nxt_regex_compile() 124 ret = pcre_exec(re->code, re->extra, (const char *) subject, length, 0, 0, in nxt_regex_match()
|
H A D | nxt_pcre2.c | 18 pcre2_code *code; member 55 re->code = pcre2_compile((PCRE2_SPTR) source->start, source->length, 0, in nxt_regex_compile() 57 if (nxt_slow_path(re->code == NULL)) { in nxt_regex_compile() 139 ret = pcre2_match(re->code, (PCRE2_SPTR) subject, length, 0, 0, match, in nxt_regex_match()
|
/unit/src/perl/ |
H A D | nxt_perl_psgi_layer.c | 161 IV code; in nxt_perl_psgi_layer_stream_close() local 163 code = PerlIOBase_close(aTHX_ f); in nxt_perl_psgi_layer_stream_close() 166 return code; in nxt_perl_psgi_layer_stream_close()
|
/unit/src/python/ |
H A D | nxt_python_asgi.c | 72 PyCodeObject *code; in nxt_python_asgi_check() local 80 code = (PyCodeObject *) PyFunction_GET_CODE(func); in nxt_python_asgi_check() 84 (code->co_flags & CO_COROUTINE) != 0 ? "" : "not ", in nxt_python_asgi_check() 85 code->co_argcount); in nxt_python_asgi_check() 87 res = (code->co_flags & CO_COROUTINE) != 0 || code->co_argcount == 1; in nxt_python_asgi_check() 147 PyCodeObject *code; in nxt_python_asgi_init() local 180 code = (PyCodeObject *) PyFunction_GET_CODE(func); in nxt_python_asgi_init() 182 if ((code->co_flags & CO_COROUTINE) == 0) { in nxt_python_asgi_init()
|
H A D | nxt_python_asgi_websocket.c | 363 PyObject *code; in nxt_py_asgi_websocket_close() local 380 if (nxt_slow_path(code != NULL && !PyLong_Check(code))) { in nxt_py_asgi_websocket_close() 384 status_code = (code != NULL) ? htons(PyLong_AsLong(code)) in nxt_py_asgi_websocket_close() 736 uint16_t code; in nxt_py_asgi_websocket_pop_msg() local 822 code = NXT_WEBSOCKET_CR_NORMAL; in nxt_py_asgi_websocket_pop_msg() 827 data = PyLong_FromLong(code); in nxt_py_asgi_websocket_pop_msg() 831 (int) code); in nxt_py_asgi_websocket_pop_msg() 1009 PyObject *msg, *code; in nxt_py_asgi_websocket_disconnect_msg() local 1017 if (nxt_slow_path(code == NULL)) { in nxt_py_asgi_websocket_disconnect_msg() 1030 Py_DECREF(code); in nxt_py_asgi_websocket_disconnect_msg() [all …]
|
/unit/test/ |
H A D | test_asgi_websockets.py | 35 def check_close(sock, code=1000, no_close=False, frame=None): argument 41 assert frame['code'] == code, 'close code' 1278 for code in valid_codes: 1281 payload = ws.serialize_close(code=code) 1286 for code in invalid_codes: 1289 payload = ws.serialize_close(code=code) 1302 payload = ws.serialize_close(code=5000)
|
H A D | test_java_websockets.py | 32 def check_close(sock, code=1000, no_close=False, frame=None): argument 38 assert frame['code'] == code, 'close code' 1206 for code in valid_codes: 1209 payload = ws.serialize_close(code=code) 1212 check_close(sock, code=code) 1214 for code in invalid_codes: 1217 payload = ws.serialize_close(code=code) 1230 payload = ws.serialize_close(code=5000)
|
H A D | test_node_websockets.py | 32 def check_close(sock, code=1000, no_close=False, frame=None): argument 38 assert frame['code'] == code, 'close code' 1226 for code in valid_codes: 1229 payload = ws.serialize_close(code=code) 1234 for code in invalid_codes: 1237 payload = ws.serialize_close(code=code) 1250 payload = ws.serialize_close(code=5000)
|
/unit/test/unit/applications/ |
H A D | websockets.py | 69 def serialize_close(self, code=1000, reason=''): argument 70 return struct.pack('!H', code) + reason.encode('utf-8') 124 (code,) = struct.unpack('!H', data[:2]) 126 if not (code in self.CLOSE_CODES or 3000 <= code < 5000): 128 frame['code'] = code
|