Home
last modified time | relevance | path

Searched refs:stream_map (Results 1 – 25 of 40) sorted by relevance

12

/external/openscreen/osp/impl/
Dmessage_demuxer.cc165 for (auto& stream_map : endpoint_buffers.second) { in SetDefaultMessageTypeWatch() local
166 if (stream_map.second.empty()) in SetDefaultMessageTypeWatch()
168 auto buffered_type = static_cast<msgs::Type>(stream_map.second[0]); in SetDefaultMessageTypeWatch()
170 auto connection_id = stream_map.first; in SetDefaultMessageTypeWatch()
173 &stream_map.second); in SetDefaultMessageTypeWatch()
186 auto& stream_map = buffers_[endpoint_id]; in OnStreamData() local
188 stream_map.erase(connection_id); in OnStreamData()
189 if (stream_map.empty()) in OnStreamData()
193 std::vector<uint8_t>& buffer = stream_map[connection_id]; in OnStreamData()
200 stream_map.erase(connection_id); in OnStreamData()
/external/rust/crates/tokio-stream/src/
Dlib.rs94 mod stream_map; module
95 pub use stream_map::StreamMap;
/external/tensorflow/tensorflow/stream_executor/tpu/
Dtpu_executor.h227 TpuPlatform::StreamMap& stream_map() { in stream_map() function
228 return *(tpu_platform().stream_map()); in stream_map()
233 return stream_map()[ptr]; in get_stream()
Dtpu_transfer_manager.cc81 TpuPlatform::GetRegisteredPlatform()->stream_map()->at( in TransferLiteralToDeviceAsync()
287 TpuPlatform::GetRegisteredPlatform()->stream_map()->at( in WriteSingleTupleIndexTable()
Dtpu_platform.h119 StreamMap* stream_map() { return &stream_map_; } in stream_map() function
Dtpu_executable.cc76 auto stream = platform->stream_map()->at( in LoadProgramAndEnqueueToStream()
Dtpu_executor.cc98 stream_map().erase(stream->implementation()); in DeallocateStream()
181 stream_map()[ptr.get()] = tpu_stream; in GetStreamImplementation()
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_fullstack_trickle.cc138 client->stream_map.count == 1 in Log()
139 ? static_cast<grpc_chttp2_stream*>(client->stream_map.values[0]) in Log()
142 server->stream_map.count == 1 in Log()
143 ? static_cast<grpc_chttp2_stream*>(server->stream_map.values[0]) in Log()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc178 GPR_ASSERT(grpc_chttp2_stream_map_size(&t->stream_map) == 0); in destruct_transport()
180 grpc_chttp2_stream_map_destroy(&t->stream_map); in destruct_transport()
504 grpc_chttp2_stream_map_init(&t->stream_map, 8); in init_transport()
702 grpc_chttp2_stream_map_add(&t->stream_map, s->id, s); in init_stream()
725 GPR_ASSERT(grpc_chttp2_stream_map_find(&t->stream_map, s->id) == nullptr); in destroy_stream_locked()
790 grpc_chttp2_stream_map_find(&t->stream_map, id)); in grpc_chttp2_parsing_lookup_stream()
1064 if (grpc_chttp2_stream_map_size(&t->stream_map) == 0) { in write_action_end_locked()
1157 grpc_chttp2_stream_map_size(&t->stream_map) < in maybe_start_some_streams()
1177 grpc_chttp2_stream_map_add(&t->stream_map, s->id, s); in maybe_start_some_streams()
2013 grpc_chttp2_stream_map_delete(&t->stream_map, id)); in remove_stream()
[all …]
Dframe_ping.cc100 grpc_chttp2_stream_map_size(&t->stream_map) == 0) { in grpc_chttp2_ping_parser_parse()
Dinternal.h312 grpc_chttp2_stream_map stream_map; member
Dwriting.cc75 grpc_chttp2_stream_map_size(&t->stream_map) == 0) in maybe_initiate_ping()
Dparsing.cc588 grpc_chttp2_stream_map_size(&t->stream_map) >= in init_header_frame_parser()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc205 GPR_ASSERT(grpc_chttp2_stream_map_size(&stream_map) == 0); in ~grpc_chttp2_transport()
207 grpc_chttp2_stream_map_destroy(&stream_map); in ~grpc_chttp2_transport()
442 grpc_chttp2_stream_map_init(&stream_map, 8); in grpc_chttp2_transport()
621 grpc_chttp2_stream_map_add(&t->stream_map, id, this);
650 GPR_ASSERT(grpc_chttp2_stream_map_find(&t->stream_map, id) == nullptr); in ~grpc_chttp2_stream()
994 if (grpc_chttp2_stream_map_size(&t->stream_map) == 0) { in write_action_end_locked()
1116 grpc_chttp2_stream_map_size(&t->stream_map) < in maybe_start_some_streams()
1137 grpc_chttp2_stream_map_add(&t->stream_map, s->id, s); in maybe_start_some_streams()
1986 grpc_chttp2_stream_map_delete(&t->stream_map, id)); in remove_stream()
2007 if (grpc_chttp2_stream_map_size(&t->stream_map) == 0) { in remove_stream()
[all …]
Dframe_ping.cc100 grpc_chttp2_stream_map_size(&t->stream_map) == 0) { in grpc_chttp2_ping_parser_parse()
Dinternal.h320 grpc_chttp2_stream_map stream_map; member
758 grpc_chttp2_stream_map_find(&t->stream_map, id)); in grpc_chttp2_parsing_lookup_stream()
Dwriting.cc82 grpc_chttp2_stream_map_size(&t->stream_map) == 0) in maybe_initiate_ping()
Dparsing.cc618 grpc_chttp2_stream_map_size(&t->stream_map) >= in init_header_frame_parser()
/external/wpa_supplicant_8/src/common/
Dieee802_11_common.c2712 int stream_map = (mcs_map >> ((i - 1) * 2)) & 0x3; in parse_mcs_map_for_max_nss() local
2714 if (stream_map != 3) { in parse_mcs_map_for_max_nss()
/external/grpc-grpc/
DgRPC-Core.podspec273 'src/core/ext/transport/chttp2/transport/stream_map.h',
693 'src/core/ext/transport/chttp2/transport/stream_map.cc',
878 'src/core/ext/transport/chttp2/transport/stream_map.h',
Dgrpc.gyp452 'src/core/ext/transport/chttp2/transport/stream_map.cc',
837 'src/core/ext/transport/chttp2/transport/stream_map.cc',
1073 'src/core/ext/transport/chttp2/transport/stream_map.cc',
1266 'src/core/ext/transport/chttp2/transport/stream_map.cc',
DAndroid.bp622 "src/core/ext/transport/chttp2/transport/stream_map.cc",
DBUILD1584 "src/core/ext/transport/chttp2/transport/stream_map.cc",
1608 "src/core/ext/transport/chttp2/transport/stream_map.h",
DgRPC-C++.podspec264 'src/core/ext/transport/chttp2/transport/stream_map.h',
Dconfig.m4260 src/core/ext/transport/chttp2/transport/stream_map.cc \

12