2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
42#ifndef CORE_SOCKET_STREAM_LEGACY_SOCKETCONNECTION_H
43#define CORE_SOCKET_STREAM_LEGACY_SOCKETCONNECTION_H
45#include "core/socket/stream/SocketConnection.h"
46#include "core/socket/stream/legacy/SocketReader.h"
47#include "core/socket/stream/legacy/SocketWriter.h"
49#ifndef DOXYGEN_SHOULD_SKIP_THIS
55namespace core::socket::
stream::legacy {
57 template <
typename PhysicalSocketT>
58 class SocketConnection final
59 :
public core::socket::
stream::
65 using PhysicalSocket = PhysicalSocketT;
66 using SocketReader =
typename Super::SocketReader;
67 using SocketWriter =
typename Super::SocketWriter;
70 using SocketAddress =
typename Super::SocketAddress;
73 PhysicalSocket&& physicalSocket,
74 const std::function<
void(SocketConnection*)>& onDisconnect,
75 const std::string& configuredServer,
76 const SocketAddress& localAddress,
77 const SocketAddress& remoteAddress,
78 const utils::Timeval& readTimeout,
79 const utils::Timeval& writeTimeout,
80 std::size_t readBlockSize,
81 std::size_t writeBlockSize,
82 const utils::Timeval& terminateTimeout);
84 template <
typename PhysicalSocket,
typename Config>
87 template <
typename PhysicalSocket,
typename Config>
SocketConnection(const std::string &instanceName, PhysicalSocket &&physicalSocket, const std::function< void(SocketConnection *)> &onDisconnect, const std::string &configuredServer, const SocketAddress &localAddress, const SocketAddress &remoteAddress, const utils::Timeval &readTimeout, const utils::Timeval &writeTimeout, std::size_t readBlockSize, std::size_t writeBlockSize, const utils::Timeval &terminateTimeout)
int main(int argc, char *argv[])