Searched refs:queue (Results 1 – 12 of 12) sorted by relevance
19 let queue = new DataMessageQueue(); variable23 expect(queue.push('abc')).toEqual(true);27 expect(queue.size()).toEqual(1);31 expect(queue.pop()).toEqual('abc');35 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()
26 std::queue<long long> timeStampQ;
109 std::queue<SpString> beQueue;
80 std::queue<std::string> splitFilePaths_;
61 std::queue<CtxFileIO *> writeQueue;
232 virtual void RequestSendPackage(uint8_t *data, const size_t length, bool queue = true);
657 void HdcUARTBase::RequestSendPackage(uint8_t *data, const size_t length, bool queue) in RequestSendPackage() argument662 if (queue) { in RequestSendPackage()
37 std::queue<long long> timeStampQ;
247 .WillRepeatedly(Invoke([&](uint8_t *data, const size_t length, bool queue) { in __anon6048c1370402() argument
1552 * 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 …]