Packages

hackney

2.0.1
4.7.2 4.7.1 4.7.0 4.6.1 4.6.0 4.5.2 4.5.1 4.5.0 4.4.5 4.4.3 4.4.2 4.4.1 4.4.0 4.3.0 4.2.3 4.2.2 4.2.1 4.2.0 4.1.0 4.0.3 4.0.2 4.0.1 4.0.0 3.2.1 3.2.0 3.1.2 3.1.1 3.1.0 3.0.3 3.0.2 3.0.1 3.0.0 retired 2.0.1 2.0.0 2.0.0-beta.1 1.25.0 1.24.1 1.24.0 1.23.0 1.22.0 1.21.0 1.20.1 1.20.0 1.19.1 1.19.0 1.18.2 1.18.1 1.18.0 1.17.4 1.17.3 1.17.2 1.17.1 1.17.0 1.16.0 1.15.2 1.15.1 1.15.0 1.14.3 1.14.2 1.14.0 1.13.0 1.12.1 1.12.0 1.11.0 1.10.1 1.10.0 1.9.0 1.8.6 1.8.5 1.8.4 1.8.3 1.8.2 1.8.0 1.7.1 1.7.0 1.6.6 retired 1.6.5 1.6.4 retired 1.6.3 1.6.2 1.6.1 1.6.0 1.5.7 1.5.6 1.5.5 1.5.4 1.5.3 1.5.2 1.5.1 1.5.0 1.4.10 1.4.8 1.4.7 1.4.6 1.4.5 1.4.4 1.4.3 1.4.2 1.4.1 1.4.0 1.3.2 1.3.1 1.3.0 1.2.0 1.1.0 1.0.6 1.0.5 1.0.2 1.0.1 0.15.2 0.15.0 0.14.3 0.14.2 0.14.1 0.14.0 0.13.1

Simple HTTP client with HTTP/1.1, HTTP/2, and HTTP/3 support

Security advisory: This version has known vulnerabilities. View advisories
HexDocs

Current section

Files

Jump to
Readme
116 Versions
6 Dependencies
Dependants
12 Advisories
Files
Activity
hackney c_src lsquic src liblsquic lsquic_alarmset.c
Raw

c_src/lsquic/src/liblsquic/lsquic_alarmset.c 

/* Copyright (c) 2017 - 2022 LiteSpeed Technologies Inc.  See LICENSE. */

/*

 * lsquic_alarmset.c -- A set of alarms

 */



#include <assert.h>

#include <string.h>



#include "lsquic_types.h"

#include "lsquic_packet_common.h"

#include "lsquic_alarmset.h"



#define LSQUIC_LOGGER_MODULE LSQLM_ALARMSET

#define LSQUIC_LOG_CONN_ID lsquic_conn_log_cid(alset->as_conn)

#include "lsquic_logger.h"





void

lsquic_alarmset_init (lsquic_alarmset_t *alset, const struct lsquic_conn *conn)

{

    alset->as_conn      = conn;

    alset->as_armed_set = 0;

}





void

lsquic_alarmset_init_alarm (lsquic_alarmset_t *alset, enum alarm_id al_id,

                            lsquic_alarm_cb_f callback, void *cb_ctx)

{

    alset->as_alarms[ al_id ].callback = callback;

    alset->as_alarms[ al_id ].cb_ctx   = cb_ctx;

}





const char *const lsquic_alid2str[] =

{

    [AL_HANDSHAKE]  =  "HANDSHAKE",

    [AL_RETX_INIT]  =  "RETX_INIT",

    [AL_RETX_HSK]   =  "RETX_HSK",

    [AL_RETX_APP]   =  "RETX_APP",

    [AL_PING]       =  "PING",

    [AL_IDLE]       =  "IDLE",

    [AL_ACK_APP]    =  "ACK_APP",

    [AL_RET_CIDS]   =  "RET_CIDS",

    [AL_CID_THROT]  =  "CID_THROT",

    [AL_PATH_CHAL_0] = "PATH_CHAL_0",

    [AL_PATH_CHAL_1] = "PATH_CHAL_1",

    [AL_PATH_CHAL_2] = "PATH_CHAL_2",

    [AL_PATH_CHAL_3] = "PATH_CHAL_3",

    [AL_SESS_TICKET] = "SESS_TICKET",

    [AL_BLOCKED_KA] = "BLOCKED_KA",

    [AL_MTU_PROBE]  = "MTU_PROBE",

    [AL_PACK_TOL]   = "PACK_TOL",

};





void

lsquic_alarmset_ring_expired (lsquic_alarmset_t *alset, lsquic_time_t now)

{

    enum alarm_id_bit armed_set;

    enum alarm_id al_id;



    for (al_id = 0, armed_set = alset->as_armed_set;

            al_id < MAX_LSQUIC_ALARMS && armed_set;

                armed_set &= ~(1 << al_id), ++al_id)

        if (armed_set & (1 << al_id))

        {

            if (alset->as_expiry[al_id] < now)

            {

                alset->as_armed_set &= ~(1 << al_id);

                LSQ_INFO("ring expired %s alarm", lsquic_alid2str[al_id]);

                alset->as_alarms[al_id].callback(al_id,

                                alset->as_alarms[al_id].cb_ctx,

                                alset->as_expiry[al_id], now);

            }

        }

}





lsquic_time_t

lsquic_alarmset_mintime (const lsquic_alarmset_t *alset, enum alarm_id *idp)

{

    lsquic_time_t expiry;

    enum alarm_id al_id, ret_id;



    if (alset->as_armed_set)

    {

        expiry = UINT64_MAX;

        for (al_id = 0, ret_id = 0; al_id < MAX_LSQUIC_ALARMS; ++al_id)

            if ((alset->as_armed_set & (1 << al_id))

                                && alset->as_expiry[al_id] < expiry)

            {

                expiry = alset->as_expiry[al_id];

                ret_id = al_id;

            }

        *idp = ret_id;

        return expiry;

    }

    else

        return 0;

}