/unit/src/ |
H A D | nxt_conn.c | 135 size_t size, length; in nxt_conn_local_addr() local 149 length = NXT_INET6_ADDR_STR_LEN; in nxt_conn_local_addr() 150 size = offsetof(nxt_sockaddr_t, u) + socklen + length; in nxt_conn_local_addr() 156 length = NXT_INET_ADDR_STR_LEN; in nxt_conn_local_addr() 157 size = offsetof(nxt_sockaddr_t, u) + socklen + length; in nxt_conn_local_addr() 167 sa->length = length; in nxt_conn_local_addr()
|
H A D | nxt_controller.c | 921 if (read >= r->length) { in nxt_controller_conn_body_read() 1055 r->length = length; in nxt_controller_request_content_length() 1094 if (path.length > 1 && path.start[path.length - 1] == '/') { in nxt_controller_process_request() 1095 path.length--; in nxt_controller_process_request() 1102 path.length = 1; in nxt_controller_process_request() 1128 path.length = 1; in nxt_controller_process_request() 1145 path.length = 1; in nxt_controller_process_request() 1178 path.length -= 9; in nxt_controller_process_request() 1703 name.length = path->length - 1; in nxt_controller_process_cert() 1964 name.length = path->length - 1; in nxt_controller_process_script() [all …]
|
H A D | nxt_http_return.c | 156 if (nxt_is_complex_uri_encoded(location->start, location->length)) { in nxt_http_return_encode() 162 encode = nxt_encode_complex_uri(NULL, location->start, location->length); in nxt_http_return_encode() 163 encoded->length = location->length + encode * 2; in nxt_http_return_encode() 165 encoded->start = nxt_mp_nget(mp, encoded->length); in nxt_http_return_encode() 170 nxt_encode_complex_uri(encoded->start, location->start, location->length); in nxt_http_return_encode() 188 if (ctx->location.length > 0) { in nxt_http_return_send_ready() 204 field->value_length = ctx->encoded.length; in nxt_http_return_send_ready()
|
H A D | nxt_router_access_log.c | 109 + alcf.path.length); in nxt_router_access_log_create() 119 access_log->path.length = alcf.path.length; in nxt_router_access_log_create() 123 nxt_memcpy(access_log->path.start, alcf.path.start, alcf.path.length); in nxt_router_access_log_create() 126 str.length = alcf.format.length + 1; in nxt_router_access_log_create() 128 str.start = nxt_malloc(str.length); in nxt_router_access_log_create() 134 p = nxt_cpymem(str.start, alcf.format.start, alcf.format.length); in nxt_router_access_log_create() 148 if (str.length > 0 && str.start[0] == '!') { in nxt_router_access_log_create() 152 str.length--; in nxt_router_access_log_create() 211 nxt_fd_write(ctx->access_log->fd, ctx->text.start, ctx->text.length); in nxt_router_access_log_write_ready() 236 b = nxt_buf_mem_alloc(tmcf->mem_pool, access_log->path.length + 1, 0); in nxt_router_access_log_open() [all …]
|
H A D | nxt_cert.c | 101 long length, reason; in nxt_cert_bio() local 192 x509 = d2i_X509(NULL, &data_copy, length); in nxt_cert_bio() 526 str.length = end - buf; in nxt_cert_details() 534 str.length = end - buf; in nxt_cert_details() 725 str.length = len; in nxt_cert_name_details() 857 name.length = nxt_strlen(de->d_name); in nxt_cert_store_load() 871 size = rt->certs.length + name.length + 1; in nxt_cert_store_load() 1164 name.length = nxt_strlen(name.start); in nxt_cert_store_get_handler() 1166 file.name = nxt_malloc(rt->certs.length + name.length + 1); in nxt_cert_store_get_handler() 1242 name.length = nxt_strlen(name.start); in nxt_cert_store_delete_handler() [all …]
|
H A D | nxt_http_request.c | 121 dot_pos = host->length; in nxt_http_validate_host() 122 host_length = host->length; in nxt_http_validate_host() 186 host->length = host_length; in nxt_http_validate_host() 481 addr.length = len; in nxt_http_request_client_ip_sockaddr() 599 if (r->host.length != 0) { in nxt_http_application_handler() 903 if (str.length == 0 in nxt_http_request_access_log() 1049 length = end - start; in nxt_http_argument() 1052 name_length = length; in nxt_http_argument() 1054 length = 0; in nxt_http_argument() 1194 str.length = name->length; in nxt_http_field_hash() [all …]
|
H A D | nxt_http_parse.c | 541 p = *pos + rp->field_name.length; in nxt_http_parse_field_name() 588 rp->field_name.length = len; in nxt_http_parse_field_name() 609 rp->field_name.length = len; in nxt_http_parse_field_name() 652 p += rp->field_value.length; in nxt_http_parse_field_value() 666 rp->field_value.length = len; in nxt_http_parse_field_value() 699 rp->field_value.length = len; in nxt_http_parse_field_value() 793 if (rp->field_name.length != 0) { in nxt_http_parse_field_end() 816 rp->field_name.length = 0; in nxt_http_parse_field_end() 817 rp->field_value.length = 0; in nxt_http_parse_field_end() 880 rp->path.length = 0; in nxt_http_parse_complex_target() [all …]
|
H A D | nxt_tstr.c | 98 tstr->str.length = str->length + strz; in nxt_tstr_compile() 100 tstr->str.start = nxt_mp_nget(state->pool, tstr->str.length); in nxt_tstr_compile() 105 p = nxt_cpymem(tstr->str.start, str->start, str->length); in nxt_tstr_compile() 131 p = memchr(str->start, '$', str->length); in nxt_tstr_compile() 167 p = memchr(str->start, '$', str->length); in nxt_tstr_test() 218 str->length--; in nxt_tstr_str() 287 val->length--; in nxt_tstr_query()
|
H A D | nxt_utf8.c | 240 ssize_t length; in nxt_utf8_length() local 243 length = 0; in nxt_utf8_length() 252 length++; in nxt_utf8_length() 255 return length; in nxt_utf8_length()
|
H A D | nxt_conf.c | 54 uint8_t length; member 168 str->length = value->u.str.length; in nxt_conf_get_string() 172 str->length = value->u.string.length; in nxt_conf_get_string() 193 value->u.string.length = str->length; in nxt_conf_set_string() 198 value->u.str.length = str->length; in nxt_conf_set_string() 219 value->u.string.length = tmp.length; in nxt_conf_set_string_dup() 224 value->u.str.length = str->length; in nxt_conf_set_string_dup() 478 if (token.length == 0) { in nxt_conf_get_path() 521 size_t length; in nxt_conf_path_next_token() local 534 length = p - start; in nxt_conf_path_next_token() [all …]
|
H A D | nxt_sockaddr.h | 32 uint8_t length; member 100 (offsetof(nxt_sockaddr_t, u) + sa->socklen + sa->length) 105 (((sa)->start + (sa)->length) - (sa)->port_start)
|
H A D | nxt_http_js.c | 123 return njs_vm_value_string_set(vm, retval, r->path->start, r->path->length); in nxt_http_js_ext_uri() 139 return njs_vm_value_string_set(vm, retval, r->host.start, r->host.length); in nxt_http_js_ext_host() 179 r->args->start + r->args->length, args); in nxt_http_js_ext_get_args() 214 if (key.length == f->name_length in nxt_http_js_ext_get_header() 296 if (key.length == nv->name_length in nxt_http_js_ext_get_cookie() 378 name.length = key.length; in nxt_http_js_ext_get_var() 383 return njs_vm_value_string_set(vm, retval, vv->start, vv->length); in nxt_http_js_ext_get_var()
|
H A D | nxt_socket.c | 177 nxt_debug(task, "bind(%d, %*s)", s, (size_t) sa->length, in nxt_socket_bind() 185 s, (size_t) sa->length, nxt_sockaddr_start(sa), nxt_socket_errno); in nxt_socket_bind() 199 s, (size_t) sa->length, nxt_sockaddr_start(sa)); in nxt_socket_connect() 211 s, (size_t) sa->length, nxt_sockaddr_start(sa)); in nxt_socket_connect() 241 s, (size_t) sa->length, nxt_sockaddr_start(sa), err); in nxt_socket_connect()
|
H A D | nxt_conf_validation.c | 1498 expected.length = p - buf; in nxt_conf_vldt_type() 1579 if (str.length == 0) { in nxt_conf_vldt_if() 1585 str.length--; in nxt_conf_vldt_if() 1679 if (exten.length == 0) { in nxt_conf_vldt_mtypes_extension() 1833 if (segments[1].length == 0 || segments[2].length != 0) { in nxt_conf_vldt_pass() 1965 name.length -= 7; in nxt_conf_vldt_proxy() 2481 if (name->length == 0) { in nxt_conf_vldt_match_patterns_set_member() 2579 if (name->length == 0) { in nxt_conf_vldt_response_header() 2982 if (name->length == 0) { in nxt_conf_vldt_environment() 3050 if (name->length == 0) { in nxt_conf_vldt_target() [all …]
|
H A D | nxt_buf.h | 248 nxt_buf_cpy(nxt_buf_t *b, const void *src, size_t length) in nxt_buf_cpy() argument 250 nxt_memcpy(b->mem.free, src, length); in nxt_buf_cpy() 251 b->mem.free += length; in nxt_buf_cpy() 259 return nxt_buf_cpy(b, str->start, str->length); in nxt_buf_cpystr()
|
H A D | nxt_application.c | 265 + module[i].version.length in nxt_discovery_modules() 266 + module[i].file.length; in nxt_discovery_modules() 388 version.length = nxt_strlen(app->version); in nxt_discovery_module() 415 module->file.length = nxt_strlen(name); in nxt_discovery_module() 916 env = nxt_malloc(name.length + value.length + 2); in nxt_app_set_environment() 921 p = nxt_cpymem(env, name.start, name.length); in nxt_app_set_environment() 923 p = nxt_cpymem(p, value.start, value.length); in nxt_app_set_environment() 1033 end = name->start + name->length; in nxt_app_lang_module() 1078 nxt_app_parse_type(u_char *p, size_t length) in nxt_app_parse_type() argument 1082 str.length = length; in nxt_app_parse_type() [all …]
|
/unit/src/nodejs/unit-http/ |
H A D | websocket_connection.js | 352 this.fragmentationSize = frame.length; 370 this.fragmentationSize = frame.length; 377 if (this.frameQueue.length === 0) { 383 this.fragmentationSize += frame.length; 493 if (frame.binaryPayload.length > 1) { 502 this.closeDescription, frame.length 531 this._debug('sendUTF: %d bytes', data.length); 564 if (data.length > 125) { 581 if (Buffer.isBuffer(binaryPayload) && binaryPayload.length > 125) { 598 var length = frame.binaryPayload.length; [all …]
|
H A D | http_server.js | 75 count = value.length; 115 for (var i = 0; i < keys.length; i++) { 153 this.headers_count -= value.length; 154 this.headers_len -= value.length * name_len; 210 for (var i = 0; i < keys.length; i++) { 272 contentLength = chunk.length; 276 contentLength = chunk.length; 470 if (typeof args[args.length - 1] === 'function') { 510 if (this._output.length <= 0) { 514 while (this._output.length > 0) { [all …]
|
H A D | websocket_router.js | 106 for (var i=0, len=this.handlers.length; i < len; i++) { 130 if (requestedProtocols.length === 0) { 135 for (var i=0; i < requestedProtocols.length; i++) { 139 for (var j=0, len=this.handlers.length; j < len; j++) {
|
/unit/src/python/ |
H A D | nxt_python.c | 322 if (proto.length == 0) { in nxt_python_start() 421 module_name = nxt_alloca(str.length + 1); in nxt_python_set_target() 423 module_name[str.length] = '\0'; in nxt_python_set_target() 440 callable = nxt_alloca(str.length + 1); in nxt_python_set_target() 442 callable[str.length] = '\0'; in nxt_python_set_target() 493 if (str.length == 0) { in nxt_python_set_prefix() 497 if (str.start[str.length - 1] == '/') { in nxt_python_set_prefix() 498 str.length--; in nxt_python_set_prefix() 500 target->prefix.length = str.length; in nxt_python_set_prefix() 501 prefix = nxt_malloc(str.length); in nxt_python_set_prefix() [all …]
|
/unit/test/python/upload/ |
H A D | wsgi.py | 6 length = int(environ.get('CONTENT_LENGTH', 0)) 9 body.write(bytes(environ['wsgi.input'].read(length)))
|
/unit/src/perl/ |
H A D | nxt_perl_psgi_layer.h | 23 nxt_perl_psgi_io_arg_t *arg, void *vbuf, size_t length); 25 nxt_perl_psgi_io_arg_t *arg, const void *vbuf, size_t length);
|
H A D | nxt_perl_psgi.c | 32 nxt_perl_psgi_io_arg_t *arg, void *vbuf, size_t length); 163 return (SSize_t) length; in nxt_perl_psgi_io_error_write() 408 size_t length; in nxt_perl_psgi_module_create() local 427 length = strlen(script); in nxt_perl_psgi_module_create() 429 buf = nxt_unit_malloc(NULL, prefix.length + length + suffix.length); in nxt_perl_psgi_module_create() 437 p = nxt_cpymem(buf, prefix.start, prefix.length); in nxt_perl_psgi_module_create() 438 p = nxt_cpymem(p, script, length); in nxt_perl_psgi_module_create() 439 nxt_memcpy(p, suffix.start, suffix.length); in nxt_perl_psgi_module_create() 769 space = memchr(status.start, ' ', status.length); in nxt_perl_psgi_result_status() 771 status.length = space - status.start; in nxt_perl_psgi_result_status() [all …]
|
/unit/src/java/nginx/unit/ |
H A D | OutputStream.java | 30 } else if ((off < 0) || (off > b.length) || (len < 0) || in write() 31 ((off + len) > b.length) || ((off + len) < 0)) { in write()
|
/unit/test/njs/import_from/ |
H A D | script.js | 4 "num" : function () {return typeof cr.createHash('md5').digest().length}
|