Telegram: initial commit

- tdlib moved to telegram dir

1 files changed, 0 insertions, 121 deletions

diff --git a/libs/tdlib/td/benchmark/bench_http_server_fast.cpp b/libs/tdlib/td/benchmark/bench_http_server_fast.cpp
deleted file mode 100644
index fbda47590b..0000000000
--- a/libs/tdlib/td/benchmark/bench_http_server_fast.cpp
+++ /dev/null
@@ -1,121 +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/actor/actor.h"
-
-#include "td/net/HttpHeaderCreator.h"
-#include "td/net/HttpQuery.h"
-#include "td/net/HttpReader.h"
-#include "td/net/TcpListener.h"
-
-#include "td/utils/buffer.h"
-#include "td/utils/BufferedFd.h"
-#include "td/utils/logging.h"
-#include "td/utils/port/Fd.h"
-#include "td/utils/port/SocketFd.h"
-#include "td/utils/Slice.h"
-#include "td/utils/Status.h"
-
-namespace td {
-
-class HttpEchoConnection : public Actor {
- public:
-  explicit HttpEchoConnection(SocketFd fd) : fd_(std::move(fd)) {
-  }
-
- private:
-  BufferedFd<SocketFd> fd_;
-  HttpReader reader_;
-  HttpQuery query_;
-  void start_up() override {
-    fd_.get_fd().set_observer(this);
-    subscribe(fd_.get_fd());
-    reader_.init(&fd_.input_buffer(), 1024 * 1024, 0);
-  }
-
-  void handle_query() {
-    query_ = HttpQuery();
-    HttpHeaderCreator hc;
-    Slice content = "hello world";
-    //auto content = BufferSlice("hello world");
-    hc.init_ok();
-    hc.set_keep_alive();
-    hc.set_content_size(content.size());
-    hc.add_header("Server", "TDLib/test");
-    hc.add_header("Date", "Thu Dec 14 01:41:50 2017");
-    hc.add_header("Content-Type:", "text/html");
-    auto res = hc.finish(content);
-    fd_.output_buffer().append(res.ok());
-  }
-
-  void loop() override {
-    auto status = [&] {
-      TRY_STATUS(loop_read());
-      TRY_STATUS(loop_write());
-      return Status::OK();
-    }();
-    if (status.is_error() || can_close(fd_)) {
-      stop();
-    }
-  }
-  Status loop_read() {
-    if (can_read(fd_)) {
-      TRY_STATUS(fd_.flush_read());
-    }
-    while (true) {
-      TRY_RESULT(need, reader_.read_next(&query_));
-      if (need == 0) {
-        handle_query();
-      } else {
-        break;
-      }
-    }
-    return Status::OK();
-  }
-  Status loop_write() {
-    TRY_STATUS(fd_.flush_write());
-    return Status::OK();
-  }
-};
-
-const int N = 4;
-class Server : public TcpListener::Callback {
- public:
-  void start_up() override {
-    listener_ = create_actor<TcpListener>("Listener", 8082, ActorOwn<TcpListener::Callback>(actor_id(this)));
-  }
-  void accept(SocketFd fd) override {
-    pos_++;
-    auto scheduler_id = pos_ % (N != 0 ? N : 1) + (N != 0);
-    create_actor_on_scheduler<HttpEchoConnection>("HttpInboundConnection", scheduler_id, std::move(fd)).release();
-  }
-  void hangup() override {
-    LOG(ERROR) << "hangup..";
-    stop();
-  }
-
- private:
-  ActorOwn<TcpListener> listener_;
-  int pos_{0};
-};
-
-int main() {
-  SET_VERBOSITY_LEVEL(VERBOSITY_NAME(ERROR));
-  auto scheduler = make_unique<ConcurrentScheduler>();
-  scheduler->init(N);
-  scheduler->create_actor_unsafe<Server>(0, "Server").release();
-  scheduler->start();
-  while (scheduler->run_main(10)) {
-    // empty
-  }
-  scheduler->finish();
-  return 0;
-}
-}  // namespace td
-
-int main() {
-  return td::main();
-}