apiref.rst revision 244e8c6f
1API Reference
2=============
3
4.. highlight:: c
5
6Preliminaries
7-------------
8
9All declarations are in :file:`lsquic.h`, so it is enough to
10
11::
12
13    #incluide <lsquic.h>
14
15in each source file.
16
17
18Library Version
19---------------
20
21LSQUIC follows the following versioning model.  The version number
22has the form MAJOR.MINOR.PATCH, where
23
24- MAJOR changes when a large redesign occurs;
25- MINOR changes when an API change or another significant change occurs; and
26- PATCH changes when a bug is fixed or another small, API-compatible change occurs.
27
28QUIC Versions
29-------------
30
31LSQUIC supports two types of QUIC protocol: Google QUIC and IETF QUIC.  The
32former will at some point become obsolete, while the latter is still being
33developed by the IETF.  Both types are included in a single enum:
34
35.. type:: enum lsquic_version
36
37    .. member:: LSQVER_043
38
39        Google QUIC version Q043
40
41    .. member:: LSQVER_046
42
43        Google QUIC version Q046
44
45    .. member:: LSQVER_050
46
47        Google QUIC version Q050
48
49    .. member:: LSQVER_ID27
50
51        IETF QUIC version ID (Internet-Draft) 27
52
53    .. member:: LSQVER_ID28
54
55        IETF QUIC version ID 28
56
57    .. member:: LSQVER_ID29
58
59        IETF QUIC version ID 29
60
61    .. member:: N_LSQVER
62
63        Special value indicating the number of versions in the enum.  It
64        may be used as argument to :func:`lsquic_engine_connect()`.
65
66Several version lists (as bitmasks) are defined in :file:`lsquic.h`:
67
68.. macro:: LSQUIC_SUPPORTED_VERSIONS
69
70List of all supported versions.
71
72.. macro:: LSQUIC_FORCED_TCID0_VERSIONS
73
74List of versions in which the server never includes CID in short packets.
75
76.. macro:: LSQUIC_EXPERIMENTAL_VERSIONS
77
78Experimental versions.
79
80.. macro:: LSQUIC_DEPRECATED_VERSIONS
81
82Deprecated versions.
83
84.. macro:: LSQUIC_GQUIC_HEADER_VERSIONS
85
86Versions that have Google QUIC-like headers.  Only Q043 remains in this
87list.
88
89.. macro:: LSQUIC_IETF_VERSIONS
90
91IETF QUIC versions.
92
93.. macro:: LSQUIC_IETF_DRAFT_VERSIONS
94
95IETF QUIC *draft* versions.  When IETF QUIC v1 is released, it will not
96be included in this list.
97
98LSQUIC Types
99------------
100
101LSQUIC declares several types used by many of its public functions.  They are:
102
103.. type:: lsquic_engine_t
104
105    Instance of LSQUIC engine.
106
107.. type:: lsquic_conn_t
108
109    QUIC connection.
110
111.. type:: lsquic_stream_t
112
113    QUIC stream.
114
115.. type:: lsquic_stream_id_t
116
117    Stream ID.
118
119.. type:: lsquic_conn_ctx_t
120
121    Connection context.  This is the return value of :member:`lsquic_stream_if.on_new_conn`.
122    To LSQUIC, this is just an opaque pointer.  User code is expected to
123    use it for its own purposes.
124
125.. type:: lsquic_stream_ctx_t
126
127    Stream context.  This is the return value of :func:`on_new_stream()`.
128    To LSQUIC, this is just an opaque pointer.  User code is expected to
129    use it for its own purposes.
130
131.. type:: lsquic_http_headers_t
132
133    HTTP headers
134
135Library Initialization
136----------------------
137
138Before using the library, internal structures must be initialized using
139the global initialization function:
140
141::
142
143    if (0 == lsquic_global_init(LSQUIC_GLOBAL_CLIENT|LSQUIC_GLOBAL_SERVER))
144        /* OK, do something useful */
145        ;
146
147This call only needs to be made once.  Afterwards, any number of LSQUIC
148engines may be instantiated.
149
150After a process is done using LSQUIC, it should clean up:
151
152::
153
154    lsquic_global_cleanup();
155
156Logging
157-------
158
159.. type:: struct lsquic_logger_if
160
161    .. member:: int     (*log_buf)(void *logger_ctx, const char *buf, size_t len)
162
163.. function:: void lsquic_logger_init (const struct lsquic_logger_if *logger_if, void *logger_ctx, enum lsquic_logger_timestamp_style)
164
165    Call this if you want to do something with LSQUIC log messages, as they are thrown out by default.
166
167.. function:: int lsquic_set_log_level (const char *log_level)
168
169    Set log level for all LSQUIC modules.
170
171    :param log_level: Acceptable values are debug, info, notice, warning, error, alert, emerg, crit (case-insensitive).
172    :return: 0 on success or -1 on failure (invalid log level).
173
174.. function:: int lsquic_logger_lopt (const char *log_specs)
175
176    Set log level for a particular module or several modules.
177
178    :param log_specs:
179
180        One or more "module=level" specifications serapated by comma.
181        For example, "event=debug,engine=info".  See `List of Log Modules`_
182
183Engine Instantiation and Destruction
184------------------------------------
185
186To use the library, an instance of the ``struct lsquic_engine`` needs to be
187created:
188
189.. function:: lsquic_engine_t *lsquic_engine_new (unsigned flags, const struct lsquic_engine_api *api)
190
191    Create a new engine.
192
193    :param flags: This is is a bitmask of :macro:`LSENG_SERVER` and
194                :macro:`LSENG_HTTP`.
195    :param api: Pointer to an initialized :type:`lsquic_engine_api`.
196
197    The engine can be instantiated either in server mode (when ``LSENG_SERVER``
198    is set) or client mode.  If you need both server and client in your program,
199    create two engines (or as many as you'd like).
200
201    Specifying ``LSENG_HTTP`` flag enables the HTTP functionality: HTTP/2-like
202    for Google QUIC connections and HTTP/3 functionality for IETF QUIC
203    connections.
204
205.. macro:: LSENG_SERVER
206
207    One of possible bitmask values passed as first argument to
208    :type:`lsquic_engine_new`.  When set, the engine instance
209    will be in the server mode.
210
211.. macro:: LSENG_HTTP
212
213    One of possible bitmask values passed as first argument to
214    :type:`lsquic_engine_new`.  When set, the engine instance
215    will enable HTTP functionality.
216
217.. function:: void lsquic_engine_cooldown (lsquic_engine_t *engine)
218
219    This function closes all mini connections and marks all full connections
220    as going away.  In server mode, this also causes the engine to stop
221    creating new connections.
222
223.. function:: void lsquic_engine_destroy (lsquic_engine_t *engine)
224
225    Destroy engine and all its resources.
226
227Engine Callbacks
228----------------
229
230``struct lsquic_engine_api`` contains a few mandatory members and several
231optional members.
232
233.. type:: struct lsquic_engine_api
234
235    .. member:: const struct lsquic_stream_if       *ea_stream_if
236    .. member:: void                                *ea_stream_if_ctx
237
238        ``ea_stream_if`` is mandatory.  This structure contains pointers
239        to callbacks that handle connections and stream events.
240
241    .. member:: lsquic_packets_out_f                 ea_packets_out
242    .. member:: void                                *ea_packets_out_ctx
243
244        ``ea_packets_out`` is used by the engine to send packets.
245
246    .. member:: const struct lsquic_engine_settings *ea_settings
247
248        If ``ea_settings`` is set to NULL, the engine uses default settings
249        (see :func:`lsquic_engine_init_settings()`)
250
251    .. member:: lsquic_lookup_cert_f                 ea_lookup_cert
252    .. member:: void                                *ea_cert_lu_ctx
253
254        Look up certificate.  Mandatory in server mode.
255
256    .. member:: struct ssl_ctx_st *                (*ea_get_ssl_ctx)(void *peer_ctx)
257
258        Get SSL_CTX associated with a peer context.  Mandatory in server
259        mode.  This is use for default values for SSL instantiation.
260
261    .. member:: const struct lsquic_hset_if         *ea_hsi_if
262    .. member:: void                                *ea_hsi_ctx
263
264        Optional header set interface.  If not specified, the incoming headers
265        are converted to HTTP/1.x format and are read from stream and have to
266        be parsed again.
267
268    .. member:: const struct lsquic_shared_hash_if  *ea_shi
269    .. member:: void                                *ea_shi_ctx
270
271        Shared hash interface can be used to share state between several
272        processes of a single QUIC server.
273
274    .. member:: const struct lsquic_packout_mem_if  *ea_pmi
275    .. member:: void                                *ea_pmi_ctx
276
277        Optional set of functions to manage memory allocation for outgoing
278        packets.
279
280    .. member:: lsquic_cids_update_f                 ea_new_scids
281    .. member:: lsquic_cids_update_f                 ea_live_scids
282    .. member:: lsquic_cids_update_f                 ea_old_scids
283    .. member:: void                                *ea_cids_update_ctx
284
285        In a multi-process setup, it may be useful to observe the CID
286        lifecycle.  This optional set of callbacks makes it possible.
287
288    .. member:: const char                          *ea_alpn
289
290        The optional ALPN string is used by the client if :macro:`LSENG_HTTP`
291        is not set.
292
293.. _apiref-engine-settings:
294
295Engine Settings
296---------------
297
298Engine behavior can be controlled by several settings specified in the
299settings structure:
300
301.. type:: struct lsquic_engine_settings
302
303    .. member:: unsigned        es_versions
304
305        This is a bit mask wherein each bit corresponds to a value in
306        :type:`lsquic_version`.  Client starts negotiating with the highest
307        version and goes down.  Server supports either of the versions
308        specified here.  This setting applies to both Google and IETF QUIC.
309
310        The default value is :macro:`LSQUIC_DF_VERSIONS`.
311
312    .. member:: unsigned        es_cfcw
313
314       Initial default connection flow control window.
315
316       In server mode, per-connection values may be set lower than
317       this if resources are scarce.
318
319       Do not set es_cfcw and es_sfcw lower than :macro:`LSQUIC_MIN_FCW`.
320
321    .. member:: unsigned        es_sfcw
322
323       Initial default stream flow control window.
324
325       In server mode, per-connection values may be set lower than
326       this if resources are scarce.
327
328       Do not set es_cfcw and es_sfcw lower than :macro:`LSQUIC_MIN_FCW`.
329
330    .. member:: unsigned        es_max_cfcw
331
332       This value is used to specify maximum allowed value CFCW is allowed
333       to reach due to window auto-tuning.  By default, this value is zero,
334       which means that CFCW is not allowed to increase from its initial
335       value.
336
337       This setting is applicable to both gQUIC and IETF QUIC.
338
339       See :member:`lsquic_engine_settings.es_cfcw`,
340       :member:`lsquic_engine_settings.es_init_max_data`.
341
342    .. member:: unsigned        es_max_sfcw
343
344       This value is used to specify the maximum value stream flow control
345       window is allowed to reach due to auto-tuning.  By default, this
346       value is zero, meaning that auto-tuning is turned off.
347
348       This setting is applicable to both gQUIC and IETF QUIC.
349
350       See :member:`lsquic_engine_settings.es_sfcw`,
351       :member:`lsquic_engine_settings.es_init_max_stream_data_bidi_local`,
352       :member:`lsquic_engine_settings.es_init_max_stream_data_bidi_remote`.
353
354    .. member:: unsigned        es_max_streams_in
355
356        Maximum incoming streams, a.k.a. MIDS.
357
358        Google QUIC only.
359
360    .. member:: unsigned long   es_handshake_to
361
362       Handshake timeout in microseconds.
363
364       For client, this can be set to an arbitrary value (zero turns the
365       timeout off).
366
367       For server, this value is limited to about 16 seconds.  Do not set
368       it to zero.
369
370       Defaults to :macro:`LSQUIC_DF_HANDSHAKE_TO`.
371
372    .. member:: unsigned long   es_idle_conn_to
373
374        Idle connection timeout, a.k.a ICSL, in microseconds; GQUIC only.
375
376        Defaults to :macro:`LSQUIC_DF_IDLE_CONN_TO`
377
378    .. member:: int             es_silent_close
379
380        SCLS (silent close)
381
382    .. member:: unsigned        es_max_header_list_size
383
384       This corresponds to SETTINGS_MAX_HEADER_LIST_SIZE
385       (:rfc:`7540#section-6.5.2`).  0 means no limit.  Defaults
386       to :func:`LSQUIC_DF_MAX_HEADER_LIST_SIZE`.
387
388    .. member:: const char     *es_ua
389
390        UAID -- User-Agent ID.  Defaults to :macro:`LSQUIC_DF_UA`.
391
392        Google QUIC only.
393
394
395       More parameters for server
396
397    .. member:: unsigned        es_max_inchoate
398
399        Maximum number of incoming connections in inchoate state.  (In
400        other words, maximum number of mini connections.)
401
402        This is only applicable in server mode.
403
404        Defaults to :macro:`LSQUIC_DF_MAX_INCHOATE`.
405
406    .. member:: int             es_support_push
407
408       Setting this value to 0 means that
409
410       For client:
411
412       1. we send a SETTINGS frame to indicate that we do not support server
413          push; and
414       2. all incoming pushed streams get reset immediately.
415
416       (For maximum effect, set es_max_streams_in to 0.)
417
418       For server:
419
420       1. :func:`lsquic_conn_push_stream()` will return -1.
421
422    .. member:: int             es_support_tcid0
423
424       If set to true value, the server will not include connection ID in
425       outgoing packets if client's CHLO specifies TCID=0.
426
427       For client, this means including TCID=0 into CHLO message.  Note that
428       in this case, the engine tracks connections by the
429       (source-addr, dest-addr) tuple, thereby making it necessary to create
430       a socket for each connection.
431
432       This option has no effect in Q046 and Q050, as the server never includes
433       CIDs in the short packets.
434
435       This setting is applicable to gQUIC only.
436
437       The default is :func:`LSQUIC_DF_SUPPORT_TCID0`.
438
439    .. member:: int             es_support_nstp
440
441       Q037 and higher support "No STOP_WAITING frame" mode.  When set, the
442       client will send NSTP option in its Client Hello message and will not
443       sent STOP_WAITING frames, while ignoring incoming STOP_WAITING frames,
444       if any.  Note that if the version negotiation happens to downgrade the
445       client below Q037, this mode will *not* be used.
446
447       This option does not affect the server, as it must support NSTP mode
448       if it was specified by the client.
449
450        Defaults to :macro:`LSQUIC_DF_SUPPORT_NSTP`.
451
452    .. member:: int             es_honor_prst
453
454       If set to true value, the library will drop connections when it
455       receives corresponding Public Reset packet.  The default is to
456       ignore these packets.
457
458       The default is :macro:`LSQUIC_DF_HONOR_PRST`.
459
460    .. member:: int             es_send_prst
461
462       If set to true value, the library will send Public Reset packets
463       in response to incoming packets with unknown Connection IDs.
464
465       The default is :macro:`LSQUIC_DF_SEND_PRST`.
466
467    .. member:: unsigned        es_progress_check
468
469       A non-zero value enables internal checks that identify suspected
470       infinite loops in user `on_read` and `on_write` callbacks
471       and break them.  An infinite loop may occur if user code keeps
472       on performing the same operation without checking status, e.g.
473       reading from a closed stream etc.
474
475       The value of this parameter is as follows: should a callback return
476       this number of times in a row without making progress (that is,
477       reading, writing, or changing stream state), loop break will occur.
478
479       The defaut value is :macro:`LSQUIC_DF_PROGRESS_CHECK`.
480
481    .. member:: int             es_rw_once
482
483       A non-zero value make stream dispatch its read-write events once
484       per call.
485
486       When zero, read and write events are dispatched until the stream
487       is no longer readable or writeable, respectively, or until the
488       user signals unwillingness to read or write using
489       :func:`lsquic_stream_wantread()` or :func:`lsquic_stream_wantwrite()`
490       or shuts down the stream.
491
492       The default value is :macro:`LSQUIC_DF_RW_ONCE`.
493
494    .. member:: unsigned        es_proc_time_thresh
495
496       If set, this value specifies the number of microseconds that
497       :func:`lsquic_engine_process_conns()` and
498       :func:`lsquic_engine_send_unsent_packets()` are allowed to spend
499       before returning.
500
501       This is not an exact science and the connections must make
502       progress, so the deadline is checked after all connections get
503       a chance to tick (in the case of :func:`lsquic_engine_process_conns())`
504       and at least one batch of packets is sent out.
505
506       When processing function runs out of its time slice, immediate
507       calls to :func:`lsquic_engine_has_unsent_packets()` return false.
508
509       The default value is :func:`LSQUIC_DF_PROC_TIME_THRESH`.
510
511    .. member:: int             es_pace_packets
512
513       If set to true, packet pacing is implemented per connection.
514
515       The default value is :func:`LSQUIC_DF_PACE_PACKETS`.
516
517    .. member:: unsigned        es_clock_granularity
518
519       Clock granularity information is used by the pacer.  The value
520       is in microseconds; default is :func:`LSQUIC_DF_CLOCK_GRANULARITY`.
521
522    .. member:: unsigned        es_init_max_data
523
524       Initial max data.
525
526       This is a transport parameter.
527
528       Depending on the engine mode, the default value is either
529       :macro:`LSQUIC_DF_INIT_MAX_DATA_CLIENT` or
530       :macro:`LSQUIC_DF_INIT_MAX_DATA_SERVER`.
531
532       IETF QUIC only.
533
534    .. member:: unsigned        es_init_max_stream_data_bidi_remote
535
536       Initial max stream data.
537
538       This is a transport parameter.
539
540       Depending on the engine mode, the default value is either
541       :macro:`LSQUIC_DF_INIT_MAX_STREAM_DATA_BIDI_REMOTE_CLIENT` or
542       :macro:`LSQUIC_DF_INIT_MAX_STREAM_DATA_BIDI_REMOTE_SERVER`.
543
544       IETF QUIC only.
545
546    .. member:: unsigned        es_init_max_stream_data_bidi_local
547
548       Initial max stream data.
549
550       This is a transport parameter.
551
552       Depending on the engine mode, the default value is either
553       :macro:`LSQUIC_DF_INIT_MAX_STREAM_DATA_BIDI_LOCAL_CLIENT` or
554       :macro:`LSQUIC_DF_INIT_MAX_STREAM_DATA_BIDI_LOCAL_SERVER`.
555
556       IETF QUIC only.
557
558    .. member:: unsigned        es_init_max_stream_data_uni
559
560       Initial max stream data for unidirectional streams initiated
561       by remote endpoint.
562
563       This is a transport parameter.
564
565       Depending on the engine mode, the default value is either
566       :macro:`LSQUIC_DF_INIT_MAX_STREAM_DATA_UNI_CLIENT` or
567       :macro:`LSQUIC_DF_INIT_MAX_STREAM_DATA_UNI_SERVER`.
568
569       IETF QUIC only.
570
571    .. member:: unsigned        es_init_max_streams_bidi
572
573       Maximum initial number of bidirectional stream.
574
575       This is a transport parameter.
576
577       Default value is :macro:`LSQUIC_DF_INIT_MAX_STREAMS_BIDI`.
578
579       IETF QUIC only.
580
581    .. member:: unsigned        es_init_max_streams_uni
582
583       Maximum initial number of unidirectional stream.
584
585       This is a transport parameter.
586
587       Default value is :macro:`LSQUIC_DF_INIT_MAX_STREAMS_UNI_CLIENT` or
588       :macro:`LSQUIC_DF_INIT_MAX_STREAM_DATA_UNI_SERVER`.
589
590       IETF QUIC only.
591
592    .. member:: unsigned        es_idle_timeout
593
594       Idle connection timeout.
595
596       This is a transport parameter.
597
598       (Note: `es_idle_conn_to` is not reused because it is in microseconds,
599       which, I now realize, was not a good choice.  Since it will be
600       obsoleted some time after the switchover to IETF QUIC, we do not
601       have to keep on using strange units.)
602
603       Default value is :macro:`LSQUIC_DF_IDLE_TIMEOUT`.
604
605       Maximum value is 600 seconds.
606
607       IETF QUIC only.
608
609    .. member:: unsigned        es_ping_period
610
611       Ping period.  If set to non-zero value, the connection will generate and
612       send PING frames in the absence of other activity.
613
614       By default, the server does not send PINGs and the period is set to zero.
615       The client's defaut value is :macro:`LSQUIC_DF_PING_PERIOD`.
616
617       IETF QUIC only.
618
619    .. member:: unsigned        es_scid_len
620
621       Source Connection ID length.  Valid values are 0 through 20, inclusive.
622
623       Default value is :macro:`LSQUIC_DF_SCID_LEN`.
624
625       IETF QUIC only.
626
627    .. member:: unsigned        es_scid_iss_rate
628
629       Source Connection ID issuance rate.  This field is measured in CIDs
630       per minute.  Using value 0 indicates that there is no rate limit for
631       CID issuance.
632
633       Default value is :macro:`LSQUIC_DF_SCID_ISS_RATE`.
634
635       IETF QUIC only.
636
637    .. member:: unsigned        es_qpack_dec_max_size
638
639       Maximum size of the QPACK dynamic table that the QPACK decoder will
640       use.
641
642       The default is :macro:`LSQUIC_DF_QPACK_DEC_MAX_SIZE`.
643
644       IETF QUIC only.
645
646    .. member:: unsigned        es_qpack_dec_max_blocked
647
648       Maximum number of blocked streams that the QPACK decoder is willing
649       to tolerate.
650
651       The default is :macro:`LSQUIC_DF_QPACK_DEC_MAX_BLOCKED`.
652
653       IETF QUIC only.
654
655    .. member:: unsigned        es_qpack_enc_max_size
656
657       Maximum size of the dynamic table that the encoder is willing to use.
658       The actual size of the dynamic table will not exceed the minimum of
659       this value and the value advertized by peer.
660
661       The default is :macro:`LSQUIC_DF_QPACK_ENC_MAX_SIZE`.
662
663       IETF QUIC only.
664
665    .. member:: unsigned        es_qpack_enc_max_blocked
666
667       Maximum number of blocked streams that the QPACK encoder is willing
668       to risk.  The actual number of blocked streams will not exceed the
669       minimum of this value and the value advertized by peer.
670
671       The default is :macro:`LSQUIC_DF_QPACK_ENC_MAX_BLOCKED`.
672
673       IETF QUIC only.
674
675    .. member:: int             es_ecn
676
677       Enable ECN support.
678
679       The default is :macro:`LSQUIC_DF_ECN`
680
681       IETF QUIC only.
682
683    .. member:: int             es_allow_migration
684
685       Allow peer to migrate connection.
686
687       The default is :macro:`LSQUIC_DF_ALLOW_MIGRATION`
688
689       IETF QUIC only.
690
691    .. member:: unsigned        es_cc_algo
692
693       Congestion control algorithm to use.
694
695       - 0:  Use default (:macro:`LSQUIC_DF_CC_ALGO)`
696       - 1:  Cubic
697       - 2:  BBR
698
699       IETF QUIC only.
700
701    .. member:: int             es_ql_bits
702
703       Use QL loss bits.  Allowed values are:
704
705       - 0:  Do not use loss bits
706       - 1:  Allow loss bits
707       - 2:  Allow and send loss bits
708
709       Default value is :macro:`LSQUIC_DF_QL_BITS`
710
711    .. member:: int             es_spin
712
713       Enable spin bit.  Allowed values are 0 and 1.
714
715       Default value is :macro:`LSQUIC_DF_SPIN`
716
717    .. member:: int             es_delayed_acks
718
719       Enable delayed ACKs extension.  Allowed values are 0 and 1.
720
721       **Warning**: this is an experimental feature.  Using it will most likely
722       lead to degraded performance.
723
724       Default value is :macro:`LSQUIC_DF_DELAYED_ACKS`
725
726    .. member:: int             es_timestamps
727
728       Enable timestamps extension.  Allowed values are 0 and 1.
729
730       Default value is @ref LSQUIC_DF_TIMESTAMPS
731
732    .. member:: unsigned short  es_max_udp_payload_size_rx
733
734       Maximum packet size we are willing to receive.  This is sent to
735       peer in transport parameters: the library does not enforce this
736       limit for incoming packets.
737
738       If set to zero, limit is not set.
739
740       Default value is :macro:`LSQUIC_DF_MAX_UDP_PAYLOAD_SIZE_RX`
741
742    .. member:: int es_dplpmtud
743
744       If set to true value, enable DPLPMTUD -- Datagram Packetization
745       Layer Path MTU Discovery.
746
747       Default value is :macro:`LSQUIC_DF_DPLPMTUD`
748
749    .. member:: unsigned short  es_base_plpmtu
750
751        PLPMTU size expected to work for most paths.
752
753        If set to zero, this value is calculated based on QUIC and IP versions.
754
755        Default value is :macro:`LSQUIC_DF_BASE_PLPMTU`
756
757    .. member:: unsigned short  es_max_plpmtu
758
759        Largest PLPMTU size the engine will try.
760
761        If set to zero, picking this value is left to the engine.
762
763        Default value is :macro:`LSQUIC_DF_MAX_PLPMTU`
764
765    .. member:: unsigned        es_mtu_probe_timer
766
767        This value specifies how long the DPLPMTUD probe timer is, in
768        milliseconds.  `[draft-ietf-tsvwg-datagram-plpmtud-22] <https://tools.ietf.org/html/draft-ietf-tsvwg-datagram-plpmtud-22>`_ says:
769
770            PROBE_TIMER:  The PROBE_TIMER is configured to expire after a period
771            longer than the maximum time to receive an acknowledgment to a
772            probe packet.  This value MUST NOT be smaller than 1 second, and
773            SHOULD be larger than 15 seconds.  Guidance on selection of the
774            timer value are provided in section 3.1.1 of the UDP Usage
775            Guidelines :rfc:`8085#section-3.1`.
776
777        If set to zero, the default is used.
778
779        Default value is :macro:`LSQUIC_DF_MTU_PROBE_TIMER`
780
781    .. member:: unsigned        es_noprogress_timeout
782
783       No progress timeout.
784
785       If connection does not make progress for this number of seconds, the
786       connection is dropped.  Here, progress is defined as user streams
787       being written to or read from.
788
789       If this value is zero, this timeout is disabled.
790
791       Default value is :macro:`LSQUIC_DF_NOPROGRESS_TIMEOUT_SERVER` in server
792       mode and :macro:`LSQUIC_DF_NOPROGRESS_TIMEOUT_CLIENT` in client mode.
793
794    .. member:: int             es_grease_quic_bit
795
796       Enable the "QUIC bit grease" extension.  When set to a true value,
797       lsquic will grease the QUIC bit on the outgoing QUIC packets if
798       the peer sent the "grease_quic_bit" transport parameter.
799
800       Default value is :macro:`LSQUIC_DF_GREASE_QUIC_BIT`
801
802To initialize the settings structure to library defaults, use the following
803convenience function:
804
805.. function:: lsquic_engine_init_settings (struct lsquic_engine_settings *, unsigned flags)
806
807    ``flags`` is a bitmask of ``LSENG_SERVER`` and ``LSENG_HTTP``
808
809After doing this, change just the settings you'd like.  To check whether
810the values are correct, another convenience function is provided:
811
812.. function:: lsquic_engine_check_settings (const struct lsquic_engine_settings *, unsigned flags, char *err_buf, size_t err_buf_sz)
813
814    Check settings for errors.  Return 0 if settings are OK, -1 otherwise.
815
816    If `err_buf` and `err_buf_sz` are set, an error string is written to the
817    buffers.
818
819The following macros in :file:`lsquic.h` specify default values:
820
821*Note that, despite our best efforts, documentation may accidentally get
822out of date.  Please check your :file:`lsquic.h` for actual values.*
823
824.. macro::      LSQUIC_MIN_FCW
825
826    Minimum flow control window is set to 16 KB for both client and server.
827    This means we can send up to this amount of data before handshake gets
828    completed.
829
830.. macro:: LSQUIC_DF_VERSIONS
831
832    By default, deprecated and experimental versions are not included.
833
834.. macro:: LSQUIC_DF_CFCW_SERVER
835.. macro:: LSQUIC_DF_CFCW_CLIENT
836.. macro:: LSQUIC_DF_SFCW_SERVER
837.. macro:: LSQUIC_DF_SFCW_CLIENT
838.. macro:: LSQUIC_DF_MAX_STREAMS_IN
839
840.. macro:: LSQUIC_DF_INIT_MAX_DATA_SERVER
841.. macro:: LSQUIC_DF_INIT_MAX_DATA_CLIENT
842.. macro:: LSQUIC_DF_INIT_MAX_STREAM_DATA_BIDI_REMOTE_SERVER
843.. macro:: LSQUIC_DF_INIT_MAX_STREAM_DATA_BIDI_LOCAL_SERVER
844.. macro:: LSQUIC_DF_INIT_MAX_STREAM_DATA_BIDI_REMOTE_CLIENT
845.. macro:: LSQUIC_DF_INIT_MAX_STREAM_DATA_BIDI_LOCAL_CLIENT
846.. macro:: LSQUIC_DF_INIT_MAX_STREAMS_BIDI
847.. macro:: LSQUIC_DF_INIT_MAX_STREAMS_UNI_CLIENT
848.. macro:: LSQUIC_DF_INIT_MAX_STREAMS_UNI_SERVER
849.. macro:: LSQUIC_DF_INIT_MAX_STREAM_DATA_UNI_CLIENT
850.. macro:: LSQUIC_DF_INIT_MAX_STREAM_DATA_UNI_SERVER
851
852.. macro:: LSQUIC_DF_IDLE_TIMEOUT
853
854    Default idle connection timeout is 30 seconds.
855
856.. macro:: LSQUIC_DF_PING_PERIOD
857
858    Default ping period is 15 seconds.
859
860.. macro:: LSQUIC_DF_HANDSHAKE_TO
861
862    Default handshake timeout is 10,000,000 microseconds (10 seconds).
863
864.. macro:: LSQUIC_DF_IDLE_CONN_TO
865
866    Default idle connection timeout is 30,000,000 microseconds.
867
868.. macro:: LSQUIC_DF_SILENT_CLOSE
869
870    By default, connections are closed silenty when they time out (no
871    CONNECTION_CLOSE frame is sent).
872
873.. macro:: LSQUIC_DF_MAX_HEADER_LIST_SIZE
874
875    Default value of maximum header list size.  If set to non-zero value,
876    SETTINGS_MAX_HEADER_LIST_SIZE will be sent to peer after handshake is
877    completed (assuming the peer supports this setting frame type).
878
879.. macro:: LSQUIC_DF_UA
880
881    Default value of UAID (user-agent ID).
882
883.. macro:: LSQUIC_DF_MAX_INCHOATE
884
885    Default is 1,000,000.
886
887.. macro:: LSQUIC_DF_SUPPORT_NSTP
888
889    NSTP is not used by default.
890
891.. macro:: LSQUIC_DF_SUPPORT_PUSH
892
893    Push promises are supported by default.
894
895.. macro:: LSQUIC_DF_SUPPORT_TCID0
896
897    Support for TCID=0 is enabled by default.
898
899.. macro:: LSQUIC_DF_HONOR_PRST
900
901    By default, LSQUIC ignores Public Reset packets.
902
903.. macro:: LSQUIC_DF_SEND_PRST
904
905    By default, LSQUIC will not send Public Reset packets in response to
906    packets that specify unknown connections.
907
908.. macro:: LSQUIC_DF_PROGRESS_CHECK
909
910    By default, infinite loop checks are turned on.
911
912.. macro:: LSQUIC_DF_RW_ONCE
913
914    By default, read/write events are dispatched in a loop.
915
916.. macro:: LSQUIC_DF_PROC_TIME_THRESH
917
918    By default, the threshold is not enabled.
919
920.. macro:: LSQUIC_DF_PACE_PACKETS
921
922    By default, packets are paced
923
924.. macro:: LSQUIC_DF_CLOCK_GRANULARITY
925
926    Default clock granularity is 1000 microseconds.
927
928.. macro:: LSQUIC_DF_SCID_LEN
929
930    The default value is 8 for simplicity and speed.
931
932.. macro:: LSQUIC_DF_SCID_ISS_RATE
933
934    The default value is 60 CIDs per minute.
935
936.. macro:: LSQUIC_DF_QPACK_DEC_MAX_BLOCKED
937
938    Default value is 100.
939
940.. macro:: LSQUIC_DF_QPACK_DEC_MAX_SIZE
941
942    Default value is 4,096 bytes.
943
944.. macro:: LSQUIC_DF_QPACK_ENC_MAX_BLOCKED
945
946    Default value is 100.
947
948.. macro:: LSQUIC_DF_QPACK_ENC_MAX_SIZE
949
950    Default value is 4,096 bytes.
951
952.. macro:: LSQUIC_DF_ECN
953
954    ECN is disabled by default.
955
956.. macro:: LSQUIC_DF_ALLOW_MIGRATION
957
958    Allow migration by default.
959
960.. macro:: LSQUIC_DF_QL_BITS
961
962    Use QL loss bits by default.
963
964.. macro:: LSQUIC_DF_SPIN
965
966    Turn spin bit on by default.
967
968.. macro:: LSQUIC_DF_CC_ALGO
969
970    Use Cubic by default.
971
972.. macro:: LSQUIC_DF_DELAYED_ACKS
973
974    Delayed ACKs are off by default.
975
976.. macro:: LSQUIC_DF_MAX_UDP_PAYLOAD_SIZE_RX
977
978    By default, incoming packet size is not limited.
979
980.. macro:: LSQUIC_DF_DPLPMTUD
981
982    By default, DPLPMTUD is enabled
983
984.. macro:: LSQUIC_DF_BASE_PLPMTU
985
986    By default, this value is left up to the engine.
987
988.. macro:: LSQUIC_DF_MAX_PLPMTU
989
990    By default, this value is left up to the engine.
991
992.. macro:: LSQUIC_DF_MTU_PROBE_TIMER
993
994    By default, we use the minimum timer of 1000 milliseconds.
995
996.. macro:: LSQUIC_DF_NOPROGRESS_TIMEOUT_SERVER
997
998    By default, drop no-progress connections after 60 seconds on the server.
999
1000.. macro:: LSQUIC_DF_NOPROGRESS_TIMEOUT_CLIENT
1001
1002    By default, do not use no-progress timeout on the client.
1003
1004.. macro:: LSQUIC_DF_GREASE_QUIC_BIT
1005
1006    By default, greasing the QUIC bit is enabled (if peer sent
1007    the "grease_quic_bit" transport parameter).
1008
1009Receiving Packets
1010-----------------
1011
1012Incoming packets are supplied to the engine using :func:`lsquic_engine_packet_in()`.
1013It is up to the engine to decide what do to with the packet.  It can find an existing
1014connection and dispatch the packet there, create a new connection (in server mode), or
1015schedule a version negotiation or stateless reset packet.
1016
1017.. function:: int lsquic_engine_packet_in (lsquic_engine_t *engine, const unsigned char *data, size_t size, const struct sockaddr *local, const struct sockaddr *peer, void *peer_ctx, int ecn)
1018
1019    Pass incoming packet to the QUIC engine.  This function can be called
1020    more than once in a row.  After you add one or more packets, call
1021    :func:`lsquic_engine_process_conns()` to schedule outgoing packets, if any.
1022
1023    :param engine: Engine instance.
1024    :param data: Pointer to UDP datagram payload.
1025    :param size: Size of UDP datagram.
1026    :param local: Local address.
1027    :param peer: Peer address.
1028    :param peer_ctx: Peer context.
1029    :param ecn: ECN marking associated with this UDP datagram.
1030
1031    :return:
1032
1033        - ``0``: Packet was processed by a real connection.
1034        - ``1``: Packet was handled successfully, but not by a connection.
1035          This may happen with version negotiation and public reset
1036          packets as well as some packets that may be ignored.
1037        - ``-1``: Some error occurred.  Possible reasons are invalid packet
1038          size or failure to allocate memory.
1039
1040.. function:: int lsquic_engine_earliest_adv_tick (lsquic_engine_t *engine, int *diff)
1041
1042    Returns true if there are connections to be processed, false otherwise.
1043
1044    :param engine:
1045
1046        Engine instance.
1047
1048    :param diff:
1049
1050        If the function returns a true value, the pointed to integer is set to the
1051        difference between the earliest advisory tick time and now.
1052        If the former is in the past, this difference is negative.
1053
1054    :return:
1055
1056        True if there are connections to be processed, false otherwise.
1057
1058Sending Packets
1059---------------
1060
1061User specifies a callback :type:`lsquic_packets_out_f` in :type:`lsquic_engine_api`
1062that the library uses to send packets.
1063
1064.. type:: struct lsquic_out_spec
1065
1066    This structure describes an outgoing packet.
1067
1068    .. member:: struct iovec          *iov
1069
1070        A vector with payload.
1071
1072    .. member:: size_t                 iovlen
1073
1074        Vector length.
1075
1076    .. member:: const struct sockaddr *local_sa
1077
1078        Local address.
1079
1080    .. member:: const struct sockaddr *dest_sa
1081
1082        Destination address.
1083
1084    .. member:: void                  *peer_ctx
1085
1086        Peer context associated with the local address.
1087
1088    .. member:: int                    ecn
1089
1090        ECN: Valid values are 0 - 3. See :rfc:`3168`.
1091
1092        ECN may be set by IETF QUIC connections if ``es_ecn`` is set.
1093
1094.. type:: typedef int (*lsquic_packets_out_f)(void *packets_out_ctx, const struct lsquic_out_spec  *out_spec, unsigned n_packets_out)
1095
1096    Returns number of packets successfully sent out or -1 on error.  -1 should
1097    only be returned if no packets were sent out.  If -1 is returned or if the
1098    return value is smaller than ``n_packets_out``, this indicates that sending
1099    of packets is not possible.
1100
1101    If not all packets could be sent out, then:
1102
1103        - errno is examined.  If it is not EAGAIN or EWOULDBLOCK, the connection
1104          whose packet caused the error is closed forthwith.
1105        - No packets are attempted to be sent out until :func:`lsquic_engine_send_unsent_packets()`
1106          is called.
1107
1108.. function:: void lsquic_engine_process_conns (lsquic_engine_t *engine)
1109
1110    Process tickable connections.  This function must be called often enough so
1111    that packets and connections do not expire.  The preferred method of doing
1112    so is by using :func:`lsquic_engine_earliest_adv_tick()`.
1113
1114.. function:: int lsquic_engine_has_unsent_packets (lsquic_engine_t *engine)
1115
1116    Returns true if engine has some unsent packets.  This happens if
1117    :member:`lsquic_engine_api.ea_packets_out` could not send everything out
1118    or if processing deadline was exceeded (see
1119    :member:`lsquic_engine_settings.es_proc_time_thresh`).
1120
1121.. function:: void lsquic_engine_send_unsent_packets (lsquic_engine_t *engine)
1122
1123    Send out as many unsent packets as possibe: until we are out of unsent
1124    packets or until ``ea_packets_out()`` fails.
1125
1126    If ``ea_packets_out()`` cannot send all packets, this function must be
1127    called to signify that sending of packets is possible again.
1128
1129Stream Callback Interface
1130-------------------------
1131
1132The stream callback interface structure lists the callbacks used by
1133the engine to communicate with the user code:
1134
1135.. type:: struct lsquic_stream_if
1136
1137    .. member:: lsquic_conn_ctx_t *(*on_new_conn)(void *stream_if_ctx, lsquic_conn_t *)
1138
1139        Called when a new connection has been created.  In server mode,
1140        this means that the handshake has been successful.  In client mode,
1141        on the other hand, this callback is called as soon as connection
1142        object is created inside the engine, but before the handshake is
1143        done.
1144
1145        The return value is the connection context associated with this
1146        connection.  Use :func:`lsquic_conn_get_ctx()` to get back this
1147        context.  It is OK for this function to return NULL.
1148
1149        This callback is mandatory.
1150
1151    .. member:: void (*on_conn_closed)(lsquic_conn_t *)
1152
1153        Connection is closed.
1154
1155        This callback is mandatory.
1156
1157    .. member:: lsquic_stream_ctx_t * (*on_new_stream)(void *stream_if_ctx, lsquic_stream_t *)
1158
1159        If you need to initiate a connection, call lsquic_conn_make_stream().
1160        This will cause `on_new_stream` callback to be called when appropriate
1161        (this operation is delayed when maximum number of outgoing streams is
1162        reached).
1163
1164        If connection is going away, this callback may be called with the
1165        second parameter set to NULL.
1166
1167        The return value is the stream context associated with the stream.
1168        A pointer to it is passed to `on_read()`, `on_write()`, and `on_close()`
1169        callbacks.  It is OK for this function to return NULL.
1170
1171        This callback is mandatory.
1172
1173    .. member:: void (*on_read)     (lsquic_stream_t *s, lsquic_stream_ctx_t *h)
1174
1175        Stream is readable: either there are bytes to be read or an error
1176        is ready to be collected.
1177
1178        This callback is mandatory.
1179
1180    .. member:: void (*on_write)    (lsquic_stream_t *s, lsquic_stream_ctx_t *h)
1181
1182        Stream is writeable.
1183
1184        This callback is mandatory.
1185
1186    .. member:: void (*on_close)    (lsquic_stream_t *s, lsquic_stream_ctx_t *h)
1187
1188        After this callback returns, the stream is no longer accessible.  This is
1189        a good time to clean up the stream context.
1190
1191        This callback is mandatory.
1192
1193    .. member:: void (*on_hsk_done)(lsquic_conn_t *c, enum lsquic_hsk_status s)
1194
1195        When handshake is completed, this callback is called.
1196
1197        This callback is optional.
1198
1199    .. member:: void (*on_goaway_received)(lsquic_conn_t *)
1200
1201        This is called when our side received GOAWAY frame.  After this,
1202        new streams should not be created.
1203
1204        This callback is optional.
1205
1206    .. member:: void (*on_new_token)(lsquic_conn_t *c, const unsigned char *token, size_t token_size)
1207
1208        When client receives a token in NEW_TOKEN frame, this callback is called.
1209
1210        This callback is optional.
1211
1212    .. member:: void (*on_sess_resume_info)(lsquic_conn_t *c, const unsigned char *, size_t)
1213
1214        This callback lets client record information needed to
1215        perform session resumption next time around.
1216
1217        This callback is optional.
1218
1219Creating Connections
1220--------------------
1221
1222In server mode, the connections are created by the library based on incoming
1223packets.  After handshake is completed, the library calls :member:`lsquic_stream_if.on_new_conn`
1224callback.
1225
1226In client mode, a new connection is created by
1227
1228.. function:: lsquic_conn_t * lsquic_engine_connect (lsquic_engine_t *engine, enum lsquic_version version, const struct sockaddr *local_sa, const struct sockaddr *peer_sa, void *peer_ctx, lsquic_conn_ctx_t *conn_ctx, const char *sni, unsigned short base_plpmtu, const unsigned char *sess_resume, size_t sess_resume_len, const unsigned char *token, size_t token_sz)
1229
1230    :param engine: Engine to use.
1231
1232    :param version:
1233
1234        To let the engine specify QUIC version, use N_LSQVER.  If session resumption
1235        information is supplied, version is picked from there instead.
1236
1237    :param local_sa:
1238
1239        Local address.
1240
1241    :param peer_sa:
1242
1243        Address of the server.
1244
1245    :param peer_ctx:
1246
1247        Context associated with the peer.  This is what gets passed to TODO.
1248
1249    :param conn_ctx:
1250
1251        Connection context can be set early using this parameter.  Useful if
1252        you need the connection context to be available in `on_conn_new()`.
1253        Note that that callback's return value replaces the connection
1254        context set here.
1255
1256    :param sni:
1257
1258        The SNI is required for Google QUIC connections; it is optional for
1259        IETF QUIC and may be set to NULL.
1260
1261    :param base_plpmtu:
1262
1263        Base PLPMTU.  If set to zero, it is selected based on the
1264        engine settings (see
1265        :member:`lsquic_engine_settings.es_base_plpmtu`),
1266        QUIC version, and IP version.
1267
1268    :param sess_resume:
1269
1270        Pointer to previously saved session resumption data needed for
1271        TLS resumption.  May be NULL.
1272
1273    :param sess_resume_len:
1274
1275        Size of session resumption data.
1276
1277    :param token:
1278
1279        Pointer to previously received token to include in the Initial
1280        packet.  Tokens are used by IETF QUIC to pre-validate client
1281        connections, potentially avoiding a retry.
1282
1283        See :member:`lsquic_stream_if.on_new_token` callback.
1284
1285        May be NULL.
1286
1287    :param token_sz:
1288
1289        Size of data pointed to by ``token``.
1290
1291Closing Connections
1292-------------------
1293
1294.. function:: void lsquic_conn_going_away (lsquic_conn_t *conn)
1295
1296    Mark connection as going away: send GOAWAY frame and do not accept
1297    any more incoming streams, nor generate streams of our own.
1298
1299    Only applicable to HTTP/3 and GQUIC connections.  Otherwise a no-op.
1300
1301.. function:: void lsquic_conn_close (lsquic_conn_t *conn)
1302
1303    This closes the connection.  :member:`lsquic_stream_if.on_conn_closed`
1304    and :member:`lsquic_stream_if.on_close` callbacks will be called.
1305
1306Creating Streams
1307----------------
1308
1309Similar to connections, streams are created by the library in server mode; they
1310correspond to requests.  In client mode, a new stream is created by
1311
1312.. function:: void lsquic_conn_make_stream (lsquic_conn_t *)
1313
1314    Create a new request stream.  This causes :member:`on_new_stream()` callback
1315    to be called.  If creating more requests is not permitted at the moment
1316    (due to number of concurrent streams limit), stream creation is registered
1317    as "pending" and the stream is created later when number of streams dips
1318    under the limit again.  Any number of pending streams can be created.
1319    Use :func:`lsquic_conn_n_pending_streams()` and
1320    :func:`lsquic_conn_cancel_pending_streams()` to manage pending streams.
1321
1322    If connection is going away, :func:`on_new_stream()` is called with the
1323    stream parameter set to NULL.
1324
1325Stream Events
1326-------------
1327
1328To register or unregister an interest in a read or write event, use the
1329following functions:
1330
1331.. function:: int lsquic_stream_wantread (lsquic_stream_t *stream, int want)
1332
1333    :param stream: Stream to read from.
1334    :param want: Boolean value indicating whether the caller wants to read
1335                 from stream.
1336    :return: Previous value of ``want`` or ``-1`` if the stream has already
1337             been closed for reading.
1338
1339    A stream becomes readable if there is was an error: for example, the
1340    peer may have reset the stream.  In this case, reading from the stream
1341    will return an error.
1342
1343.. function:: int lsquic_stream_wantwrite (lsquic_stream_t *stream, int want)
1344
1345    :param stream: Stream to write to.
1346    :param want: Boolean value indicating whether the caller wants to write
1347                 to stream.
1348    :return: Previous value of ``want`` or ``-1`` if the stream has already
1349             been closed for writing.
1350
1351Reading From Streams
1352--------------------
1353
1354.. function:: ssize_t lsquic_stream_read (lsquic_stream_t *stream, unsigned char *buf, size_t sz)
1355
1356    :param stream: Stream to read from.
1357    :param buf: Buffer to copy data to.
1358    :param sz: Size of the buffer.
1359    :return: Number of bytes read, zero if EOS has been reached, or -1 on error.
1360
1361    Read up to ``sz`` bytes from ``stream`` into buffer ``buf``.
1362
1363    ``-1`` is returned on error, in which case ``errno`` is set:
1364
1365    - ``EBADF``: The stream is closed.
1366    - ``ECONNRESET``: The stream has been reset.
1367    - ``EWOULDBLOCK``: There is no data to be read.
1368
1369.. function:: ssize_t lsquic_stream_readv (lsquic_stream_t *stream, const struct iovec *vec, int iovcnt)
1370
1371    :param stream: Stream to read from.
1372    :param vec: Array of ``iovec`` structures.
1373    :param iovcnt: Number of elements in ``vec``.
1374    :return: Number of bytes read, zero if EOS has been reached, or -1 on error.
1375
1376    Similar to :func:`lsquic_stream_read()`, but reads data into a vector.
1377
1378.. function:: ssize_t lsquic_stream_readf (lsquic_stream_t *stream, size_t (*readf)(void *ctx, const unsigned char *buf, size_t len, int fin), void *ctx)
1379
1380    :param stream: Stream to read from.
1381
1382    :param readf:
1383
1384        The callback takes four parameters:
1385
1386        - Pointer to user-supplied context;
1387        - Pointer to the data;
1388        - Data size (can be zero); and
1389        - Indicator whether the FIN follows the data.
1390
1391        The callback returns number of bytes processed.  If this number is zero
1392        or is smaller than ``len``, reading from stream stops.
1393
1394    :param ctx: Context pointer passed to ``readf``.
1395
1396    This function allows user-supplied callback to read the stream contents.
1397    It is meant to be used for zero-copy stream processing.
1398
1399    Return value and errors are same as in :func:`lsquic_stream_read()`.
1400
1401Writing To Streams
1402------------------
1403
1404.. function:: ssize_t lsquic_stream_write (lsquic_stream_t *stream, const void *buf, size_t len)
1405
1406    :param stream: Stream to write to.
1407    :param buf: Buffer to copy data from.
1408    :param len: Number of bytes to copy.
1409    :return: Number of bytes written -- which may be smaller than ``len`` -- or a negative
1410             value when an error occurs.
1411
1412    Write ``len`` bytes to the stream.  Returns number of bytes written, which
1413    may be smaller that ``len``.
1414
1415    A negative return value indicates a serious error (the library is likely
1416    to have aborted the connection because of it).
1417
1418.. function:: ssize_t lsquic_stream_writev (lsquic_stream_t *s, const struct iovec *vec, int count)
1419
1420    Like :func:`lsquic_stream_write()`, but read data from a vector.
1421
1422.. type:: struct lsquic_reader
1423
1424    Used as argument to :func:`lsquic_stream_writef()`.
1425
1426    .. member:: size_t (*lsqr_read) (void *lsqr_ctx, void *buf, size_t count)
1427
1428        :param lsqr_ctx: Pointer to user-specified context.
1429        :param buf: Memory location to write to.
1430        :param count: Size of available memory pointed to by ``buf``.
1431        :return:
1432
1433            Number of bytes written.  This is not a ``ssize_t`` because
1434            the read function is not supposed to return an error.  If an error
1435            occurs in the read function (for example, when reading from a file
1436            fails), it is supposed to deal with the error itself.
1437
1438    .. member:: size_t (*lsqr_size) (void *lsqr_ctx)
1439
1440        Return number of bytes remaining in the reader.
1441
1442    .. member:: void    *lsqr_ctx
1443
1444        Context pointer passed both to ``lsqr_read()`` and to ``lsqr_size()``.
1445
1446.. function:: ssize_t lsquic_stream_writef (lsquic_stream_t *stream, struct lsquic_reader *reader)
1447
1448    :param stream: Stream to write to.
1449    :param reader: Reader to read from.
1450    :return: Number of bytes written or -1 on error.
1451
1452    Write to stream using :type:`lsquic_reader`.  This is the most generic of
1453    the write functions -- :func:`lsquic_stream_write()` and
1454    :func:`lsquic_stream_writev()` utilize the same mechanism.
1455
1456.. function:: int lsquic_stream_flush (lsquic_stream_t *stream)
1457
1458    :param stream: Stream to flush.
1459    :return: 0 on success and -1 on failure.
1460
1461    Flush any buffered data.  This triggers packetizing even a single byte
1462    into a separate frame.  Flushing a closed stream is an error.
1463
1464Closing Streams
1465---------------
1466
1467Streams can be closed for reading, writing, or both.
1468``on_close()`` callback is called at some point after a stream is closed
1469for both reading and writing,
1470
1471.. function:: int lsquic_stream_shutdown (lsquic_stream_t *stream, int how)
1472
1473    :param stream: Stream to shut down.
1474    :param how:
1475
1476        This parameter specifies what do to.  Allowed values are:
1477
1478        - 0: Stop reading.
1479        - 1: Stop writing.
1480        - 2: Stop both reading and writing.
1481
1482    :return: 0 on success or -1 on failure.
1483
1484.. function:: int lsquic_stream_close (lsquic_stream_t *stream)
1485
1486    :param stream: Stream to close.
1487    :return: 0 on success or -1 on failure.
1488
1489Sending HTTP Headers
1490--------------------
1491
1492.. type:: struct lsxpack_header
1493
1494This type is defined in _lsxpack_header.h_.  See that header file for
1495more information.
1496
1497    .. member:: char             *buf
1498
1499        the buffer for headers
1500
1501    .. member:: uint32_t          name_hash
1502
1503        hash value for name
1504
1505    .. member:: uint32_t          nameval_hash
1506
1507        hash value for name + value
1508
1509    .. member:: lsxpack_strlen_t  name_offset
1510
1511        the offset for name in the buffer
1512
1513    .. member:: lsxpack_strlen_t  name_len
1514
1515        the length of name
1516
1517    .. member:: lsxpack_strlen_t  val_offset
1518
1519        the offset for value in the buffer
1520
1521    .. member:: lsxpack_strlen_t  val_len
1522
1523        the length of value
1524
1525    .. member:: uint16_t          chain_next_idx
1526
1527        mainly for cookie value chain
1528
1529    .. member:: uint8_t           hpack_index
1530
1531        HPACK static table index
1532
1533    .. member:: uint8_t           qpack_index
1534
1535        QPACK static table index
1536
1537    .. member:: uint8_t           app_index
1538
1539        APP header index
1540
1541    .. member:: enum lsxpack_flag flags:8
1542
1543        combination of lsxpack_flag
1544
1545    .. member:: uint8_t           indexed_type
1546
1547        control to disable index or not
1548
1549    .. member:: uint8_t           dec_overhead
1550
1551        num of extra bytes written to decoded buffer
1552
1553.. type:: lsquic_http_headers_t
1554
1555    .. member::     int   count
1556
1557        Number of headers in ``headers``.
1558
1559    .. member::     struct lsxpack_header   *headers
1560
1561        Pointer to an array of HTTP headers.
1562
1563    HTTP header list structure.  Contains a list of HTTP headers.
1564
1565.. function:: int lsquic_stream_send_headers (lsquic_stream_t *stream, const lsquic_http_headers_t *headers, int eos)
1566
1567    :param stream:
1568
1569        Stream to send headers on.
1570
1571    :param headers:
1572
1573        Headers to send.
1574
1575    :param eos:
1576
1577        Boolean value to indicate whether these headers constitute the whole
1578        HTTP message.
1579
1580    :return:
1581
1582        0 on success or -1 on error.
1583
1584Receiving HTTP Headers
1585----------------------
1586
1587If ``ea_hsi_if`` is not set in :type:`lsquic_engine_api`, the library will translate
1588HPACK- and QPACK-encoded headers into HTTP/1.x-like headers and prepend them to the
1589stream.  To the stream-reading function, it will look as if a standard HTTP/1.x
1590message.
1591
1592Alternatively, you can specify header-processing set of functions and manage header
1593fields yourself.  In that case, the header set must be "read" from the stream via
1594:func:`lsquic_stream_get_hset()`.
1595
1596.. type:: struct lsquic_hset_if
1597
1598    .. member::  void * (*hsi_create_header_set)(void *hsi_ctx, lsquic_stream_t *stream, int is_push_promise)
1599
1600        :param hsi_ctx: User context.  This is the pointer specifed in ``ea_hsi_ctx``.
1601        :param stream: Stream with which the header set is associated.  May be set
1602                       to NULL in server mode.
1603        :param is_push_promise: Boolean value indicating whether this header set is
1604                                for a push promise.
1605        :return: Pointer to user-defined header set object.
1606
1607        Create a new header set.  This object is (and must be) fetched from a
1608        stream by calling :func:`lsquic_stream_get_hset()` before the stream can
1609        be read.
1610
1611    .. member:: struct lsxpack_header * (*hsi_prepare_decode)(void *hdr_set, struct lsxpack_header *hdr, size_t space)
1612
1613        Return a header set prepared for decoding.  If ``hdr`` is NULL, this
1614        means return a new structure with at least ``space`` bytes available
1615        in the decoder buffer.  On success, a newly prepared header is
1616        returned.
1617
1618        If ``hdr`` is not NULL, it means there was not enough decoder buffer
1619        and it must be increased to at least ``space`` bytes.  ``buf``, ``val_len``,
1620        and ``name_offset`` member of the ``hdr`` structure may change.  On
1621        success, the return value is the same as ``hdr``.
1622
1623        If NULL is returned, the space cannot be allocated.
1624
1625    .. member:: int (*hsi_process_header)(void *hdr_set, struct lsxpack_header *hdr)
1626
1627        Process new header.
1628
1629        :param hdr_set:
1630
1631            Header set to add the new header field to.  This is the object
1632            returned by ``hsi_create_header_set()``.
1633
1634        :param hdr:
1635
1636            The header returned by @ref ``hsi_prepare_decode()``.
1637
1638        :return:
1639
1640            Return 0 on success, a positive value if a header error occured,
1641            or a negative value on any other error.  A positive return value
1642            will result in cancellation of associated stream. A negative return
1643            value will result in connection being aborted.
1644
1645    .. member:: void                (*hsi_discard_header_set)(void *hdr_set)
1646
1647        :param hdr_set: Header set to discard.
1648
1649        Discard header set.  This is called for unclaimed header sets and
1650        header sets that had an error.
1651
1652    .. member:: enum lsquic_hsi_flag hsi_flags
1653
1654        These flags specify properties of decoded headers passed to
1655        ``hsi_process_header()``.  This is only applicable to QPACK headers;
1656        HPACK library header properties are based on compilation, not
1657        run-time, options.
1658
1659.. function:: void * lsquic_stream_get_hset (lsquic_stream_t *stream)
1660
1661    :param stream: Stream to fetch header set from.
1662
1663    :return: Header set associated with the stream.
1664
1665    Get header set associated with the stream.  The header set is created by
1666    ``hsi_create_header_set()`` callback.  After this call, the ownership of
1667    the header set is transferred to the caller.
1668
1669    This call must precede calls to :func:`lsquic_stream_read()`,
1670    :func:`lsquic_stream_readv()`, and :func:`lsquic_stream_readf()`.
1671
1672    If the optional header set interface is not specified,
1673    this function returns NULL.
1674
1675Push Promises
1676-------------
1677
1678.. function:: int lsquic_conn_push_stream (lsquic_conn_t *conn, void *hdr_set, lsquic_stream_t *stream, const lsquic_http_headers_t *headers)
1679
1680    :return:
1681
1682        - 0: Stream pushed successfully.
1683        - 1: Stream push failed because it is disabled or because we hit
1684             stream limit or connection is going away.
1685        - -1: Stream push failed because of an internal error.
1686
1687    A server may push a stream.  This call creates a new stream in reference
1688    to stream ``stream``.  It will behave as if the client made a request: it will
1689    trigger ``on_new_stream()`` event and it can be used as a regular client-initiated stream.
1690
1691    ``hdr_set`` must be set.  It is passed as-is to :func:`lsquic_stream_get_hset()`.
1692
1693.. function:: int lsquic_conn_is_push_enabled (lsquic_conn_t *conn)
1694
1695    :return: Boolean value indicating whether push promises are enabled.
1696
1697    Only makes sense in server mode: the client cannot push a stream and this
1698    function always returns false in client mode.
1699
1700.. function:: int lsquic_stream_is_pushed (const lsquic_stream_t *stream)
1701
1702    :return: Boolean value indicating whether this is a pushed stream.
1703
1704.. function:: int lsquic_stream_refuse_push (lsquic_stream_t *stream)
1705
1706    Refuse pushed stream.  Call it from ``on_new_stream()``.  No need to
1707    call :func:`lsquic_stream_close()` after this.  ``on_close()`` will be called.
1708
1709.. function:: int lsquic_stream_push_info (const lsquic_stream_t *stream, lsquic_stream_id_t *ref_stream_id, void **hdr_set)
1710
1711    Get information associated with pushed stream
1712
1713    :param ref_stream_id: Stream ID in response to which push promise was sent.
1714    :param hdr_set: Header set. This object was passed to or generated by :func:`lsquic_conn_push_stream()`.
1715
1716    :return: 0 on success and -1 if this is not a pushed stream.
1717
1718Stream Priorities
1719-----------------
1720
1721.. function:: unsigned lsquic_stream_priority (const lsquic_stream_t *stream)
1722
1723    Return current priority of the stream.
1724
1725.. function:: int lsquic_stream_set_priority (lsquic_stream_t *stream, unsigned priority)
1726
1727    Set stream priority.  Valid priority values are 1 through 256, inclusive.
1728    Lower value means higher priority.
1729
1730    :return: 0 on success of -1 on failure (this happens if priority value is invalid).
1731
1732Miscellaneous Engine Functions
1733------------------------------
1734
1735.. function:: unsigned lsquic_engine_quic_versions (const lsquic_engine_t *engine)
1736
1737    Return the list of QUIC versions (as bitmask) this engine instance supports.
1738
1739.. function:: unsigned lsquic_engine_count_attq (lsquic_engine_t *engine, int from_now)
1740
1741    Return number of connections whose advisory tick time is before current
1742    time plus ``from_now`` microseconds from now.  ``from_now`` can be negative.
1743
1744Miscellaneous Connection Functions
1745----------------------------------
1746
1747.. function:: enum lsquic_version lsquic_conn_quic_version (const lsquic_conn_t *conn)
1748
1749    Get QUIC version used by the connection.
1750
1751    If version has not yet been negotiated (can happen in client mode), ``-1`` is
1752    returned.
1753
1754.. function:: const lsquic_cid_t * lsquic_conn_id (const lsquic_conn_t *conn)
1755
1756    Get connection ID.
1757
1758.. function:: lsquic_engine_t * lsquic_conn_get_engine (lsquic_conn_t *conn)
1759
1760    Get pointer to the engine.
1761
1762.. function:: int lsquic_conn_get_sockaddr (lsquic_conn_t *conn, const struct sockaddr **local, const struct sockaddr **peer)
1763
1764    Get current (last used) addresses associated with the current path
1765    used by the connection.
1766
1767.. function:: struct stack_st_X509 * lsquic_conn_get_server_cert_chain (lsquic_conn_t *conn)
1768
1769    Get certificate chain returned by the server.  This can be used for
1770    server certificate verification.
1771
1772    The caller releases the stack using sk_X509_free().
1773
1774.. function:: lsquic_conn_ctx_t * lsquic_conn_get_ctx (const lsquic_conn_t *conn)
1775
1776    Get user-supplied context associated with the connection.
1777
1778.. function:: void lsquic_conn_set_ctx (lsquic_conn_t *conn, lsquic_conn_ctx_t *ctx)
1779
1780    Set user-supplied context associated with the connection.
1781
1782.. function:: void * lsquic_conn_get_peer_ctx (lsquic_conn_t *conn, const struct sockaddr *local_sa)
1783
1784    Get peer context associated with the connection and local address.
1785
1786.. function:: enum LSQUIC_CONN_STATUS lsquic_conn_status (lsquic_conn_t *conn, char *errbuf, size_t bufsz)
1787
1788    Get connection status.
1789
1790Miscellaneous Stream Functions
1791------------------------------
1792
1793.. function:: unsigned lsquic_conn_n_avail_streams (const lsquic_conn_t *conn)
1794
1795    Return max allowed outbound streams less current outbound streams.
1796
1797.. function:: unsigned lsquic_conn_n_pending_streams (const lsquic_conn_t *conn)
1798
1799    Return number of delayed streams currently pending.
1800
1801.. function:: unsigned lsquic_conn_cancel_pending_streams (lsquic_conn_t *, unsigned n)
1802
1803    Cancel ``n`` pending streams.  Returns new number of pending streams.
1804
1805.. function:: lsquic_conn_t * lsquic_stream_conn (const lsquic_stream_t *stream)
1806
1807    Get a pointer to the connection object.  Use it with connection functions.
1808
1809.. function:: int lsquic_stream_is_rejected (const lsquic_stream_t *stream)
1810
1811    Returns true if this stream was rejected, false otherwise.  Use this as
1812    an aid to distinguish between errors.
1813
1814Other Functions
1815---------------
1816
1817.. function:: enum lsquic_version lsquic_str2ver (const char *str, size_t len)
1818
1819    Translate string QUIC version to LSQUIC QUIC version representation.
1820
1821.. function:: enum lsquic_version lsquic_alpn2ver (const char *alpn, size_t len)
1822
1823    Translate ALPN (e.g. "h3", "h3-23", "h3-Q046") to LSQUIC enum.
1824
1825Miscellaneous Types
1826-------------------
1827
1828.. type:: struct lsquic_shared_hash_if
1829
1830    The shared hash interface is used to share data between multiple LSQUIC instances.
1831
1832    .. member:: int (*shi_insert)(void *shi_ctx, void *key, unsigned key_sz, void *data, unsigned data_sz, time_t expiry)
1833
1834        :param shi_ctx:
1835
1836            Shared memory context pointer
1837
1838        :param key:
1839
1840            Key data.
1841
1842        :param key_sz:
1843
1844            Key size.
1845
1846        :param data:
1847
1848            Pointer to the data to store.
1849
1850        :param data_sz:
1851
1852            Data size.
1853
1854        :param expiry: When this item expires.  If you want your item to never expire, set this to zero.
1855
1856        :return: 0 on success, -1 on failure.
1857
1858        If inserted successfully, ``free()`` will be called on ``data`` and ``key``
1859        pointer when the element is deleted, whether due to expiration
1860        or explicit deletion.
1861
1862    .. member:: int (*shi_delete)(void *shi_ctx, const void *key, unsigned key_sz)
1863
1864        Delete item from shared hash
1865
1866        :return: 0 on success, -1 on failure.
1867
1868    .. member:: int (*shi_lookup)(void *shi_ctx, const void *key, unsigned key_sz, void **data, unsigned *data_sz)
1869
1870        :param shi_ctx:
1871
1872            Shared memory context pointer
1873
1874        :param key:
1875
1876            Key data.
1877
1878        :param key_sz:
1879
1880            Key size.
1881
1882        :param data:
1883
1884            Pointer to set to the result.
1885
1886        :param data_sz:
1887
1888            Pointer to the data size.
1889
1890        :return:
1891
1892            - ``1``: found.
1893            - ``0``: not found.
1894            - ``-1``:  error (perhaps not enough room in ``data`` if copy was attempted).
1895
1896         The implementation may choose to copy the object into buffer pointed
1897         to by ``data``, so you should have it ready.
1898
1899.. type:: struct lsquic_packout_mem_if
1900
1901    The packet out memory interface is used by LSQUIC to get buffers to
1902    which outgoing packets will be written before they are passed to
1903    :member:`lsquic_engine_api.ea_packets_out` callback.
1904
1905    If not specified, malloc() and free() are used.
1906
1907    .. member:: void *  (*pmi_allocate) (void *pmi_ctx, void *peer_ctx, unsigned short sz, char is_ipv6)
1908
1909        Allocate buffer for sending.
1910
1911    .. member:: void    (*pmi_release)  (void *pmi_ctx, void *peer_ctx, void *buf, char is_ipv6)
1912
1913        This function is used to release the allocated buffer after it is
1914        sent via ``ea_packets_out()``.
1915
1916    .. member:: void    (*pmi_return)  (void *pmi_ctx, void *peer_ctx, void *buf, char is_ipv6)
1917
1918        If allocated buffer is not going to be sent, return it to the
1919        caller using this function.
1920
1921.. type:: typedef void (*lsquic_cids_update_f)(void *ctx, void **peer_ctx, const lsquic_cid_t *cids, unsigned n_cids)
1922
1923    :param ctx:
1924
1925        Context associated with the CID lifecycle callbacks (ea_cids_update_ctx).
1926
1927    :param peer_ctx:
1928
1929        Array of peer context pointers.
1930
1931    :param cids:
1932
1933        Array of connection IDs.
1934
1935    :param n_cids:
1936
1937        Number of elements in the peer context pointer and connection ID arrays.
1938
1939.. type:: struct lsquic_keylog_if
1940
1941    SSL keylog interface.
1942
1943    .. member:: void *    (*kli_open) (void *keylog_ctx, lsquic_conn_t *conn)
1944
1945        Return keylog handle or NULL if no key logging is desired.
1946
1947    .. member:: void      (*kli_log_line) (void *handle, const char *line)
1948
1949        Log line.  The first argument is the pointer returned by ``kli_open()``.
1950
1951    .. member:: void      (*kli_close) (void *handle)
1952
1953        Close handle.
1954
1955.. type:: enum lsquic_logger_timestamp_style
1956
1957    Enumerate timestamp styles supported by LSQUIC logger mechanism.
1958
1959    .. member:: LLTS_NONE
1960
1961        No timestamp is generated.
1962
1963    .. member:: LLTS_HHMMSSMS
1964
1965        The timestamp consists of 24 hours, minutes, seconds, and milliseconds.  Example: 13:43:46.671
1966
1967    .. member:: LLTS_YYYYMMDD_HHMMSSMS
1968
1969        Like above, plus date, e.g: 2017-03-21 13:43:46.671
1970
1971    .. member:: LLTS_CHROMELIKE
1972
1973        This is Chrome-like timestamp used by proto-quic.  The timestamp
1974        includes month, date, hours, minutes, seconds, and microseconds.
1975
1976        Example: 1223/104613.946956 (instead of 12/23 10:46:13.946956).
1977
1978        This is to facilitate reading two logs side-by-side.
1979
1980    .. member:: LLTS_HHMMSSUS
1981
1982        The timestamp consists of 24 hours, minutes, seconds, and microseconds.  Example: 13:43:46.671123
1983
1984    .. member:: LLTS_YYYYMMDD_HHMMSSUS
1985
1986        Date and time using microsecond resolution, e.g: 2017-03-21 13:43:46.671123
1987
1988.. type:: enum LSQUIC_CONN_STATUS
1989
1990    .. member:: LSCONN_ST_HSK_IN_PROGRESS
1991    .. member:: LSCONN_ST_CONNECTED
1992    .. member:: LSCONN_ST_HSK_FAILURE
1993    .. member:: LSCONN_ST_GOING_AWAY
1994    .. member:: LSCONN_ST_TIMED_OUT
1995    .. member:: LSCONN_ST_RESET
1996
1997        If es_honor_prst is not set, the connection will never get public
1998        reset packets and this flag will not be set.
1999
2000    .. member:: LSCONN_ST_USER_ABORTED
2001    .. member:: LSCONN_ST_ERROR
2002    .. member:: LSCONN_ST_CLOSED
2003    .. member:: LSCONN_ST_PEER_GOING_AWAY
2004
2005.. type:: enum lsquic_hsi_flag
2006
2007    These flags are ORed together to specify properties of
2008    :type:`lsxpack_header` passed to :member:`lsquic_hset_if.hsi_process_header`.
2009
2010    .. member:: LSQUIC_HSI_HTTP1X
2011
2012        Turn HTTP/1.x mode on or off.  In this mode, decoded name and value
2013        pair are separated by ``": "`` and ``"\r\n"`` is appended to the end
2014        of the string.  By default, this mode is off.
2015
2016    .. member:: LSQUIC_HSI_HASH_NAME
2017
2018        Include name hash into lsxpack_header.
2019
2020    .. member:: LSQUIC_HSI_HASH_NAMEVAL
2021
2022        Include nameval hash into lsxpack_header.
2023
2024Global Variables
2025----------------
2026
2027.. var:: const char *const lsquic_ver2str[N_LSQVER]
2028
2029    Convert LSQUIC version to human-readable string
2030
2031List of Log Modules
2032-------------------
2033
2034The following log modules are defined:
2035
2036- *alarmset*: Alarm processing.
2037- *bbr*: BBR congestion controller.
2038- *bw-sampler*: Bandwidth sampler (used by BBR).
2039- *cfcw*: Connection flow control window.
2040- *conn*: Connection.
2041- *crypto*: Low-level Google QUIC cryptography tracing.
2042- *cubic*: Cubic congestion controller.
2043- *di*: "Data In" handler (storing incoming data before it is read).
2044- *eng-hist*: Engine history.
2045- *engine*: Engine.
2046- *event*: Cross-module significant events.
2047- *frame-reader*: Reader of the HEADERS stream in Google QUIC.
2048- *frame-writer*: Writer of the HEADERS stream in Google QUIC.
2049- *handshake*: Handshake and packet encryption and decryption.
2050- *hcsi-reader*: Reader of the HTTP/3 control stream.
2051- *hcso-writer*: Writer of the HTTP/3 control stream.
2052- *headers*: HEADERS stream (Google QUIC).
2053- *hsk-adapter*: 
2054- *http1x*: Header conversion to HTTP/1.x.
2055- *logger*: Logger.
2056- *mini-conn*: Mini connection.
2057- *pacer*: Pacer.
2058- *parse*: Parsing.
2059- *prq*: PRQ stands for Packet Request Queue.  This logs scheduling
2060  and sending packets not associated with a connection: version
2061  negotiation and stateless resets.
2062- *purga*: CID purgatory.
2063- *qdec-hdl*: QPACK decoder stream handler.
2064- *qenc-hdl*: QPACK encoder stream handler.
2065- *qlog*: QLOG output.  At the moment, it is out of date.
2066- *qpack-dec*: QPACK decoder.
2067- *qpack-enc*: QPACK encoder.
2068- *rechist*: Receive history.
2069- *sendctl*: Send controller.
2070- *sfcw*: Stream flow control window.
2071- *spi*: Stream priority iterator.
2072- *stream*: Stream operation.
2073- *tokgen*: Token generation and validation.
2074- *trapa*: Transport parameter processing.
2075