Home
last modified time | relevance | path

Searched refs:id (Results 1 – 25 of 33) sorted by relevance

12

/unit/go/
H A Dport.go23 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 Dnxt_cgo_lib.c54 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 Dnxt_cq_test.c115 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 Dnxt_unit_websocket_chat.c28 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 Dloader.js2 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 Dapp.java13 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 DSession.java27 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 Dnxt_port_hash.c28 && 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 Dnxt_unit.c1522 port->id.pid, port->id.id); in nxt_unit_request_check_response_port()
4321 m.get_mmap.id = id; in nxt_unit_get_mmap()
5256 port_hash_id.id = id; in nxt_unit_port_id_init()
5260 port_id->id = id; in nxt_unit_port_id_init()
5361 m.new_port.id = port->id.id; in nxt_unit_send_port()
5443 port->id.pid, port->id.id, in nxt_unit_add_port()
5522 port->id.pid, port->id.id, in nxt_unit_add_port()
5539 port->id.pid, port->id.id); in nxt_unit_add_port()
5549 port->id.pid, port->id.id); in nxt_unit_add_port()
6095 (int) port->id.pid, (int) port->id.id, in nxt_unit_ctx_port_recv()
[all …]
H A Dnxt_app_log.c46 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 Dnxt_port.c49 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 Dnxt_port_memory.c167 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()
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()
567 hdr->src_pid, hdr->dst_pid, hdr->id, c); in nxt_port_mmap_get_tracking()
624 buf[0] = mmap_handler->hdr->id; in nxt_port_mmap_tracking_write()
722 hdr->src_pid, hdr->dst_pid, hdr->id, c); in nxt_port_mmap_get_buf()
835 hdr->src_pid, hdr->dst_pid, hdr->id, mmap_msg->chunk_id); in nxt_port_mmap_get_incoming_buf()
[all …]
H A Dnxt_external.c129 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 Dnxt_port.h259 nxt_port_id_t id; member
280 nxt_port_id_t id; member
289 nxt_port_id_t id; member
295 uint32_t id; member
312 nxt_port_t *nxt_port_new(nxt_task_t *task, nxt_port_id_t id, nxt_pid_t pid,
H A Dnxt_application.c187 stream, discovery_port->id, b); in nxt_discovery_start()
1038 init->ready_port.id.pid = proto_port->pid; in nxt_unit_default_init()
1039 init->ready_port.id.id = proto_port->id; in nxt_unit_default_init()
1045 init->router_port.id.pid = router_port->pid; in nxt_unit_default_init()
1046 init->router_port.id.id = router_port->id; in nxt_unit_default_init()
1050 init->read_port.id.pid = my_port->pid; in nxt_unit_default_init()
1051 init->read_port.id.id = my_port->id; in nxt_unit_default_init()
H A Dnxt_http_websocket.c104 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 Dnxt_clone.c260 nxt_int_t id; in nxt_clone_vldt_credential_uidmap() local
280 id = map->map[0].host; in nxt_clone_vldt_credential_uidmap()
282 if (nxt_slow_path((nxt_uid_t) id != nxt_euid)) { in nxt_clone_vldt_credential_uidmap()
285 "(uid %d) into child namespaces.", id, nxt_euid); in nxt_clone_vldt_credential_uidmap()
H A Dnxt_unit.h71 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 Dnxt_port_socket.c206 (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 Dnxt_router.c723 nxt_assert(port->id != 0); in nxt_router_new_port_handler()
2868 nxt_assert(port->id == 0); in nxt_router_app_prefork_ready()
4526 nxt_assert(port->id == 0); in nxt_router_app_port_ready()
4798 port->pid, port->id, in nxt_router_app_port_release()
4801 if (port->id == NXT_SHARED_PORT_ID) { in nxt_router_app_port_release()
4911 if (port->id != 0) { in nxt_router_app_port_close()
4915 port->pid, port->id); in nxt_router_app_port_close()
5387 msg.pm.reply_port = reply_port->id; in nxt_router_app_prepare_request()
5398 msg.mm.mmap_id = hdr->id; in nxt_router_app_prepare_request()
5889 port->pid, port->id); in nxt_router_get_mmap_handler()
[all …]
H A Dnxt_port_memory_int.h50 uint32_t id; member
H A Dnxt_runtime.h112 nxt_pid_t pid, nxt_port_id_t id, nxt_process_type_t type);
/unit/test/java/include/
H A Dapp.java20 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 Dapp.java19 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 DWsSession.java98 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()

12