Home
last modified time | relevance | path

Searched defs:batch (Results 1 – 25 of 41) sorted by relevance

12

/third_party/grpc/src/core/lib/transport/
Dmetadata_batch.cc59 static void assert_valid_callouts(grpc_metadata_batch* batch) { in assert_valid_callouts()
77 void grpc_metadata_batch_assert_ok(grpc_metadata_batch* batch) { in grpc_metadata_batch_assert_ok()
82 void grpc_metadata_batch_init(grpc_metadata_batch* batch) { in grpc_metadata_batch_init()
87 void grpc_metadata_batch_destroy(grpc_metadata_batch* batch) { in grpc_metadata_batch_destroy()
107 static grpc_error* link_callout(grpc_metadata_batch* batch, in link_callout()
123 static grpc_error* maybe_link_callout(grpc_metadata_batch* batch, in maybe_link_callout()
133 static void maybe_unlink_callout(grpc_metadata_batch* batch, in maybe_unlink_callout()
145 grpc_error* grpc_metadata_batch_add_head(grpc_metadata_batch* batch, in grpc_metadata_batch_add_head()
169 grpc_error* grpc_metadata_batch_link_head(grpc_metadata_batch* batch, in grpc_metadata_batch_link_head()
186 grpc_metadata_batch* batch, grpc_linked_mdelem* storage, in grpc_metadata_batch_link_head()
[all …]
Dmetadata_batch.h118 grpc_metadata_batch* batch, grpc_linked_mdelem* storage, in grpc_metadata_batch_add_head()
124 grpc_metadata_batch* batch, grpc_linked_mdelem* storage, in grpc_metadata_batch_add_head()
142 grpc_metadata_batch* batch, grpc_linked_mdelem* storage, in grpc_metadata_batch_add_tail()
148 grpc_metadata_batch* batch, grpc_linked_mdelem* storage, in grpc_metadata_batch_add_tail()
/third_party/grpc/src/core/ext/transport/chttp2/transport/
Dincoming_metadata.cc64 grpc_chttp2_incoming_metadata_buffer* buffer, grpc_metadata_batch* batch) { in grpc_chttp2_incoming_metadata_buffer_publish()
Dincoming_metadata.h43 grpc_metadata_batch batch; member
/third_party/flutter/skia/src/core/
DSkTaskGroup.cpp21 void SkTaskGroup::batch(int N, std::function<void(int)> fn) { in batch() function in SkTaskGroup
/third_party/libdrm/tests/exynos/
Dexynos_fimg2d_perf.c117 unsigned buf_width, unsigned buf_height, unsigned iterations, unsigned batch) in fimg2d_perf_multi()
234 unsigned int iters = 0, batch = 3; in main() local
/third_party/grpc/src/core/lib/security/transport/
Dserver_auth_filter.cc97 const grpc_metadata_batch* batch) { in metadata_batch_to_md_array()
139 grpc_transport_stream_op_batch* batch = calld->recv_initial_metadata_batch; in on_md_processing_done_inner() local
214 grpc_transport_stream_op_batch* batch = calld->recv_initial_metadata_batch; in recv_initial_metadata_ready() local
262 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in server_auth_start_transport_stream_op_batch()
Dclient_auth_filter.cc159 grpc_transport_stream_op_batch* batch = in on_credentials_metadata() local
238 grpc_transport_stream_op_batch* batch) { in send_security_metadata()
330 grpc_transport_stream_op_batch* batch = in on_host_checked() local
362 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in client_auth_start_transport_stream_op_batch()
/third_party/grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc389 Metadata(CallData* calld, grpc_metadata_batch* batch) in Metadata()
510 grpc_transport_stream_op_batch batch; member
587 grpc_transport_stream_op_batch* batch; member
2146 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in StartTransportStreamOpBatch()
2245 grpc_transport_stream_op_batch* batch = pending->batch; in MaybeCacheSendOpsForBatch() local
2374 grpc_transport_stream_op_batch* batch) { in MaybeInjectRecvTrailingMetadataReadyForLoadBalancingPolicy()
2392 size_t CallData::GetBatchIndex(grpc_transport_stream_op_batch* batch) { in GetBatchIndex()
2406 grpc_transport_stream_op_batch* batch) { in PendingBatchesAdd()
2480 grpc_transport_stream_op_batch* batch = pending->batch; in MaybeClearPendingBatch() local
2502 grpc_transport_stream_op_batch* batch = in FailPendingBatchInCallCombiner() local
[all …]
/third_party/Linux_Kernel/include/linux/
Dpercpu_counter.h125 __percpu_counter_compare(struct percpu_counter *fbc, s64 rhs, s32 batch) in __percpu_counter_compare()
139 __percpu_counter_add(struct percpu_counter *fbc, s64 amount, s32 batch) in __percpu_counter_add()
Dshrinker.h56 long batch; /* reclaim batch size, 0 = default */ member
/third_party/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.cc377 grpc_transport_stream_op_batch* batch = in StartBatchInCallCombiner() local
385 grpc_transport_stream_op_batch* batch) { in StartBatch()
412 auto* batch = grpc_make_transport_stream_op( in StartCancel() local
/third_party/grpc/src/core/ext/filters/http/message_compress/
Dmessage_decompress_filter.cc324 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in DecompressStartTransportStreamOpBatch()
353 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in DecompressStartTransportStreamOpBatch()
Dmessage_compress_filter.cc435 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in CompressStartTransportStreamOpBatch()
500 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in CompressStartTransportStreamOpBatch()
/third_party/boost/libs/graph_parallel/src/
Dmpi_process_group.cpp148 mpi_process_group::outgoing_messages& batch,bool out_of_band) in handle_batch()
485 outgoing_messages batch; in maybe_send_batch() local
509 outgoing_messages batch; in send_batch() local
721 outgoing_messages batch; in receive_batch() local
/third_party/grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc305 grpc_transport_stream_op_batch* batch) { in update_path_for_get()
346 static void remove_if_present(grpc_metadata_batch* batch, in remove_if_present()
354 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in http_client_start_transport_stream_op_batch()
/third_party/grpc/src/core/lib/channel/
Dconnected_channel.cc80 call_data* calld, grpc_transport_stream_op_batch* batch) { in get_state_for_batch()
103 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in connected_channel_start_transport_stream_op_batch()
/third_party/grpc/src/cpp/common/
Dchannel_filter.h50 explicit MetadataBatch(grpc_metadata_batch* batch) : batch_(batch) {} in MetadataBatch()
52 grpc_metadata_batch* batch() const { return batch_; } in batch() function
/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dclient_load_reporting_filter.cc98 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in clr_start_transport_stream_op_batch()
/third_party/grpc/src/core/ext/filters/http/
Dclient_authority_filter.cc52 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in client_authority_start_transport_stream_op_batch()
/third_party/grpc/src/core/ext/filters/workarounds/
Dworkaround_cronet_compression_filter.cc47 static bool get_user_agent_mdelem(const grpc_metadata_batch* batch, in get_user_agent_mdelem()
/third_party/flutter/skia/src/gpu/ccpr/
DGrCCStroker.cpp694 const Batch& batch = fBatches[batchID]; in drawStrokes() local
733 void GrCCStroker::appendStrokeMeshesToBuffers(int numSegmentsLog2, const Batch& batch, in appendStrokeMeshesToBuffers()
789 const Batch& batch, const InstanceTallies* startIndices[2], in drawConnectingGeometry()
/third_party/libxkbcommon/src/x11/
Dutil.c193 for (size_t batch = 0; batch < num_batches; batch++) { in adopt_atoms() local
/third_party/grpc/test/core/end2end/tests/
Dfilter_context.cc237 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in start_transport_stream_op_batch()
/third_party/openssl/apps/
Dca.c255 int batch = 0, default_op = 1, doupdatedb = 0, ext_copy = EXT_COPY_NONE; in ca_main() local
1269 long days, int batch, const char *ext_sect, CONF *lconf, in certify()
1337 const char *enddate, long days, int batch, const char *ext_sect, in certify_cert()
1390 int batch, int verbose, X509_REQ *req, const char *ext_sect, in do_body()

12