if (fr_time_delta_ispos(frame->instruction->actions.retry.irt)) {
fr_assert(fr_time_gt(now, fr_time_wrap(0)));
- (void) fr_retry_init(&state->retry, now, &frame->instruction->actions.retry); /* can't fail */
+ fr_retry_init(&state->retry, now, &frame->instruction->actions.retry);
if (fr_event_timer_at(request, unlang_interpret_event_list(request),
&state->ev, state->retry.next,
* @param now when the retransmission starts
* @param config the counters to track. They shouldn't change while the retransmission is happening
*/
-int fr_retry_init(fr_retry_t *r, fr_time_t now, fr_retry_config_t const *config)
+void fr_retry_init(fr_retry_t *r, fr_time_t now, fr_retry_config_t const *config)
{
uint64_t scale;
fr_time_delta_t rt;
r->rt = rt;
r->next = fr_time_add(now, rt);
-
- return 0;
}
/** Initialize a retransmission counter
FR_RETRY_MRD, //!< reached maximum retransmission duration
} fr_retry_state_t;
-int fr_retry_init(fr_retry_t *r, fr_time_t now, fr_retry_config_t const *config) CC_HINT(nonnull);
+void fr_retry_init(fr_retry_t *r, fr_time_t now, fr_retry_config_t const *config) CC_HINT(nonnull);
fr_retry_state_t fr_retry_next(fr_retry_t *r, fr_time_t now) CC_HINT(nonnull);
#ifdef __cplusplus
if (fr_time_eq(u->retry.start, fr_time_wrap(0))) {
u->id = fr_rand() & 0xff; /* We don't care what the value is here */
h->status_checking = true; /* Ensure this is valid */
- (void) fr_retry_init(&u->retry, fr_time(), &h->inst->parent->retry[u->code]);
+ fr_retry_init(&u->retry, fr_time(), &h->inst->parent->retry[u->code]);
/*
* Status checks can never be retransmitted
* Start retransmissions from when the socket is writable.
*/
if (fr_time_eq(u->retry.start, fr_time_wrap(0))) {
- (void) fr_retry_init(&u->retry, fr_time(), &h->inst->parent->retry[u->code]);
+ fr_retry_init(&u->retry, fr_time(), &h->inst->parent->retry[u->code]);
fr_assert(fr_time_delta_ispos(u->retry.rt));
fr_assert(fr_time_gt(u->retry.next, fr_time_wrap(0)));
}
/*
* Start retransmissions from when the socket is writable.
*/
- (void) fr_retry_init(&u->retry, fr_time(), &h->inst->parent->retry);
+ fr_retry_init(&u->retry, fr_time(), &h->inst->parent->retry);
fr_assert(fr_time_delta_ispos(u->retry.rt));
fr_assert(fr_time_gt(u->retry.next, fr_time_wrap(0)));