diff options
| author | Roman Arutyunyan <arut@nginx.com> | 2023-01-31 14:12:18 +0400 |
|---|---|---|
| committer | Roman Arutyunyan <arut@nginx.com> | 2023-01-31 14:12:18 +0400 |
| commit | 341c21c9f6373ceeb0ad2513e14c5cd97e958b28 (patch) | |
| tree | f2a7369f0f992f1ba534e9a399c68503f252c5ed /src/event/quic/ngx_event_quic_frames.c | |
| parent | c3edcc17b6843bbfeb61f2dc7c51115b6a4272b0 (diff) | |
| download | nginx-341c21c9f6373ceeb0ad2513e14c5cd97e958b28.tar.gz nginx-341c21c9f6373ceeb0ad2513e14c5cd97e958b28.tar.bz2 | |
QUIC: ngx_quic_copy_buffer() function.
The function copies passed data to QUIC buffer chain and returns it.
The chain can be used in ngx_quic_frame_t data field.
Diffstat (limited to 'src/event/quic/ngx_event_quic_frames.c')
| -rw-r--r-- | src/event/quic/ngx_event_quic_frames.c | 33 |
1 files changed, 33 insertions, 0 deletions
diff --git a/src/event/quic/ngx_event_quic_frames.c b/src/event/quic/ngx_event_quic_frames.c index 9a1a6afe5..9fcc97e02 100644 --- a/src/event/quic/ngx_event_quic_frames.c +++ b/src/event/quic/ngx_event_quic_frames.c @@ -387,6 +387,39 @@ ngx_quic_split_frame(ngx_connection_t *c, ngx_quic_frame_t *f, size_t len) ngx_chain_t * +ngx_quic_copy_buffer(ngx_connection_t *c, u_char *data, size_t len) +{ + ngx_buf_t buf; + ngx_chain_t cl, *out; + ngx_quic_buffer_t qb; + + ngx_memzero(&buf, sizeof(ngx_buf_t)); + + buf.pos = data; + buf.last = buf.pos + len; + buf.temporary = 1; + + cl.buf = &buf; + cl.next = NULL; + + ngx_memzero(&qb, sizeof(ngx_quic_buffer_t)); + + if (ngx_quic_write_buffer(c, &qb, &cl, len, 0) == NGX_CHAIN_ERROR) { + return NGX_CHAIN_ERROR; + } + + out = ngx_quic_read_buffer(c, &qb, len); + if (out == NGX_CHAIN_ERROR) { + return NGX_CHAIN_ERROR; + } + + ngx_quic_free_buffer(c, &qb); + + return out; +} + + +ngx_chain_t * ngx_quic_read_buffer(ngx_connection_t *c, ngx_quic_buffer_t *qb, uint64_t limit) { uint64_t n; |
