/unit/docs/ |
H A D | unit-openapi.yaml | 5145 description: "JSON message on success." 5151 description: "JSON message on error."
|
/unit/ |
H A D | CHANGES | 907 producing "last message send failed: Resource temporarily
|
H A D | CONTRIBUTING.md | 77 - Limit the subject line to 67 characters, and the rest of the commit message
|
/unit/src/ |
H A D | nxt_main_process.c | 1119 u_char message[2048]; in nxt_main_port_socket_handler() local 1141 ls.start = message; in nxt_main_port_socket_handler() 1142 ls.end = message + sizeof(message); in nxt_main_port_socket_handler()
|
H A D | nxt_file.h | 208 #define nxt_write_syslog(priority, message) \ argument 209 syslog(priority, "%s", message)
|
H A D | nxt_php_sapi.c | 130 static void nxt_php_log_message(const char *message, int syslog_type_int); 133 static void nxt_php_log_message(char *message, int syslog_type_int); 135 static void nxt_php_log_message(char *message TSRMLS_DC); 1618 nxt_php_log_message(const char *message, int syslog_type_int) argument 1622 nxt_php_log_message(char *message, int syslog_type_int) 1625 nxt_php_log_message(char *message TSRMLS_DC) 1635 "php message: %s", message); 1639 "php message: %s", message);
|
/unit/test/unit/applications/ |
H A D | websockets.py | 210 def message(self, sock, mes_type, message, fragmention_size=None, **kwargs): argument 211 message_len = len(message) 217 self.frame_write(sock, mes_type, message, **kwargs) 225 self.frame_write(sock, op_code, message[pos:end], fin=fin, **kwargs)
|
/unit/test/ |
H A D | test_node_websockets.py | 70 message = 'blah' 74 ws.frame_write(sock, ws.OP_TEXT, message) 79 ws.frame_write(sock, ws.OP_TEXT, message) 90 message = 'blah' 107 message = 'blah' 111 ws.frame_write(sock, ws.OP_TEXT, message, fin=False) 113 ws.frame_write(sock, ws.OP_CONT, message) 127 message = 'blah' 153 message = '0123456789' * 3000 157 ws.frame_write(sock, ws.OP_TEXT, message) [all …]
|
H A D | test_java_websockets.py | 70 message = 'blah' 74 ws.frame_write(sock, ws.OP_TEXT, message) 77 assert message == frame['data'].decode('utf-8'), 'mirror' 79 ws.frame_write(sock, ws.OP_TEXT, message) 90 message = 'blah' 94 ws.frame_write(sock, ws.OP_TEXT, message, mask=False) 107 message = 'blah' 111 ws.frame_write(sock, ws.OP_TEXT, message, fin=False) 113 ws.frame_write(sock, ws.OP_CONT, message) 127 message = 'blah' [all …]
|
H A D | test_node_es_modules.py | 35 message = 'blah' 39 ws.frame_write(sock, ws.OP_TEXT, message) 42 assert message == frame['data'].decode('utf-8'), 'mirror' 44 ws.frame_write(sock, ws.OP_TEXT, message) 47 assert message == frame['data'].decode('utf-8'), 'mirror 2'
|
H A D | test_asgi_websockets.py | 89 message = 'blah' 93 ws.frame_write(sock, ws.OP_TEXT, message) 98 ws.frame_write(sock, ws.OP_TEXT, message) 109 message = 'blah' 113 ws.frame_write(sock, ws.OP_TEXT, message) 131 message = 'blah' 148 message = 'blah' 179 message = 'blah' 205 message = '0123456789' * 300 217 assert message == data, 'large' [all …]
|
/unit/test/python/lifespan/empty/ |
H A D | asgi.py | 11 message = await receive() 12 if message['type'] == 'lifespan.startup': 15 elif message['type'] == 'lifespan.shutdown':
|
/unit/test/python/lifespan/failed/ |
H A D | asgi.py | 4 message = await receive() 5 if message['type'] == 'lifespan.startup': 9 if message['type'] == 'lifespan.shutdown':
|
/unit/test/node/websockets/mirror_fragmentation/ |
H A D | app.js | 15 connection.on('message', function(message) { argument 17 connection.send(message.utf8Data);
|
/unit/test/node/websockets/mirror/ |
H A D | app.js | 18 connection.on('message', function(message) { argument 19 if (message.type === 'utf8') { 20 connection.send(message.utf8Data); 21 } else if (message.type === 'binary') { 22 connection.send(message.binaryData);
|
/unit/test/node/loader/es_modules_websocket/ |
H A D | app.mjs | 20 connection.on('message', function(message) { argument 21 if (message.type === 'utf8') { 22 connection.send(message.utf8Data); 23 } else if (message.type === 'binary') { 24 connection.send(message.binaryData);
|
/unit/test/node/loader/es_modules_websocket_indirect/ |
H A D | module.mjs | 20 connection.on('message', function(message) { argument 21 if (message.type === 'utf8') { 22 connection.send(message.utf8Data); 23 } else if (message.type === 'binary') { 24 connection.send(message.binaryData);
|
/unit/src/python/ |
H A D | nxt_python_asgi_lifespan.c | 510 PyObject *message) in nxt_py_asgi_lifespan_send_startup() argument 518 if (nxt_fast_path(message != NULL && PyUnicode_Check(message))) { in nxt_py_asgi_lifespan_send_startup() 519 message_str = PyUnicode_AsUTF8AndSize(message, &message_len); in nxt_py_asgi_lifespan_send_startup() 580 PyObject *message) in nxt_py_asgi_lifespan_send_shutdown() argument
|
/unit/src/java/nginx/unit/websocket/ |
H A D | WsRemoteEndpointImplBase.java | 748 private final CharBuffer message; field in WsRemoteEndpointImplBase.TextMessageSendHandler 755 public TextMessageSendHandler(SendHandler handler, CharBuffer message, in TextMessageSendHandler() argument 759 this.message = message; in TextMessageSendHandler() 768 CoderResult cr = encoder.encode(message, buffer, true); in write()
|
/unit/src/java/nginx/unit/ |
H A D | Context.java | 3007 public void log(String message, Throwable throwable) 3009 log(message);
|
/unit/src/nodejs/unit-http/ |
H A D | websocket_server.js | 169 e.message,
|
/unit/src/java/nginx/unit/websocket/pojo/ |
H A D | PojoMessageHandlerWholeText.java | 99 protected Object decode(String message) throws DecodeException { in decode() argument 102 return Util.coerceToType(primitiveType, message); in decode() 107 if (((Text<?>) decoder).willDecode(message)) { in decode() 108 return ((Text<?>) decoder).decode(message); in decode() 111 StringReader r = new StringReader(message); in decode() 115 throw new DecodeException(message, sm.getString( in decode() 125 protected Object convert(String message) { in convert() argument 126 return new StringReader(message); in convert()
|
H A D | PojoMessageHandlerWholeBase.java | 46 public final void onMessage(T message) { in onMessage() argument 57 payload = decode(message); in onMessage() 66 payload = convert(message); in onMessage() 68 payload = message; in onMessage() 87 protected Object convert(T message) { in convert() argument 88 return message; in convert() 92 protected abstract Object decode(T message) throws DecodeException; in decode() argument
|
H A D | PojoMessageHandlerWholeBinary.java | 91 protected Object decode(ByteBuffer message) throws DecodeException { in decode() argument 94 if (((Binary<?>) decoder).willDecode(message)) { in decode() 95 return ((Binary<?>) decoder).decode(message); in decode() 98 byte[] array = new byte[message.limit() - message.position()]; in decode() 99 message.get(array); in decode() 104 throw new DecodeException(message, sm.getString( in decode() 114 protected Object convert(ByteBuffer message) { in convert() argument 115 byte[] array = new byte[message.remaining()]; in convert() 116 message.get(array); in convert()
|
H A D | PojoMessageHandlerWholePong.java | 38 protected Object decode(PongMessage message) { in decode() argument
|