Packages

hackney

3.0.2
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_rechist.h
Raw

c_src/lsquic/src/liblsquic/lsquic_rechist.h 

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

/*

 * lsquic_rechist.h -- History of received packets.

 *

 * The purpose of received packet history is to generate ACK frames.

 */



#ifndef LSQUIC_RECHIST_H

#define LSQUIC_RECHIST_H 1



#ifndef LSQUIC_TEST

#define LSQUIC_TEST 0

#endif



/* Structure is exposed to facilitate some manipulations in unit tests. */

struct rechist_elem {

    lsquic_packno_t     re_low;

    unsigned            re_count;

    unsigned            re_next;    /* UINT_MAX means no next element */

};





struct lsquic_rechist {

    /* elems and masks are allocated in contiguous memory */

    struct rechist_elem            *rh_elems;

    uintptr_t                      *rh_masks;

    lsquic_packno_t                 rh_cutoff;

    lsquic_time_t                   rh_largest_acked_received;

    unsigned                        rh_n_masks;

    unsigned                        rh_n_alloced;

    unsigned                        rh_n_used;

    unsigned                        rh_head;

    unsigned                        rh_max_ranges;

    enum {

        RH_CUTOFF_SET   = (1 << 0),

    }                               rh_flags;

    struct

    {

        struct lsquic_packno_range      range;

        unsigned                        next;

    }                               rh_iter;

};



typedef struct lsquic_rechist lsquic_rechist_t;



void

lsquic_rechist_init (struct lsquic_rechist *, int is_ietf, unsigned max_ranges);



void

lsquic_rechist_cleanup (struct lsquic_rechist *);



enum received_st {

    REC_ST_OK,

    REC_ST_DUP,

    REC_ST_ERR,

};



enum received_st

lsquic_rechist_received (lsquic_rechist_t *, lsquic_packno_t,

                         lsquic_time_t now);



void

lsquic_rechist_stop_wait (lsquic_rechist_t *, lsquic_packno_t);



const struct lsquic_packno_range *

lsquic_rechist_first (lsquic_rechist_t *);



const struct lsquic_packno_range *

lsquic_rechist_next (lsquic_rechist_t *);



lsquic_packno_t

lsquic_rechist_largest_packno (const lsquic_rechist_t *);



lsquic_packno_t

lsquic_rechist_cutoff (const lsquic_rechist_t *);



lsquic_time_t

lsquic_rechist_largest_recv (const lsquic_rechist_t *);



size_t

lsquic_rechist_mem_used (const struct lsquic_rechist *);



const struct lsquic_packno_range *

lsquic_rechist_peek (struct lsquic_rechist *);



#define lsquic_rechist_is_empty(rechist_) ((rechist_)->rh_n_used == 0)



int

lsquic_rechist_copy_ranges (struct lsquic_rechist *, void *rechist_ctx,

    const struct lsquic_packno_range * (*first) (void *),

    const struct lsquic_packno_range * (*next) (void *));



#endif