Searched refs:queue_name_ (Results 1 – 4 of 4) sorted by relevance
54 XfeedQueueManager(string queue_name) : queue_name_(queue_name) {} in XfeedQueueManager()89 const string queue_name_;
44 VLOG(3) << "Enqueueing " << queue_name_ << " buffer (of " << buffers.size() in EnqueueBuffersAtomically()
47 queue_name_ = queue_runner_def.queue_name(); in Init()77 Env::Default(), SanitizeThreadSuffix(queue_name_), nthreads)); in Init()
112 string queue_name_; variable