technocloud-public/nginx-unit
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Introduced the generic API nxt_buf_dummy_completion().

Browse Source 
No functional changes.
This commit is contained in:
Zhidao HONG
2021-08-12 17:39:00 +08:00
parent 598f1493f6
commit 48a9399f23
2 changed files with 9 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/nxt_buf.h
View File

@@ -288,4 +288,10 @@ nxt_buf_cpystr(nxt_buf_t *b, const nxt_str_t *str)
} }
nxt_inline void
nxt_buf_dummy_completion(nxt_task_t *task, void *obj, void *data)
{
}
#endif /* _NXT_BUF_H_INCLIDED_ */ #endif /* _NXT_BUF_H_INCLIDED_ */

14
src/nxt_router.c
View File

@@ -237,8 +237,6 @@ static void nxt_router_http_request_error(nxt_task_t *task, void *obj,
static void nxt_router_http_request_done(nxt_task_t *task, void *obj, static void nxt_router_http_request_done(nxt_task_t *task, void *obj,
void *data); void *data);
static void nxt_router_dummy_buf_completion(nxt_task_t *task, void *obj,
void *data);
static void nxt_router_app_prepare_request(nxt_task_t *task, static void nxt_router_app_prepare_request(nxt_task_t *task,
nxt_request_rpc_data_t *req_rpc_data); nxt_request_rpc_data_t *req_rpc_data);
static nxt_buf_t *nxt_router_prepare_msg(nxt_task_t *task, static nxt_buf_t *nxt_router_prepare_msg(nxt_task_t *task,
@@ -2532,7 +2530,7 @@ nxt_router_listen_socket_rpc_create(nxt_task_t *task,
goto fail; goto fail;
} }
b->completion_handler = nxt_router_dummy_buf_completion; b->completion_handler = nxt_buf_dummy_completion;
b->mem.free = nxt_cpymem(b->mem.free, skcf->listen->sockaddr, size); b->mem.free = nxt_cpymem(b->mem.free, skcf->listen->sockaddr, size);
@@ -2763,7 +2761,7 @@ nxt_router_app_rpc_create(nxt_task_t *task,
goto fail; goto fail;
} }
b->completion_handler = nxt_router_dummy_buf_completion; b->completion_handler = nxt_buf_dummy_completion;
nxt_buf_cpystr(b, &app->name); nxt_buf_cpystr(b, &app->name);
*b->mem.free++ = '\0'; *b->mem.free++ = '\0';
@@ -3792,7 +3790,7 @@ nxt_router_access_log_open(nxt_task_t *task, nxt_router_temp_conf_t *tmcf)
goto fail; goto fail;
} }
b->completion_handler = nxt_router_dummy_buf_completion; b->completion_handler = nxt_buf_dummy_completion;
nxt_buf_cpystr(b, &access_log->path); nxt_buf_cpystr(b, &access_log->path);
*b->mem.free++ = '\0'; *b->mem.free++ = '\0';
@@ -5242,12 +5240,6 @@ nxt_router_http_request_done(nxt_task_t *task, void *obj, void *data)
} }
static void
nxt_router_dummy_buf_completion(nxt_task_t *task, void *obj, void *data)
{
}
static void static void
nxt_router_app_prepare_request(nxt_task_t *task, nxt_router_app_prepare_request(nxt_task_t *task,
nxt_request_rpc_data_t *req_rpc_data) nxt_request_rpc_data_t *req_rpc_data)