/dports/databases/mantis/mantisbt-2.25.2/plugins/EmailReporting/core_pear/Net/ |
H A D | IMAP.php | 406 $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 D | wire_format_unittest.cc | 431 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 D | stream.ex | 60 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 D | IMAP.php | 400 $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 D | wire_format_unittest.cc | 342 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 D | fetch_test.exs | 38 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 D | wire_format_unittest.cc | 421 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 D | wire_format_unittest.cc | 421 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 D | wire_format_unittest.cc | 421 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 D | wire_format_unittest.cc | 421 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 D | wire_format_unittest.cc | 421 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 D | wire_format_unittest.cc | 421 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 D | wire_format_unittest.cc | 425 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 D | wire_format_unittest.cc | 425 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 D | wire_format_unittest.inc | 426 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 D | imap-copy-command.vala | 16 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 D | imap-expunge-command.vala | 21 public ExpungeCommand.uid(MessageSet message_set, 24 assert(message_set.is_uid); 25 this.args.add(message_set.to_parameter());
|
H A D | imap-store-command.vala | 45 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 D | produce.ex | 66 {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 D | legacy.py | 76 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 D | unittest_mset_wire_format_pb2.pyi | 9 def message_set(self) -> TestMessageSet: ... 10 def __init__(self, message_set: Optional[TestMessageSet] = ...) -> None: ...
|
H A D | unittest_mset_pb2.pyi | 9 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 D | unittest_mset_wire_format_pb2.pyi | 21 def message_set(self) -> TestMessageSet: ... 24 message_set: Optional[TestMessageSet] = ...,
|
/dports/net/elixir-kafka_ex/kafka_ex-0.10.0/test/integration/ |
H A D | consumer_group_implementation_test.exs | 86 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 D | consumer.rs | 27 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()
|