Home
last modified time | relevance | path

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

12

/third_party/mindspore/mindspore/ccsrc/ps/ps_cache/ps_data/
Dps_data_prefetch.cc25 void PsDataPrefetch::CreateDataChannel(const std::string &channel_name, size_t step_num) { in CreateDataChannel() argument
29 …MS_LOG(INFO) << "PS cache creates data channel(channel name:" << channel_name << ", step num:" << … in CreateDataChannel()
30 auto iter = ps_data_channel_map_.find(channel_name); in CreateDataChannel()
32 MS_LOG(WARNING) << "The ps data channel already exists, channel name:" << channel_name; in CreateDataChannel()
37 auto channel = std::make_shared<PsDataChannel>(channel_name, step_num); in CreateDataChannel()
38 (void)ps_data_channel_map_.emplace(channel_name, channel); in CreateDataChannel()
42 std::shared_ptr<PsDataChannel> PsDataPrefetch::ps_data_channel(const std::string &channel_name) con… in ps_data_channel()
43 auto iter = ps_data_channel_map_.find(channel_name); in ps_data_channel()
45 MS_LOG(ERROR) << "The ps data channel does not exist, channel name:" << channel_name; in ps_data_channel()
51 bool PsDataPrefetch::PrefetchData(const std::string &channel_name, void *data, const size_t data_si… in PrefetchData() argument
[all …]
Dps_data_prefetch.h39 EXPORT void CreateDataChannel(const std::string &channel_name, size_t step_num);
40 EXPORT bool PrefetchData(const std::string &channel_name, void *data, const size_t data_size,
42 EXPORT bool FinalizeData(const std::string &channel_name);
44 EXPORT bool QueryData(const std::string &channel_name, void **data_ptr) const;
45 EXPORT size_t data_size(const std::string &channel_name) const;
46 EXPORT bool TryWakeChannel(const std::string &channel_name);
53 std::shared_ptr<PsDataChannel> ps_data_channel(const std::string &channel_name) const;
Dps_data_channel.h27 PsDataChannel(const std::string &channel_name, size_t step_num) in PsDataChannel() argument
28 : channel_name_(channel_name), in PsDataChannel()
/third_party/gstreamer/gstplugins_bad/sys/dvb/
Dparsechannels.c52 const gchar * channel_name, const gchar * key);
62 const gchar * filename, const gchar * channel_name, GError ** error);
64 const gchar * filename, const gchar * channel_name, GError ** error);
68 const gchar * property, GKeyFile * kf, const gchar * channel_name,
71 const gchar * property, GKeyFile * kf, const gchar * channel_name,
74 const gchar * property, GKeyFile * kf, const gchar * channel_name,
77 const gchar * property, GKeyFile * kf, const gchar * channel_name,
80 const gchar * property, GKeyFile * kf, const gchar * channel_name,
83 const gchar * property, GKeyFile * kf, const gchar * channel_name,
86 const gchar * property, GKeyFile * kf, const gchar * channel_name,
[all …]
Dparsechannels.h28 const gchar * channel_name,
/third_party/node/test/fixtures/wpt/FileAPI/url/
Durl-in-tags-revoke.window.js56 function receive_message_on_channel(t, channel_name) { argument
57 const channel = new BroadcastChannel(channel_name);
65 function window_contents_for_channel(channel_name) { argument
68 'new BroadcastChannel("' + channel_name + '").postMessage("foobar");\n' +
74 const channel_name = 'noopener-window-test'; constant
75 const blob = new Blob([window_contents_for_channel(channel_name)], {type: 'text/html'});
76 receive_message_on_channel(t, channel_name).then(t.step_func_done(t => {
103 const channel_name = 'a-click-test'; constant
104 const blob = new Blob([window_contents_for_channel(channel_name)], {type: 'text/html'});
105 receive_message_on_channel(t, channel_name).then(t.step_func_done(t => {
/third_party/mindspore/mindspore/ccsrc/runtime/device/gpu/
Dgpu_buffer_mgr.cc51 BlockQueueStatus_T GpuBufferMgr::Create(unsigned int device_id, const std::string &channel_name, vo… in Create() argument
53 std::string name = std::to_string(device_id) + std::string("_") + channel_name; in Create()
68 unsigned int GpuBufferMgr::Open(unsigned int device_id, const std::string &channel_name, in Open() argument
71 std::string name = std::to_string(device_id) + std::string("_") + channel_name; in Open()
87 unsigned int GpuBufferMgr::Open(unsigned int device_id, const std::string &channel_name, in Open() argument
90 std::string name = std::to_string(device_id) + std::string("_") + channel_name; in Open()
172 inline bool GpuBufferMgr::isCreated(unsigned int device_id, const std::string &channel_name) { in isCreated() argument
173 std::string name = std::to_string(device_id) + std::string("_") + channel_name; in isCreated()
215 size_t GpuBufferMgr::Size(unsigned int device_id, const std::string &channel_name) { in Size() argument
216 std::string name = std::to_string(device_id) + std::string("_") + channel_name; in Size()
[all …]
Dgpu_buffer_mgr.h83 …EXPORT BlockQueueStatus_T Create(unsigned int device_id, const std::string &channel_name, void *ad…
87 …EXPORT unsigned int Open(unsigned int device_id, const std::string &channel_name, const std::vecto…
91 …EXPORT unsigned int Open(unsigned int device_id, const std::string &channel_name, const std::vecto…
116 EXPORT size_t Size(unsigned int device_id, const std::string &channel_name);
120 EXPORT size_t Capacity(unsigned int device_id, const std::string &channel_name);
139 inline bool isCreated(unsigned int device_id, const std::string &channel_name);
/third_party/boost/libs/log/example/doc/
Dexpressions_channel_severity_filter.cpp87 void test_logging(logger_type& lg, std::string const& channel_name) in test_logging() argument
89 BOOST_LOG_CHANNEL_SEV(lg, channel_name, normal) << "A normal severity level message"; in test_logging()
90 … BOOST_LOG_CHANNEL_SEV(lg, channel_name, notification) << "A notification severity level message"; in test_logging()
91 BOOST_LOG_CHANNEL_SEV(lg, channel_name, warning) << "A warning severity level message"; in test_logging()
92 BOOST_LOG_CHANNEL_SEV(lg, channel_name, error) << "An error severity level message"; in test_logging()
93 BOOST_LOG_CHANNEL_SEV(lg, channel_name, critical) << "A critical severity level message"; in test_logging()
/third_party/boost/boost/log/expressions/predicates/
Dchannel_severity_filter.hpp154 attribute_name const& channel_name, in channel_severity_filter_terminal() argument
161 m_channel_name(channel_name), in channel_severity_filter_terminal()
311 channel_severity_filter(attribute_name const& channel_name, attribute_name const& severity_name) in channel_severity_filter() argument
315 typename result_type::base_type act = {{ terminal_type(channel_name, severity_name) }}; in channel_severity_filter()
333 channel_severity_filter(attribute_name const& channel_name, attribute_keyword< SeverityDescriptorT,… in channel_severity_filter() argument
337 …typename result_type::base_type act = {{ terminal_type(channel_name, severity_keyword.get_name()) … in channel_severity_filter()
366 channel_severity_filter(attribute_name const& channel_name, attribute_actor< SeverityT, SeverityFal… in channel_severity_filter() argument
370 …typename result_type::base_type act = {{ terminal_type(channel_name, severity_placeholder.get_name… in channel_severity_filter()
389 channel_severity_filter(attribute_name const& channel_name, attribute_name const& severity_name, Se… in channel_severity_filter() argument
393 …typename result_type::base_type act = {{ terminal_type(channel_name, severity_name, fallback_to_no… in channel_severity_filter()
[all …]
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/tdt/
Dtdt_plugin.cc30 TdtPlugin::TdtPlugin(const std::string &channel_name, int32_t device_id) { in TdtPlugin() argument
36 acl_handle_ = acltdtCreateChannel(device_id, channel_name.c_str()); in TdtPlugin()
57 Status TdtPlugin::hostPush(TensorRow ts_row, bool is_wait, std::string channel_name, bool profiling… in hostPush() argument
59 MS_LOG(DEBUG) << "TDT channel name is " << channel_name << "."; in hostPush()
84 …if (!ps::PsDataPrefetch::GetInstance().PrefetchData(channel_name, acltdtGetDataAddrFromItem(item0), in hostPush()
Dtdt_plugin.h42 …Status hostPush(TensorRow ts_row, bool is_wait, std::string channel_name, bool profilig, int32_t &…
45 TdtPlugin(const std::string &channel_name, int32_t device_id);
/third_party/flutter/engine/flutter/shell/platform/common/cpp/client_wrapper/include/flutter/
Dmethod_channel.h61 std::string channel_name = name_; in SetMethodCallHandler() local
62 BinaryMessageHandler binary_handler = [handler, codec, channel_name]( in SetMethodCallHandler()
73 << channel_name << std::endl; in SetMethodCallHandler()
Dbasic_message_channel.h66 std::string channel_name = name_; in SetMessageHandler() local
67 BinaryMessageHandler binary_handler = [handler, codec, channel_name]( in SetMessageHandler()
76 std::cerr << "Unable to decode message on channel " << channel_name in SetMessageHandler()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/util/
Drdr.h27 …explicit MDChannelInfo(std::string channel_name) : channel_name_(channel_name), preprocess_batch_(… in MDChannelInfo() argument
/third_party/ffmpeg/libavfilter/
Davf_showvolume.c378 …const char *channel_name = av_get_channel_name(av_channel_layout_extract_channel(insamples->channe… in filter_frame() local
379 if (!channel_name) in filter_frame()
381 … drawtext(s->out, c * (s->h + s->b) + (s->h - 10) / 2, outlink->h - 35, channel_name, 1); in filter_frame()
414 …const char *channel_name = av_get_channel_name(av_channel_layout_extract_channel(insamples->channe… in filter_frame() local
415 if (!channel_name) in filter_frame()
417 drawtext(s->out, 2, c * (s->h + s->b) + (s->h - 8) / 2, channel_name, 0); in filter_frame()
Daf_channelmap.c351 const char *channel_name; in channelmap_config_input() local
366 channel_name = av_get_channel_name(m->in_channel); in channelmap_config_input()
369 channel_name, layout_name); in channelmap_config_input()
/third_party/mindspore/mindspore/ccsrc/ps/ps_cache/
Dps_cache_manager.h134 void IncreaseGraphStep(const std::string &channel_name);
146 std::string channel_name();
147 void set_channel_name(const std::string channel_name);
Dps_cache_manager.cc206 auto channel = channel_name(); in InitDataChannel()
264 std::string PsCacheManager::channel_name() { in channel_name() function in mindspore::ps::PsCacheManager
269 void PsCacheManager::set_channel_name(const std::string channel_name) { in set_channel_name() argument
270 if (channel_name_ == channel_name) { in set_channel_name()
274 channel_name_ = channel_name; in set_channel_name()
292 void PsCacheManager::IncreaseGraphStep(const std::string &channel_name) { in IncreaseGraphStep() argument
309 set_channel_name(channel_name); in IncreaseGraphStep()
310 if (!PsDataPrefetch::GetInstance().TryWakeChannel(channel_name)) { in IncreaseGraphStep()
311 MS_LOG(EXCEPTION) << "TryWakeChannel failed, channel name: " << channel_name; in IncreaseGraphStep()
/third_party/mindspore/mindspore/core/utils/
Dms_context.cc128 std::string channel_name = "_npu_log"; in CreateTensorPrintThread() local
129 acl_handle_ = acltdtCreateChannel(device_id, (kReceivePrefix + channel_name).c_str()); in CreateTensorPrintThread()
/third_party/ffmpeg/libavutil/
Dchannel_layout.c34 struct channel_name { struct
39 static const struct channel_name channel_names[] = { argument
/third_party/cef/libcef/common/
Dcrash_reporter_client.h54 std::wstring* channel_name) override;
Dcrash_reporter_client.cc582 std::wstring* channel_name) { in GetProductNameAndVersion() argument
586 *channel_name = std::wstring(); in GetProductNameAndVersion()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/datasetops/
Ddevice_queue_op.h66 …DeviceQueueOp(std::string channel_name, DeviceType device_type, int32_t device_id, int32_t prefetc…
/third_party/mindspore/mindspore/ccsrc/backend/session/
Dgpu_session.cc554 std::string channel_name; in ExecuteGraph() local
555 …(ps::PsDataPrefetch::GetInstance().cache_enable() && IsGetNextGraph(kernel_graph, &channel_name)) { in ExecuteGraph()
556 ps::ps_cache_instance.IncreaseGraphStep(channel_name); in ExecuteGraph()

12