mirror of
https://github.com/nginx/nginx.git
synced 2025-02-25 18:55:26 -06:00
Implemented ngx_quic_stream_send_chain() method.
- just call send in a loop
This commit is contained in:
parent
05d1464c68
commit
dcb6aab460
@ -1983,7 +1983,41 @@ static ngx_chain_t *
|
|||||||
ngx_quic_stream_send_chain(ngx_connection_t *c, ngx_chain_t *in,
|
ngx_quic_stream_send_chain(ngx_connection_t *c, ngx_chain_t *in,
|
||||||
off_t limit)
|
off_t limit)
|
||||||
{
|
{
|
||||||
// TODO
|
size_t len;
|
||||||
|
ssize_t n;
|
||||||
|
ngx_buf_t *b;
|
||||||
|
|
||||||
|
while (in) {
|
||||||
|
b = in->buf;
|
||||||
|
|
||||||
|
if (!ngx_buf_in_memory(b)) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (ngx_buf_size(b) == 0) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
len = b->last - b->pos;
|
||||||
|
|
||||||
|
n = ngx_quic_stream_send(c, b->pos, len);
|
||||||
|
|
||||||
|
if (n == NGX_ERROR) {
|
||||||
|
return NGX_CHAIN_ERROR;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (n == NGX_AGAIN) {
|
||||||
|
return in;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (n != (ssize_t) len) {
|
||||||
|
b->pos += n;
|
||||||
|
return in;
|
||||||
|
}
|
||||||
|
|
||||||
|
in = in->next;
|
||||||
|
}
|
||||||
|
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user