Searched refs:output_list_ (Results 1 – 8 of 8) sorted by relevance
73 output_list_.push_back(df); in EnqueueDataFrame()534 if (output_list_.empty()) { in DoWrite()539 if (output_list_.empty()) { in DoWrite()543 while (!output_list_.empty()) { in DoWrite()545 << "DoWrite: Items in output list: " << output_list_.size(); in DoWrite()553 if (sm_interface_ && output_list_.size() < 2) { in DoWrite()556 DataFrame* data_frame = output_list_.front(); in DoWrite()563 output_list_.pop_front(); in DoWrite()571 if (output_list_.size() > 1) { in DoWrite()572 VLOG(2) << log_prefix_ << "Outlist size: " << output_list_.size() in DoWrite()[all …]
60 OutputList* output_list() { return &output_list_; } in output_list()148 OutputList output_list_; variable
134 OutputList* output_list_; variable
24 output_list_(connection->output_list()), in HttpSM()
69 output_list_.push_back(df); in EnqueueDataFrame()530 if (output_list_.empty()) { in DoWrite()535 if (output_list_.empty()) { in DoWrite()539 while (!output_list_.empty()) { in DoWrite()541 << output_list_.size(); in DoWrite()549 if (sm_interface_ && output_list_.size() < 2) { in DoWrite()552 DataFrame* data_frame = output_list_.front(); in DoWrite()559 output_list_.pop_front(); in DoWrite()567 if (output_list_.size() > 1) { in DoWrite()568 VLOG(2) << log_prefix_ << "Outlist size: " << output_list_.size() in DoWrite()[all …]
61 OutputList* output_list() { return &output_list_; } in output_list()146 OutputList output_list_; variable
126 OutputList* output_list_; variable
26 output_list_(connection->output_list()), in HttpSM()