summaryrefslogtreecommitdiff
path: root/libs/tdlib/td/benchmark/bench_http_reader.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'libs/tdlib/td/benchmark/bench_http_reader.cpp')
-rw-r--r--libs/tdlib/td/benchmark/bench_http_reader.cpp118
1 files changed, 0 insertions, 118 deletions
diff --git a/libs/tdlib/td/benchmark/bench_http_reader.cpp b/libs/tdlib/td/benchmark/bench_http_reader.cpp
deleted file mode 100644
index 2afe2d73ff..0000000000
--- a/libs/tdlib/td/benchmark/bench_http_reader.cpp
+++ /dev/null
@@ -1,118 +0,0 @@
-//
-// Copyright Aliaksei Levin (levlam@telegram.org), Arseny Smirnov (arseny30@gmail.com) 2014-2018
-//
-// Distributed under the Boost Software License, Version 1.0. (See accompanying
-// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
-//
-#include "td/net/HttpQuery.h"
-#include "td/net/HttpReader.h"
-
-#include "td/utils/benchmark.h"
-#include "td/utils/buffer.h"
-#include "td/utils/find_boundary.h"
-#include "td/utils/logging.h"
-
-static std::string http_query = "GET / HTTP/1.1\r\nConnection:keep-alive\r\nhost:127.0.0.1:8080\r\n\r\n";
-static const size_t block_size = 2500;
-
-class HttpReaderBench : public td::Benchmark {
- std::string get_description() const override {
- return "HttpReaderBench";
- }
-
- void run(int n) override {
- int cnt = static_cast<int>(block_size / http_query.size());
- td::HttpQuery q;
- int parsed = 0;
- int sent = 0;
- for (int i = 0; i < n; i += cnt) {
- for (int j = 0; j < cnt; j++) {
- writer_.append(http_query);
- sent++;
- }
- reader_.sync_with_writer();
- while (true) {
- auto wait = http_reader_.read_next(&q).ok();
- if (wait != 0) {
- break;
- }
- parsed++;
- }
- }
- CHECK(parsed == sent);
- }
- td::ChainBufferWriter writer_;
- td::ChainBufferReader reader_;
- td::HttpReader http_reader_;
-
- void start_up() override {
- writer_ = td::ChainBufferWriter::create_empty();
- reader_ = writer_.extract_reader();
- http_reader_.init(&reader_, 10000, 0);
- }
-};
-
-class BufferBench : public td::Benchmark {
- std::string get_description() const override {
- return "BufferBench";
- }
-
- void run(int n) override {
- int cnt = static_cast<int>(block_size / http_query.size());
- for (int i = 0; i < n; i += cnt) {
- for (int j = 0; j < cnt; j++) {
- writer_.append(http_query);
- }
- reader_.sync_with_writer();
- for (int j = 0; j < cnt; j++) {
- reader_.cut_head(http_query.size());
- }
- }
- }
- td::ChainBufferWriter writer_;
- td::ChainBufferReader reader_;
- td::HttpReader http_reader_;
-
- void start_up() override {
- writer_ = td::ChainBufferWriter::create_empty();
- reader_ = writer_.extract_reader();
- }
-};
-
-class FindBoundaryBench : public td::Benchmark {
- std::string get_description() const override {
- return "FindBoundaryBench";
- }
-
- void run(int n) override {
- int cnt = static_cast<int>(block_size / http_query.size());
- for (int i = 0; i < n; i += cnt) {
- for (int j = 0; j < cnt; j++) {
- writer_.append(http_query);
- }
- reader_.sync_with_writer();
- for (int j = 0; j < cnt; j++) {
- size_t len = 0;
- find_boundary(reader_.clone(), "\r\n\r\n", len);
- CHECK(size_t(len) + 4 == http_query.size());
- reader_.cut_head(len + 2);
- reader_.advance(2);
- }
- }
- }
- td::ChainBufferWriter writer_;
- td::ChainBufferReader reader_;
- td::HttpReader http_reader_;
-
- void start_up() override {
- writer_ = td::ChainBufferWriter::create_empty();
- reader_ = writer_.extract_reader();
- }
-};
-
-int main() {
- SET_VERBOSITY_LEVEL(VERBOSITY_NAME(WARNING));
- td::bench(BufferBench());
- td::bench(FindBoundaryBench());
- td::bench(HttpReaderBench());
-}