summaryrefslogtreecommitdiffhomepage
path: root/src/nxt_stream_module.c
diff options
context:
space:
mode:
authorAndrew Clayton <a.clayton@nginx.com>2023-03-27 19:28:54 +0100
committerAndrew Clayton <a.clayton@nginx.com>2023-04-24 19:39:09 +0100
commitb9177d36e71a9f62198b00fa40f277c06d2264bb (patch)
tree3941280ca6ab849457ba17a75afb4cc7feb183bc /src/nxt_stream_module.c
parent6f36a67fc37004511299133e39d9a6fbb9d55a0c (diff)
downloadunit-b9177d36e71a9f62198b00fa40f277c06d2264bb.tar.gz
unit-b9177d36e71a9f62198b00fa40f277c06d2264bb.tar.bz2
Remove a bunch of dead code.
This removes a bunch of unused files that would have been touched by subsequent commits that switch to using nxt_bool_t (AKA unit6_t) in structures. In auto/sources we have NXT_LIB_SRC0=" \ src/nxt_buf_filter.c \ src/nxt_job_file.c \ src/nxt_stream_module.c \ src/nxt_stream_source.c \ src/nxt_upstream_source.c \ src/nxt_http_source.c \ src/nxt_fastcgi_source.c \ src/nxt_fastcgi_record_parse.c \ \ src/nxt_mem_pool_cleanup.h \ src/nxt_mem_pool_cleanup.c \ " None of these seem to actually be used anywhere (other than within themselves). That variable is _not_ referenced anywhere else. Also remove the unused related header files: src/nxt_buf_filter.h, src/nxt_fastcgi_source.h, src/nxt_http_source.h, src/nxt_job_file.h, src/nxt_stream_source.h and src/nxt_upstream_source.h Also, these files do not seem to be used, no mention under auto/ or build/ src/nxt_file_cache.c src/nxt_cache.c src/nxt_job_file_cache.c src/nxt_cache.h is #included in src/nxt_main.h, but AFAICT is not actually used. With all the above removed $ ./configure --openssl --debug --tests && make -j && make -j tests && make libnxt all builds. Buildbot passes. NOTE: You may need to do a 'make clean' before the next build attempt. Reviewed-by: Alejandro Colomar <alx@nginx.com> Signed-off-by: Andrew Clayton <a.clayton@nginx.com>
Diffstat (limited to 'src/nxt_stream_module.c')
-rw-r--r--src/nxt_stream_module.c131
1 files changed, 0 insertions, 131 deletions
diff --git a/src/nxt_stream_module.c b/src/nxt_stream_module.c
deleted file mode 100644
index 25aaec57..00000000
--- a/src/nxt_stream_module.c
+++ /dev/null
@@ -1,131 +0,0 @@
-
-/*
- * Copyright (C) Igor Sysoev
- * Copyright (C) NGINX, Inc.
- */
-
-#include <nxt_main.h>
-#include <nxt_runtime.h>
-
-
-static void nxt_stream_connection_peer(nxt_task_t *task,
- nxt_upstream_peer_t *up);
-static void nxt_stream_connection_close(nxt_task_t *task, void *obj,
- void *data);
-
-
-void
-nxt_stream_connection_init(nxt_task_t *task, void *obj, void *data)
-{
- nxt_conn_t *c;
- nxt_runtime_t *rt;
- nxt_upstream_peer_t *up;
-
- c = obj;
-
- nxt_debug(task, "stream connection init");
-
- up = nxt_mp_zget(c->mem_pool, sizeof(nxt_upstream_peer_t));
- if (nxt_slow_path(up == NULL)) {
- goto fail;
- }
-
- up->data = c;
-
- rt = task->thread->runtime;
-
- if (rt->upstream.length != 0) {
- up->addr = rt->upstream;
-
- } else {
- nxt_str_set(&up->addr, "127.0.0.1:8080");
- }
-
- up->ready_handler = nxt_stream_connection_peer;
- up->mem_pool = c->mem_pool;
-
- nxt_upstream_round_robin_peer(task, up);
- return;
-
-fail:
-
- /* TODO: close connection */
- return;
-}
-
-
-static void
-nxt_stream_connection_peer(nxt_task_t *task, nxt_upstream_peer_t *up)
-{
- nxt_conn_t *c;
- nxt_conn_proxy_t *p;
-
- c = up->data;
-
- up->sockaddr->type = SOCK_STREAM;
-
- nxt_log_debug(c->socket.log, "stream connection peer %*s",
- (size_t) up->sockaddr->length,
- nxt_sockaddr_start(up->sockaddr));
-
- p = nxt_conn_proxy_create(c);
- if (nxt_slow_path(p == NULL)) {
- goto fail;
- }
-
- p->client->socket.data = p;
- p->peer->socket.data = p;
-
- p->client_buffer_size = 1024;
- p->peer_buffer_size = 4096;
- //p->client_wait_timeout = 9000;
- p->connect_timeout = 7000;
- p->reconnect_timeout = 500;
- //p->peer_wait_timeout = 5000;
- p->client_write_timeout = 3000;
- p->peer_write_timeout = 3000;
- p->completion_handler = nxt_stream_connection_close;
- //p->retries = 10;
- p->peer->remote = up->sockaddr;
-
- if (0) {
- nxt_event_engine_t *engine;
- nxt_event_write_rate_t *rate;
-
- rate = nxt_mp_get(c->mem_pool, sizeof(nxt_event_write_rate_t));
-
- if (nxt_slow_path(rate == NULL)) {
- goto fail;
- }
-
- c->rate = rate;
-
- rate->limit = 1024;
- rate->limit_after = 0;
- rate->average = rate->limit;
-
- engine = nxt_thread_event_engine();
- rate->last = engine->timers.now;
- }
-
- nxt_conn_proxy(task, p);
- return;
-
-fail:
-
- /* TODO: close connection */
- return;
-}
-
-
-static void
-nxt_stream_connection_close(nxt_task_t *task, void *obj, void *data)
-{
- nxt_event_conn_proxy_t *p;
-
- p = obj;
-
- nxt_log_debug(p->client->socket.log, "stream connection close");
-
- nxt_mp_destroy(p->client->mem_pool);
-}