| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/filters/http/message_compress/ |
| H A D | message_compress_filter.cc | 220 grpc_transport_stream_op_batch* send_message_batch = in send_message_batch_continue() local
221 calld->send_message_batch; in send_message_batch_continue()
222 calld->send_message_batch = nullptr; in send_message_batch_continue()
223 grpc_call_next_op(elem, send_message_batch); in send_message_batch_continue()
269 calld->send_message_batch->on_complete; in finish_send_message()
277 if (calld->send_message_batch != nullptr) { in fail_send_message_batch_in_call_combiner()
280 calld->send_message_batch = nullptr; in fail_send_message_batch_in_call_combiner()
361 if (calld->send_message_batch != nullptr) { in compress_start_transport_stream_op_batch()
394 if (calld->send_message_batch != nullptr) { in compress_start_transport_stream_op_batch()
403 GPR_ASSERT(calld->send_message_batch == nullptr); in compress_start_transport_stream_op_batch()
[all …]
|
| /dports/devel/grpc134/grpc-1.34.1/src/core/ext/filters/http/client/ |
| H A D | http_client_filter.cc | 94 grpc_transport_stream_op_batch* send_message_batch; member
271 calld->send_message_batch, error, calld->call_combiner); in on_send_message_next_done()
277 calld->send_message_batch, error, calld->call_combiner); in on_send_message_next_done()
285 grpc_call_next_op(elem, calld->send_message_batch); in on_send_message_next_done()
400 calld->send_message_batch = batch; in http_client_start_transport_stream_op_batch()
471 calld->send_message_batch, error, calld->call_combiner); in http_client_start_transport_stream_op_batch()
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/http/client/ |
| H A D | http_client_filter.cc | 94 grpc_transport_stream_op_batch* send_message_batch; member
271 calld->send_message_batch, error, calld->call_combiner); in on_send_message_next_done()
277 calld->send_message_batch, error, calld->call_combiner); in on_send_message_next_done()
285 grpc_call_next_op(elem, calld->send_message_batch); in on_send_message_next_done()
400 calld->send_message_batch = batch; in http_client_start_transport_stream_op_batch()
471 calld->send_message_batch, error, calld->call_combiner); in http_client_start_transport_stream_op_batch()
|
| /dports/devel/grpc/grpc-1.42.0/src/core/ext/filters/http/client/ |
| H A D | http_client_filter.cc | 95 grpc_transport_stream_op_batch* send_message_batch; member
240 calld->send_message_batch->send_message = true; in send_message_on_complete()
284 calld->send_message_batch, error, calld->call_combiner); in on_send_message_next_done()
290 calld->send_message_batch, error, calld->call_combiner); in on_send_message_next_done()
298 grpc_call_next_op(elem, calld->send_message_batch); in on_send_message_next_done()
413 calld->send_message_batch = batch; in http_client_start_transport_stream_op_batch()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/filters/http/client/ |
| H A D | http_client_filter.cc | 85 grpc_transport_stream_op_batch* send_message_batch; member
261 calld->send_message_batch, error, calld->call_combiner); in on_send_message_next_done()
267 calld->send_message_batch, error, calld->call_combiner); in on_send_message_next_done()
275 grpc_call_next_op(elem, calld->send_message_batch); in on_send_message_next_done()
390 calld->send_message_batch = batch; in hc_start_transport_stream_op_batch()
459 calld->send_message_batch, error, calld->call_combiner); in hc_start_transport_stream_op_batch()
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/filters/http/client/ |
| H A D | http_client_filter.cc | 95 grpc_transport_stream_op_batch* send_message_batch; member
240 calld->send_message_batch->send_message = true; in send_message_on_complete()
284 calld->send_message_batch, error, calld->call_combiner); in on_send_message_next_done()
290 calld->send_message_batch, error, calld->call_combiner); in on_send_message_next_done()
298 grpc_call_next_op(elem, calld->send_message_batch); in on_send_message_next_done()
413 calld->send_message_batch = batch; in http_client_start_transport_stream_op_batch()
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/filters/http/client/ |
| H A D | http_client_filter.cc | 94 grpc_transport_stream_op_batch* send_message_batch; member
232 calld->send_message_batch->send_message = true; in send_message_on_complete()
276 calld->send_message_batch, error, calld->call_combiner); in on_send_message_next_done()
282 calld->send_message_batch, error, calld->call_combiner); in on_send_message_next_done()
290 grpc_call_next_op(elem, calld->send_message_batch); in on_send_message_next_done()
405 calld->send_message_batch = batch; in http_client_start_transport_stream_op_batch()
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/http/message_compress/ |
| H A D | message_compress_filter.cc | 295 grpc_transport_stream_op_batch* send_message_batch = send_message_batch_; in SendMessageBatchContinue() local
297 grpc_call_next_op(elem, send_message_batch); in SendMessageBatchContinue()
|
| /dports/devel/grpc134/grpc-1.34.1/src/core/ext/filters/http/message_compress/ |
| H A D | message_compress_filter.cc | 295 grpc_transport_stream_op_batch* send_message_batch = send_message_batch_; in SendMessageBatchContinue() local
297 grpc_call_next_op(elem, send_message_batch); in SendMessageBatchContinue()
|
| /dports/devel/grpc/grpc-1.42.0/src/core/ext/filters/http/message_compress/ |
| H A D | message_compress_filter.cc | 301 grpc_transport_stream_op_batch* send_message_batch = send_message_batch_; in SendMessageBatchContinue() local
303 grpc_call_next_op(elem, send_message_batch); in SendMessageBatchContinue()
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/filters/http/message_compress/ |
| H A D | message_compress_filter.cc | 301 grpc_transport_stream_op_batch* send_message_batch = send_message_batch_; in SendMessageBatchContinue() local
303 grpc_call_next_op(elem, send_message_batch); in SendMessageBatchContinue()
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/filters/http/message_compress/ |
| H A D | message_compress_filter.cc | 301 grpc_transport_stream_op_batch* send_message_batch = send_message_batch_; in SendMessageBatchContinue() local
303 grpc_call_next_op(elem, send_message_batch); in SendMessageBatchContinue()
|
| /dports/net/py-kombu/kombu-4.6.11/kombu/asynchronous/aws/sqs/ |
| H A D | queue.py | 89 return self.connection.send_message_batch(
|
| H A D | connection.py | 115 def send_message_batch(self, queue, messages, callback=None): member in AsyncSQSConnection
|
| /dports/devel/py-moto/moto-2.2.16/tests/test_sqs/ |
| H A D | test_sqs.py | 1801 conn.send_message_batch(
2103 response = client.send_message_batch(
2269 client.send_message_batch.when.called_with(
2276 client.send_message_batch.when.called_with(
2283 client.send_message_batch.when.called_with(
2291 client.send_message_batch.when.called_with(
2299 client.send_message_batch.when.called_with(
2307 client.send_message_batch.when.called_with(
2316 client.send_message_batch.when.called_with(
2329 client.send_message_batch.when.called_with(
[all …]
|
| /dports/devel/py-moto/moto-2.2.16/moto/sqs/ |
| H A D | responses.py | 266 def send_message_batch(self): member in SQSResponse
321 messages = self.sqs_backend.send_message_batch(queue_name, entries)
|
| /dports/net/google-cloud-sdk/google-cloud-sdk/platform/gsutil/gslib/vendored/boto/tests/unit/sqs/ |
| H A D | test_connection.py | 293 self.service_connection.send_message_batch(queue, (message1, message2))
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/catapult/third_party/gsutil/gslib/vendored/boto/tests/unit/sqs/ |
| H A D | test_connection.py | 293 self.service_connection.send_message_batch(queue, (message1, message2))
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/depot_tools/external_bin/gsutil/gsutil_4.28/gsutil/third_party/boto/tests/unit/sqs/ |
| H A D | test_connection.py | 293 self.service_connection.send_message_batch(queue, (message1, message2))
|
| /dports/devel/py-boto/boto-2.49.0/tests/unit/sqs/ |
| H A D | test_connection.py | 293 self.service_connection.send_message_batch(queue, (message1, message2))
|
| /dports/net/google-cloud-sdk/google-cloud-sdk/platform/gsutil/gslib/vendored/boto/boto/sqs/ |
| H A D | connection.py | 392 def send_message_batch(self, queue, messages): member in SQSConnection
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/catapult/third_party/gsutil/gslib/vendored/boto/boto/sqs/ |
| H A D | connection.py | 392 def send_message_batch(self, queue, messages): member in SQSConnection
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/depot_tools/external_bin/gsutil/gsutil_4.28/gsutil/third_party/boto/boto/sqs/ |
| H A D | connection.py | 392 def send_message_batch(self, queue, messages): member in SQSConnection
|
| /dports/devel/py-boto/boto-2.49.0/boto/sqs/ |
| H A D | connection.py | 392 def send_message_batch(self, queue, messages): member in SQSConnection
|
| /dports/devel/py-ddtrace/ddtrace-0.56.1/tests/contrib/botocore/ |
| H A D | test.py | 325 sqs.send_message_batch(QueueUrl=queue["QueueUrl"], Entries=entries)
368 sqs.send_message_batch(QueueUrl=queue["QueueUrl"], Entries=entries)
412 sqs.send_message_batch(QueueUrl=queue["QueueUrl"], Entries=entries)
|