Home
last modified time | relevance | path

Searched refs:stream_list (Results 1 – 25 of 33) sorted by relevance

12

/third_party/mindspore/mindspore/ccsrc/runtime/device/ascend/ge_runtime/task/
Dstream_active_task.cc29 auto stream_list = model_context.stream_list(); in StreamActiveTask() local
32 MS_LOG(INFO) << "Stream list size: " << stream_list.size() << ", stream id: " << stream_id in StreamActiveTask()
34 if (stream_id >= stream_list.size() || active_stream_id >= stream_list.size()) { in StreamActiveTask()
37 stream_ = stream_list[stream_id]; in StreamActiveTask()
38 active_stream_ = stream_list[active_stream_id]; in StreamActiveTask()
Dmemcpy_async_task.cc26 auto stream_list = model_context.stream_list(); in MemcpyAsyncTask() local
29 MS_LOG(INFO) << "Stream list size: " << stream_list.size() << ", stream id: " << stream_id; in MemcpyAsyncTask()
30 if (stream_id >= stream_list.size()) { in MemcpyAsyncTask()
31 …EPTION) << "Index: " << task_info->stream_id() << " >= stream_list.size(): " << stream_list.size(); in MemcpyAsyncTask()
33 stream_ = stream_list[stream_id]; in MemcpyAsyncTask()
Dprofiler_task.cc24 auto stream_list = model_context.stream_list(); in ProfilerTask() local
26 MS_LOG(INFO) << "Stream list size: " << stream_list.size() << ", stream id: " << stream_id; in ProfilerTask()
27 if (stream_id >= stream_list.size()) { in ProfilerTask()
28 …EPTION) << "Index: " << task_info->stream_id() << " >= stream_list.size(): " << stream_list.size(); in ProfilerTask()
30 stream_ = stream_list[stream_id]; in ProfilerTask()
Dtbe_task.cc32 auto stream_list = model_context.stream_list(); in TbeTask() local
33 if (stream_list.size() == 1) { in TbeTask()
34 stream_ = stream_list[0]; in TbeTask()
35 } else if (stream_list.size() > task_info->stream_id()) { in TbeTask()
36 stream_ = stream_list[task_info->stream_id()]; in TbeTask()
38 …EPTION) << "Index: " << task_info->stream_id() << " >= stream_list.size(): " << stream_list.size(); in TbeTask()
Devent_record_task.cc29 auto stream_list = model_context.stream_list(); in EventRecordTask() local
33 if (stream_id >= stream_list.size() || event_id >= event_list.size()) { in EventRecordTask()
34 MS_LOG(EXCEPTION) << "stream_list size: " << stream_list.size() << ", stream_id: " << stream_id in EventRecordTask()
37 stream_ = stream_list[stream_id]; in EventRecordTask()
Devent_wait_task.cc28 auto stream_list = model_context.stream_list(); in EventWaitTask() local
32 if (stream_id >= stream_list.size() || event_id >= event_list.size()) { in EventWaitTask()
33 MS_LOG(EXCEPTION) << "stream_list size: " << stream_list.size() << ", stream_id: " << stream_id in EventWaitTask()
36 stream_ = stream_list[stream_id]; in EventWaitTask()
Dlabel_set_task.cc27 auto stream_list = model_context.stream_list(); in LabelSetTask() local
31 MS_LOG(INFO) << "Stream list size: " << stream_list.size() << ", stream id: " << stream_id; in LabelSetTask()
33 if (stream_id >= stream_list.size() || label_id >= label_list.size()) { in LabelSetTask()
36 stream_ = stream_list[stream_id]; in LabelSetTask()
Dlabel_switch_task.cc31 auto stream_list = model_context.stream_list(); in LabelSwitchTask() local
33 MS_LOG(INFO) << "Stream list size: " << stream_list.size() << ", stream id: " << stream_id; in LabelSwitchTask()
34 if (stream_id >= stream_list.size()) { in LabelSwitchTask()
37 stream_ = stream_list[stream_id]; in LabelSwitchTask()
Dlabel_goto_task.cc28 auto stream_list = model_context.stream_list(); in LabelGotoTask() local
33 MS_LOG(INFO) << "Stream list size: " << stream_list.size() << ", stream id: " << stream_id; in LabelGotoTask()
35 if (stream_id >= stream_list.size() || label_id_ >= label_list.size()) { in LabelGotoTask()
38 stream_ = stream_list[stream_id]; in LabelGotoTask()
Daicpu_task.cc35 auto stream_list = model_context.stream_list(); in AicpuTask() local
36 if (stream_list.size() == 1) { in AicpuTask()
37 stream_ = stream_list[0]; in AicpuTask()
38 } else if (stream_list.size() > task_info_->stream_id()) { in AicpuTask()
39 stream_ = stream_list[task_info_->stream_id()]; in AicpuTask()
41 …PTION) << "Index: " << task_info_->stream_id() << " >= stream_list.size(): " << stream_list.size(); in AicpuTask()
Dhccl_task.cc40 auto stream_list = model_context.stream_list(); in HcclTask() local
41 if (stream_list.size() == 1) { in HcclTask()
42 stream_ = stream_list[0]; in HcclTask()
43 } else if (stream_list.size() > task_info_->stream_id()) { in HcclTask()
44 stream_ = stream_list[task_info_->stream_id()]; in HcclTask()
46 …PTION) << "Index: " << task_info_->stream_id() << " >= stream_list.size(): " << stream_list.size(); in HcclTask()
/third_party/weston/clients/
Dweston-debug.c61 struct wl_list stream_list; member
103 wl_list_insert(app->stream_list.prev, &stream->link); in stream_alloc()
119 wl_list_for_each(stream, &app->stream_list, link) { in stream_find()
148 wl_list_for_each_safe(stream, tmp, &app->stream_list, link) in destroy_streams()
229 wl_list_for_each(stream, &app->stream_list, link) { in start_streams()
248 wl_list_for_each(stream, &app->stream_list, link) { in list_streams()
395 wl_list_init(&app.stream_list); in main()
409 wl_list_empty(&app.stream_list)) { in main()
416 if (app.opt.bind_all && !wl_list_empty(&app.stream_list)) { in main()
467 wl_list_for_each(stream, &app.stream_list, link) { in main()
/third_party/mindspore/mindspore/ccsrc/backend/kernel_compiler/
Dtask_stream.h38 …id set_gen_stream_list(const std::vector<rtStream_t> &stream_list) { gen_stream_list_ = stream_lis… in set_gen_stream_list() argument
39 …id set_run_stream_list(const std::vector<rtStream_t> &stream_list) { run_stream_list_ = stream_lis… in set_run_stream_list() argument
/third_party/mindspore/mindspore/ccsrc/backend/kernel_compiler/rts/
Dstream_active.cc55 auto stream_list = kernel::TaskStream::GetInstance()->gen_stream_list(); in Launch() local
57 if (index >= stream_list.size()) { in Launch()
58 … MS_LOG(EXCEPTION) << "Invalid index: " << index << " stream_list size: " << stream_list.size(); in Launch()
60 act_stream = stream_list[index]; in Launch()
Dstream_switch.cc73 auto stream_list = kernel::TaskStream::GetInstance()->gen_stream_list(); in Launch() local
74 if (true_stream_index_ >= stream_list.size()) { in Launch()
76 << " total stream size: " << stream_list.size(); in Launch()
78 rtStream_t true_stream_ = stream_list[true_stream_index_]; in Launch()
/third_party/mindspore/mindspore/ccsrc/runtime/device/ascend/ge_runtime/
Dmodel_context.h27 rtStream_t rt_model_stream, const std::vector<rtStream_t> &stream_list, in ModelContext() argument
34 stream_list_(stream_list), in ModelContext()
44 const std::vector<rtStream_t> &stream_list() const { return stream_list_; } in stream_list() function
/third_party/gstreamer/gstplugins_bad/gst-libs/gst/player/
Dgstplayer-media-info.c413 if (info->stream_list) in gst_player_media_info_finalize()
414 g_list_free_full (info->stream_list, g_object_unref); in gst_player_media_info_finalize()
514 info->stream_list = g_list_append (info->stream_list, s); in gst_player_media_info_copy()
586 ret->stream_list = g_list_append (ret->stream_list, s); in gst_player_media_info_wrapped()
696 return info->stream_list; in gst_player_media_info_get_stream_list()
830 return g_list_length (info->stream_list); in gst_player_media_info_get_number_of_streams()
Dgstplayer-media-info-private.h81 GList *stream_list; member
/third_party/wayland-ivi-extension/ivi-layermanagement-examples/simple-weston-client/src/
Dsimple-weston-client.c85 struct wl_list stream_list; member
155 wl_list_insert(wlcontext->stream_list.prev, &stream->link); in stream_alloc()
177 wl_list_for_each_safe(stream, tmp, &wlcontext->stream_list, link) { in destroy_streams()
215 wl_list_for_each(stream, &wlcontext->stream_list, link) { in start_streams()
439 wl_list_for_each(stream, &wlcontext->stream_list, link) in stream_find()
490 if (wlcontext->debug_iface || wl_list_empty(&wlcontext->stream_list)) in registry_handle_global()
541 if (!wl_list_empty(&wlcontext->stream_list) && in init_wayland_context()
834 wl_list_init(&wlcontext->stream_list); in main()
854 if (!wl_list_empty(&wlcontext->stream_list) && in main()
888 wl_list_for_each(stream, &wlcontext->stream_list, link) in main()
/third_party/mindspore/mindspore/ccsrc/debug/rdr/
Dstream_exec_order_recorder.h86 …auto stream_list = AnfAlgo::GetNodeAttr<std::vector<uint32_t>>(cur_cnode_ptr, kAttrActiveStreamLis… in StreamExecOrderRecorder() local
87 for (size_t j = 0; j < stream_list.size(); ++j) { in StreamExecOrderRecorder()
88 exec_node.SetActiveStreamId(stream_list[j]); in StreamExecOrderRecorder()
/third_party/gstreamer/gstplugins_bad/gst-libs/gst/play/
Dgstplay-media-info.c463 if (info->stream_list) in gst_play_media_info_finalize()
464 g_list_free_full (info->stream_list, g_object_unref); in gst_play_media_info_finalize()
594 for (l = ref->stream_list; l != NULL; l = l->next) { in gst_play_media_info_copy()
598 info->stream_list = g_list_append (info->stream_list, s); in gst_play_media_info_copy()
700 return info->stream_list; in gst_play_media_info_get_stream_list()
841 return g_list_length (info->stream_list); in gst_play_media_info_get_number_of_streams()
/third_party/gstreamer/gstplugins_base/gst-libs/gst/pbutils/
Dgstdiscoverer-types.c383 g_list_free (info->stream_list); in gst_discoverer_info_finalize()
439 for (tmp = ptr->stream_list; tmp; tmp = tmp->next) { in gst_discoverer_info_copy()
444 ret->stream_list = g_list_append (ret->stream_list, new_stream); in gst_discoverer_info_copy()
497 for (tmp = info->stream_list; tmp; tmp = tmp->next) { in gst_discoverer_info_get_streams()
1056 for (tmp = info->stream_list; tmp; tmp = tmp->next) in gst_discoverer_info_get_stream_list()
/third_party/gstreamer/gstplugins_bad/gst/mpegtsdemux/
Dmpegtsbase.c544 for (tmp = program->stream_list; tmp; tmp = tmp->next) in mpegts_base_free_program()
547 if (program->stream_list) in mpegts_base_free_program()
548 g_list_free (program->stream_list); in mpegts_base_free_program()
654 program->stream_list = g_list_append (program->stream_list, bstream); in mpegts_base_program_add_stream()
688 program->stream_list = g_list_remove_all (program->stream_list, stream); in mpegts_base_program_remove_stream()
742 for (tmp = program->stream_list; tmp; tmp = tmp->next) { in mpegts_base_update_program()
765 for (tmp = program->stream_list; tmp; tmp = tmp->next) { in mpegts_base_update_program()
860 if (nbstreams != g_list_length (oldprogram->stream_list)) { in mpegts_base_is_same_program()
862 nbstreams, g_list_length (oldprogram->stream_list)); in mpegts_base_is_same_program()
969 GST_DEBUG ("program stream_list is now %p", program->stream_list); in mpegts_base_deactivate_program()
Dtsdemux.c995 for (tmp = demux->program->stream_list; tmp; tmp = tmp->next) { in gst_ts_demux_do_seek()
1013 for (tmp = demux->program->stream_list; tmp; tmp = tmp->next) { in gst_ts_demux_do_seek()
1111 for (tmp = demux->program->stream_list; tmp; tmp = tmp->next) { in push_event()
1139 for (tmp = demux->program->stream_list; tmp; tmp = tmp->next) { in handle_psi()
2187 for (walk = demux->program->stream_list; walk; walk = g_list_next (walk)) in gst_ts_demux_flush_streams()
2221 for (tmp = program->stream_list; tmp; tmp = tmp->next) { in gst_ts_demux_update_program()
2273 for (tmp = demux->previous_program->stream_list; tmp; tmp = tmp->next) { in gst_ts_demux_program_started()
2282 for (tmp = program->stream_list; tmp; tmp = tmp->next) { in gst_ts_demux_program_started()
2310 for (tmp = program->stream_list; tmp; tmp = tmp->next) { in gst_ts_demux_program_started()
2437 for (tmp = demux->program->stream_list; tmp; tmp = tmp->next) { in check_pending_buffers()
[all …]
/third_party/grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc121 struct inproc_stream* stream_list = nullptr; member
139 stream_list_next = t->stream_list; in inproc_stream()
140 if (t->stream_list) { in inproc_stream()
141 t->stream_list->stream_list_prev = this; in inproc_stream()
143 t->stream_list = this; in inproc_stream()
345 s->t->stream_list = n; in close_stream_locked()
1135 while (t->stream_list != nullptr) { in close_transport_locked()
1138 t->stream_list, in close_transport_locked()

12