]>
Commit | Line | Data |
---|---|---|
12471842 PL |
1 | /* |
2 | * This file is part of PowerDNS or dnsdist. | |
3 | * Copyright -- PowerDNS.COM B.V. and its contributors | |
4 | * | |
5 | * This program is free software; you can redistribute it and/or modify | |
6 | * it under the terms of version 2 of the GNU General Public License as | |
7 | * published by the Free Software Foundation. | |
8 | * | |
9 | * In addition, for the avoidance of any doubt, permission is granted to | |
10 | * link this program with OpenSSL and to (re)distribute the binaries | |
11 | * produced as the result of such linking. | |
12 | * | |
13 | * This program is distributed in the hope that it will be useful, | |
14 | * but WITHOUT ANY WARRANTY; without even the implied warranty of | |
15 | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |
16 | * GNU General Public License for more details. | |
17 | * | |
18 | * You should have received a copy of the GNU General Public License | |
19 | * along with this program; if not, write to the Free Software | |
20 | * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. | |
21 | */ | |
aa7929a3 RG |
22 | #pragma once |
23 | #include "config.h" | |
24 | ||
25 | #include <atomic> | |
26 | #include <condition_variable> | |
27 | #include <queue> | |
28 | #include <thread> | |
29 | ||
30 | #include "iputils.hh" | |
31 | ||
32 | class RemoteLogger | |
33 | { | |
34 | public: | |
35 | RemoteLogger(const ComboAddress& remote, uint16_t timeout=2, uint64_t maxQueuedEntries=100, uint8_t reconnectWaitTime=1); | |
36 | ~RemoteLogger(); | |
37 | void queueData(const std::string& data); | |
38 | std::string toString() | |
39 | { | |
40 | return d_remote.toStringWithPort(); | |
41 | } | |
42 | private: | |
43 | bool reconnect(); | |
44 | bool sendData(const char* buffer, size_t bufferSize); | |
45 | void worker(); | |
46 | ||
47 | std::queue<std::string> d_writeQueue; | |
48 | std::mutex d_writeMutex; | |
49 | std::condition_variable d_queueCond; | |
50 | ComboAddress d_remote; | |
51 | uint64_t d_maxQueuedEntries; | |
52 | int d_socket{-1}; | |
53 | uint16_t d_timeout; | |
54 | uint8_t d_reconnectWaitTime; | |
55 | std::thread d_thread; | |
56 | std::atomic<bool> d_exiting{false}; | |
57 | }; |