Home
last modified time | relevance | path

Searched refs:copy_size (Results 1 – 3 of 3) sorted by relevance

/unit/src/ruby/
H A Dnxt_ruby_stream_io.c152 long copy_size, u_size; in nxt_ruby_stream_io_read() local
157 copy_size = rctx->req->content_length; in nxt_ruby_stream_io_read()
162 if (u_size < 0 || copy_size == 0) { in nxt_ruby_stream_io_read()
166 if (copy_size > u_size) { in nxt_ruby_stream_io_read()
167 copy_size = u_size; in nxt_ruby_stream_io_read()
171 if (copy_size == 0) { in nxt_ruby_stream_io_read()
175 buf = rb_str_buf_new(copy_size); in nxt_ruby_stream_io_read()
181 copy_size = nxt_unit_request_read(rctx->req, RSTRING_PTR(buf), copy_size); in nxt_ruby_stream_io_read()
186 rb_str_cat(RARRAY_PTR(args)[1], RSTRING_PTR(buf), copy_size); in nxt_ruby_stream_io_read()
189 rb_str_set_len(buf, copy_size); in nxt_ruby_stream_io_read()
/unit/src/
H A Dnxt_http_websocket.c31 size_t frame_size, used_size, copy_size, buf_free_size; in nxt_http_websocket_client() local
64 copy_size = nxt_min(used_size, frame_size); in nxt_http_websocket_client()
66 while (copy_size > 0) { in nxt_http_websocket_client()
77 chunk_copy_size = nxt_min(buf_free_size, copy_size); in nxt_http_websocket_client()
82 copy_size -= chunk_copy_size; in nxt_http_websocket_client()
87 frame_size -= copy_size; in nxt_http_websocket_client()
H A Dnxt_router.c5192 size_t copy_size; in nxt_router_prepare_msg() local
5445 copy_size = nxt_min(free_size, size); in nxt_router_prepare_msg()
5447 buf->mem.free = nxt_cpymem(buf->mem.free, pos, copy_size); in nxt_router_prepare_msg()
5449 size -= copy_size; in nxt_router_prepare_msg()
5450 pos += copy_size; in nxt_router_prepare_msg()