Home
last modified time | relevance | path

Searched refs:stream_id (Results 1 – 25 of 151) sorted by relevance

1234567

/external/grpc-grpc/test/http2_test/
Dhttp2_base_server.py74 logging.info('RequestReceived Event for stream: %d' % event.stream_id)
77 logging.info('DataReceived Event for stream: %d' % event.stream_id)
80 logging.info('WindowUpdated Event for stream: %d' % event.stream_id)
92 self._conn.acknowledge_received_data(len(event.data), event.stream_id)
93 self._recv_buffer[event.stream_id] += event.data
96 self._recv_buffer[event.stream_id] = ''
97 self._stream_id = event.stream_id
98 self._stream_status[event.stream_id] = True
100 stream_id=event.stream_id,
112 for stream_id in self._send_remaining:
[all …]
Dtest_data_frame_padding.py51 …logging.info('on data received. Stream id: %d. Data length: %d' % (event.stream_id, len(event.data…
55 sr = self._base_server.parse_received_data(event.stream_id)
60 logging.info('Stream id: %d. total resp size: %d' % (event.stream_id, len(response_data)))
66 …self._base_server.setup_send(response_data , event.stream_id, pad_length=self._pad_length, read_ch…
70 logging.info('on request received. Stream id: %s.' % event.stream_id)
71 self._total_updates[event.stream_id] = 0
75 logging.info('on window update. Stream id: %s. Delta: %s' % (event.stream_id, event.delta))
76 self._total_updates[event.stream_id] += event.delta
77 total = self._total_updates[event.stream_id]
78 logging.info('... - total updates for stream %d : %d' % (event.stream_id, total))
Dtest_goaway.py45 def on_send_done(self, stream_id): argument
46 self._base_server.on_send_done_default(stream_id)
47 logging.info('Sending GOAWAY for stream %d:' % stream_id)
48 …f._base_server._conn.close_connection(error_code=0, additional_data=None, last_stream_id=stream_id)
49 self._base_server._stream_status[stream_id] = False
57 sr = self._base_server.parse_received_data(event.stream_id)
62 self._base_server.setup_send(response_data, event.stream_id)
Dtest_rst_after_data.py33 sr = self._base_server.parse_received_data(event.stream_id)
37 self._base_server.setup_send(response_data, event.stream_id)
40 def on_send_done(self, stream_id): argument
42 self._base_server._stream_status[stream_id] = False
Dtest_rst_during_data.py33 sr = self._base_server.parse_received_data(event.stream_id)
39 self._base_server.setup_send(truncated_response_data, event.stream_id)
41 def on_send_done(self, stream_id): argument
43 self._base_server._stream_status[stream_id] = False
/external/curl/lib/
Dhttp2.c586 newstream->stream_id = frame->promised_stream_id; in push_promise()
642 int32_t stream_id = frame->hd.stream_id; in on_frame_recv() local
645 if(!stream_id) { in on_frame_recv()
670 data_s = nghttp2_session_get_stream_user_data(session, stream_id); in on_frame_recv()
674 stream_id)); in on_frame_recv()
681 stream_id)); in on_frame_recv()
686 frame->hd.type, stream_id)); in on_frame_recv()
693 stream_id, NGHTTP2_PROTOCOL_ERROR); in on_frame_recv()
732 ncopy, stream_id, stream->mem)); in on_frame_recv()
760 frame->hd.type, stream_id)); in on_frame_recv()
[all …]
/external/tensorflow/tensorflow/core/common_runtime/gpu/
Dgpu_stream_util.cc83 int stream_id = highest_stream_id + 1; in AssignStreams() local
87 stream_id = (*node_to_stream_id)[e->src()->id()]; in AssignStreams()
93 if (opts.send_stream >= 0) stream_id = opts.send_stream; in AssignStreams()
95 if (opts.recv_stream >= 0) stream_id = opts.recv_stream; in AssignStreams()
97 if (opts.const_stream >= 0) stream_id = opts.const_stream; in AssignStreams()
99 if (opts.compute_stream >= 0) stream_id = opts.compute_stream; in AssignStreams()
102 (*node_to_stream_id)[node_id] = stream_id % opts.max_streams; in AssignStreams()
103 highest_stream_id = std::max(stream_id, highest_stream_id); in AssignStreams()
/external/libopus/src/
Dopus_multistream.c57 int get_left_channel(const ChannelLayout *layout, int stream_id, int prev) in get_left_channel() argument
63 if (layout->mapping[i]==stream_id*2) in get_left_channel()
69 int get_right_channel(const ChannelLayout *layout, int stream_id, int prev) in get_right_channel() argument
75 if (layout->mapping[i]==stream_id*2+1) in get_right_channel()
81 int get_mono_channel(const ChannelLayout *layout, int stream_id, int prev) in get_mono_channel() argument
87 if (layout->mapping[i]==stream_id+layout->nb_coupled_streams) in get_mono_channel()
/external/webrtc/talk/app/webrtc/
Drtpsender.h77 const std::string& stream_id,
105 void set_stream_id(const std::string& stream_id) override { in set_stream_id() argument
106 stream_id_ = stream_id; in set_stream_id()
108 std::string stream_id() const override { return stream_id_; } in stream_id() function
136 const std::string& stream_id,
163 void set_stream_id(const std::string& stream_id) override { in set_stream_id() argument
164 stream_id_ = stream_id; in set_stream_id()
166 std::string stream_id() const override { return stream_id_; } in stream_id() function
Drtpsenderinterface.h66 virtual void set_stream_id(const std::string& stream_id) = 0;
67 virtual std::string stream_id() const = 0;
84 PROXY_CONSTMETHOD0(std::string, stream_id)
/external/adhd/cras/src/common/
Dcras_messages.h103 cras_stream_id_t stream_id; /* unique id for this stream */ member
123 cras_stream_id_t stream_id; /* unique id for this stream */ member
134 cras_stream_id_t stream_id, in cras_fill_connect_message() argument
145 m->stream_id = stream_id; in cras_fill_connect_message()
160 cras_stream_id_t stream_id; member
164 cras_stream_id_t stream_id) in cras_fill_disconnect_stream_message() argument
166 m->stream_id = stream_id; in cras_fill_disconnect_stream_message()
472 cras_stream_id_t stream_id; member
478 cras_stream_id_t stream_id, in cras_fill_set_aec_dump_message() argument
483 m->stream_id = stream_id; in cras_fill_set_aec_dump_message()
[all …]
/external/webrtc/webrtc/modules/video_render/ios/
Dvideo_render_ios_impl.h36 VideoRenderCallback* AddIncomingRenderStream(const uint32_t stream_id,
43 int32_t DeleteIncomingRenderStream(const uint32_t stream_id) override;
45 int32_t GetIncomingRenderStreamProperties(const uint32_t stream_id,
64 uint32_t RenderFrameRate(const uint32_t stream_id);
65 int32_t SetStreamCropping(const uint32_t stream_id,
70 int32_t ConfigureRenderer(const uint32_t stream_id,
/external/adhd/cras/src/tests/
Dcras_router.c46 cras_stream_id_t stream_id, in got_samples() argument
69 cras_stream_id_t stream_id, in put_samples() argument
93 cras_stream_id_t stream_id, in stream_error() argument
103 cras_stream_id_t *stream_id, in start_stream() argument
109 rc = cras_client_add_stream(client, stream_id, params); in start_stream()
115 *stream_id, in start_stream()
128 cras_stream_id_t stream_id = 0; in run_file_io_stream() local
156 start_stream(client, &stream_id, params, volume_scaler) == 0; in run_file_io_stream()
Dcras_test_client.c126 cras_stream_id_t stream_id, in got_samples() argument
163 cras_stream_id_t stream_id, in put_samples() argument
213 cras_stream_id_t stream_id, in put_stdin_samples() argument
234 cras_stream_id_t stream_id, in stream_error() argument
587 (unsigned long long)info->streams[i].stream_id, in print_audio_debug_info()
699 cras_stream_id_t *stream_id, in start_stream() argument
707 stream_id, params); in start_stream()
709 rc = cras_client_add_stream(client, stream_id, params); in start_stream()
714 return cras_client_set_stream_volume(client, *stream_id, stream_volume); in start_stream()
732 static void run_aecdump(struct cras_client *client, uint64_t stream_id, in run_aecdump() argument
[all …]
Dcras_client_unittest.cc111 cras_stream_id_t stream_id, in capture_samples_ready() argument
275 cras_stream_id_t stream_id; in TEST_F() local
287 &client_, stream_ptr, &stream_id, NO_DEVICE)); in TEST_F()
293 &client_, stream_ptr, &stream_id, NO_DEVICE)); in TEST_F()
295 EXPECT_EQ(stream_id, stream_ptr->id); in TEST_F()
299 EXPECT_EQ(stream_ptr, stream_from_id(&client_, stream_id)); in TEST_F()
303 EXPECT_EQ(0, client_thread_rm_stream(&client_, stream_id)); in TEST_F()
310 EXPECT_EQ(NULL, stream_from_id(&client_, stream_id)); in TEST_F()
/external/tensorflow/tensorflow/contrib/ignite/kernels/igfs/
Digfs_client.h72 Status WriteBlock(int64_t stream_id, const uint8_t *data, int32_t len) { in WriteBlock() argument
73 return SendRequestGetResponse(WriteBlockRequest(stream_id, data, len), in WriteBlock()
77 Status ReadBlock(ReadBlockCtrlResponse *res, int64_t stream_id, int64_t pos, in ReadBlock() argument
79 return SendRequestGetResponse(ReadBlockRequest(stream_id, pos, length), in ReadBlock()
83 Status Close(CtrlResponse<CloseResponse> *res, int64_t stream_id) { in Close() argument
84 return SendRequestGetResponse(CloseRequest(stream_id), res); in Close()
Digfs_messages.cc130 StreamCtrlRequest::StreamCtrlRequest(int32_t command_id_, int64_t stream_id, in StreamCtrlRequest() argument
132 : Request(command_id_), stream_id_(stream_id), length_(length) {} in StreamCtrlRequest()
206 TF_RETURN_IF_ERROR(client->ReadLong(&stream_id)); in Read()
222 TF_RETURN_IF_ERROR(client->ReadLong(&stream_id)); in Read()
247 TF_RETURN_IF_ERROR(client->ReadLong(&stream_id)); in Read()
282 ReadBlockRequest::ReadBlockRequest(int64_t stream_id, int64_t pos, in ReadBlockRequest() argument
284 : StreamCtrlRequest(READ_BLOCK_ID, stream_id, length), pos(pos) {} in ReadBlockRequest()
322 WriteBlockRequest::WriteBlockRequest(int64_t stream_id, const uint8_t *data, in WriteBlockRequest() argument
324 : StreamCtrlRequest(WRITE_BLOCK_ID, stream_id, length), data(data) {} in WriteBlockRequest()
Digfs_messages.h98 StreamCtrlRequest(int32_t command_id, int64_t stream_id, int32_t length);
229 int64_t stream_id; variable
242 int64_t stream_id; variable
261 int64_t stream_id; variable
293 explicit CloseRequest(int64_t stream_id);
305 ReadBlockRequest(int64_t stream_id, int64_t pos, int32_t length);
334 WriteBlockRequest(int64_t stream_id, const uint8_t *data, int32_t length);
/external/adhd/cras/examples/
Dcplay.c23 cras_stream_id_t stream_id, in put_samples() argument
43 cras_stream_id_t stream_id, in stream_error() argument
55 cras_stream_id_t stream_id; in main() local
86 num_channels, NO_DEVICE, &stream_id); in main()
/external/deqp-deps/SPIRV-Tools/source/val/
Dvalidate_primitives.cpp51 const uint32_t stream_id = inst->word(1); in PrimitivesPass() local
52 const uint32_t stream_type = _.GetTypeId(stream_id); in PrimitivesPass()
59 const SpvOp stream_opcode = _.GetIdOpcode(stream_id); in PrimitivesPass()
/external/swiftshader/third_party/SPIRV-Tools/source/val/
Dvalidate_primitives.cpp51 const uint32_t stream_id = inst->word(1); in PrimitivesPass() local
52 const uint32_t stream_type = _.GetTypeId(stream_id); in PrimitivesPass()
59 const SpvOp stream_opcode = _.GetIdOpcode(stream_id); in PrimitivesPass()
/external/adhd/cras/src/server/
Dserver_stream.c61 stream_config->stream_id = in server_stream_create()
82 if (stream_list_rm(stream_list, stream_config->stream_id)) in server_stream_rm_cb()
84 stream_config->stream_id); in server_stream_rm_cb()
Dcras_rclient.c63 stream_config.stream_id = msg->stream_id; in handle_client_stream_connect()
82 syslog(LOG_DEBUG, "Send connected for stream %x\n", msg->stream_id); in handle_client_stream_connect()
87 msg->stream_id, in handle_client_stream_connect()
96 msg->stream_id, in handle_client_stream_connect()
107 stream->stream_id); in handle_client_stream_connect()
120 &stream_connected, rc, msg->stream_id, in handle_client_stream_connect()
125 &stream_connected_old, rc, msg->stream_id, in handle_client_stream_connect()
144 msg->stream_id); in handle_client_stream_disconnect()
666 m->stream_id, in cras_rclient_message_from_client()
/external/adhd/cras/src/libcras/
Dcras_helpers.c21 cras_stream_id_t stream_id, in play_buffer_callback() argument
47 cras_stream_id_t stream_id, in play_buffer_error() argument
156 cras_stream_id_t stream_id; in cras_helper_play_buffer() local
167 frame_rate, num_channels, dev_idx, &stream_id); in cras_helper_play_buffer()
Dcras_client.h79 cras_stream_id_t stream_id,
101 cras_stream_id_t stream_id,
117 cras_stream_id_t stream_id,
640 cras_stream_id_t stream_id);
652 cras_stream_id_t stream_id,
1115 cras_stream_id_t stream_id,

1234567