Searched refs:queue_name (Results 1 – 10 of 10) sorted by relevance
50 static const char *queue_name = "/fork_19_1_mq"; variable67 mq = mq_open(queue_name, O_RDWR | O_CREAT | O_NONBLOCK, in main()80 mq_unlink(queue_name); in main()90 mq_unlink(queue_name); in main()97 mq_unlink(queue_name); in main()107 mq_unlink(queue_name); in main()148 mq_unlink(queue_name); in main()155 mq_unlink(queue_name); in main()165 mq_unlink(queue_name); in main()172 mq_unlink(queue_name); in main()[all …]
54 XfeedQueueManager(string queue_name) : queue_name_(queue_name) {} in XfeedQueueManager() argument
14 string queue_name = 1; field
107 // value: "queue_name: \"test_queue\"\n"
178 ops.prepend_name_scope(queue_runner_def.queue_name, import_scope))371 queue_runner_def.queue_name = ops.strip_name_scope(
1648 queue_runner = queue_runner_pb2.QueueRunnerDef(queue_name="test_queue")2535 queue_runner = queue_runner_pb2.QueueRunnerDef(queue_name="test_queue")
84 const std::string& queue_name, const std::vector<std::string>& enqueue_ops, in BuildQueueRunnerDef() argument88 *queue_runner_def.mutable_queue_name() = queue_name; in BuildQueueRunnerDef()
47 queue_name_ = queue_runner_def.queue_name(); in Init()
651 Status LookupOrCreateBatcherQueue(const string& queue_name, in LookupOrCreateBatcherQueue() argument655 auto it = batcher_queues_.find(queue_name); in LookupOrCreateBatcherQueue()672 batcher_queues_[queue_name] = std::move(new_queue); in LookupOrCreateBatcherQueue()
38 WorkQueue* NewTaskQueue(const char* queue_name) { in NewTaskQueue() argument