/unit/test/ |
H A D | test_asgi_lifespan.py | 17 for name in ['startup', 'shutdown']: 22 assert not exists, name 35 for name in ['startup', 'shutdown', 'version']:
|
/unit/src/ |
H A D | nxt_job.c | 111 nxt_debug(task, "%s start", job->name); in nxt_job_start() 145 nxt_debug(task, "%s thread", job->name); in nxt_job_thread_trampoline() 159 nxt_debug(task, "%s return", job->name); in nxt_job_return() 173 nxt_debug(task, "%s cancellation", job->name); in nxt_job_return() 194 nxt_debug(task, "%s cancellation", job->name); in nxt_job_thread_return_handler()
|
H A D | nxt_openssl.c | 35 u_char name[16]; member 770 nxt_memcpy(name, ticket[0].name, 16); 783 if (memcmp(name, ticket[i].name, 16) == 0) { 933 item->name = domain; 984 str = item->name; 987 item->name.start++; 988 item->name.length--; 990 if (item->name.length == 0 || item->name.start[0] != '.') { 999 lhq.key = item->name; 1003 lhq.key_hash = nxt_murmur_hash2(item->name.start, item->name.length); [all …]
|
H A D | nxt_listen_socket.c | 44 nxt_file_name_t *name, *tmp; in nxt_listen_socket_create() local 134 name = (nxt_file_name_t *) sa->u.sockaddr_un.sun_path; in nxt_listen_socket_create() 137 if (nxt_file_set_access(name, access) != NXT_OK) { in nxt_listen_socket_create() 144 if (nxt_file_chown(name, user, group) != NXT_OK) { in nxt_listen_socket_create() 190 name = (nxt_file_name_t *) orig_sa->u.sockaddr_un.sun_path; in nxt_listen_socket_create() 192 if (nxt_file_rename(tmp, name) != NXT_OK) { in nxt_listen_socket_create() 209 name = (nxt_file_name_t *) sa->u.sockaddr_un.sun_path; in nxt_listen_socket_create() 211 (void) nxt_file_delete(name); in nxt_listen_socket_create()
|
H A D | nxt_http_proxy.c | 56 nxt_str_t name; in nxt_http_proxy_init() local 62 nxt_conf_get_string(acf->proxy, &name); in nxt_http_proxy_init() 64 if (nxt_str_start(&name, "http://", 7)) { in nxt_http_proxy_init() 65 name.length -= 7; in nxt_http_proxy_init() 66 name.start += 7; in nxt_http_proxy_init() 68 sa = nxt_sockaddr_parse(mp, &name); in nxt_http_proxy_init() 82 up->name.length = sa->length; in nxt_http_proxy_init() 83 up->name.start = nxt_sockaddr_start(sa); in nxt_http_proxy_init() 111 nxt_debug(task, "http proxy: \"%V\"", &u->name); in nxt_http_proxy() 263 (size_t) field->name_length, field->name, in nxt_http_proxy_header_read()
|
H A D | nxt_process.c | 164 process->name = init.name; in nxt_process_init_start() 530 process->name, nxt_errno); in nxt_process_init_pidns() 593 nxt_debug(task, "fork(%s): %PI", process->name, pid); in nxt_process_create() 649 nxt_debug(task, "%s setup", process->name); in nxt_process_setup() 651 nxt_process_title(task, "unit: %s", process->name); in nxt_process_setup() 751 nxt_alert(task, "%s failed to start", process->name); in nxt_process_do_start() 900 nxt_debug(task, "%s created", process->name); in nxt_process_send_created() 924 nxt_log(task, NXT_LOG_INFO, "%s started", process->name); in nxt_process_created_ok() 956 nxt_alert(task, "%s failed to start", init->name); in nxt_process_created_error() 1075 nxt_debug(task, "%s sent ready", process->name); in nxt_process_send_ready() [all …]
|
H A D | nxt_php_sapi.c | 260 ag->armed = ag->auto_global_callback(ag->name); in PHP_FUNCTION() 459 nxt_str_t name; in nxt_php_start() local 681 nxt_str_t name, value; in nxt_php_set_options() local 701 if (nxt_str_eq(&name, "disable_functions", 17)) { in nxt_php_set_options() 712 if (nxt_str_eq(&name, "disable_classes", 15)) { in nxt_php_set_options() 1419 const char *name; local 1511 name = nxt_unit_sptr_get(&f->name); 1513 nxt_php_set_sptr(req, name, &f->value, f->value_length, 1551 php_register_variable_safe((char *) name, str, new_len, 1558 nxt_php_set_str(nxt_unit_request_info_t *req, const char *name, argument [all …]
|
H A D | nxt_http_route.c | 103 } name; member 272 string = nxt_str_dup(mp, &route->name, &name); in nxt_http_routes_create() 777 nxt_str_null(&name); in nxt_http_route_ruleset_create() 816 rule->u.name.hash = hash; in nxt_http_route_rule_name_create() 817 rule->u.name.start = name->start; in nxt_http_route_rule_name_create() 818 rule->u.name.length = name->length; in nxt_http_route_rule_name_create() 1497 if (nxt_strstr_eq(&(*route)->name, name)) { in nxt_http_route_find() 1548 nxt_str_t *name) in nxt_http_pass_application() argument 1930 || nxt_strncasecmp(rule->u.name.start, f->name, f->name_length) in nxt_http_route_header() 1981 && memcmp(rule->u.name.start, nv->name, nv->name_length) == 0) in nxt_http_route_test_argument() [all …]
|
H A D | nxt_conf.c | 77 nxt_conf_value_t name; member 286 nxt_conf_set_string(&member->name, name); in nxt_conf_set_member() 302 return nxt_conf_set_string_dup(&member->name, mp, name); in nxt_conf_set_member_dup() 314 nxt_conf_set_string(&member->name, name); in nxt_conf_set_member_string() 328 nxt_conf_set_string(&member->name, name); in nxt_conf_set_member_string_dup() 343 nxt_conf_set_string(&member->name, name); in nxt_conf_set_member_integer() 363 nxt_conf_set_string(&member->name, name); in nxt_conf_set_member_null() 572 if (nxt_strstr_eq(&str, name)) { in nxt_conf_get_object_member() 760 nxt_conf_get_string(&member->name, name); in nxt_conf_next_object_member() 1497 u_char *p, *name; in nxt_conf_json_parse_object() local [all …]
|
H A D | nxt_controller.c | 163 .name = "controller", 250 file.name = (nxt_file_name_t *) name; in nxt_controller_file_read() 1703 name.length = path->length - 1; in nxt_controller_process_cert() 1704 name.start = path->start + 1; in nxt_controller_process_cert() 1706 p = memchr(name.start, '/', name.length); in nxt_controller_process_cert() 1709 name.length = p - name.start; in nxt_controller_process_cert() 1724 if (name.length != 0) { in nxt_controller_process_cert() 1965 name.start = path->start + 1; in nxt_controller_process_script() 1967 p = memchr(name.start, '/', name.length); in nxt_controller_process_script() 1970 name.length = p - name.start; in nxt_controller_process_script() [all …]
|
H A D | nxt_job.h | 53 const char *name; member 77 (job)->name = text
|
H A D | nxt_router.c | 133 nxt_str_t *name); 1003 nxt_memcpy(p, app->name.start, app->name.length); in nxt_router_status_handler() 1005 app_stat->name.length = app->name.length; in nxt_router_status_handler() 1845 app->name.length = name.length; in nxt_router_conf_create() 1846 nxt_memcpy(app->name.start, name.start, name.length); in nxt_router_conf_create() 2458 if (nxt_strstr_eq(name, &app->name)) { in nxt_router_app_find() 2568 lhq.key_hash = nxt_djb_hash(app->name.start, app->name.length); in nxt_router_apps_hash_add() 2595 lhq.key_hash = nxt_djb_hash(name->start, name->length); in nxt_router_apps_hash_get() 2596 lhq.key = *name; in nxt_router_apps_hash_get() 2674 nxt_str_t *name) in nxt_router_socket_conf() argument [all …]
|
H A D | nxt_js.h | 25 njs_str_t *name); 29 nxt_int_t nxt_js_add_module(nxt_js_conf_t *jcf, nxt_str_t *name,
|
H A D | nxt_http.h | 94 (_field)->name = (u_char *) _name; \ 102 (_field)->name = (u_char *) _name; \ 212 u_char *name; member 351 int64_t nxt_http_field_hash(nxt_mp_t *mp, nxt_str_t *name, 353 int64_t nxt_http_argument_hash(nxt_mp_t *mp, nxt_str_t *name); 354 int64_t nxt_http_header_hash(nxt_mp_t *mp, nxt_str_t *name); 355 int64_t nxt_http_cookie_hash(nxt_mp_t *mp, nxt_str_t *name); 366 nxt_router_conf_t *rtcf, nxt_str_t *name); 407 nxt_int_t nxt_upstream_find(nxt_upstreams_t *upstreams, nxt_str_t *name,
|
H A D | nxt_tls.h | 50 nxt_str_t name; member 58 nxt_str_t name; member
|
H A D | nxt_http_parse.h | 81 nxt_str_t name; member 93 u_char *name; member 147 lhq.key.start = field->name; in nxt_http_field_process()
|
H A D | nxt_main_process.c | 505 app_conf->name.start = start; in nxt_main_start_process_handler() 508 init->name = (const char *) start; in nxt_main_start_process_handler() 510 process->name = nxt_mp_alloc(process->mem_pool, app_conf->name.length in nxt_main_start_process_handler() 517 p = (u_char *) process->name; in nxt_main_start_process_handler() 519 p = nxt_cpymem(p, init->name, app_conf->name.length); in nxt_main_start_process_handler() 526 start += app_conf->name.length + 1; in nxt_main_start_process_handler() 904 new_file->name = file->name; in nxt_main_process_sigusr1_handler() 1329 const char *name; in nxt_main_port_socket_unlink_handler() local 1387 offsetof(nxt_fs_mount_t, name), 1678 file.name = (nxt_file_name_t *) name; in nxt_main_file_store() [all …]
|
H A D | nxt_port_memory.c | 374 u_char *p, name[64]; in nxt_shm_open() local 376 p = nxt_sprintf(name, name + sizeof(name), NXT_SHM_PREFIX "unit.%PI.%uxD", in nxt_shm_open() 384 fd = syscall(SYS_memfd_create, name, MFD_CLOEXEC); in nxt_shm_open() 387 nxt_alert(task, "memfd_create(%s) failed %E", name, nxt_errno); in nxt_shm_open() 392 nxt_debug(task, "memfd_create(%s): %FD", name, fd); in nxt_shm_open() 409 shm_unlink((char *) name); in nxt_shm_open() 411 fd = shm_open((char *) name, O_CREAT | O_EXCL | O_RDWR, S_IRUSR | S_IWUSR); in nxt_shm_open() 414 nxt_alert(task, "shm_open(%s) failed %E", name, nxt_errno); in nxt_shm_open() 419 nxt_debug(task, "shm_open(%s): %FD", name, fd); in nxt_shm_open() 421 if (nxt_slow_path(shm_unlink((char *) name) == -1)) { in nxt_shm_open() [all …]
|
H A D | nxt_upstream_round_robin.c | 50 nxt_str_t name; in nxt_upstream_round_robin_create() local 67 srvcf = nxt_conf_next_object_member(servers_conf, &name, &next); in nxt_upstream_round_robin_create() 95 srvcf = nxt_conf_next_object_member(servers_conf, &name, &next); in nxt_upstream_round_robin_create() 97 sa = nxt_sockaddr_parse(mp, &name); in nxt_upstream_round_robin_create()
|
H A D | nxt_http_parse.c | 810 field->name = rp->field_name.start; in nxt_http_parse_field_end() 1164 if (nxt_strcasestr_eq(&lhq->key, &field->name)) { in nxt_http_field_hash_test() 1185 nxt_str_t *name; in nxt_http_fields_hash() local 1195 name = &items[i].name; in nxt_http_fields_hash() 1197 for (j = 0; j < name->length; j++) { in nxt_http_fields_hash() 1198 ch = nxt_lowcase(name->start[j]); in nxt_http_fields_hash() 1203 lhq.key = *name; in nxt_http_fields_hash() 1223 nxt_str_t *name; in nxt_http_fields_hash_collisions() local 1240 name = &items[i].name; in nxt_http_fields_hash_collisions() 1242 for (j = 0; j < name->length; j++) { in nxt_http_fields_hash_collisions() [all …]
|
/unit/src/wasm/ |
H A D | nxt_wasm.c | 59 const char *name; in nxt_wasm_do_send_headers() local 62 name = (const char *)rh + rh->fields[i].name_off; in nxt_wasm_do_send_headers() 65 nxt_unit_response_add_field(ctx->req, name, rh->fields[i].name_len, in nxt_wasm_do_send_headers() 130 const char *name = nxt_unit_sptr_get(&sf->name); in nxt_wasm_request_handler() local 134 df->name_len = strlen(name); in nxt_wasm_request_handler() 135 memcpy((uint8_t *)wr + offset, name, df->name_len + 1); in nxt_wasm_request_handler()
|
/unit/pkg/rpm/ |
H A D | unit.module.spec.in | 2 %define bdir %{_builddir}/%{name}-%{version} 38 BuildRoot: %{_tmppath}/%{name}-%{version}-%{release}-root-%(%{__id_u} -n) 58 %setup -qcTn %{name}-%{unit_version} 82 if [ `basename %{SOURCE100}` == COPYRIGHT.%{name} ]; then
|
/unit/src/java/ |
H A D | nxt_jni.c | 108 const char *name, uint8_t name_len) in nxt_java_findHeader() argument 117 field_name = nxt_unit_sptr_get(&f->name); in nxt_java_findHeader() 119 if (nxt_java_strcaseeq(name, field_name, name_len)) { in nxt_java_findHeader()
|
H A D | nxt_jni_Request.c | 22 jlong req_ptr, jstring name, jint name_len); 26 jlong req_ptr, jstring name, jint name_len); 28 jlong req_ptr, jstring name, jint name_len); 274 jstring name, jint name_len) in nxt_java_Request_getHeader() argument 280 name_str = (*env)->GetStringUTFChars(env, name, NULL); in nxt_java_Request_getHeader() 290 (*env)->ReleaseStringUTFChars(env, name, name_str); in nxt_java_Request_getHeader() 313 jstring name, jint name_len) in nxt_java_Request_getHeaders() argument 319 name_str = (*env)->GetStringUTFChars(env, name, NULL); in nxt_java_Request_getHeaders() 329 (*env)->ReleaseStringUTFChars(env, name, name_str); in nxt_java_Request_getHeaders() 342 jstring name, jint name_len) in nxt_java_Request_getIntHeader() argument [all …]
|
/unit/test/ruby/header_array/ |
H A D | config.ru | 3 'x-array' => ['name=value', '', 'value', 'av'],
|