*/
static void trunk_request_enter_unassigned(fr_trunk_request_t *treq)
{
- fr_trunk_t *trunk = treq->trunk;
+ fr_trunk_t *trunk = treq->trunk;
switch (treq->state) {
case FR_TRUNK_REQUEST_UNASSIGNED:
*/
static void trunk_request_enter_pending(fr_trunk_request_t *treq, fr_trunk_connection_t *tconn)
{
- fr_trunk_t *trunk = treq->trunk;
+ fr_trunk_t *trunk = treq->trunk;
rad_assert(tconn->trunk == trunk);
rad_assert(tconn->state == FR_TRUNK_CONN_ACTIVE);
*/
static void trunk_request_enter_sent(fr_trunk_request_t *treq)
{
- fr_trunk_connection_t *tconn = treq->tconn;
- fr_trunk_t *trunk = treq->trunk;
+ fr_trunk_connection_t *tconn = treq->tconn;
+ fr_trunk_t *trunk = treq->trunk;
if (!fr_cond_assert(!tconn || (tconn->trunk == trunk))) return;
*/
static void trunk_request_enter_cancel(fr_trunk_request_t *treq, fr_trunk_cancel_reason_t reason)
{
- fr_trunk_connection_t *tconn = treq->tconn;
- fr_trunk_t *trunk = treq->trunk;
+ fr_trunk_connection_t *tconn = treq->tconn;
+ fr_trunk_t *trunk = treq->trunk;
if (!fr_cond_assert(!tconn || (tconn->trunk == trunk))) return;
*/
static void trunk_request_enter_cancel_complete(fr_trunk_request_t *treq)
{
- fr_trunk_connection_t *tconn = treq->tconn;
- fr_trunk_t *trunk = treq->trunk;
+ fr_trunk_connection_t *tconn = treq->tconn;
+ fr_trunk_t *trunk = treq->trunk;
if (!fr_cond_assert(!tconn || (tconn->trunk == trunk))) return;
if (!fr_cond_assert(!treq->request)) return; /* Only a valid state for REQUEST * which have been cancelled */
static fr_trunk_enqueue_t trunk_request_check_enqueue(fr_trunk_connection_t **tconn_out, fr_trunk_t *trunk,
REQUEST *request)
{
- fr_trunk_connection_t *tconn;
+ fr_trunk_connection_t *tconn;
uint64_t limit;
/*
*/
static fr_trunk_enqueue_t trunk_request_enqueue_existing(fr_trunk_request_t *treq)
{
- fr_trunk_t *trunk = treq->trunk;
- fr_trunk_connection_t *tconn = NULL;
+ fr_trunk_t *trunk = treq->trunk;
+ fr_trunk_connection_t *tconn = NULL;
fr_trunk_enqueue_t rcode;
/*
fr_trunk_enqueue_t fr_trunk_request_enqueue(fr_trunk_request_t **treq_out, fr_trunk_t *trunk,
REQUEST *request, void *preq, void *rctx)
{
- fr_trunk_connection_t *tconn;
+ fr_trunk_connection_t *tconn;
fr_trunk_request_t *treq;
fr_trunk_enqueue_t rcode;
static void _trunk_connection_on_failed(UNUSED fr_connection_t *conn, UNUSED fr_connection_state_t state, void *uctx)
{
fr_trunk_connection_t *tconn = talloc_get_type_abort(uctx, fr_trunk_connection_t);
- fr_trunk_t *trunk = tconn->trunk;
+ fr_trunk_t *trunk = tconn->trunk;
/*
* Other conditions will be handled by on_closed