Home
last modified time | relevance | path

Searched refs:message (Results 1 – 25 of 34) sorted by last modified time

12

/unit/docs/
H A Dunit-openapi.yaml5145 description: "JSON message on success."
5151 description: "JSON message on error."
/unit/
H A DCHANGES907 producing "last message send failed: Resource temporarily
H A DCONTRIBUTING.md77 - Limit the subject line to 67 characters, and the rest of the commit message
/unit/src/
H A Dnxt_main_process.c1119 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 Dnxt_file.h208 #define nxt_write_syslog(priority, message) \ argument
209 syslog(priority, "%s", message)
H A Dnxt_php_sapi.c130 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 Dwebsockets.py210 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 Dtest_node_websockets.py70 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 Dtest_java_websockets.py70 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 Dtest_node_es_modules.py35 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 Dtest_asgi_websockets.py89 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 Dasgi.py11 message = await receive()
12 if message['type'] == 'lifespan.startup':
15 elif message['type'] == 'lifespan.shutdown':
/unit/test/python/lifespan/failed/
H A Dasgi.py4 message = await receive()
5 if message['type'] == 'lifespan.startup':
9 if message['type'] == 'lifespan.shutdown':
/unit/test/node/websockets/mirror_fragmentation/
H A Dapp.js15 connection.on('message', function(message) { argument
17 connection.send(message.utf8Data);
/unit/test/node/websockets/mirror/
H A Dapp.js18 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 Dapp.mjs20 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 Dmodule.mjs20 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 Dnxt_python_asgi_lifespan.c510 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 DWsRemoteEndpointImplBase.java748 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 DContext.java3007 public void log(String message, Throwable throwable)
3009 log(message);
/unit/src/nodejs/unit-http/
H A Dwebsocket_server.js169 e.message,
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerWholeText.java99 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 DPojoMessageHandlerWholeBase.java46 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 DPojoMessageHandlerWholeBinary.java91 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 DPojoMessageHandlerWholePong.java38 protected Object decode(PongMessage message) { in decode() argument

12