Home
last modified time | relevance | path

Searched refs:p (Results 101 – 125 of 159) sorted by last modified time

1234567

/unit/src/
H A Dnxt_http_chunk_parse.c202 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 Dnxt_clang.h201 #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 Dnxt_gnutls.c686 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 Dnxt_malloc.c33 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 Dnxt_cert.c277 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 Dnxt_external.c64 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 Dnxt_java.c81 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 Dnxt_tls.h100 u_char *nxt_openssl_copy_error(u_char *p, u_char *end);
H A Dnxt_h1proto_websocket.c403 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 Dnxt_event_engine.c631 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 Dnxt_pcre2.c14 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 Dnxt_app_log.c22 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 Dnxt_log.c69 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 Dnxt_websocket.c62 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 Dnxt_thread.c22 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 Dnxt_thread_time.c228 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 DContext.java208 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 Dtest13 # 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 Dport.go57 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 Dnxt_python_asgi_websocket.c675 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 Ddefault.jsp2 <html><body><p>You should see this on <a href="/dir2/">/dir2/</a> URL.</p></body></html>
/unit/test/java/get_params/
H A Dapp.java45 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 Dapp.java121 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 Dapp.java80 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 Dnxt_sprintf_test.c33 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()

1234567