lsquic_alarmset.c revision bc520ef7 
1/* Copyright (c) 2017 - 2020 LiteSpeed Technologies Inc.  See LICENSE. */
2/*
3 * lsquic_alarmset.c -- A set of alarms
4 */
5
6#include <assert.h>
7#include <string.h>
8
9#include "lsquic_types.h"
10#include "lsquic_packet_common.h"
11#include "lsquic_alarmset.h"
12
13#define LSQUIC_LOGGER_MODULE LSQLM_ALARMSET
14#define LSQUIC_LOG_CONN_ID lsquic_conn_log_cid(alset->as_conn)
15#include "lsquic_logger.h"
16
17
18void
19lsquic_alarmset_init (lsquic_alarmset_t *alset, const struct lsquic_conn *conn)
20{
21    alset->as_conn      = conn;
22    alset->as_armed_set = 0;
23}
24
25
26void
27lsquic_alarmset_init_alarm (lsquic_alarmset_t *alset, enum alarm_id al_id,
28                            lsquic_alarm_cb_f callback, void *cb_ctx)
29{
30    alset->as_alarms[ al_id ].callback = callback;
31    alset->as_alarms[ al_id ].cb_ctx   = cb_ctx;
32}
33
34
35const char *const lsquic_alid2str[] =
36{
37    [AL_HANDSHAKE]  =  "HANDSHAKE",
38    [AL_RETX_INIT]  =  "RETX_INIT",
39    [AL_RETX_HSK]   =  "RETX_HSK",
40    [AL_RETX_APP]   =  "RETX_APP",
41    [AL_PING]       =  "PING",
42    [AL_IDLE]       =  "IDLE",
43    [AL_ACK_APP]    =  "ACK_APP",
44    [AL_RET_CIDS]   =  "RET_CIDS",
45    [AL_CID_THROT]  =  "CID_THROT",
46    [AL_PATH_CHAL_0] = "PATH_CHAL_0",
47    [AL_PATH_CHAL_1] = "PATH_CHAL_1",
48    [AL_SESS_TICKET] = "SESS_TICKET",
49    [AL_BLOCKED_KA] = "BLOCKED_KA",
50};
51
52
53void
54lsquic_alarmset_ring_expired (lsquic_alarmset_t *alset, lsquic_time_t now)
55{
56    enum alarm_id_bit armed_set;
57    enum alarm_id al_id;
58
59    for (al_id = 0, armed_set = alset->as_armed_set;
60            al_id < MAX_LSQUIC_ALARMS && armed_set;
61                armed_set &= ~(1 << al_id), ++al_id)
62        if (armed_set & (1 << al_id))
63        {
64            if (alset->as_expiry[al_id] < now)
65            {
66                alset->as_armed_set &= ~(1 << al_id);
67                LSQ_INFO("ring expired %s alarm", lsquic_alid2str[al_id]);
68                alset->as_alarms[al_id].callback(al_id,
69                                alset->as_alarms[al_id].cb_ctx,
70                                alset->as_expiry[al_id], now);
71            }
72        }
73}
74
75
76lsquic_time_t
77lsquic_alarmset_mintime (const lsquic_alarmset_t *alset, enum alarm_id *idp)
78{
79    lsquic_time_t expiry;
80    enum alarm_id al_id, ret_id;
81
82    if (alset->as_armed_set)
83    {
84        expiry = UINT64_MAX;
85        for (al_id = 0, ret_id = 0; al_id < MAX_LSQUIC_ALARMS; ++al_id)
86            if ((alset->as_armed_set & (1 << al_id))
87                                && alset->as_expiry[al_id] < expiry)
88            {
89                expiry = alset->as_expiry[al_id];
90                ret_id = al_id;
91            }
92        *idp = ret_id;
93        return expiry;
94    }
95    else
96        return 0;
97}
98