This repository was archived by the owner on Apr 6, 2019. It is now read-only.
File tree 5 files changed +7
-2
lines changed
5 files changed +7
-2
lines changed Original file line number Diff line number Diff line change 22
22
23
23
#pragma once
24
24
25
+ #include < atomic>
26
+ #include < condition_variable>
25
27
#include < queue>
26
28
#include < vector>
27
29
28
30
#include < cpp_redis/misc/logger.hpp>
29
31
#include < cpp_redis/network/redis_connection.hpp>
30
- #include < tacopie/network/io_service.hpp>
31
32
32
33
namespace cpp_redis {
33
34
Original file line number Diff line number Diff line change 22
22
23
23
#pragma once
24
24
25
+ #include < atomic>
25
26
#include < functional>
26
27
#include < map>
27
28
#include < mutex>
Original file line number Diff line number Diff line change @@ -37,6 +37,7 @@ client::client(void)
37
37
38
38
client::client (const std::shared_ptr<network::tcp_client_iface>& tcp_client)
39
39
: m_client(tcp_client)
40
+ , m_sentinel(tcp_client)
40
41
, m_reconnecting(false )
41
42
, m_cancel(false )
42
43
, m_callbacks_running(0 ) {
Original file line number Diff line number Diff line change 24
24
#include < cpp_redis/misc/error.hpp>
25
25
#include < cpp_redis/misc/logger.hpp>
26
26
#include < cpp_redis/network/redis_connection.hpp>
27
- #include < tacopie/network/io_service.hpp>
28
27
29
28
namespace cpp_redis {
30
29
Original file line number Diff line number Diff line change 24
24
#include < cpp_redis/misc/error.hpp>
25
25
#include < cpp_redis/misc/logger.hpp>
26
26
27
+ #include < thread>
28
+
27
29
namespace cpp_redis {
28
30
29
31
#ifndef __CPP_REDIS_USE_CUSTOM_TCP_CLIENT
@@ -37,6 +39,7 @@ subscriber::subscriber(void)
37
39
38
40
subscriber::subscriber (const std::shared_ptr<network::tcp_client_iface>& tcp_client)
39
41
: m_client(tcp_client)
42
+ , m_sentinel(tcp_client)
40
43
, m_reconnecting(false )
41
44
, m_cancel(false )
42
45
, m_auth_reply_callback(nullptr ) {
You can’t perform that action at this time.
0 commit comments