lsquic_alarmset.h revision bc520ef7
17d09751dSDmitri Tikhonov/* Copyright (c) 2017 - 2020 LiteSpeed Technologies Inc. See LICENSE. */ 250aadb33SDmitri Tikhonov/* 350aadb33SDmitri Tikhonov * lsquic_alarmset.h -- A set of alarms 450aadb33SDmitri Tikhonov */ 550aadb33SDmitri Tikhonov 650aadb33SDmitri Tikhonov#ifndef LSQUIC_ALARM_H 750aadb33SDmitri Tikhonov#define LSQUIC_ALARM_H 1 850aadb33SDmitri Tikhonov 950aadb33SDmitri Tikhonov#include "lsquic_int_types.h" 1050aadb33SDmitri Tikhonov 115392f7a3SLiteSpeed Techenum alarm_id; 125392f7a3SLiteSpeed Techstruct lsquic_conn; 135392f7a3SLiteSpeed Tech 145392f7a3SLiteSpeed Techtypedef void (*lsquic_alarm_cb_f)(enum alarm_id, void *cb_ctx, 1550aadb33SDmitri Tikhonov lsquic_time_t expiry, lsquic_time_t now); 1650aadb33SDmitri Tikhonov 1750aadb33SDmitri Tikhonovtypedef struct lsquic_alarm { 1850aadb33SDmitri Tikhonov lsquic_alarm_cb_f callback; 1950aadb33SDmitri Tikhonov void *cb_ctx; 2050aadb33SDmitri Tikhonov} lsquic_alarm_t; 2150aadb33SDmitri Tikhonov 2250aadb33SDmitri Tikhonov 2350aadb33SDmitri Tikhonovenum alarm_id { 2450aadb33SDmitri Tikhonov AL_HANDSHAKE, 255392f7a3SLiteSpeed Tech AL_RETX_INIT, 265392f7a3SLiteSpeed Tech AL_RETX_HSK = AL_RETX_INIT + PNS_HSK, 275392f7a3SLiteSpeed Tech AL_RETX_APP = AL_RETX_INIT + PNS_APP, 2850aadb33SDmitri Tikhonov AL_PING, 2950aadb33SDmitri Tikhonov AL_IDLE, 30bc520ef7SDmitri Tikhonov AL_ACK_APP, 315392f7a3SLiteSpeed Tech AL_RET_CIDS, 325392f7a3SLiteSpeed Tech AL_CID_THROT, 335392f7a3SLiteSpeed Tech AL_PATH_CHAL, 345392f7a3SLiteSpeed Tech AL_PATH_CHAL_0 = AL_PATH_CHAL, 355392f7a3SLiteSpeed Tech AL_PATH_CHAL_1, 3665728dc5SDmitri Tikhonov AL_SESS_TICKET, 379fc12041SDmitri Tikhonov AL_BLOCKED_KA, /* Blocked Keep-Alive */ 3850aadb33SDmitri Tikhonov MAX_LSQUIC_ALARMS 3950aadb33SDmitri Tikhonov}; 4050aadb33SDmitri Tikhonov 4150aadb33SDmitri Tikhonov 4250aadb33SDmitri Tikhonovenum alarm_id_bit { 4350aadb33SDmitri Tikhonov ALBIT_HANDSHAKE = 1 << AL_HANDSHAKE, 445392f7a3SLiteSpeed Tech ALBIT_RETX_INIT = 1 << AL_RETX_INIT, 455392f7a3SLiteSpeed Tech ALBIT_RETX_HSK = 1 << AL_RETX_HSK, 465392f7a3SLiteSpeed Tech ALBIT_RETX_APP = 1 << AL_RETX_APP, 475392f7a3SLiteSpeed Tech ALBIT_ACK_APP = 1 << AL_ACK_APP, 4850aadb33SDmitri Tikhonov ALBIT_PING = 1 << AL_PING, 4950aadb33SDmitri Tikhonov ALBIT_IDLE = 1 << AL_IDLE, 505392f7a3SLiteSpeed Tech ALBIT_RET_CIDS = 1 << AL_RET_CIDS, 515392f7a3SLiteSpeed Tech ALBIT_CID_THROT = 1 << AL_CID_THROT, 525392f7a3SLiteSpeed Tech ALBIT_PATH_CHAL_0 = 1 << AL_PATH_CHAL_0, 535392f7a3SLiteSpeed Tech ALBIT_PATH_CHAL_1 = 1 << AL_PATH_CHAL_1, 5465728dc5SDmitri Tikhonov ALBIT_SESS_TICKET = 1 << AL_SESS_TICKET, 559fc12041SDmitri Tikhonov ALBIT_BLOCKED_KA = 1 << AL_BLOCKED_KA, 5650aadb33SDmitri Tikhonov}; 5750aadb33SDmitri Tikhonov 5850aadb33SDmitri Tikhonov 5950aadb33SDmitri Tikhonovtypedef struct lsquic_alarmset { 6050aadb33SDmitri Tikhonov enum alarm_id_bit as_armed_set; 6150aadb33SDmitri Tikhonov lsquic_time_t as_expiry[MAX_LSQUIC_ALARMS]; 625392f7a3SLiteSpeed Tech const struct lsquic_conn *as_conn; /* Used for logging */ 6350aadb33SDmitri Tikhonov struct lsquic_alarm as_alarms[MAX_LSQUIC_ALARMS]; 6450aadb33SDmitri Tikhonov} lsquic_alarmset_t; 6550aadb33SDmitri Tikhonov 6650aadb33SDmitri Tikhonov 6750aadb33SDmitri Tikhonovvoid 685392f7a3SLiteSpeed Techlsquic_alarmset_init (lsquic_alarmset_t *, const struct lsquic_conn *); 6950aadb33SDmitri Tikhonov 7050aadb33SDmitri Tikhonovvoid 7150aadb33SDmitri Tikhonovlsquic_alarmset_init_alarm (lsquic_alarmset_t *, enum alarm_id, 7250aadb33SDmitri Tikhonov lsquic_alarm_cb_f, void *cb_ctx); 7350aadb33SDmitri Tikhonov 7450aadb33SDmitri Tikhonov#define lsquic_alarmset_set(alarmset, al_id, exp) do { \ 7550aadb33SDmitri Tikhonov (alarmset)->as_armed_set |= 1 << (al_id); \ 7650aadb33SDmitri Tikhonov (alarmset)->as_expiry[al_id] = exp; \ 7750aadb33SDmitri Tikhonov} while (0) 7850aadb33SDmitri Tikhonov 7950aadb33SDmitri Tikhonov#define lsquic_alarmset_unset(alarmset, al_id) do { \ 8050aadb33SDmitri Tikhonov (alarmset)->as_armed_set &= ~(1 << (al_id)); \ 8150aadb33SDmitri Tikhonov} while (0) 8250aadb33SDmitri Tikhonov 8350aadb33SDmitri Tikhonov#define lsquic_alarmset_is_set(alarmset, al_id) \ 8450aadb33SDmitri Tikhonov ((alarmset)->as_armed_set & (1 << (al_id))) 8550aadb33SDmitri Tikhonov 865392f7a3SLiteSpeed Tech#define lsquic_alarmset_are_set(alarmset, flags) \ 875392f7a3SLiteSpeed Tech ((alarmset)->as_armed_set & (flags)) 885392f7a3SLiteSpeed Tech 8950aadb33SDmitri Tikhonov/* Timers "fire," alarms "ring." */ 9050aadb33SDmitri Tikhonovvoid 9150aadb33SDmitri Tikhonovlsquic_alarmset_ring_expired (lsquic_alarmset_t *, lsquic_time_t now); 9250aadb33SDmitri Tikhonov 93e8bd737dSDmitri Tikhonovlsquic_time_t 940adf085aSDmitri Tikhonovlsquic_alarmset_mintime (const lsquic_alarmset_t *, enum alarm_id *); 950adf085aSDmitri Tikhonov 960adf085aSDmitri Tikhonovextern const char *const lsquic_alid2str[]; 97e8bd737dSDmitri Tikhonov 9850aadb33SDmitri Tikhonov#endif 99