Lines Matching refs:cc
140 redisAsyncContext *cc; /* Hiredis context for commands. */ member
935 link->cc = NULL; in createInstanceLink()
956 if (link->cc == c) { in instanceLinkCloseConnection()
957 link->cc = NULL; in instanceLinkCloseConnection()
979 if (ri && ri->link->cc) { in releaseInstanceLink()
986 redisCallbackList *callbacks = &link->cc->replies; in releaseInstanceLink()
1000 instanceLinkCloseConnection(link,link->cc); in releaseInstanceLink()
1070 if (match->link->cc != NULL) in sentinelUpdateSentinelAddressInAllMasters()
1071 instanceLinkCloseConnection(match->link,match->link->cc); in sentinelUpdateSentinelAddressInAllMasters()
1106 link->cc = NULL; in instanceLinkConnectionError()
1406 instanceLinkCloseConnection(ri->link,ri->link->cc); in sentinelResetMaster()
1913 if (link->cc == NULL) { in sentinelReconnectInstance()
1914 link->cc = redisAsyncConnectBind(ri->addr->ip,ri->addr->port,NET_FIRST_BIND_ADDR); in sentinelReconnectInstance()
1915 if (link->cc->err) { in sentinelReconnectInstance()
1917 link->cc->errstr); in sentinelReconnectInstance()
1918 instanceLinkCloseConnection(link,link->cc); in sentinelReconnectInstance()
1922 link->cc->data = link; in sentinelReconnectInstance()
1923 redisAeAttach(server.el,link->cc); in sentinelReconnectInstance()
1924 redisAsyncSetConnectCallback(link->cc, in sentinelReconnectInstance()
1926 redisAsyncSetDisconnectCallback(link->cc, in sentinelReconnectInstance()
1928 sentinelSendAuthIfNeeded(ri,link->cc); in sentinelReconnectInstance()
1929 sentinelSetClientName(ri,link->cc,"cmd"); in sentinelReconnectInstance()
1968 if (link->cc && (ri->flags & SRI_SENTINEL || link->pc)) in sentinelReconnectInstance()
2289 if (redisAsyncCommand(ri->link->cc, in sentinelPingReplyCallback()
2481 if (anetSockName(ri->link->cc->c.fd,ip,sizeof(ip),NULL) == -1) in sentinelSendHello()
2497 retval = redisAsyncCommand(ri->link->cc, in sentinelSendHello()
2543 int retval = redisAsyncCommand(ri->link->cc, in sentinelSendPing()
2607 retval = redisAsyncCommand(ri->link->cc, in sentinelSendPeriodicCommands()
3413 if (ri->link->cc && in sentinelCheckSubjectivelyDown()
3422 instanceLinkCloseConnection(ri->link,ri->link->cc); in sentinelCheckSubjectivelyDown()
3582 retval = redisAsyncCommand(ri->link->cc, in sentinelAskMasterStateToOtherSentinels()
3762 retval = redisAsyncCommand(ri->link->cc, in sentinelSendSlaveOf()
3767 retval = redisAsyncCommand(ri->link->cc, in sentinelSendSlaveOf()
3772 retval = redisAsyncCommand(ri->link->cc, in sentinelSendSlaveOf()
3782 retval = redisAsyncCommand(ri->link->cc, in sentinelSendSlaveOf()
3787 retval = redisAsyncCommand(ri->link->cc, in sentinelSendSlaveOf()