diff options
| author | Max Romanov <max.romanov@nginx.com> | 2017-10-04 14:58:47 +0300 |
|---|---|---|
| committer | Max Romanov <max.romanov@nginx.com> | 2017-10-04 14:58:47 +0300 |
| commit | 6a64533fa3b96bb64bfde4615e40376d65a292cb (patch) | |
| tree | a18ed8059158d833290519e1135209747e28af21 /src/nxt_runtime.h | |
| parent | 414d508e04d26ebef0e3e1ba4ed518b11d3af1a0 (diff) | |
| download | unit-6a64533fa3b96bb64bfde4615e40376d65a292cb.tar.gz unit-6a64533fa3b96bb64bfde4615e40376d65a292cb.tar.bz2 | |
Introducing use counters for port and app. Thread safe port write.
Use counter helps to simplify logic around port and application free.
Port 'post' function introduced to simplify post execution of particular
function to original port engine's thread.
Write message queue is protected by mutex which makes port write operation
thread safe.
Diffstat (limited to 'src/nxt_runtime.h')
| -rw-r--r-- | src/nxt_runtime.h | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/nxt_runtime.h b/src/nxt_runtime.h index d0decfd2..5aa897dc 100644 --- a/src/nxt_runtime.h +++ b/src/nxt_runtime.h @@ -102,11 +102,11 @@ nxt_process_t *nxt_runtime_process_new(nxt_runtime_t *rt); nxt_process_t *nxt_runtime_process_get(nxt_runtime_t *rt, nxt_pid_t pid); -void nxt_runtime_process_add(nxt_runtime_t *rt, nxt_process_t *process); +void nxt_runtime_process_add(nxt_task_t *task, nxt_process_t *process); nxt_process_t *nxt_runtime_process_find(nxt_runtime_t *rt, nxt_pid_t pid); -void nxt_runtime_process_remove(nxt_runtime_t *rt, nxt_process_t *process); +void nxt_runtime_process_remove(nxt_task_t *task, nxt_process_t *process); nxt_process_t *nxt_runtime_process_first(nxt_runtime_t *rt, nxt_lvlhsh_each_t *lhe); @@ -115,9 +115,9 @@ nxt_process_t *nxt_runtime_process_first(nxt_runtime_t *rt, nxt_lvlhsh_each(&rt->processes, lhe) -void nxt_runtime_port_add(nxt_runtime_t *rt, nxt_port_t *port); +void nxt_runtime_port_add(nxt_task_t *task, nxt_port_t *port); -void nxt_runtime_port_remove(nxt_runtime_t *rt, nxt_port_t *port); +void nxt_runtime_port_remove(nxt_task_t *task, nxt_port_t *port); nxt_port_t *nxt_runtime_port_find(nxt_runtime_t *rt, nxt_pid_t pid, nxt_port_id_t port_id); |