| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/compiler/test/fixtures/sink/gen-swift/test/fixtures/sink/ |
| H A D | SinkService.java | 30 …est.fixtures.sink.FinalResponse> method( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in method()
32 …est.fixtures.sink.FinalResponse> method( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in method()
50 …ixtures.sink.FinalResponse> methodThrow( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodThrow()
52 …ixtures.sink.FinalResponse> methodThrow( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodThrow()
60 …res.sink.FinalResponse> methodSinkThrow( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodSinkThrow()
62 …res.sink.FinalResponse> methodSinkThrow( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodSinkThrow()
70 …es.sink.FinalResponse> methodFinalThrow( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodFinalThrow()
80 …res.sink.FinalResponse> methodBothThrow( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodBothThrow()
82 …res.sink.FinalResponse> methodBothThrow( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodBothThrow()
90 …fixtures.sink.FinalResponse> methodFast( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodFast()
[all …]
|
| H A D | SinkServiceAsyncReactiveWrapper.java | 28 …est.fixtures.sink.FinalResponse> method( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in method()
33 …s.sink.FinalResponse>> methodAndReponse( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodAndReponse()
38 …ixtures.sink.FinalResponse> methodThrow( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodThrow()
43 …res.sink.FinalResponse> methodSinkThrow( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodSinkThrow()
48 …es.sink.FinalResponse> methodFinalThrow( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodFinalThrow()
53 …res.sink.FinalResponse> methodBothThrow( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodBothThrow()
58 …fixtures.sink.FinalResponse> methodFast( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodFast()
|
| H A D | SinkServiceBlockingReactiveWrapper.java | 28 …est.fixtures.sink.FinalResponse> method( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in method()
33 …s.sink.FinalResponse>> methodAndReponse( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodAndReponse()
38 …ixtures.sink.FinalResponse> methodThrow( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodThrow()
43 …res.sink.FinalResponse> methodSinkThrow( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodSinkThrow()
48 …es.sink.FinalResponse> methodFinalThrow( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodFinalThrow()
53 …res.sink.FinalResponse> methodBothThrow( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodBothThrow()
58 …fixtures.sink.FinalResponse> methodFast( org.reactivestreams.Publisher<test.fixtures.sink.SinkPayl… in methodFast()
|
| /dports/net-mgmt/jnettop/jnettop-0.13.0/ |
| H A D | jresolv.c | 27 …esolveStreamTCP(const gchar *data, guint len, jbase_stream *stream, jbase_payload_info *payloads) { in resolveStreamTCP()
45 …solveStreamUDP(const gchar *data, guint len, jbase_stream *stream, jbase_payload_info *payloads) { in resolveStreamUDP()
58 …olveStreamICMP(const gchar *data, guint len, jbase_stream *stream, jbase_payload_info *payloads) { in resolveStreamICMP()
68 …esolveStreamIP(const gchar *data, guint len, jbase_stream *stream, jbase_payload_info *payloads) { in resolveStreamIP()
109 …solveStreamTCP6(const gchar *data, guint len, jbase_stream *stream, jbase_payload_info *payloads) { in resolveStreamTCP6()
127 …olveStreamUDP6(const gchar *data, guint len, jbase_stream *stream, jbase_payload_info *payloads) { in resolveStreamUDP6()
140 …lveStreamICMP6(const gchar *data, guint len, jbase_stream *stream, jbase_payload_info *payloads) { in resolveStreamICMP6()
150 …solveStreamIP6(const gchar *data, guint len, jbase_stream *stream, jbase_payload_info *payloads) { in resolveStreamIP6()
177 …solveStreamARP(const gchar *data, guint len, jbase_stream *stream, jbase_payload_info *payloads) { in resolveStreamARP()
199 …lveStream8021Q(const gchar *data, guint len, jbase_stream *stream, jbase_payload_info *payloads) { in resolveStream8021Q()
[all …]
|
| /dports/net/py-kafka-python/kafka-python-1.4.5/kafka/ |
| H A D | client.py | 179 def _payloads_by_broker(self, payloads): argument
190 def _send_broker_aware_request(self, payloads, encoder_fn, decoder_fn): argument
229 def failed_payloads(payloads): argument
585 def send_metadata_request(self, payloads=(), fail_on_error=True, argument
599 def send_produce_request(self, payloads=(), acks=1, timeout=1000, argument
649 def send_fetch_request(self, payloads=(), fail_on_error=True, argument
669 def send_offset_request(self, payloads=(), fail_on_error=True, argument
679 def send_list_offset_request(self, payloads=(), fail_on_error=True, argument
689 def send_offset_commit_request(self, group, payloads=(), argument
699 def send_offset_fetch_request(self, group, payloads=(), argument
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/modules/rtp_rtcp/source/ |
| H A D | video_rtp_depacketizer_av1_unittest.cc | 120 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
135 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
149 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
166 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
178 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
192 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
205 rtc::ArrayView<const uint8_t> payloads[] = {payload1, payload2}; in TEST() local
222 rtc::ArrayView<const uint8_t> payloads[] = {payload1, payload2}; in TEST() local
253 rtc::ArrayView<const uint8_t> payloads[] = {payload1, payload2}; in TEST() local
329 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
[all …]
|
| H A D | rtp_packetizer_av1_unittest.cc | 103 std::vector<rtc::ArrayView<const uint8_t>> payloads(rtp_payloads.size()); in ReassembleFrame() local
262 auto payloads = Packetize(kFrame, limits); in TEST() local
314 auto payloads = Packetize(kFrame, limits); in TEST() local
327 auto payloads = Packetize(kFrame, limits); in TEST() local
344 auto payloads = Packetize(kFrame, limits); in TEST() local
358 auto payloads = Packetize(kFrame, limits); in TEST() local
|
| /dports/net-im/tg_owt/tg_owt-d578c76/src/modules/rtp_rtcp/source/ |
| H A D | video_rtp_depacketizer_av1_unittest.cc | 120 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
135 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
149 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
166 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
178 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
192 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
205 rtc::ArrayView<const uint8_t> payloads[] = {payload1, payload2}; in TEST() local
222 rtc::ArrayView<const uint8_t> payloads[] = {payload1, payload2}; in TEST() local
253 rtc::ArrayView<const uint8_t> payloads[] = {payload1, payload2}; in TEST() local
329 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
[all …]
|
| H A D | rtp_packetizer_av1_unittest.cc | 105 std::vector<rtc::ArrayView<const uint8_t>> payloads(rtp_payloads.size()); in ReassembleFrame() local
264 auto payloads = Packetize(kFrame, limits); in TEST() local
316 auto payloads = Packetize(kFrame, limits); in TEST() local
329 auto payloads = Packetize(kFrame, limits); in TEST() local
343 auto payloads = Packetize(kFrame, limits, VideoFrameType::kVideoFrameDelta, in TEST() local
357 auto payloads = Packetize(kFrame, limits, VideoFrameType::kVideoFrameDelta, in TEST() local
374 auto payloads = Packetize(kFrame, limits); in TEST() local
388 auto payloads = Packetize(kFrame, limits); in TEST() local
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/modules/rtp_rtcp/source/ |
| H A D | video_rtp_depacketizer_av1_unittest.cc | 120 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
135 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
149 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
166 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
178 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
192 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
205 rtc::ArrayView<const uint8_t> payloads[] = {payload1, payload2}; in TEST() local
222 rtc::ArrayView<const uint8_t> payloads[] = {payload1, payload2}; in TEST() local
253 rtc::ArrayView<const uint8_t> payloads[] = {payload1, payload2}; in TEST() local
329 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
[all …]
|
| H A D | rtp_packetizer_av1_unittest.cc | 103 std::vector<rtc::ArrayView<const uint8_t>> payloads(rtp_payloads.size()); in ReassembleFrame() local
262 auto payloads = Packetize(kFrame, limits); in TEST() local
314 auto payloads = Packetize(kFrame, limits); in TEST() local
327 auto payloads = Packetize(kFrame, limits); in TEST() local
344 auto payloads = Packetize(kFrame, limits); in TEST() local
358 auto payloads = Packetize(kFrame, limits); in TEST() local
|
| /dports/www/firefox/firefox-99.0/third_party/libwebrtc/modules/rtp_rtcp/source/ |
| H A D | video_rtp_depacketizer_av1_unittest.cc | 120 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
135 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
149 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
166 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
178 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
192 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
205 rtc::ArrayView<const uint8_t> payloads[] = {payload1, payload2}; in TEST() local
222 rtc::ArrayView<const uint8_t> payloads[] = {payload1, payload2}; in TEST() local
253 rtc::ArrayView<const uint8_t> payloads[] = {payload1, payload2}; in TEST() local
329 rtc::ArrayView<const uint8_t> payloads[] = {payload1}; in TEST() local
[all …]
|
| H A D | rtp_packetizer_av1_unittest.cc | 103 std::vector<rtc::ArrayView<const uint8_t>> payloads(rtp_payloads.size()); in ReassembleFrame() local
262 auto payloads = Packetize(kFrame, limits); in TEST() local
314 auto payloads = Packetize(kFrame, limits); in TEST() local
327 auto payloads = Packetize(kFrame, limits); in TEST() local
344 auto payloads = Packetize(kFrame, limits); in TEST() local
358 auto payloads = Packetize(kFrame, limits); in TEST() local
|
| /dports/net/py-kafka-python/kafka-python-1.4.5/kafka/protocol/ |
| H A D | legacy.py | 118 def encode_produce_request(cls, payloads=(), acks=1, timeout=1000): argument
174 def encode_fetch_request(cls, payloads=(), max_wait_time=100, min_bytes=4096): argument
229 def encode_offset_request(cls, payloads=()): argument
258 def encode_list_offset_request(cls, payloads=()): argument
287 def encode_metadata_request(cls, topics=(), payloads=None): argument
304 def encode_consumer_metadata_request(cls, client_id, correlation_id, payloads): argument
336 def encode_offset_commit_request(cls, group, payloads): argument
370 def encode_offset_fetch_request(cls, group, payloads, from_kafka=False): argument
419 def create_gzip_message(payloads, key=None, compresslevel=None): argument
440 def create_snappy_message(payloads, key=None): argument
|
| /dports/net/py-kafka-python/kafka-python-1.4.5/test/ |
| H A D | test_consumer.py | 108 def mock_offset_fetch_request(group, payloads, **kwargs): argument
113 def mock_offset_commit_request(group, payloads, **kwargs): argument
131 def mock_offset_request(payloads, **kwargs): argument
146 def fail_requests(payloads, **kwargs): argument
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/doc/api/ |
| H A D | lint.md | 261 ### Escape YAML for JSON encoding
298 ### Parse a CI Lint response
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/nearby_sharing/ |
| H A D | outgoing_share_target_info.h | 37 void set_text_payloads(std::vector<PayloadPtr> payloads) { in set_text_payloads()
45 void set_file_payloads(std::vector<PayloadPtr> payloads) { in set_file_payloads()
|
| /dports/security/masscan/masscan-1.3.2/src/ |
| H A D | templ-payloads.c | 204 const struct PayloadsUDP *payloads, in payloads_udp_lookup()
235 payloads_udp_destroy(struct PayloadsUDP *payloads) in payloads_udp_destroy()
257 payloads_udp_trim(struct PayloadsUDP *payloads, const struct MassIP *targets) in payloads_udp_trim()
286 payloads_oproto_trim(struct PayloadsUDP *payloads, const struct MassIP *targets) in payloads_oproto_trim()
493 payloads_datagram_add(struct PayloadsUDP *payloads, in payloads_datagram_add()
554 struct PayloadsUDP *payloads, in payloads_read_pcap()
668 struct PayloadsUDP *payloads) in payloads_udp_readfile()
757 struct PayloadsUDP *payloads; in payloads_udp_create() local
802 struct PayloadsUDP *payloads; in payloads_oproto_create() local
|
| /dports/editors/poke/poke-1.0/libpoke/ |
| H A D | pkl-pass.c | 136 void *payloads[], in pkl_call_node_handlers()
306 void *payloads[], struct pkl_phase *phases[], in pkl_do_pass_1()
631 struct pkl_phase *phases[], void *payloads[], in pkl_do_subpass()
658 struct pkl_phase *phases[], void *payloads[], in pkl_do_pass()
|
| /dports/misc/usd/USD-21.11/pxr/usd/pcp/testenv/ |
| H A D | testPcpDynamicFileFormatPlugin.py | 163 def _VerifyFoundDynamicPayloads(self, cache, payloads): argument
184 def _VerifyNotFoundDynamicPayloads(self, cache, payloads): argument
199 def _VerifyComputeDynamicPayloads(self, cache, payloads, hasPayloadId=False): argument
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/android/feed/core/javatests/src/org/chromium/chrome/browser/feed/library/api/internal/modelprovider/ |
| H A D | RemoveTrackingTest.java | 51 List<PayloadWithId> payloads = protocolBuilder.buildAsPayloadWithId(); in testMatch() local
65 List<PayloadWithId> payloads = protocolBuilder.buildAsPayloadWithId(); in testNoMatch() local
|
| /dports/net-im/prosody-modules/Community-Modules-bb8459c220c9/mod_rest/ |
| H A D | README.markdown | 383 ### Messages
396 ### Presence
401 ### IQ
|
| /dports/textproc/luceneplusplus/LucenePlusPlus-rel_3.0.8/src/core/search/payloads/ |
| H A D | PayloadSpanUtil.cpp | 33 Collection<ByteArray> payloads(Collection<ByteArray>::newInstance()); in getPayloadsForQuery() local
38 void PayloadSpanUtil::queryToSpanQuery(const QueryPtr& query, Collection<ByteArray> payloads) { in queryToSpanQuery()
135 void PayloadSpanUtil::getPayloads(Collection<ByteArray> payloads, const SpanQueryPtr& query) { in getPayloads()
|
| /dports/lang/mono/mono-5.10.1.57/external/api-doc-tools/external/Lucene.Net.Light/src/core/Search/Payloads/ |
| H A D | PayloadSpanUtil.cs | 76 private void QueryToSpanQuery(Query query, ICollection<byte[]> payloads) in QueryToSpanQuery()
194 private void GetPayloads(ICollection<byte[]> payloads, SpanQuery query) in GetPayloads()
|
| /dports/www/py-wfuzz/wfuzz-3.1.0/src/wfuzz/plugins/iterators/ |
| H A D | iterations.py | 31 def payloads(self): member in zip
62 def payloads(self): member in product
92 def payloads(self): member in chain
|