library/cpp/actors/interconnect/poller_tcp.h


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

#pragma once

#include "poller_tcp_unit.h"
#include "poller.h"

#include <util/generic/vector.h>
#include <util/generic/hash.h>

namespace NInterconnect {
    class TPollerThreads: public NActors::IPoller { 
    public: 
        TPollerThreads(size_t units = 1U, bool useSelect = false); 
        ~TPollerThreads(); 

        void Start(); 
        void Stop(); 

        void StartRead(const TIntrusivePtr<TSharedDescriptor>& s, TFDDelegate&& operation) override; 
        void StartWrite(const TIntrusivePtr<TSharedDescriptor>& s, TFDDelegate&& operation) override; 

    private: 
        TVector<TPollerUnit::TPtr> Units; 
    }; 

}