Home
last modified time | relevance | path

Searched +full:- +full:- +full:batch (Results 1 – 25 of 714) sorted by relevance

12345678910>>...29

/third_party/grpc/src/core/lib/transport/
Dmetadata_batch.cc9 * http://www.apache.org/licenses/LICENSE-2.0
37 GPR_ASSERT((list->head == nullptr) == (list->tail == nullptr)); in assert_valid_list()
38 if (!list->head) return; in assert_valid_list()
39 GPR_ASSERT(list->head->prev == nullptr); in assert_valid_list()
40 GPR_ASSERT(list->tail->next == nullptr); in assert_valid_list()
41 GPR_ASSERT((list->head == list->tail) == (list->head->next == nullptr)); in assert_valid_list()
44 for (l = list->head; l; l = l->next) { in assert_valid_list()
45 GPR_ASSERT(!GRPC_MDISNULL(l->md)); in assert_valid_list()
46 GPR_ASSERT((l->prev == nullptr) == (l == list->head)); in assert_valid_list()
47 GPR_ASSERT((l->next == nullptr) == (l == list->tail)); in assert_valid_list()
[all …]
Dmetadata_batch.h9 * http://www.apache.org/licenses/LICENSE-2.0
50 /** Metadata elements in this batch */
53 /** Used to calculate grpc-timeout at the point of sending,
54 or GRPC_MILLIS_INF_FUTURE if this batch does not need to send a
55 grpc-timeout */
59 void grpc_metadata_batch_init(grpc_metadata_batch* batch);
60 void grpc_metadata_batch_destroy(grpc_metadata_batch* batch);
61 void grpc_metadata_batch_clear(grpc_metadata_batch* batch);
62 bool grpc_metadata_batch_is_empty(grpc_metadata_batch* batch);
64 /* Returns the transport size of the batch. */
[all …]
Dtransport.cc9 * http://www.apache.org/licenses/LICENSE-2.0
44 (grpc_core::ExecCtx::Get()->flags() & in grpc_stream_destroy()
47 The thread we're running on MAY be owned (indirectly) by a call-stack. in grpc_stream_destroy()
48 If that's the case, destroying the call-stack MAY try to destroy the in grpc_stream_destroy()
51 Throw this over to the executor (on a core-owned thread) and process it in grpc_stream_destroy()
53 grpc_core::Executor::Run(&refcount->destroy, GRPC_ERROR_NONE); in grpc_stream_destroy()
55 grpc_core::ExecCtx::Run(DEBUG_LOCATION, &refcount->destroy, in grpc_stream_destroy()
65 ((grpc_stream_refcount*)(((uint8_t*)(p)) - \
71 grpc_stream_ref(STREAM_REF_FROM_SLICE_REF(&refcount->slice_refcount), in grpc_slice_from_stream_owned_buffer()
74 grpc_stream_ref(STREAM_REF_FROM_SLICE_REF(&refcount->slice_refcount)); in grpc_slice_from_stream_owned_buffer()
[all …]
/third_party/skia/third_party/externals/dawn/src/dawn_native/
DIndirectDrawMetadata.cpp7 // http://www.apache.org/licenses/LICENSE-2.0
29 return limits.v1.maxStorageBufferBindingSize - limits.v1.minStorageBufferOffsetAlignment - in ComputeMaxIndirectValidationBatchOffsetRange()
45 IndexedIndirectValidationBatch& batch = *it; in AddIndexedIndirectDraw() local
46 if (batch.draws.size() >= maxDrawCallsPerIndirectValidationBatch) { in AddIndexedIndirectDraw()
47 // This batch is full. If its minOffset is to the right of the new offset, we can in AddIndexedIndirectDraw()
48 // just insert a new batch here. in AddIndexedIndirectDraw()
49 if (newOffset < batch.minOffset) { in AddIndexedIndirectDraw()
58 if (newOffset >= batch.minOffset && newOffset <= batch.maxOffset) { in AddIndexedIndirectDraw()
59 batch.draws.push_back(std::move(draw)); in AddIndexedIndirectDraw()
63 if (newOffset < batch.minOffset && batch.maxOffset - newOffset <= maxBatchOffsetRange) { in AddIndexedIndirectDraw()
[all …]
DIndirectDrawValidationEncoder.cpp7 // http://www.apache.org/licenses/LICENSE-2.0
68 [[group(0), binding(0)]] var<storage, read> batch: BatchInfo;
83 let cIndex = batch.indirectOffsets[drawIndex];
98 if (id.x >= batch.numDraws) {
102 let clientIndex = batch.indirectOffsets[id.x];
109 if (batch.numIndexBufferElementsHigh >= 2u) {
117 if (batch.numIndexBufferElementsHigh == 0u &&
118 batch.numIndexBufferElementsLow < firstIndex) {
125 let maxIndexCount = batch.numIndexBufferElementsLow - firstIndex;
137 InternalPipelineStore* store = device->GetInternalPipelineStore(); in GetOrCreateRenderValidationPipeline()
[all …]
/third_party/grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc8 // http://www.apache.org/licenses/LICENSE-2.0
93 // time. This includes one batch for each of the following ops:
262 GRPC_CHANNEL_STACK_REF(chand_->owning_stack_, "ResolverResultHandler"); in ResolverResultHandler()
269 GRPC_CHANNEL_STACK_UNREF(chand_->owning_stack_, "ResolverResultHandler"); in ~ResolverResultHandler()
273 chand_->OnResolverResultChangedLocked(std::move(result)); in ReturnResult()
277 chand_->OnResolverErrorLocked(error); in ReturnError()
372 // No need to hold a ref, since the map is updated in the control-plane
380 int keepalive_time_ = -1;
417 grpc_call_element* elem, grpc_transport_stream_op_batch* batch);
440 // Returns the index into pending_batches_ to be used for batch.
[all …]
/third_party/grpc/src/php/tests/unit_tests/
DCallTest.php10 * http://www.apache.org/licenses/LICENSE-2.0
27 self::$port = self::$server->addHttp2Port('0.0.0.0:53000');
28 self::$server->start();
33 $this->channel = new Grpc\Channel('localhost:'.self::$port, [
36 $this->call = new Grpc\Call($this->channel,
43 $this->channel->close();
48 $this->assertSame('Grpc\Call', get_class($this->call));
49 $this->assertObjectHasAttribute('channel', $this->call);
54 $batch = [
57 $result = $this->call->startBatch($batch);
[all …]
/third_party/grpc/src/core/lib/channel/
Dconnected_channel.cc9 * http://www.apache.org/licenses/LICENSE-2.0
58 GRPC_CALL_COMBINER_START(state->call_combiner, state->original_closure, in run_in_call_combiner()
59 GRPC_ERROR_REF(error), state->reason); in run_in_call_combiner()
70 state->original_closure = *original_closure; in intercept_callback()
71 state->call_combiner = calld->call_combiner; in intercept_callback()
72 state->reason = reason; in intercept_callback()
74 &state->closure, in intercept_callback()
80 call_data* calld, grpc_transport_stream_op_batch* batch) { in get_state_for_batch() argument
81 if (batch->send_initial_metadata) return &calld->on_complete[0]; in get_state_for_batch()
82 if (batch->send_message) return &calld->on_complete[1]; in get_state_for_batch()
[all …]
/third_party/grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc8 * http://www.apache.org/licenses/LICENSE-2.0
46 #define EXPECTED_CONTENT_TYPE_LENGTH (sizeof(EXPECTED_CONTENT_TYPE) - 1)
112 if (b->idx.named.status != nullptr) { in client_filter_incoming_metadata()
115 * https://github.com/grpc/grpc/blob/master/doc/http-grpc-status-mapping.md. in client_filter_incoming_metadata()
117 if (b->idx.named.grpc_status != nullptr || in client_filter_incoming_metadata()
118 grpc_mdelem_static_value_eq(b->idx.named.status->md, in client_filter_incoming_metadata()
122 char* val = grpc_dump_slice(GRPC_MDVALUE(b->idx.named.status->md), in client_filter_incoming_metadata()
130 "Received http2 :status header with non-200 OK status"), in client_filter_incoming_metadata()
141 if (b->idx.named.grpc_message != nullptr) { in client_filter_incoming_metadata()
143 GRPC_MDVALUE(b->idx.named.grpc_message->md)); in client_filter_incoming_metadata()
[all …]
/third_party/libdrm/intel/
Dmeson.build1 # Copyright © 2017-2018 Intel Corporation
66 'gen4-3d.batch',
67 find_program('tests/gen4-3d.batch.sh'),
71 'gen45-3d.batch',
72 find_program('tests/gm45-3d.batch.sh'),
76 'gen5-3d.batch',
77 find_program('tests/gen5-3d.batch.sh'),
81 'gen6-3d.batch',
82 find_program('tests/gen6-3d.batch.sh'),
86 'gen7-3d.batch',
[all …]
/third_party/skia/third_party/externals/swiftshader/src/Device/
DRenderer.cpp7 // http://www.apache.org/licenses/LICENSE-2.0
51 inline bool setBatchIndices(unsigned int batch[128][3], VkPrimitiveTopology topology, VkProvokingVe… in setBatchIndices()
60 auto pointBatch = &(batch[0][0]); in setBatchIndices()
67 index--; in setBatchIndices()
79 batch[i][0] = indices[index + (provokeFirst ? 0 : 1)]; in setBatchIndices()
80 batch[i][1] = indices[index + (provokeFirst ? 1 : 0)]; in setBatchIndices()
81 batch[i][2] = indices[index + 1]; in setBatchIndices()
92 batch[i][0] = indices[index + (provokeFirst ? 0 : 1)]; in setBatchIndices()
93 batch[i][1] = indices[index + (provokeFirst ? 1 : 0)]; in setBatchIndices()
94 batch[i][2] = indices[index + 1]; in setBatchIndices()
[all …]
/third_party/flutter/skia/src/gpu/ccpr/
DGrCCStroker.h4 * Use of this source code is governed by a BSD-style license that can be
35 // Parses a device-space SkPath into the current batch, using the SkPath's original verbs with
37 // optional post-device-space translate for placement in an atlas.
39 // Strokes intended as hairlines must have a strokeDevWidth of 1. Non-hairline strokes can only
49 // Compiles the outstanding parsed paths into a batch, and returns an ID that can be used to
54 // current batch before calling this method, and cannot parse new paths afer.
57 // Called after prepareToDraw(). Draws the given batch of path strokes.
63 static constexpr BatchID kEmptyBatchID = -1;
74 // Defines a sub-batch of stroke instances that have a scissor test and the same scissor rect.
79 : fEndInstances(&alloc->emplace_back(startIndices)), fScissor(scissor) {} in ScissorSubBatch()
[all …]
DGrCCFiller.h4 * Use of this source code is governed by a BSD-style license that can be
37 // Parses a device-space SkPath into the current batch, using the SkPath's original verbs and
38 // 'deviceSpacePts'. Accepts an optional post-device-space translate for placement in an atlas.
44 // Compiles the outstanding parsed paths into a batch, and returns an ID that can be used to
49 // current batch before calling this method, and cannot parse new paths afer.
52 // Called after prepareToDraw(). Draws the given batch of path fills.
72 SkASSERT(this->hasFanTessellation()); in fanTessellationCount()
76 SkASSERT(this->hasFanTessellation()); in fanTessellation()
86 int fFanTessellationCount = -1;
90 // Defines a batch of CCPR primitives. Start indices are deduced by looking at the previous
[all …]
/third_party/grpc/src/core/lib/security/transport/
Dclient_auth_filter.cc9 * http://www.apache.org/licenses/LICENSE-2.0
49 /* We can have a per-channel credentials. */
54 security_connector->Ref(DEBUG_LOCATION, "client_auth_filter")), in channel_data()
55 auth_context(auth_context->Ref(DEBUG_LOCATION, "client_auth_filter")) {} in channel_data()
65 /* We can have a per-call credentials. */
69 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in call_data()
80 sec_ctx->auth_context.reset(DEBUG_LOCATION, "client_auth_filter"); in call_data()
81 sec_ctx->auth_context = in call_data()
82 chand->auth_context->Ref(DEBUG_LOCATION, "client_auth_filter"); in call_data()
111 grpc_auth_metadata_context(); // Zero-initialize the C struct.
[all …]
Dserver_auth_filter.cc9 * http://www.apache.org/licenses/LICENSE-2.0
43 : auth_context(auth_context->Ref()), creds(creds->Ref()) {} in channel_data()
63 channel_data* chand = static_cast<channel_data*>(elem->channel_data); in call_data()
64 server_ctx->auth_context = in call_data()
65 chand->auth_context->Ref(DEBUG_LOCATION, "server_auth_filter"); in call_data()
97 const grpc_metadata_batch* batch) { in metadata_batch_to_md_array() argument
101 for (l = batch->list.head; l != nullptr; l = l->next) { in metadata_batch_to_md_array()
103 grpc_mdelem md = l->md; in metadata_batch_to_md_array()
112 usr_md->key = grpc_slice_ref_internal(key); in metadata_batch_to_md_array()
113 usr_md->value = grpc_slice_ref_internal(value); in metadata_batch_to_md_array()
[all …]
/third_party/skia/third_party/externals/swiftshader/src/Renderer/
DRenderer.cpp7 // http://www.apache.org/licenses/LICENSE-2.0
46 extern bool symmetricNormalizedDepth; // [-1, 1] instead of [0, 1]
110 int ref = reference--; // Atomic in release()
132 references = -1; in DrawCall()
135 data->constants = &constants; in DrawCall()
212 sync->lock(EXCLUSIVE); in ~Renderer()
213 sync->destruct(); in ~Renderer()
215 sync->unlock(); in ~Renderer()
257 context->drawType = drawType; in draw()
262 int ss = context->getSuperSampleCount(); in draw()
[all …]
/third_party/grpc/doc/core/
Dtransport_explainer.md9 plug in below the core API (one level below the C++ or other wrapped-language
16 * [In-process](https://github.com/grpc/grpc/tree/master/src/core/ext/transport/inproc)
18 Among these, the in-process is likely the easiest to understand, though arguably
19 also the least similar to a "real" sockets-based transport since it is only used
27 synonymously since all RPCs are actually streams internally.) The ops in a batch
31 - Client: initiate an RPC
32 - Server: supply response headers
34 - Client: get response headers
35 - Server: accept an RPC
39 - Client: half-close indicating that no more messages will be coming
[all …]
/third_party/python/Tools/msi/
Duploadrelease.ps119 Optional path besides -build to locate CHM files.
21 Optional path besides -build to locate ZIP files.
34 [string]$server="python-downloads",
45 if (-not $build) { throw "-build option is required" }
46 if (-not $user) { throw "-user option is required" }
48 $tools = $script:MyInvocation.MyCommand.Path | Split-Path -parent;
50 if (-not ((Test-Path "$build\win32\python-*.exe") -or (Test-Path "$build\amd64\python-*.exe"))) {
51 throw "-build argument does not look like a 'build' directory"
54 function find-putty-tool { in find-putty-tool()
56 $t = gcm $n -EA 0 in find-putty-tool()
[all …]
/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dclient_load_reporting_filter.cc9 * http://www.apache.org/licenses/LICENSE-2.0
60 calld->send_initial_metadata_succeeded = true; in on_complete_for_send()
62 grpc_core::Closure::Run(DEBUG_LOCATION, calld->original_on_complete_for_send, in on_complete_for_send()
69 calld->recv_initial_metadata_succeeded = true; in recv_initial_metadata_ready()
72 calld->original_recv_initial_metadata_ready, in recv_initial_metadata_ready()
78 GPR_ASSERT(args->context != nullptr); in clr_init_call_elem()
79 new (elem->call_data) call_data(); in clr_init_call_elem()
86 call_data* calld = static_cast<call_data*>(elem->call_data); in clr_destroy_call_elem()
87 if (calld->client_stats != nullptr) { in clr_destroy_call_elem()
90 calld->client_stats->AddCallFinished( in clr_destroy_call_elem()
[all …]
/third_party/grpc/src/core/ext/filters/http/message_compress/
Dmessage_decompress_filter.cc9 // http://www.apache.org/licenses/LICENSE-2.0
50 : max_recv_size_(GetMaxRecvSizeFromChannelArgs(args->channel_args)) {} in ChannelData()
62 max_recv_message_length_(chand->max_recv_size()) { in CallData()
79 if (limits != nullptr && limits->limits().max_recv_size >= 0 && in CallData()
80 (limits->limits().max_recv_size < max_recv_message_length_ || in CallData()
82 max_recv_message_length_ = limits->limits().max_recv_size; in CallData()
89 grpc_call_element* elem, grpc_transport_stream_op_batch* batch);
156 calld->recv_initial_metadata_->idx.named.grpc_encoding; in OnRecvInitialMetadataReady()
158 calld->algorithm_ = DecodeMessageCompressionAlgorithm(grpc_encoding->md); in OnRecvInitialMetadataReady()
161 calld->MaybeResumeOnRecvMessageReady(); in OnRecvInitialMetadataReady()
[all …]
Dmessage_compress_filter.cc9 * http://www.apache.org/licenses/LICENSE-2.0
52 grpc_channel_args_compression_algorithm_get_states(args->channel_args); in ChannelData()
55 args->channel_args); in ChannelData()
73 GPR_ASSERT(!args->is_last); in ChannelData()
93 /** The default, channel-level, compression algorithm */
107 ChannelData* channeld = static_cast<ChannelData*>(elem->channel_data); in CallData()
110 if (GPR_LIKELY(GPR_BITGET(channeld->enabled_compression_algorithms_bitset(), in CallData()
111 channeld->default_compression_algorithm()))) { in CallData()
114 channeld->default_compression_algorithm()); in CallData()
128 grpc_call_element* elem, grpc_transport_stream_op_batch* batch);
[all …]
/third_party/grpc/src/core/ext/transport/chttp2/transport/
Dincoming_metadata.cc9 * http://www.apache.org/licenses/LICENSE-2.0
32 buffer->size += GRPC_MDELEM_LENGTH(elem); in grpc_chttp2_incoming_metadata_buffer_add()
34 if (buffer->count < buffer->kPreallocatedMDElem) { in grpc_chttp2_incoming_metadata_buffer_add()
35 storage = &buffer->preallocated_mdelems[buffer->count]; in grpc_chttp2_incoming_metadata_buffer_add()
36 buffer->count++; in grpc_chttp2_incoming_metadata_buffer_add()
39 buffer->arena->Alloc(sizeof(grpc_linked_mdelem))); in grpc_chttp2_incoming_metadata_buffer_add()
41 storage->md = elem; in grpc_chttp2_incoming_metadata_buffer_add()
42 return grpc_metadata_batch_link_tail(&buffer->batch, storage); in grpc_chttp2_incoming_metadata_buffer_add()
47 for (grpc_linked_mdelem* l = buffer->batch.list.head; l != nullptr; in grpc_chttp2_incoming_metadata_buffer_replace_or_add()
48 l = l->next) { in grpc_chttp2_incoming_metadata_buffer_replace_or_add()
[all …]
/third_party/typescript/tests/baselines/reference/
DrecursiveArrayNotCircular.symbols26 Batch
27 >Batch : Symbol(ActionType.Batch, Decl(recursiveArrayNotCircular.ts, 5, 8))
48 | Action<ActionType.Batch, ReducerAction[]>
51 >Batch : Symbol(ActionType.Batch, Decl(recursiveArrayNotCircular.ts, 5, 8))
59 >Error : Symbol(Error, Decl(lib.es5.d.ts, --, --), Decl(lib.es5.d.ts, --, --))
108 case ActionType.Batch:
109 >ActionType.Batch : Symbol(ActionType.Batch, Decl(recursiveArrayNotCircular.ts, 5, 8))
111 >Batch : Symbol(ActionType.Batch, Decl(recursiveArrayNotCircular.ts, 5, 8))
114 >action.payload.map : Symbol(Array.map, Decl(lib.es5.d.ts, --, --))
118 >map : Symbol(Array.map, Decl(lib.es5.d.ts, --, --))
/third_party/boost/libs/graph_parallel/src/
Dmpi_process_group.cpp1 // Copyright (C) 2004-2006 The Trustees of Indiana University.
3 // Copyright (C) 2007 Matthias Troyer <troyer@boost-consulting.com>
27 // subgroups and are building 64-bit binaries. 250 allows all the CTest
28 // tests to pass in both 32 and 64-bit modes. If you create multiple process
29 // groups with PREALLOCATE_BATCHES at a reasonable level in 32-bit mode you
90 // no synchronization stage means -1 in impl()
92 synchronizing_stage.resize(n,-1); in impl()
125 // determine batch message size by serializing the largest possible batch in set_batch_size()
146 // global batch handlers
148 mpi_process_group::outgoing_messages& batch,bool out_of_band) in handle_batch() argument
[all …]
/third_party/skia/bench/
DBulkRectBench.cpp4 * Use of this source code is governed by a BSD-style license that can be
35 kGrid // Small, non-overlapping rectangles in a grid covering the output surface
57 return this->INHERITED::isSuitableFor(backend); in isSuitableFor()
95 SkCanvas::ImageSetEntry batch[kRectCount]; in drawImagesBatch() local
98 batch[i].fImage = fImages[imageIndex]; in drawImagesBatch()
99 batch[i].fSrcRect = SkRect::MakeIWH(fImages[imageIndex]->width(), in drawImagesBatch()
100 fImages[imageIndex]->height()); in drawImagesBatch()
101 batch[i].fDstRect = fRects[i]; in drawImagesBatch()
102 batch[i].fAAFlags = SkCanvas::kAll_QuadAAFlags; in drawImagesBatch()
108 canvas->experimental_DrawEdgeAAImageSet(batch, kRectCount, nullptr, nullptr, in drawImagesBatch()
[all …]

12345678910>>...29