@@ -41,11 +41,11 @@ RedisConnection::RedisConnection(const String& host, int port, const String& pat
4141RedisConnection::RedisConnection (boost::asio::io_context& io, String host, int port, String path, String username, String password,
4242 int db, bool useTls, bool insecure, String certPath, String keyPath, String caPath, String crlPath,
4343 String tlsProtocolmin, String cipherList, double connectTimeout, DebugInfo di, const RedisConnection::Ptr& parent)
44- : m_Host (std::move(host )), m_Port(port), m_Path( std::move(path) ), m_Username(std::move(username)), m_Password(std::move(password)),
44+ : m_Path (std::move(path )), m_Host( std::move(host)), m_Port(port ), m_Username(std::move(username)), m_Password(std::move(password)),
4545 m_DbIndex(db), m_CertPath(std::move(certPath)), m_KeyPath(std::move(keyPath)), m_Insecure(insecure),
4646 m_CaPath(std::move(caPath)), m_CrlPath(std::move(crlPath)), m_TlsProtocolmin(std::move(tlsProtocolmin)),
47- m_CipherList(std::move(cipherList)), m_ConnectTimeout(connectTimeout), m_DebugInfo(std::move(di)), m_Connecting( false ), m_Connected( false ),
48- m_Started (false ), m_Strand(io ), m_QueuedWrites(io), m_QueuedReads(io), m_LogStatsTimer(io), m_Parent(parent)
47+ m_CipherList(std::move(cipherList)), m_ConnectTimeout(connectTimeout), m_DebugInfo(std::move(di)), m_Strand(io ),
48+ m_Connecting (false ), m_Connected( false ), m_Started( false ), m_QueuedWrites(io), m_QueuedReads(io), m_LogStatsTimer(io), m_Parent(parent)
4949{
5050 if (useTls && m_Path.IsEmpty ()) {
5151 UpdateTLSContext ();
@@ -224,7 +224,7 @@ void RedisConnection::EnqueueCallback(const std::function<void(boost::asio::yiel
224224 auto ctime (Utility::GetTime ());
225225
226226 asio::post (m_Strand, [this , callback, priority, ctime]() {
227- m_Queues.Writes [priority].emplace (WriteQueueItem{nullptr , nullptr , nullptr , nullptr , callback, ctime});
227+ m_Queues.Writes [priority].emplace (WriteQueueItem{nullptr , nullptr , nullptr , nullptr , callback, ctime, QueryAffects{} });
228228 m_QueuedWrites.Set ();
229229 });
230230}
0 commit comments