Home
last modified time | relevance | path

Searched refs:compressed_payload (Results 1 – 25 of 44) sorted by relevance

12

/dports/net/jgroups/jgroups-2.12.0/src/org/jgroups/protocols/
H A DCOMPRESS.java83 byte[] compressed_payload=new byte[length]; in down()
91 deflater.deflate(compressed_payload); in down()
96 System.arraycopy(compressed_payload, 0, new_payload, 0, compressed_size); in down()
131 byte[] compressed_payload=msg.getRawBuffer(); in up()
132 if(compressed_payload != null && compressed_payload.length > 0) { in up()
139 inflater.setInput(compressed_payload, msg.getOffset(), msg.getLength()); in up()
143 … log.trace("uncompressed " + compressed_payload.length + " bytes to " + original_size + in up()
/dports/net/py-wsproto/wsproto-1.0.0/test/
H A Dtest_permessage_deflate.py240 compressed_payload = b"\xaa\xa8\xc0\n\x00\x00"
250 len(compressed_payload),
264 compressed_payload = b"\xaa\xa8\xc0\n\x00\x00"
286 len(compressed_payload) - split,
322 len(compressed_payload),
333 compressed_payload = b"x" * 23
343 len(compressed_payload),
351 compressed_payload = b"x" * 23
361 len(compressed_payload),
441 assert data == compressed_payload
[all …]
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/websockets/
H A Dwebsocket_deflate_stream.cc211 scoped_refptr<IOBufferWithSize> compressed_payload = in AppendCompressedFrame() local
213 if (!compressed_payload.get()) { in AppendCompressedFrame()
218 deflater_outputs_.push_back(compressed_payload); in AppendCompressedFrame()
225 compressed->payload = compressed_payload->data(); in AppendCompressedFrame()
226 compressed->header.payload_length = compressed_payload->size(); in AppendCompressedFrame()
240 scoped_refptr<IOBufferWithSize> compressed_payload = in AppendPossiblyCompressedMessage() local
242 if (!compressed_payload.get()) { in AppendPossiblyCompressedMessage()
247 deflater_outputs_.push_back(compressed_payload); in AppendPossiblyCompressedMessage()
261 static_cast<uint64_t>(compressed_payload->size())) { in AppendPossiblyCompressedMessage()
276 compressed->payload = compressed_payload->data(); in AppendPossiblyCompressedMessage()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/net/websockets/
H A Dwebsocket_deflate_stream.cc211 scoped_refptr<IOBufferWithSize> compressed_payload = in AppendCompressedFrame() local
213 if (!compressed_payload.get()) { in AppendCompressedFrame()
218 deflater_outputs_.push_back(compressed_payload); in AppendCompressedFrame()
225 compressed->payload = compressed_payload->data(); in AppendCompressedFrame()
226 compressed->header.payload_length = compressed_payload->size(); in AppendCompressedFrame()
240 scoped_refptr<IOBufferWithSize> compressed_payload = in AppendPossiblyCompressedMessage() local
242 if (!compressed_payload.get()) { in AppendPossiblyCompressedMessage()
247 deflater_outputs_.push_back(compressed_payload); in AppendPossiblyCompressedMessage()
261 static_cast<uint64_t>(compressed_payload->size())) { in AppendPossiblyCompressedMessage()
276 compressed->payload = compressed_payload->data(); in AppendPossiblyCompressedMessage()
[all …]
/dports/www/firefox-esr/firefox-91.8.0/testing/web-platform/tests/tools/third_party/pywebsocket3/test/
H A Dtest_msgutil.py697 compressed_payload = compress.compress(payload)
699 compressed_payload = compressed_payload[:-4]
708 while bytes_chunked < len(compressed_payload):
716 len(compressed_payload) // 10,
717 len(compressed_payload) - bytes_chunked))
726 if bytes_chunked == len(compressed_payload):
797 compressed_payload = b''
821 compressed_payload = compressed_payload[:-4]
839 self.assertTrue(125 < len(compressed_payload))
840 self.assertTrue(len(compressed_payload) < 65536)
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/pywebsocket3/src/test/
H A Dtest_msgutil.py697 compressed_payload = compress.compress(payload)
699 compressed_payload = compressed_payload[:-4]
708 while bytes_chunked < len(compressed_payload):
716 len(compressed_payload) // 10,
717 len(compressed_payload) - bytes_chunked))
726 if bytes_chunked == len(compressed_payload):
797 compressed_payload = b''
821 compressed_payload = compressed_payload[:-4]
839 self.assertTrue(125 < len(compressed_payload))
840 self.assertTrue(len(compressed_payload) < 65536)
[all …]
/dports/www/firefox/firefox-99.0/testing/web-platform/tests/tools/third_party/pywebsocket3/test/
H A Dtest_msgutil.py697 compressed_payload = compress.compress(payload)
699 compressed_payload = compressed_payload[:-4]
708 while bytes_chunked < len(compressed_payload):
716 len(compressed_payload) // 10,
717 len(compressed_payload) - bytes_chunked))
726 if bytes_chunked == len(compressed_payload):
797 compressed_payload = b''
821 compressed_payload = compressed_payload[:-4]
839 self.assertTrue(125 < len(compressed_payload))
840 self.assertTrue(len(compressed_payload) < 65536)
[all …]
/dports/mail/thunderbird/thunderbird-91.8.0/testing/web-platform/tests/tools/third_party/pywebsocket3/test/
H A Dtest_msgutil.py697 compressed_payload = compress.compress(payload)
699 compressed_payload = compressed_payload[:-4]
708 while bytes_chunked < len(compressed_payload):
716 len(compressed_payload) // 10,
717 len(compressed_payload) - bytes_chunked))
726 if bytes_chunked == len(compressed_payload):
797 compressed_payload = b''
821 compressed_payload = compressed_payload[:-4]
839 self.assertTrue(125 < len(compressed_payload))
840 self.assertTrue(len(compressed_payload) < 65536)
[all …]
/dports/lang/spidermonkey78/firefox-78.9.0/testing/web-platform/tests/tools/third_party/pywebsocket3/test/
H A Dtest_msgutil.py698 compressed_payload = compress.compress(payload)
700 compressed_payload = compressed_payload[:-4]
709 while bytes_chunked < len(compressed_payload):
717 len(compressed_payload) // 10,
718 len(compressed_payload) - bytes_chunked))
727 if bytes_chunked == len(compressed_payload):
799 compressed_payload = b''
823 compressed_payload = compressed_payload[:-4]
843 self.assertTrue(125 < len(compressed_payload))
844 self.assertTrue(len(compressed_payload) < 65536)
[all …]
/dports/lang/spidermonkey60/firefox-60.9.0/testing/web-platform/tests/tools/pywebsocket/src/test/
H A Dtest_msgutil.py1013 compressed_payload = compress.compress(payload)
1015 compressed_payload = compressed_payload[:-4]
1024 while bytes_chunked < len(compressed_payload):
1031 len(compressed_payload) / 10,
1034 chunk = compressed_payload[
1041 if bytes_chunked == len(compressed_payload):
1113 compressed_payload = ''
1138 compressed_payload = compressed_payload[:-4]
1158 self.assertTrue(125 < len(compressed_payload))
1159 self.assertTrue(len(compressed_payload) < 65536)
[all …]
/dports/www/firefox-legacy/firefox-52.8.0esr/testing/web-platform/tests/tools/pywebsocket/src/test/
H A Dtest_msgutil.py1013 compressed_payload = compress.compress(payload)
1015 compressed_payload = compressed_payload[:-4]
1024 while bytes_chunked < len(compressed_payload):
1031 len(compressed_payload) / 10,
1034 chunk = compressed_payload[
1041 if bytes_chunked == len(compressed_payload):
1113 compressed_payload = ''
1138 compressed_payload = compressed_payload[:-4]
1158 self.assertTrue(125 < len(compressed_payload))
1159 self.assertTrue(len(compressed_payload) < 65536)
[all …]
/dports/net/beacon/beacon-1.4/common/src/
H A Dsap.h57 unsigned short compressed_payload:1; member
59 unsigned short compressed_payload:1;
H A Dsap.c154 printf(" Compressed Flag: %d\n", p->header->compressed_payload); in print_sap_packet()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/pulsar-1.0.0/src/
H A Dproducer.rs565 let (compressed_payload, result) = encoder.finish(); in send_compress()
568 message.payload = compressed_payload; in send_compress()
583 let compressed_payload = e.finish().map_err(ProducerError::Io)?; in send_compress() localVariable
585 message.payload = compressed_payload; in send_compress()
596 let compressed_payload = in send_compress() localVariable
599 message.payload = compressed_payload; in send_compress()
609 let compressed_payload: Vec<u8> = Vec::new(); in send_compress() localVariable
610 let mut encoder = snap::write::FrameEncoder::new(compressed_payload); in send_compress()
614 let compressed_payload = encoder in send_compress() localVariable
625 message.payload = compressed_payload; in send_compress()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/catapult/third_party/mapreduce/mapreduce/
H A Dmodel.py137 compressed_payload = ""
139 compressed_payload = zlib.compress(payload_str)
142 if not compressed_payload:
145 elif len(compressed_payload) < self.MAX_TASK_PAYLOAD:
146 self._payload = self.PAYLOAD_PARAM + compressed_payload
147 elif len(compressed_payload) > self.MAX_DB_PAYLOAD:
150 (self.name, len(compressed_payload)))
156 payload_entity = _HugeTaskPayload(payload=compressed_payload,
/dports/devel/grpc134/grpc-1.34.1/test/core/end2end/
H A Dend2end_nosec_tests.cc60 extern void compressed_payload(grpc_end2end_test_config config);
296 compressed_payload(config); in grpc_end2end_tests()
422 compressed_payload(config); in grpc_end2end_tests()
H A Dend2end_tests.cc62 extern void compressed_payload(grpc_end2end_test_config config);
300 compressed_payload(config); in grpc_end2end_tests()
430 compressed_payload(config); in grpc_end2end_tests()
/dports/devel/grpc130/grpc-1.30.2/test/core/end2end/
H A Dend2end_nosec_tests.cc60 extern void compressed_payload(grpc_end2end_test_config config);
293 compressed_payload(config); in grpc_end2end_tests()
418 compressed_payload(config); in grpc_end2end_tests()
H A Dend2end_tests.cc62 extern void compressed_payload(grpc_end2end_test_config config);
297 compressed_payload(config); in grpc_end2end_tests()
426 compressed_payload(config); in grpc_end2end_tests()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/test/core/end2end/
H A Dend2end_nosec_tests.cc58 extern void compressed_payload(grpc_end2end_test_config config);
289 compressed_payload(config); in grpc_end2end_tests()
410 compressed_payload(config); in grpc_end2end_tests()
H A Dend2end_tests.cc60 extern void compressed_payload(grpc_end2end_test_config config);
293 compressed_payload(config); in grpc_end2end_tests()
418 compressed_payload(config); in grpc_end2end_tests()
/dports/www/p5-Mojolicious/Mojolicious-9.22/t/mojo/
H A Dwebsocket_frames.t268 my $compressed_payload = $fragmented_compressed->build_message({text => 'just works'})->[5];
270 $fragmented_compressed->parse_message([0, 1, 0, 0, WS_TEXT, substr($compressed_payload, 0, 3)]);
272 $fragmented_compressed->parse_message([0, 0, 0, 0, WS_CONTINUATION, substr($compressed_payload, 3, …
274 $fragmented_compressed->parse_message([1, 0, 0, 0, WS_CONTINUATION, substr($compressed_payload, 6)]…
/dports/devel/grpc/grpc-1.42.0/test/core/end2end/
H A Dend2end_nosec_tests.cc60 extern void compressed_payload(grpc_end2end_test_config config);
324 compressed_payload(config); in grpc_end2end_tests()
459 compressed_payload(config); in grpc_end2end_tests()
H A Dend2end_tests.cc62 extern void compressed_payload(grpc_end2end_test_config config);
331 compressed_payload(config); in grpc_end2end_tests()
471 compressed_payload(config); in grpc_end2end_tests()
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/sync/engine/net/
H A Dhttp_bridge_unittest.cc217 std::string compressed_payload(http_bridge->GetResponseContent(), in TEST_F() local
220 compression::GzipUncompress(compressed_payload, &uncompressed_payload); in TEST_F()

12