Home
last modified time | relevance | path

Searched refs:decode (Results 1 – 25 of 30) sorted by relevance

12

/unit/src/java/javax/websocket/
H A DDecoder.java32 T decode(ByteBuffer bytes) throws DecodeException; in decode() method
39 T decode(InputStream is) throws DecodeException, IOException; in decode() method
44 T decode(String s) throws DecodeException; in decode() method
51 T decode(Reader reader) throws DecodeException, IOException; in decode() method
/unit/test/
H A Dtest_node_es_modules.py41 assert message == frame['data'].decode('utf-8'), 'mirror'
46 assert message == frame['data'].decode('utf-8'), 'mirror 2'
H A Dtest_proxy.py44 data = recvall(connection).decode()
196 resp = self.recvall(socks[i], buff_size=buff_size).decode()
261 '200 OK', self.recvall(sock).decode()
295 resp = self._resp_to_dict(self.recvall(sock).decode())
403 assert re.search('200 OK', sock.recv(100).decode()), 'first'
417 assert re.search('200 OK', sock.recv(100).decode()), 'second'
H A Dtest_respawn.py25 output = subprocess.check_output(['ps', 'ax', '-O', 'ppid']).decode()
61 out = subprocess.check_output(['ps', 'ax', '-O', 'ppid']).decode()
H A Dtest_asgi_websockets.py47 def check_frame(self, frame, fin, opcode, payload, decode=True): argument
48 if opcode == self.ws.OP_BINARY or not decode:
51 data = frame['data'].decode('utf-8')
95 assert message == frame['data'].decode('utf-8'), 'mirror'
114 assert message == frame['data'].decode('utf-8'), 'mirror'
154 assert message + ' ' + message == frame['data'].decode(
207 data = frame['data'].decode('utf-8')
210 data += frame['data'].decode('utf-8')
474 def check_ping(payload, chopsize=None, decode=True): argument
478 self.check_frame(frame, True, op_pong, payload, decode=decode)
[all …]
H A Dconftest.py182 ).decode()
454 ).decode()
569 .decode()
661 ).decode()
671 ).decode()
707 output = subprocess.check_output(['ps', 'ax', '-O', 'ppid']).decode()
H A Dtest_node_websockets.py41 def check_frame(self, frame, fin, opcode, payload, decode=True): argument
42 if opcode == self.ws.OP_BINARY or not decode:
45 data = frame['data'].decode('utf-8')
74 assert message == frame['data'].decode('utf-8'), 'mirror'
79 assert message == frame['data'].decode('utf-8'), 'mirror 2'
112 assert message + ' ' + message == frame['data'].decode(
153 data = frame['data'].decode('utf-8')
156 data += frame['data'].decode('utf-8')
420 def check_ping(payload, chopsize=None, decode=True): argument
424 self.check_frame(frame, True, op_pong, payload, decode=decode)
[all …]
H A Dtest_java_websockets.py41 def check_frame(self, frame, fin, opcode, payload, decode=True): argument
42 if opcode == self.ws.OP_BINARY or not decode:
45 data = frame['data'].decode('utf-8')
74 assert message == frame['data'].decode('utf-8'), 'mirror'
79 assert message == frame['data'].decode('utf-8'), 'mirror 2'
112 assert message + ' ' + message == frame['data'].decode(
158 assert message1 == frame1['data'].decode('utf-8'), 'client 1'
401 def check_ping(payload, chopsize=None, decode=True): argument
405 self.check_frame(frame, True, op_pong, payload, decode=decode)
410 check_ping(b'\xfe' * 125, decode=False) # 2_4
[all …]
H A Dtest_reconfigure_tls.py78 self.recvall(ssl_sock).decode().startswith('HTTP/1.1 200 OK')
H A Dtest_settings.py184 data = sock.recv(16).decode()
188 data += self.recvall(sock).decode()
H A Dtest_ruby_application.py232 .decode()
405 resp = self.recvall(sock).decode('utf-8')
H A Dtest_proxy_chunked.py49 data = recvall(connection).decode()
H A Dtest_perl_application.py276 resp = self.recvall(sock).decode('utf-8')
H A Dtest_java_application.py974 body = "%s\r\n%s\r\n%s" % (preamble, encoded.decode(), epilogue)
1020 resp = self.recvall(sock).decode('utf-8')
H A Dtest_python_procman.py26 '.*unit: "' + self.app_name + '" application', output.decode()
/unit/src/
H A Dnxt_string.c757 static const uint8_t decode[] = { in nxt_base64_decode() local
786 if (decode[*src] != 77) { in nxt_base64_decode()
819 v1 = decode[src[0]]; in nxt_base64_decode()
820 v2 = decode[src[1]]; in nxt_base64_decode()
821 v3 = decode[src[2]]; in nxt_base64_decode()
822 v4 = decode[src[3]]; in nxt_base64_decode()
832 v1 = decode[src[0]]; in nxt_base64_decode()
833 v2 = decode[src[1]]; in nxt_base64_decode()
838 v3 = decode[src[2]]; in nxt_base64_decode()
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerWholeBinary.java91 protected Object decode(ByteBuffer message) throws DecodeException { in decode() method in PojoMessageHandlerWholeBinary
95 return ((Binary<?>) decoder).decode(message); in decode()
102 return ((BinaryStream<?>) decoder).decode(bais); in decode()
H A DPojoMessageHandlerWholeText.java99 protected Object decode(String message) throws DecodeException { in decode() method in PojoMessageHandlerWholeText
108 return ((Text<?>) decoder).decode(message); in decode()
113 return ((TextStream<?>) decoder).decode(r); in decode()
H A DPojoMessageHandlerWholeBase.java57 payload = decode(message); in onMessage()
92 protected abstract Object decode(T message) throws DecodeException; in decode() method in PojoMessageHandlerWholeBase
H A DPojoMessageHandlerWholePong.java38 protected Object decode(PongMessage message) { in decode() method in PojoMessageHandlerWholePong
/unit/test/python/log_body/
H A Dwsgi.py5 environ['wsgi.errors'].write(body.decode())
/unit/test/unit/
H A Dutils.py73 ).decode()
84 ).decode()
H A Dhttp.py105 resp = self.recvall(sock, **recvall_kwargs).decode(
119 resp['body'] = self._parse_chunked_body(resp['body']).decode(
137 print(log.decode(encoding, 'ignore'))
318 boundary = binascii.hexlify(os.urandom(16)).decode('ascii')
/unit/test/unit/applications/
H A Dwebsockets.py26 return base64.b64encode(raw_key).decode()
30 return base64.b64encode(sha1).decode()
57 resp += sock.recv(4096).decode()
124 reason = data[2:].decode('utf-8')
/unit/src/java/nginx/unit/websocket/
H A DWsFrameBase.java330 CoderResult cr = utf8DecoderControl.decode(controlBufferBinary, in processDataControl()
412 CoderResult cr = utf8DecoderMessage.decode(messageBufferBinary, messageBufferText, in processDataText()
455 CoderResult cr = utf8DecoderMessage.decode(messageBufferBinary, messageBufferText, in processDataText()

12