Home
last modified time | relevance | path

Searched refs:buf (Results 1 – 25 of 92) sorted by last modified time

1234

/unit/src/
H A Dnxt_unit.c1416 l += b->buf.end - b->buf.free; in nxt_unit_process_req_body()
2634 buf = &mmap_buf->buf; in nxt_unit_mmap_buf_send()
2674 buf->free = buf->start; in nxt_unit_mmap_buf_send()
3028 buf = &mmap_buf.buf; in nxt_unit_response_write_cb()
3213 copy = buf->end - buf->free; in nxt_unit_buf_read()
3229 buf = nxt_unit_buf_next(buf); in nxt_unit_buf_read()
3344 buf = &mmap_buf.buf; in nxt_unit_websocket_sendv()
3392 if (buf->free > buf->start) { in nxt_unit_websocket_sendv()
3439 size = ws_impl->buf->buf.end - ws_impl->buf->buf.start; in nxt_unit_websocket_retain()
3450 ws_impl->buf->buf.start = b; in nxt_unit_websocket_retain()
[all …]
H A Dnxt_sockaddr.c455 return p - buf; in nxt_sockaddr_ntop()
460 p = buf; in nxt_sockaddr_ntop()
473 return p - buf; in nxt_sockaddr_ntop()
502 return p - buf; in nxt_sockaddr_ntop()
525 return buf; in nxt_inet6_ntop()
559 p = buf; in nxt_inet6_ntop()
1199 end = buf + length; in nxt_inet_addr()
1201 while (buf < end) { in nxt_inet_addr()
1203 c = *buf++; in nxt_inet_addr()
1247 buf++; in nxt_inet6_addr()
[all …]
H A Dnxt_string.h32 #define nxt_strchr(buf, delim) \ argument
33 (u_char *) strchr((char *) buf, delim)
36 #define nxt_memzero(buf, length) \ argument
37 (void) memset(buf, 0, length)
40 #define nxt_memset(buf, c, length) \ argument
41 (void) memset(buf, c, length)
H A Dnxt_port_socket.c176 msg.buf = b; in nxt_port_socket_write2()
225 msg.buf = NULL; in nxt_port_socket_write2()
407 sb.buf = msg->buf; in nxt_port_write_handler()
457 msg->buf = nxt_port_buf_completion(task, wq, msg->buf, plain_size, in nxt_port_write_handler()
775 msg.buf = b; in nxt_port_read_handler()
994 msg.buf = b; in nxt_port_queue_read_handler()
1189 b = orig_b = msg->buf; in nxt_port_read_msg_process()
1208 nxt_buf_chain_add(&fmsg->buf, msg->buf); in nxt_port_read_msg_process()
1211 msg->buf = NULL; in nxt_port_read_msg_process()
1220 msg->buf = fmsg->buf; in nxt_port_read_msg_process()
[all …]
H A Dnxt_http_request.c28 static u_char *nxt_http_date_cache_handler(u_char *buf, nxt_realtime_t *now,
838 nxt_http_date_cache_handler(u_char *buf, nxt_realtime_t *now, struct tm *tm, in nxt_http_date_cache_handler() argument
841 return nxt_http_date(buf, tm); in nxt_http_date_cache_handler()
H A Dnxt_http.h293 nxt_http_date(u_char *buf, struct tm *tm) in nxt_http_date() argument
301 return nxt_sprintf(buf, buf + NXT_HTTP_DATE_LEN, in nxt_http_date()
H A Dnxt_conf.c98 u_char buf[NXT_CONF_MAX_TOKEN_LEN]; member
515 end = nxt_decode_uri(parse->buf, start, length); in nxt_conf_path_next_token()
520 token->length = end - parse->buf; in nxt_conf_path_next_token()
521 token->start = parse->buf; in nxt_conf_path_next_token()
H A Dnxt_router.c580 msg_info->buf = NULL; in nxt_router_msg_cancel()
3762 u_char *buf, *p; in nxt_router_access_log_writer() local
3855 nxt_fd_write(access_log->fd, buf, p - buf); in nxt_router_access_log_writer()
3879 return nxt_sprintf(buf, buf + size, format, in nxt_router_access_log_date()
4232 if (msg->buf == b) { in nxt_router_response_ready_handler()
5408 req_rpc_data->msg_info.buf = buf; in nxt_router_app_prepare_request()
5452 buf->mem.pos = buf->mem.free; in nxt_router_app_prepare_request()
5734 buf = out; in nxt_router_prepare_msg()
5735 tail = &buf->next; in nxt_router_prepare_msg()
5772 buf->mem.free = nxt_cpymem(buf->mem.free, pos, copy_size); in nxt_router_prepare_msg()
[all …]
H A Dnxt_h1proto.c1211 u_char buf[UNKNOWN_STATUS_LENGTH]; in nxt_h1p_request_header_send() local
1253 (void) nxt_sprintf(buf, buf + UNKNOWN_STATUS_LENGTH, in nxt_h1p_request_header_send()
1257 unknown_status.start = buf; in nxt_h1p_request_header_send()
H A Dnxt_conf_validation.c1235 u_char buf[nxt_length(NXT_CONF_VLDT_ANY_TYPE_STR)]; in nxt_conf_vldt_type() local
1253 p = buf; in nxt_conf_vldt_type()
1287 expected.length = p - buf; in nxt_conf_vldt_type()
1288 expected.start = buf; in nxt_conf_vldt_type()
H A Dnxt_port_rpc.c372 nxt_buf_t buf; in nxt_port_rpc_remove_peer() local
390 nxt_memzero(&buf, sizeof(buf)); in nxt_port_rpc_remove_peer()
394 msg.buf = &buf; in nxt_port_rpc_remove_peer()
506 msg.buf = &nxt_port_close_dummy_buf; in nxt_port_rpc_close()
H A Dnxt_port_memory.c727 bmem = msg->buf; in nxt_port_mmap_write()
770 pb = &msg->buf; in nxt_port_mmap_read()
773 for (b = msg->buf; b != NULL; b = b->next) { in nxt_port_mmap_read()
H A Dnxt_port.h182 nxt_buf_t *buf; member
196 nxt_buf_t *buf; member
300 nxt_buf_t buf; member
H A Dnxt_sprintf.c253 buf = nxt_integer(&spf, buf, err); in nxt_vsprintf()
260 buf = nxt_strerror(err, buf, end - buf); in nxt_vsprintf()
413 buf = nxt_number(&spf, buf, i); in nxt_vsprintf()
423 buf = nxt_integer(&spf, buf, frac); in nxt_vsprintf()
552 buf = nxt_integer(&spf, buf, ui64); in nxt_vsprintf()
567 buf = nxt_cpymem(buf, p, length); in nxt_vsprintf()
571 return buf; in nxt_vsprintf()
680 *buf++ = *p++; in nxt_integer()
683 return buf; in nxt_integer()
721 *buf++ = *p++; in nxt_number()
[all …]
H A Dnxt_openssl.c96 void *buf, size_t size);
639 u_char buf[80]; local
685 len = nxt_base64_decode(buf, value.start, value.length);
687 nxt_memcpy(ticket->name, buf, 16);
690 nxt_memcpy(ticket->aes_key, buf + 16, 16);
691 nxt_memcpy(ticket->hmac_key, buf + 32, 16);
695 nxt_memcpy(ticket->hmac_key, buf + 16, 32);
696 nxt_memcpy(ticket->aes_key, buf + 48, 32);
1394 ret = SSL_write(tls->session, buf, size);
1399 sb->socket, buf, size, ret, err);
[all …]
H A Dnxt_thread_time.h20 u_char *(*handler)(u_char *buf, nxt_realtime_t *now,
69 nxt_time_string_t *ts, u_char *buf);
H A Dnxt_socket.h80 struct sockaddr buf; member
H A Dnxt_fastcgi_source.c15 u_char *buf; member
270 b->mem.free = nxt_cpymem(b->mem.free, param.buf, len); in nxt_fastcgi_request_create()
278 param.buf += len; in nxt_fastcgi_request_create()
356 param->buf = param->length; in nxt_fastcgi_next_param()
363 param->buf = param->length; in nxt_fastcgi_next_param()
370 param->buf = fs->u.request.name.data; in nxt_fastcgi_next_param()
376 param->buf = fs->u.request.value.data; in nxt_fastcgi_next_param()
H A Dnxt_file.h155 NXT_EXPORT ssize_t nxt_file_write(nxt_file_t *file, const u_char *buf,
157 NXT_EXPORT ssize_t nxt_file_read(nxt_file_t *file, u_char *buf, size_t size,
185 NXT_EXPORT ssize_t nxt_fd_write(nxt_fd_t fd, u_char *buf, size_t size);
186 NXT_EXPORT ssize_t nxt_fd_read(nxt_fd_t fd, u_char *buf, size_t size);
198 #define nxt_write_console(fd, buf, size) \ argument
199 write(fd, buf, size)
209 NXT_EXPORT size_t nxt_dir_current(char *buf, size_t len);
H A Dnxt_cache.c27 nxt_cache_query_t *q, u_char *buf, size_t size);
468 u_char buf[1024]; in nxt_cache_release() local
473 p = buf; in nxt_cache_release()
474 size = sizeof(buf); in nxt_cache_release()
513 u_char *buf, size_t size) in nxt_cache_release_locked() argument
542 ret = cache->delete_copy(cache, node, buf, size); in nxt_cache_release_locked()
H A Dnxt_main_process.c61 const char *name, u_char *buf, size_t size);
335 nxt_buf_mem_used_size(&msg->buf->mem), msg->buf->mem.pos); in nxt_main_data_handler()
617 nxt_buf_t *buf; in nxt_main_process_whoami_handler() local
625 if (nxt_slow_path(msg->buf == NULL in nxt_main_process_whoami_handler()
679 if (nxt_slow_path(buf == NULL)) { in nxt_main_process_whoami_handler()
683 buf->mem.free = nxt_cpymem(buf->mem.free, &pid, sizeof(nxt_pid_t)); in nxt_main_process_whoami_handler()
1050 b = msg->buf; in nxt_main_port_socket_handler()
1310 b = msg->buf; in nxt_main_port_modules_handler()
1537 u_char *buf, size_t size) in nxt_main_file_store() argument
1553 n = nxt_file_write(&file, buf, size, 0); in nxt_main_file_store()
[all …]
H A Dnxt_gnutls.c37 static ssize_t nxt_gnutls_pull(gnutls_transport_ptr_t data, void *buf,
39 static ssize_t nxt_gnutls_push(gnutls_transport_ptr_t data, const void *buf,
49 static ssize_t nxt_gnutls_conn_io_send(nxt_event_conn_t *c, void *buf,
352 nxt_gnutls_pull(gnutls_transport_ptr_t data, void *buf, size_t size) in nxt_gnutls_pull() argument
361 n = thr->engine->event->io->recv(c, buf, size, 0); in nxt_gnutls_pull()
373 nxt_gnutls_push(gnutls_transport_ptr_t data, const void *buf, size_t size) in nxt_gnutls_push() argument
382 n = thr->engine->event->io->send(c, (u_char *) buf, size); in nxt_gnutls_push()
540 nxt_gnutls_conn_io_send(nxt_event_conn_t *c, void *buf, size_t size) in nxt_gnutls_conn_io_send() argument
548 n = gnutls_record_send(ssltls->session, buf, size); in nxt_gnutls_conn_io_send()
551 c->socket.fd, buf, size, n); in nxt_gnutls_conn_io_send()
[all …]
/unit/src/ruby/
H A Dnxt_ruby_stream_io.c94 VALUE buf; in nxt_ruby_stream_io_gets() local
111 buf = rb_str_buf_new(res); in nxt_ruby_stream_io_gets()
113 if (nxt_slow_path(buf == Qnil)) { in nxt_ruby_stream_io_gets()
117 res = nxt_unit_request_read(req, RSTRING_PTR(buf), res); in nxt_ruby_stream_io_gets()
119 rb_str_set_len(buf, res); in nxt_ruby_stream_io_gets()
121 return buf; in nxt_ruby_stream_io_gets()
151 VALUE buf; in nxt_ruby_stream_io_read() local
175 buf = rb_str_buf_new(copy_size); in nxt_ruby_stream_io_read()
177 if (nxt_slow_path(buf == Qnil)) { in nxt_ruby_stream_io_read()
189 rb_str_set_len(buf, copy_size); in nxt_ruby_stream_io_read()
[all …]
/unit/auto/
H A Dclang18 char buf[4];
20 buf[0] = '0';
21 set(0, buf, \"%d\", 1);
23 if (buf[0] == '1')
41 char buf[4];
43 buf[0] = '0';
44 set(0, buf, \"%d\", 1);
46 if (buf[0] == '1')
/unit/src/perl/
H A Dnxt_perl_psgi.c406 char *buf, *p; in nxt_perl_psgi_module_create() local
428 buf = nxt_unit_malloc(NULL, prefix.length + length + suffix.length); in nxt_perl_psgi_module_create()
429 if (nxt_slow_path(buf == NULL)) { in nxt_perl_psgi_module_create()
436 p = nxt_cpymem(buf, prefix.start, prefix.length); in nxt_perl_psgi_module_create()
440 return buf; in nxt_perl_psgi_module_create()

1234