Searched refs:running_ (Results 1 – 12 of 12) sorted by relevance
144 running_ = false; in ~StreamConsumer()154 bool running_ = true; variable
143 running_ = false; in ~StreamConsumer()153 bool running_ = true; variable
168 running_ = false; in ~StreamConsumer()178 bool running_ = true; variable
222 running_ = false; in ~StreamConsumer()232 bool running_ = true; variable
319 while (running_ == true) { in CreateProducer()351 if (running_ == false) { in CreateProducer()
318 while (running_ == true) { in CreateProducer()350 if (running_ == false) { in CreateProducer()
357 while (running_ == true) { in CreateProducer()389 if (running_ == false) { in CreateProducer()
405 while (running_ == true) { in CreateProducer()438 if (running_ == false) { in CreateProducer()
532 while (running_ == true) { in CreateProducer()565 if (running_ == false) { in CreateProducer()