| /unit/go/ |
| H A D | port.go | 23 id int member
101 pid: int(p.id.pid),
102 id: int(p.id.id),
130 pid: int(p.id.pid),
131 id: int(p.id.id),
143 func nxt_go_port_send(pid C.int, id C.int, buf unsafe.Pointer, buf_size C.int,
148 id: int(id),
154 nxt_go_alert("port %d:%d not found", pid, id)
171 func nxt_go_port_recv(pid C.int, id C.int, buf unsafe.Pointer, buf_size C.int,
176 id: int(id),
[all …]
|
| H A D | nxt_cgo_lib.c | 54 return nxt_go_port_send(port->id.pid, port->id.id, in nxt_cgo_port_send()
63 return nxt_go_port_recv(port->id.pid, port->id.id, in nxt_cgo_port_recv()
|
| /unit/src/test/ |
| H A D | nxt_cq_test.c | 115 int id; member
195 if ((int) v == wi->id) { in enq_deq_worker()
298 wi->id = id; in worker_create()
466 id = 0; in main()
469 worker_create(wi + id, id, enq_worker); in main()
473 worker_create(wi + id, id, deq_worker); in main()
477 worker_create(wi + id, id, wenq_worker); in main()
481 worker_create(wi + id, id, wdeq_worker); in main()
485 worker_create(wi + id, id, enq_deq_worker); in main()
489 worker_create(wi + id, id, cas_worker); in main()
[all …]
|
| H A D | nxt_unit_websocket_chat.c | 28 int id; member
77 data->id = ws_chat_next_id++; in ws_chat_request_handler()
83 buf_size = snprintf(buf, sizeof(buf), "Guest #%d has joined.", data->id); in ws_chat_request_handler()
173 buf_size = snprintf(buf, sizeof(buf), "Guest #%d: ", data->id); in ws_chat_websocket_handler()
194 data->id); in ws_chat_close_handler()
|
| /unit/src/nodejs/unit-http/ |
| H A D | loader.js | 2 if (module.parent && module.parent.id === "internal/preload") {
11 Module.prototype.require = function (id) { argument
12 switch(id) {
|
| /unit/test/java/url_pattern/ |
| H A D | app.java | 13 private String id; field in app
19 id = sc.getInitParameter("id"); in init()
26 response.addHeader("X-Id", id); in doGet()
34 out.println("app.doGet(): #" + this + ", " + id); in doGet()
|
| /unit/src/java/nginx/unit/ |
| H A D | Session.java | 27 private String id; field in Session
32 public Session(Context context, String id, in Session() argument
35 this.id = id; in Session()
41 public void setId(String id) in setId() argument
43 this.id = id; in setId()
55 return id; in getId()
|
| /unit/src/ |
| H A D | nxt_port_hash.c | 28 && pid_port_id->port_id == port->id) in nxt_port_hash_test()
70 pid_port.port_id = port->id; in nxt_port_hash_add()
85 port->id, port->pid); in nxt_port_hash_add()
101 pid_port.port_id = port->id; in nxt_port_hash_remove()
114 port->id, port->pid); in nxt_port_hash_remove()
|
| H A D | nxt_unit.c | 1536 port->id.pid, port->id.id); in nxt_unit_request_check_response_port()
4329 m.get_mmap.id = id; in nxt_unit_get_mmap()
5263 port_hash_id.id = id; in nxt_unit_port_id_init()
5267 port_id->id = id; in nxt_unit_port_id_init()
5367 m.new_port.id = port->id.id; in nxt_unit_send_port()
5449 port->id.pid, port->id.id, in nxt_unit_add_port()
5528 port->id.pid, port->id.id, in nxt_unit_add_port()
5545 port->id.pid, port->id.id); in nxt_unit_add_port()
5555 port->id.pid, port->id.id); in nxt_unit_add_port()
6101 (int) port->id.pid, (int) port->id.id, in nxt_unit_ctx_port_recv()
[all …]
|
| H A D | nxt_app_log.c | 46 const char *id; in nxt_log_time_handler()
52 id = "[%V] %PI#%PT#%PF "; in nxt_log_time_handler()
56 id = "[%V] %PI#%PT "; in nxt_log_time_handler()
60 p = nxt_sprintf(p, end, id, &nxt_log_levels[level], nxt_pid, in nxt_log_time_handler()
|
| H A D | nxt_port.c | 49 nxt_port_new(nxt_task_t *task, nxt_port_id_t id, nxt_pid_t pid, in nxt_port_new() argument
64 port->id = id; in nxt_port_new()
81 nxt_thread_log_debug("port %p %d:%d new, type %d", port, pid, id, type); in nxt_port_new()
93 port->id, port->type); in nxt_port_close()
117 size = (port->id == (nxt_port_id_t) -1) ? sizeof(nxt_app_queue_t) in nxt_port_close()
130 port->id, port->type); in nxt_port_release()
247 msg->id = new_port->id; in nxt_port_send_port()
273 msg->fd[0], new_port_msg->pid, new_port_msg->id); in nxt_port_new_port_handler()
275 port = nxt_runtime_port_find(rt, new_port_msg->pid, new_port_msg->id); in nxt_port_new_port_handler()
278 new_port_msg->id); in nxt_port_new_port_handler()
[all …]
|
| H A D | nxt_port_memory.c | 167 b->is_port_mmap_sent, hdr->src_pid, hdr->dst_pid, hdr->id, c); in nxt_port_mmap_buf_completion()
261 port_mmap = nxt_port_mmap_at(&process->incoming, hdr->id); in nxt_port_incoming_port_mmap()
337 hdr->id = mmaps->size - 1; in nxt_port_new_port_mmap()
353 hdr->id, nxt_pid); in nxt_port_new_port_mmap()
515 nxt_port_get_port_incoming_mmap(nxt_task_t *task, nxt_pid_t spid, uint32_t id) in nxt_port_get_port_incoming_mmap() argument
527 if (nxt_fast_path(process->incoming.size > id)) { in nxt_port_get_port_incoming_mmap()
528 mmap_handler = process->incoming.elts[id].mmap_handler; in nxt_port_get_port_incoming_mmap()
533 nxt_debug(task, "invalid incoming mmap id %uD for pid %PI", id, spid); in nxt_port_get_port_incoming_mmap()
591 hdr->src_pid, hdr->dst_pid, hdr->id, c); in nxt_port_mmap_get_buf()
704 hdr->src_pid, hdr->dst_pid, hdr->id, mmap_msg->chunk_id); in nxt_port_mmap_get_incoming_buf()
[all …]
|
| H A D | nxt_external.c | 129 proto_port->pid, proto_port->id, proto_port->pair[1], in nxt_external_start()
130 router_port->pid, router_port->id, router_port->pair[1], in nxt_external_start()
131 my_port->pid, my_port->id, my_port->pair[0], in nxt_external_start()
|
| H A D | nxt_port.h | 269 nxt_port_id_t id; member
290 nxt_port_id_t id; member
299 nxt_port_id_t id; member
305 uint32_t id; member
322 nxt_port_t *nxt_port_new(nxt_task_t *task, nxt_port_id_t id, nxt_pid_t pid,
|
| H A D | nxt_application.c | 194 stream, discovery_port->id, b); in nxt_discovery_start()
1134 init->ready_port.id.pid = proto_port->pid; in nxt_unit_default_init()
1135 init->ready_port.id.id = proto_port->id; in nxt_unit_default_init()
1141 init->router_port.id.pid = router_port->pid; in nxt_unit_default_init()
1142 init->router_port.id.id = router_port->id; in nxt_unit_default_init()
1146 init->read_port.id.pid = my_port->pid; in nxt_unit_default_init()
1147 init->read_port.id.id = my_port->id; in nxt_unit_default_init()
|
| H A D | nxt_clone.c | 246 nxt_int_t id; in nxt_clone_vldt_credential_uidmap() local
266 id = map->map[0].host; in nxt_clone_vldt_credential_uidmap()
268 if (nxt_slow_path((nxt_uid_t) id != nxt_euid)) { in nxt_clone_vldt_credential_uidmap()
271 "(uid %d) into child namespaces.", id, nxt_euid); in nxt_clone_vldt_credential_uidmap()
|
| H A D | nxt_http_websocket.c | 104 task->thread->engine->port->id, out); in nxt_http_websocket_client()
150 task->thread->engine->port->id, NULL); in nxt_http_websocket_error_handler()
|
| H A D | nxt_unit.h | 71 uint16_t id; member
79 nxt_unit_port_id_t id; member
243 void nxt_unit_port_id_init(nxt_unit_port_id_t *port_id, pid_t pid, uint16_t id);
|
| H A D | nxt_port_socket.c | 206 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_socket_write2()
233 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_socket_write2()
289 mm->mmap_id = hdr->id; in nxt_port_enqueue_buf()
852 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_queue_read_handler()
859 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_queue_read_handler()
875 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_queue_read_handler()
934 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_queue_read_handler()
941 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_queue_read_handler()
947 (int) port->pid, (int) port->id, port->socket.fd, in nxt_port_queue_read_handler()
959 (int) port->pid, (int) port->id, in nxt_port_queue_read_handler()
[all …]
|
| H A D | nxt_router.c | 722 nxt_assert(port->id != 0); in nxt_router_new_port_handler()
3117 nxt_assert(port->id == 0); in nxt_router_app_prefork_ready()
4434 nxt_assert(port->id == 0); in nxt_router_app_port_ready()
4706 port->pid, port->id, in nxt_router_app_port_release()
4709 if (port->id == NXT_SHARED_PORT_ID) { in nxt_router_app_port_release()
4819 if (port->id != 0) { in nxt_router_app_port_close()
4823 port->pid, port->id); in nxt_router_app_port_close()
5295 msg.pm.reply_port = reply_port->id; in nxt_router_app_prepare_request()
5305 msg.mm.mmap_id = hdr->id; in nxt_router_app_prepare_request()
5803 port->pid, port->id); in nxt_router_get_mmap_handler()
[all …]
|
| H A D | nxt_port_memory_int.h | 50 uint32_t id; member
|
| H A D | nxt_runtime.h | 113 nxt_pid_t pid, nxt_port_id_t id, nxt_process_type_t type);
|
| /unit/test/java/include/ |
| H A D | app.java | 20 private String id; field in app
42 id = sc.getInitParameter("id"); in init()
70 response.addHeader("X-" + dtype + "-Id", id); in doGet()
81 if (id.equals("inc")) { in doGet()
111 if (id.equals("data")) { in doGet()
112 out.println("app.doGet(): #" + this + ", " + id); in doGet()
|
| /unit/test/java/forward/ |
| H A D | app.java | 19 private String id; field in app
41 id = sc.getInitParameter("id"); in init()
69 response.addHeader("X-" + dtype + "-Id", id); in doGet()
86 if (id.equals("fwd")) { in doGet()
115 if (id.equals("data")) { in doGet()
122 out.println("app.doGet(): #" + this + ", " + id); in doGet()
|
| /unit/src/java/nginx/unit/websocket/ |
| H A D | WsSession.java | 98 private final String id; field in WsSession
197 this.id = Long.toHexString(ids.getAndIncrement()); in WsSession()
212 log.debug(sm.getString("wsSession.created", id)); in WsSession()
496 log.debug(sm.getString("wsSession.doClose", id)); in doClose()
648 log.debug(sm.getString("wsSession.sendCloseFail", id), e); in sendCloseMessage()
793 return id; in getId()
1061 throw new IllegalStateException(sm.getString("wsSession.closed", id)); in checkState()
|