false,
hiredisSystemMock,
adapterMock,
- logger));
+ logger,
+ false));
}
~AsyncHiredisCommandDispatcherDisconnectedTest()
true,
hiredisSystemMock,
adapterMock,
- logger));
+ logger,
+ false));
}
~AsyncHiredisCommandDispatcherWithPermanentCommandCallbacksTest()
};
using AsyncHiredisCommandDispatcherDeathTest = AsyncHiredisCommandDispatcherConnectedTest;
+
+ class AsyncHiredisCommandDispatcherForSentinelTest: public AsyncHiredisCommandDispatcherBaseTest
+ {
+ public:
+ AsyncHiredisCommandDispatcherForSentinelTest()
+ {
+ InSequence dummy;
+ expectationsUntilConnect();
+ expectAdapterAttach();
+ expectRedisAsyncSetConnectCallback();
+ expectRedisAsyncSetDisconnectCallback();
+ dispatcher.reset(new AsyncHiredisCommandDispatcher(engineMock,
+ "host",
+ htons(6379U),
+ contentsBuilderMock,
+ true,
+ hiredisSystemMock,
+ adapterMock,
+ logger,
+ true));
+ }
+
+ ~AsyncHiredisCommandDispatcherForSentinelTest()
+ {
+ expectRedisAsyncFree();
+ }
+ };
}
TEST_F(AsyncHiredisCommandDispatcherDisconnectedTest, IsNotCopyable)
false,
hiredisSystemMock,
adapterMock,
- logger));
+ logger,
+ false));
expectDisarmConnectionRetryTimer();
}
false,
hiredisSystemMock,
adapterMock,
- logger));
+ logger,
+ false));
}
TEST_F(AsyncHiredisCommandDispatcherDisconnectedTest, FailedCommandListQueryArmsRetryTimer)
savedCb(&ac, &redisReplyBuilder.buildNilReply(), savedPd);
EXPECT_EXIT(savedCb(&ac, &redisReplyBuilder.buildNilReply(), savedPd), KilledBySignal(SIGABRT), "");
}
+
+TEST_F(AsyncHiredisCommandDispatcherForSentinelTest, CommandListInquiryIsNotSent)
+{
+ EXPECT_CALL(hiredisSystemMock, redisAsyncCommandArgv(_, _, _, _, _, _))
+ .Times(0);
+ connected(&ac, 0);
+}