Searched refs:min_deadline (Results 1 – 4 of 4) 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 …]
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()
644 min_deadline = (datetime.now() +648 self.assertTrue(t.deadline >= min_deadline)
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()