Searched refs:min_deadline (Results 1 – 5 of 5) sorted by relevance
65 grpc_millis min_deadline; member284 shard->min_deadline = compute_min_deadline(shard); in timer_list_init()340 shard->min_deadline < in note_deadline_change()341 g_shard_queue[shard->shard_queue_index - 1]->min_deadline) { in note_deadline_change()345 shard->min_deadline > in note_deadline_change()346 g_shard_queue[shard->shard_queue_index + 1]->min_deadline) { in note_deadline_change()424 shard->min_deadline); in timer_init()426 if (deadline < shard->min_deadline) { in timer_init()427 grpc_millis old_min_deadline = g_shard_queue[0]->min_deadline; in timer_init()428 shard->min_deadline = deadline; in timer_init()[all …]
68 grpc_millis min_deadline; member286 shard->min_deadline = compute_min_deadline(shard); in timer_list_init()342 shard->min_deadline < in note_deadline_change()343 g_shard_queue[shard->shard_queue_index - 1]->min_deadline) { in note_deadline_change()347 shard->min_deadline > in note_deadline_change()348 g_shard_queue[shard->shard_queue_index + 1]->min_deadline) { in note_deadline_change()427 shard->min_deadline); in timer_init()429 if (deadline < shard->min_deadline) { in timer_init()430 grpc_millis old_min_deadline = g_shard_queue[0]->min_deadline; in timer_init()431 shard->min_deadline = deadline; in timer_init()[all …]
207 grpc_millis* min_deadline = nullptr; in test2() local210 if (min_deadline == nullptr) { in test2()211 min_deadline = &elems[i].elem.deadline; in test2()213 if (elems[i].elem.deadline < *min_deadline) { in test2()214 min_deadline = &elems[i].elem.deadline; in test2()219 GPR_ASSERT(grpc_timer_heap_top(&pq)->deadline == *min_deadline); in test2()
417 const grpc_millis min_deadline = in continue_connect_locked() local420 args.deadline = std::max(c->next_attempt_deadline, min_deadline); in continue_connect_locked()
1037 const grpc_millis min_deadline = in ContinueConnectingLocked() local1040 args.deadline = std::max(next_attempt_deadline_, min_deadline); in ContinueConnectingLocked()