aboutsummaryrefslogtreecommitdiffhomepage
path: root/benchmark/bench_http_server_fast.cpp
diff options
context:
space:
mode:
authorArseny Smirnov <arseny30@gmail.com>2020-07-13 11:55:43 +0300
committerArseny Smirnov <arseny30@gmail.com>2020-07-13 11:55:43 +0300
commitfee05df2cc4ac4ce9ddf6237de88f3e182d519d7 (patch)
tree0e5065e989fa930afd595914b53a0f1672ebeabd /benchmark/bench_http_server_fast.cpp
parent15c387eff0490f4ca1f15a47f190d6e7965845ea (diff)
HttpConnection: write_next_noflush for writes without flushing to socket
GitOrigin-RevId: 0b4ffbd7600b1ce466caf8a33897b555a2855211
Diffstat (limited to 'benchmark/bench_http_server_fast.cpp')
-rw-r--r--benchmark/bench_http_server_fast.cpp6
1 files changed, 5 insertions, 1 deletions
diff --git a/benchmark/bench_http_server_fast.cpp b/benchmark/bench_http_server_fast.cpp
index 0d012f112..c4353dc17 100644
--- a/benchmark/bench_http_server_fast.cpp
+++ b/benchmark/bench_http_server_fast.cpp
@@ -34,6 +34,10 @@ class HttpEchoConnection : public Actor {
Scheduler::subscribe(fd_.get_poll_info().extract_pollable_fd(this));
reader_.init(&fd_.input_buffer(), 1024 * 1024, 0);
}
+ void tear_down() override {
+ Scheduler::unsubscribe_before_close(fd_.get_poll_info().get_pollable_fd_ref());
+ fd_.close();
+ }
void handle_query() {
query_ = HttpQuery();
@@ -80,7 +84,7 @@ class HttpEchoConnection : public Actor {
}
};
-const int N = 4;
+const int N = 8;
class Server : public TcpListener::Callback {
public:
void start_up() override {