/unit/src/ |
H A D | nxt_http_chunk_parse.c | 202 u_char *p; in nxt_http_chunk_buffer() local 206 p = hcp->pos; in nxt_http_chunk_buffer() 207 size = in->mem.free - p; in nxt_http_chunk_buffer() 222 b->mem.pos = p; in nxt_http_chunk_buffer() 223 b->mem.start = p; in nxt_http_chunk_buffer() 226 p += hcp->chunk_size; in nxt_http_chunk_buffer() 227 hcp->pos = p; in nxt_http_chunk_buffer() 229 b->mem.free = p; in nxt_http_chunk_buffer() 230 b->mem.end = p; in nxt_http_chunk_buffer()
|
H A D | nxt_clang.h | 201 #define nxt_container_of(p, type, field) \ argument 202 (type *) ((u_char *) (p) - offsetof(type, field)) 205 #define nxt_pointer_to(p, offset) \ argument 206 ((void *) ((char *) (p) + (offset))) 209 #define nxt_value_at(type, p, offset) \ argument 210 *(type *) ((u_char *) p + offset) 246 #define nxt_align_ptr(p, a) \ argument 247 (u_char *) (((uintptr_t) (p) + ((uintptr_t) (a) - 1)) \ 250 #define nxt_trunc_ptr(p, a) \ argument 251 (u_char *) ((uintptr_t) (p) & ~((uintptr_t) (a) - 1))
|
H A D | nxt_gnutls.c | 686 u_char *p, msg[NXT_MAX_ERROR_STR]; in nxt_gnutls_conn_log_error() local 693 p = nxt_vsprintf(msg, msg + sizeof(msg), fmt, args); in nxt_gnutls_conn_log_error() 697 p - msg, msg, err, gnutls_strerror(err)); in nxt_gnutls_conn_log_error() 734 u_char *p, msg[NXT_MAX_ERROR_STR]; in nxt_gnutls_log_error() local 737 p = nxt_vsprintf(msg, msg + sizeof(msg), fmt, args); in nxt_gnutls_log_error() 741 p - msg, msg, err, gnutls_strerror(err)); in nxt_gnutls_log_error()
|
H A D | nxt_malloc.c | 33 void *p; in nxt_malloc() local 35 p = malloc(size); in nxt_malloc() 45 return p; in nxt_malloc() 52 void *p; in nxt_zalloc() local 60 return p; in nxt_zalloc() 103 nxt_free(p); in nxt_lvlhsh_free() 110 nxt_free(void *p) in nxt_free() argument 114 free(p); in nxt_free() 139 return p; in nxt_memalign() 155 void *p; in nxt_memalign() local [all …]
|
H A D | nxt_cert.c | 277 char *p; in nxt_nxt_cert_pem_suffix() local 293 p--; in nxt_nxt_cert_pem_suffix() 295 if (*p != ' ') { in nxt_nxt_cert_pem_suffix() 299 return p - pem_str; in nxt_nxt_cert_pem_suffix() 877 if (p == NULL) { in nxt_cert_store_load() 882 buf = p; in nxt_cert_store_load() 886 p = nxt_cpymem(p, name.start, name.length + 1); in nxt_cert_store_load() 1126 u_char *p; in nxt_cert_store_get_handler() local 1173 p = nxt_cpymem(p, name.start, name.length + 1); in nxt_cert_store_get_handler() 1216 u_char *p; in nxt_cert_store_delete_handler() local [all …]
|
H A D | nxt_external.c | 64 u_char *p, *end; in nxt_external_start() local 121 p = nxt_sprintf(buf, end, in nxt_external_start() 136 if (nxt_slow_path(p == end)) { in nxt_external_start() 182 p = (u_char *) &argv[argc]; in nxt_external_start() 190 argv[i++] = (char *) p; in nxt_external_start() 194 p = nxt_cpymem(p, str.start, str.length); in nxt_external_start() 195 *p++ = '\0'; in nxt_external_start()
|
H A D | nxt_java.c | 81 char *path, *relpath, *p, *rootfs; in nxt_java_setup() local 112 p = nxt_cpymem(path, process->isolation.rootfs, rootfs_len); in nxt_java_setup() 113 p = nxt_cpymem(p, relpath, jars_dir_len); in nxt_java_setup() 114 *p = '\0'; in nxt_java_setup()
|
H A D | nxt_tls.h | 100 u_char *nxt_openssl_copy_error(u_char *p, u_char *end);
|
H A D | nxt_h1proto_websocket.c | 403 uint8_t *p, *mask; in nxt_h1p_conn_ws_frame_process() local 420 p = nxt_pointer_to(wsh, hsize); in nxt_h1p_conn_ws_frame_process() 422 code = ((p[0] ^ mask[0]) << 8) + (p[1] ^ mask[1]); in nxt_h1p_conn_ws_frame_process() 581 u_char *p; in hxt_h1p_send_ws_error() local 590 p = nxt_vsprintf(buf, buf + sizeof(buf), (char *) err->desc.start, in hxt_h1p_send_ws_error() 595 desc.length = p - buf; in hxt_h1p_send_ws_error() 613 p = nxt_websocket_frame_init(wsh, sizeof(err->code) + desc.length); in hxt_h1p_send_ws_error() 618 *p++ = (err->code >> 8) & 0xFF; in hxt_h1p_send_ws_error() 619 *p++ = err->code & 0xFF; in hxt_h1p_send_ws_error() 621 out->mem.free = nxt_cpymem(p, desc.start, desc.length); in hxt_h1p_send_ws_error()
|
H A D | nxt_event_engine.c | 631 nxt_event_engine_mem_free(nxt_event_engine_t *engine, uint8_t hint, void *p, in nxt_event_engine_mem_free() argument 639 block = p; in nxt_event_engine_mem_free() 655 "event engine mem free(%p, %z) not found", p, size); in nxt_event_engine_mem_free() 675 nxt_mp_free(engine->mem_pool, p); in nxt_event_engine_mem_free()
|
H A D | nxt_pcre2.c | 14 static void nxt_pcre2_free(void *p, void *memory_data); 105 nxt_pcre2_free(void *p, void *mp) in nxt_pcre2_free() argument
|
H A D | nxt_app_log.c | 22 u_char *p, *end; in nxt_log_time_handler() local 41 syslogmsg = p; in nxt_log_time_handler() 60 p = nxt_sprintf(p, end, id, &nxt_log_levels[level], nxt_pid, in nxt_log_time_handler() 63 p = nxt_sprintf(p, end, "[%V] %PI#%PT ", &nxt_log_levels[level], nxt_pid, in nxt_log_time_handler() 68 p = nxt_sprintf(p, end, "*%D ", log->ident); in nxt_log_time_handler() 72 p = nxt_vsprintf(p, end, fmt, args); in nxt_log_time_handler() 76 p = log->ctx_handler(log->ctx, p, end); in nxt_log_time_handler() 79 if (p > end - nxt_length("\n")) { in nxt_log_time_handler() 80 p = end - nxt_length("\n"); in nxt_log_time_handler() 83 *p++ = '\n'; in nxt_log_time_handler() [all …]
|
H A D | nxt_log.c | 69 u_char *p, *end; in nxt_log_handler() local 76 p = msg; in nxt_log_handler() 80 p = nxt_cpystrn(p, nxt_log_prefix, end - p); in nxt_log_handler() 81 *p++ = ':'; in nxt_log_handler() 82 *p++ = ' '; in nxt_log_handler() 86 syslogmsg = p; in nxt_log_handler() 89 p = nxt_sprintf(p, end, (log->ident != 0) ? "[%V] *%D " : "[%V] ", in nxt_log_handler() 93 p = nxt_vsprintf(p, end, fmt, args); in nxt_log_handler() 97 p = log->ctx_handler(log->ctx, p, end); in nxt_log_handler() 101 p = end - nxt_length("\n"); in nxt_log_handler() [all …]
|
H A D | nxt_websocket.c | 62 p = h->payload_len; in nxt_websocket_frame_header_size() 66 if (p == 126) { in nxt_websocket_frame_header_size() 68 } else if (p == 127) { in nxt_websocket_frame_header_size() 87 p = h->payload_len; in nxt_websocket_frame_payload_len() 89 if (p == 126) { in nxt_websocket_frame_payload_len() 91 } else if (p == 127) { in nxt_websocket_frame_payload_len() 95 return p; in nxt_websocket_frame_payload_len() 106 p = data; in nxt_websocket_frame_init() 110 return p + 2; in nxt_websocket_frame_init() 116 return p + 4; in nxt_websocket_frame_init() [all …]
|
H A D | nxt_thread.c | 22 void *p; in nxt_thread_init_data() local 50 p = nxt_zalloc(tsd->size); in nxt_thread_init_data() 51 if (p == NULL) { in nxt_thread_init_data() 55 err = pthread_setspecific((pthread_key_t) tsd->key, p); in nxt_thread_init_data()
|
H A D | nxt_thread_time.c | 228 u_char *p; in nxt_thread_time_string() local 320 p = tsc->string.start; in nxt_thread_time_string() 322 if (nxt_slow_path(p == NULL)) { in nxt_thread_time_string() 325 p = nxt_zalloc(ts->size); in nxt_thread_time_string() 328 if (p == NULL) { in nxt_thread_time_string() 332 tsc->string.start = p; in nxt_thread_time_string() 335 p = ts->handler(p, &thr->time.now.realtime, tm, ts->size, ts->format); in nxt_thread_time_string() 337 tsc->string.length = p - tsc->string.start; in nxt_thread_time_string()
|
/unit/src/java/nginx/unit/ |
H A D | Context.java | 208 pattern = p; in PrefixPattern() 524 exact2servlet_.put(p.pattern, p.servlet); in loadApp() 671 Path p; in extractWar() local 673 p = ep; in extractWar() 1641 reg.setInitParameter(p.name(), p.value()); 1694 reg.setInitParameter(p.name(), p.value()); 2257 if (p.startsWith("/") && p.endsWith("/*")) { 2259 pattern_ = p.substring(0, p.length() - 2); 2270 pattern_ = p.substring(1, p.length()); 2295 pattern_ = p; [all …]
|
/unit/auto/os/ |
H A D | test | 13 # Linux uname -p can return "unknown". 30 NXT_SYSTEM_PLATFORM=`uname -p 2>/dev/null` 51 NXT_SYSTEM_PLATFORM=`uname -p 2>/dev/null` 71 NXT_SYSTEM_PLATFORM=`uname -p 2>/dev/null` 92 NXT_SYSTEM_PLATFORM=`uname -p 2>/dev/null`
|
/unit/go/ |
H A D | port.go | 57 port_registry_.m[p.key] = p 64 if p.rcv != nil { 65 p.rcv.Close() 68 if p.snd != nil { 69 p.snd.Close() 102 id: int(p.id.id), 110 p.in_fd = -1 111 p.out_fd = -1 131 id: int(p.id.id), 153 if p == nil { [all …]
|
/unit/src/python/ |
H A D | nxt_python_asgi_websocket.c | 675 nxt_py_asgi_penging_frame_t *p; in nxt_py_asgi_websocket_suspend_frame() local 697 if (nxt_slow_path(p == NULL)) { in nxt_py_asgi_websocket_suspend_frame() 709 p->frame = frame; in nxt_py_asgi_websocket_suspend_frame() 710 nxt_queue_insert_tail(&ws->pending_frames, &p->link); in nxt_py_asgi_websocket_suspend_frame() 926 nxt_py_asgi_penging_frame_t *p; in nxt_py_asgi_websocket_pending_len() local 931 res += p->frame->payload_len; in nxt_py_asgi_websocket_pending_len() 933 if (p->frame->header->fin) { in nxt_py_asgi_websocket_pending_len() 951 nxt_py_asgi_penging_frame_t *p; in nxt_py_asgi_websocket_pop_frame() local 956 p = nxt_queue_link_data(lnk, nxt_py_asgi_penging_frame_t, link); in nxt_py_asgi_websocket_pop_frame() 958 frame = p->frame; in nxt_py_asgi_websocket_pop_frame() [all …]
|
/unit/test/java/welcome_files/dir2/ |
H A D | default.jsp | 2 <html><body><p>You should see this on <a href="/dir2/">/dir2/</a> URL.</p></body></html>
|
/unit/test/java/get_params/ |
H A D | app.java | 45 for (Map.Entry <String, String[]> p : parameter_map.entrySet()) { in doGet() 46 map = map.concat(p.getKey() + "=" + String.join(",", p.getValue()) + " "); in doGet()
|
/unit/test/java/include/ |
H A D | app.java | 121 for (Map.Entry<String,String[]> p : pmap.entrySet()) { in doGet() 122 out.println("- " + p.getKey() + "=" + String.join(",", p.getValue())); in doGet()
|
/unit/test/java/forward/ |
H A D | app.java | 80 for (Map.Entry<String,String[]> p : pmap.entrySet()) { in doGet() 81 … response.addHeader("X-" + dtype + "-Param-" + p.getKey(), "" + String.join(",", p.getValue())); in doGet() 129 for (Map.Entry<String,String[]> p : pmap.entrySet()) { in doGet() 130 out.println("- " + p.getKey() + "=" + String.join(",", p.getValue())); in doGet()
|
/unit/src/test/ |
H A D | nxt_sprintf_test.c | 33 u_char *p; in nxt_sprintf_test_double() local 35 p = nxt_sprintf(buf, end, fmt, n); in nxt_sprintf_test_double() 36 *p = '\0'; in nxt_sprintf_test_double()
|