From 7d1119680e7881af7f5934773721cb48f40b35e7 Mon Sep 17 00:00:00 2001
From: Nikolai Kochetov <nik-kochetov@yandex-team.ru>
Date: Fri, 19 Feb 2021 11:52:33 +0300
Subject: [PATCH] Remove not needed file.

---
 src/Client/PacketReceiver.h | 145 ------------------------------------
 1 file changed, 145 deletions(-)
 delete mode 100644 src/Client/PacketReceiver.h

diff --git a/src/Client/PacketReceiver.h b/src/Client/PacketReceiver.h
deleted file mode 100644
index c9475bafa71..00000000000
--- a/src/Client/PacketReceiver.h
+++ /dev/null
@@ -1,145 +0,0 @@
-#pragma once
-
-#if defined(OS_LINUX)
-
-#include <Client/IConnections.h>
-#include <Common/FiberStack.h>
-#include <Common/Fiber.h>
-#include <Common/Epoll.h>
-#include <Common/TimerDescriptor.h>
-
-namespace DB
-{
-
-/// Class for nonblocking packet receiving. It runs connection->receivePacket
-/// in fiber and sets special read callback which is called when
-/// reading from socket blocks. When read callback is called,
-/// socket and receive timeout are added in epoll and execution returns to the main program.
-/// So, you can poll this epoll file descriptor to determine when to resume
-/// packet receiving (beside polling epoll descriptor, you also need to check connection->hasPendingData(),
-/// because small packet can be read in buffer with the previous one, so new packet will be ready in buffer,
-/// but there is no data socket to poll).
-class PacketReceiver
-{
-public:
-    PacketReceiver(Connection * connection_) : connection(connection_)
-    {
-        epoll.add(receive_timeout.getDescriptor());
-        epoll.add(connection->getSocket()->impl()->sockfd());
-        fiber = boost::context::fiber(std::allocator_arg_t(), fiber_stack, Routine{*this});
-    }
-
-    /// Resume packet receiving.
-    void resume()
-    {
-        /// If there is no pending data, check receive timeout.
-        if (!connection->hasReadPendingData() && !checkReceiveTimeout())
-            return;
-
-        fiber = std::move(fiber).resume();
-        if (exception)
-            std::rethrow_exception(std::move(exception));
-    }
-
-    void cancel()
-    {
-        Fiber to_destroy = std::move(fiber);
-        connection = nullptr;
-    }
-
-    Packet getPacket() { return std::move(packet); }
-
-    int getFileDescriptor() const { return epoll.getFileDescriptor(); }
-
-    bool isPacketReady() const { return !is_read_in_process; }
-
-    bool isReceiveTimeoutExpired() const { return is_receive_timeout_expired; }
-
-private:
-    /// When epoll file descriptor is ready, check if it's an expired timeout
-    bool checkReceiveTimeout()
-    {
-        bool is_socket_ready = false;
-        is_receive_timeout_expired = false;
-
-        epoll_event events[2];
-        events[0].data.fd = events[1].data.fd = -1;
-        size_t ready_count = epoll.getManyReady(2, events, true);
-
-        for (size_t i = 0; i != ready_count; ++i)
-        {
-            if (events[i].data.fd == connection->getSocket()->impl()->sockfd())
-                is_socket_ready = true;
-            if (events[i].data.fd == receive_timeout.getDescriptor())
-                is_receive_timeout_expired = true;
-        }
-
-        if (is_receive_timeout_expired && !is_socket_ready)
-        {
-            receive_timeout.reset();
-            return false;
-        }
-
-        return true;
-    }
-
-    struct Routine
-    {
-        PacketReceiver & receiver;
-
-        struct ReadCallback
-        {
-            PacketReceiver & receiver;
-            Fiber & sink;
-
-            void operator()(int, const Poco::Timespan & timeout, const std::string &)
-            {
-                receiver.receive_timeout.setRelative(timeout);
-                receiver.is_read_in_process = true;
-                sink = std::move(sink).resume();
-                receiver.is_read_in_process = false;
-                receiver.receive_timeout.reset();
-            }
-        };
-
-        Fiber operator()(Fiber && sink)
-        {
-            try
-            {
-                AsyncCallbackSetter async_setter(receiver.connection, ReadCallback{receiver, sink});
-                while (true)
-                {
-                    receiver.packet = receiver.connection->receivePacket();
-                    sink = std::move(sink).resume();
-                }
-
-            }
-            catch (const boost::context::detail::forced_unwind &)
-            {
-                /// This exception is thrown by fiber implementation in case if fiber is being deleted but hasn't exited
-                /// It should not be caught or it will segfault.
-                /// Other exceptions must be caught
-                throw;
-            }
-            catch (...)
-            {
-                receiver.exception = std::current_exception();
-            }
-
-            return std::move(sink);
-        }
-    };
-
-    Connection * connection;
-    TimerDescriptor receive_timeout;
-    Epoll epoll;
-    Fiber fiber;
-    FiberStack fiber_stack;
-    Packet packet;
-    bool is_read_in_process = false;
-    bool is_receive_timeout_expired = false;
-    std::exception_ptr exception;
-};
-
-}
-#endif