Searched refs:active_stream_id (Results 1 – 3 of 3) sorted by relevance
31 uint32_t active_stream_id = task_info->active_stream_id(); in StreamActiveTask() local33 << ", active stream id: " << active_stream_id; in StreamActiveTask()34 if (stream_id >= stream_list.size() || active_stream_id >= stream_list.size()) { in StreamActiveTask()38 active_stream_ = stream_list[active_stream_id]; in StreamActiveTask()45 …_LOG(INFO) << "Stream " << task_info_->stream_id() << " active " << task_info_->active_stream_id(); in Distribute()
38 …void SetActiveStreamId(const uint32_t &active_stream_id) { active_stream_ids_.push_back(active_str… in SetActiveStreamId() argument
354 StreamActiveTaskInfo(const std::string &op_name, uint32_t stream_id, uint32_t active_stream_id) in StreamActiveTaskInfo() argument355 …nfo(op_name, stream_id, TaskInfoType::STREAM_ACTIVE, false), active_stream_id_(active_stream_id) {} in StreamActiveTaskInfo()358 uint32_t active_stream_id() const { return active_stream_id_; } in active_stream_id() function