Searched refs:queue (Results 1 – 15 of 15) sorted by relevance
18 let queue = new DataMessageQueue(); variable22 expect(queue.push('abc')).toEqual(true);26 expect(queue.size()).toEqual(1);30 expect(queue.pop()).toEqual('abc');34 expect(queue.push(null)).toEqual(false);
99 Queue<JsonObject> queue = new LinkedList<>(); in checkCompressNativeLibs() local100 queue.offer(jsonObject); in checkCompressNativeLibs()101 while (queue.size() > 0) { in checkCompressNativeLibs()102 JsonObject curJsonObject = queue.poll(); in checkCompressNativeLibs()109 queue.offer(entry.getValue().getAsJsonObject()); in checkCompressNativeLibs()
243 let mut queue = VecDeque::new(); in read_and_send_data() localVariable252 queue.push_back(worker); in read_and_send_data()256 if queue.is_empty() { in read_and_send_data()259 let handler = queue.pop_front(); in read_and_send_data()275 queue.push_back(worker); in read_and_send_data()
61 std::queue<CtxFileIO *> writeQueue;
232 virtual void RequestSendPackage(uint8_t *data, const size_t length, bool queue = true);
659 void HdcUARTBase::RequestSendPackage(uint8_t *data, const size_t length, bool queue) in RequestSendPackage() argument664 if (queue) { in RequestSendPackage()
92 std::queue<std::string> splitFilePaths_;
84 let mut queue = Self::get_sub_app_files_resurively(&path); in init_install() localVariable85 self.transfer.task_queue.append(&mut queue); in init_install()
109 std::queue<SpString> beQueue;
33 std::queue<long long> timeStampQ;
26 std::queue<long long> timeStampQ;
37 std::queue<long long> timeStampQ;
247 .WillRepeatedly(Invoke([&](uint8_t *data, const size_t length, bool queue) { in __anon7f708f190402() argument
1274 * dimensions or adds the job to the execution queue.
7449 struct request_queue *queue; member7698 struct request_queue *queue; member8013 void **queue; member23100 struct list_head queue[100]; member29159 struct request_queue *queue; member29181 struct request_queue *queue; member35173 struct ptr_ring *queue; member36312 struct watch_queue *queue; member58881 struct hlist_head queue[1024]; member61929 struct request_queue *queue; member[all …]