Searched refs:target_queue_iterator (Results 1 – 3 of 3) sorted by relevance
279 const queue_iterator_type target_queue_iterator = find_or_create_queue_unlocked(_target); in send_intern() local293 const bool queue_size_zero_on_entry(target_queue_iterator->second.second.empty()); in send_intern()294 if (!check_queue_limit(_data, _size, target_queue_iterator->second.first)) { in send_intern()358 queue_train(target_queue_iterator, target_train, in send_intern()398 const queue_iterator_type target_queue_iterator = find_or_create_queue_unlocked(_target); in send_segments() local399 const bool queue_size_zero_on_entry(target_queue_iterator->second.second.empty()); in send_segments()426 queue_train(target_queue_iterator, target_train, queue_size_zero_on_entry); in send_segments()429 const bool queue_size_still_zero(target_queue_iterator->second.second.empty()); in send_segments()431 target_queue_iterator->second.second.emplace_back(s); in send_segments()432 target_queue_iterator->second.first += s->size(); in send_segments()[all …]
232 const queue_iterator_type target_queue_iterator(find_or_create_queue_unlocked(its_target)); in send_error() local233 auto& its_qpair = target_queue_iterator->second; in send_error()243 send_queued(target_queue_iterator); in send_error()
124 const queue_iterator_type target_queue_iterator(find_or_create_queue_unlocked(its_target)); in send_error() local125 auto& its_qpair = target_queue_iterator->second; in send_error()135 send_queued(target_queue_iterator); in send_error()