Home
last modified time | relevance | path

Searched refs:message_set (Results 1 – 25 of 287) sorted by relevance

12345678910>>...12

/dports/databases/mantis/mantisbt-2.25.2/plugins/EmailReporting/core_pear/Net/
H A DIMAP.php406 $message_set = $msg_id;
409 $message_set = '1:*';
452 $message_set = $msg_id;
455 $message_set = '1:*';
975 $message_set = $msg_id;
978 $message_set = '1:*';
1181 $message_set = '1:*';
1309 $message_set = '1:*';
1371 $message_set = '1:*';
1881 $message_set = '1:*';
[all …]
/dports/devel/protobuf/protobuf-3.17.3/src/google/protobuf/
H A Dwire_format_unittest.cc431 message_set in TEST()
435 message_set in TEST()
478 message_set in TEST()
482 message_set in TEST()
489 size_t size = message_set.ByteSizeLong(); in TEST()
565 message_set in TEST()
570 message_set in TEST()
615 message_set in TEST()
629 message_set in TEST()
685 message_set.ByteSizeLong(); in TEST()
[all …]
/dports/net/elixir-kafka_ex/kafka_ex-0.10.0/lib/kafka_ex/
H A Dstream.ex60 message_set: message_set
66 {message_set, last_offset + 1}
97 offset_to_commit = last_offset(acc, fetch_response.message_set)
110 defp need_commit?(%{message_set: []}, _auto_commit), do: false
116 defp last_offset({:cont, {_, n}}, message_set)
117 when n <= length(message_set) do
118 message = Enum.at(message_set, n - 1)
123 defp last_offset({:cont, _}, message_set) do
124 message = List.last(message_set)
/dports/mail/pear-Net_IMAP/Net_IMAP-1.1.3/Net/
H A DIMAP.php400 $message_set = $msg_id;
403 $message_set = '1:*';
446 $message_set = $msg_id;
449 $message_set = '1:*';
969 $message_set = $msg_id;
972 $message_set = '1:*';
1175 $message_set = '1:*';
1303 $message_set = '1:*';
1365 $message_set = '1:*';
1875 $message_set = '1:*';
[all …]
/dports/devel/protobuf25/protobuf-2.5.0/src/google/protobuf/
H A Dwire_format_unittest.cc342 unittest::TestMessageSet message_set; in TEST() local
343 message_set.MutableExtension( in TEST()
345 message_set.MutableExtension( in TEST()
385 unittest::TestMessageSet message_set; in TEST() local
386 message_set.MutableExtension( in TEST()
388 message_set.MutableExtension( in TEST()
393 int size = message_set.ByteSize(); in TEST()
462 unittest::TestMessageSet message_set; in TEST() local
506 unittest::TestMessageSet message_set; in TEST() local
514 unittest::TestMessageSet message_set; in TEST() local
[all …]
/dports/net/elixir-kafka_ex/kafka_ex-0.10.0/test/protocol/
H A Dfetch_test.exs38 message_set: [
74 message_set: [
119 message_set: [
144 message_set: [
170 message_set: [
204 message_set: [
213 message_set: [
240 message_set: [
254 message_set: [
289 message_set: [message]
[all …]
/dports/databases/percona57-server/percona-server-5.7.36-39/extra/protobuf/protobuf-2.6.1/src/google/protobuf/
H A Dwire_format_unittest.cc421 unittest::TestMessageSet message_set; in TEST() local
422 message_set.MutableExtension( in TEST()
424 message_set.MutableExtension( in TEST()
464 unittest::TestMessageSet message_set; in TEST() local
465 message_set.MutableExtension( in TEST()
467 message_set.MutableExtension( in TEST()
472 int size = message_set.ByteSize(); in TEST()
541 unittest::TestMessageSet message_set; in TEST() local
585 unittest::TestMessageSet message_set; in TEST() local
593 unittest::TestMessageSet message_set; in TEST() local
[all …]
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/extra/protobuf/protobuf-2.6.1/src/google/protobuf/
H A Dwire_format_unittest.cc421 unittest::TestMessageSet message_set; in TEST() local
422 message_set.MutableExtension( in TEST()
424 message_set.MutableExtension( in TEST()
464 unittest::TestMessageSet message_set; in TEST() local
465 message_set.MutableExtension( in TEST()
467 message_set.MutableExtension( in TEST()
472 int size = message_set.ByteSize(); in TEST()
541 unittest::TestMessageSet message_set; in TEST() local
585 unittest::TestMessageSet message_set; in TEST() local
593 unittest::TestMessageSet message_set; in TEST() local
[all …]
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/extra/protobuf/protobuf-2.6.1/src/google/protobuf/
H A Dwire_format_unittest.cc421 unittest::TestMessageSet message_set; in TEST() local
422 message_set.MutableExtension( in TEST()
424 message_set.MutableExtension( in TEST()
464 unittest::TestMessageSet message_set; in TEST() local
465 message_set.MutableExtension( in TEST()
467 message_set.MutableExtension( in TEST()
472 int size = message_set.ByteSize(); in TEST()
541 unittest::TestMessageSet message_set; in TEST() local
585 unittest::TestMessageSet message_set; in TEST() local
593 unittest::TestMessageSet message_set; in TEST() local
[all …]
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/extra/protobuf/protobuf-2.6.1/src/google/protobuf/
H A Dwire_format_unittest.cc421 unittest::TestMessageSet message_set; in TEST() local
422 message_set.MutableExtension( in TEST()
424 message_set.MutableExtension( in TEST()
464 unittest::TestMessageSet message_set; in TEST() local
465 message_set.MutableExtension( in TEST()
467 message_set.MutableExtension( in TEST()
472 int size = message_set.ByteSize(); in TEST()
541 unittest::TestMessageSet message_set; in TEST() local
585 unittest::TestMessageSet message_set; in TEST() local
593 unittest::TestMessageSet message_set; in TEST() local
[all …]
/dports/databases/percona57-client/percona-server-5.7.36-39/extra/protobuf/protobuf-2.6.1/src/google/protobuf/
H A Dwire_format_unittest.cc421 unittest::TestMessageSet message_set; in TEST() local
422 message_set.MutableExtension( in TEST()
424 message_set.MutableExtension( in TEST()
464 unittest::TestMessageSet message_set; in TEST() local
465 message_set.MutableExtension( in TEST()
467 message_set.MutableExtension( in TEST()
472 int size = message_set.ByteSize(); in TEST()
541 unittest::TestMessageSet message_set; in TEST() local
585 unittest::TestMessageSet message_set; in TEST() local
593 unittest::TestMessageSet message_set; in TEST() local
[all …]
/dports/databases/mysql57-client/mysql-5.7.36/extra/protobuf/protobuf-2.6.1/src/google/protobuf/
H A Dwire_format_unittest.cc421 unittest::TestMessageSet message_set; in TEST() local
422 message_set.MutableExtension( in TEST()
424 message_set.MutableExtension( in TEST()
464 unittest::TestMessageSet message_set; in TEST() local
465 message_set.MutableExtension( in TEST()
467 message_set.MutableExtension( in TEST()
472 int size = message_set.ByteSize(); in TEST()
541 unittest::TestMessageSet message_set; in TEST() local
585 unittest::TestMessageSet message_set; in TEST() local
593 unittest::TestMessageSet message_set; in TEST() local
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/protobuf/src/google/protobuf/
H A Dwire_format_unittest.cc425 message_set in TEST()
429 message_set in TEST()
472 message_set in TEST()
476 message_set in TEST()
483 int size = message_set.ByteSize(); in TEST()
484 EXPECT_EQ(size, message_set.GetCachedSize()); in TEST()
559 message_set in TEST()
564 message_set in TEST()
609 message_set in TEST()
623 message_set in TEST()
[all …]
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/protobuf/src/google/protobuf/
H A Dwire_format_unittest.cc425 message_set in TEST()
429 message_set in TEST()
472 message_set in TEST()
476 message_set in TEST()
483 int size = message_set.ByteSize(); in TEST()
484 EXPECT_EQ(size, message_set.GetCachedSize()); in TEST()
559 message_set in TEST()
564 message_set in TEST()
609 message_set in TEST()
623 message_set in TEST()
[all …]
/dports/devel/py-grpcio-tools/grpcio-tools-1.43.0/third_party/protobuf/src/google/protobuf/
H A Dwire_format_unittest.inc426 message_set
430 message_set
473 message_set
477 message_set
484 size_t size = message_set.ByteSizeLong();
560 message_set
565 message_set
610 message_set
624 message_set
680 message_set.ByteSizeLong();
[all …]
/dports/mail/geary/geary-40.0/src/engine/imap/command/
H A Dimap-copy-command.vala16 public CopyCommand(MessageSet message_set,
19 base(message_set.is_uid ? UID_NAME : NAME, null, should_send);
21 this.args.add(message_set.to_parameter());
H A Dimap-expunge-command.vala21 public ExpungeCommand.uid(MessageSet message_set,
24 assert(message_set.is_uid);
25 this.args.add(message_set.to_parameter());
H A Dimap-store-command.vala45 public StoreCommand(MessageSet message_set,
50 base(message_set.is_uid ? UID_NAME : NAME, null, should_send);
52 this.args.add(message_set.to_parameter());
/dports/net/elixir-kafka_ex/kafka_ex-0.10.0/lib/kafka_ex/protocol/
H A Dproduce.ex66 {message_set, mssize} = create_message_set(messages, compression)
73 message_set
91 {message_set, _} = create_message_set(messages, :none)
94 Compression.compress(compression_type, message_set)
105 message_set = [<<0::64-signed>>, <<msize::32-signed>>, message]
107 {[message_set, message_set2], 8 + 4 + msize + ms2size}
/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/protocol/
H A Dlegacy.py76 message_set = []
79 message_set.append(struct.pack('>qi%ds' % len(encoded_message), 0,
82 return b''.join(message_set)
431 message_set = KafkaProtocol._encode_message_set(
434 gzipped = gzip_encode(message_set, compresslevel=compresslevel)
452 message_set = KafkaProtocol._encode_message_set(
455 snapped = snappy_encode(message_set)
/dports/devel/py-jedi/jedi-0.18.0/jedi/third_party/typeshed/third_party/2and3/google/protobuf/
H A Dunittest_mset_wire_format_pb2.pyi9 def message_set(self) -> TestMessageSet: ...
10 def __init__(self, message_set: Optional[TestMessageSet] = ...) -> None: ...
H A Dunittest_mset_pb2.pyi9 def message_set(self) -> TestMessageSet: ...
10 def __init__(self, message_set: Optional[TestMessageSet] = ...) -> None: ...
/dports/misc/glow/glow-f24d960e3cc80db95ac0bc17b1900dbf60ca044a/thirdparty/onnx/stubs/google/protobuf/
H A Dunittest_mset_wire_format_pb2.pyi21 def message_set(self) -> TestMessageSet: ...
24 message_set: Optional[TestMessageSet] = ...,
/dports/net/elixir-kafka_ex/kafka_ex-0.10.0/test/integration/
H A Dconsumer_group_implementation_test.exs86 def handle_message_set(message_set, state) do
88 "Consumer #{inspect(self())} handled message set #{inspect(message_set)}"
93 %{state | message_sets: state.message_sets ++ [message_set]}
106 def correct_last_message?(message_set, expected_message, expected_offset) do
108 "Got message set: #{inspect(message_set)} " <>
112 message = List.last(message_set)
270 message_set = TestConsumer.last_message_set(consumer_pid)
271 correct_last_message?(message_set, messages[px], starting_offsets[px])
/dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/kafka-0.8.0/tests/integration/consumer_producer/
H A Dconsumer.rs27 let message_set = messages_iter.next().unwrap(); in test_consumer_poll() localVariable
29 assert_eq!(1, message_set.messages().len(), "should only be one message"); in test_consumer_poll()
31 let message_content = message_set.messages()[0].value; in test_consumer_poll()

12345678910>>...12