Lines Matching refs:pc

141     redisAsyncContext *pc; /* Hiredis context for Pub / Sub. */  member
936 link->pc = NULL; in createInstanceLink()
960 if (link->pc == c) link->pc = NULL; in instanceLinkCloseConnection()
1001 instanceLinkCloseConnection(link,link->pc); in releaseInstanceLink()
1072 if (match->link->pc != NULL) in sentinelUpdateSentinelAddressInAllMasters()
1073 instanceLinkCloseConnection(match->link,match->link->pc); in sentinelUpdateSentinelAddressInAllMasters()
1102 pubsub = (link->pc == c); in instanceLinkConnectionError()
1104 link->pc = NULL; in instanceLinkConnectionError()
1407 instanceLinkCloseConnection(ri->link,ri->link->pc); in sentinelResetMaster()
1936 if ((ri->flags & (SRI_MASTER|SRI_SLAVE)) && link->pc == NULL) { in sentinelReconnectInstance()
1937 link->pc = redisAsyncConnectBind(ri->addr->ip,ri->addr->port,NET_FIRST_BIND_ADDR); in sentinelReconnectInstance()
1938 if (link->pc->err) { in sentinelReconnectInstance()
1940 link->pc->errstr); in sentinelReconnectInstance()
1941 instanceLinkCloseConnection(link,link->pc); in sentinelReconnectInstance()
1946 link->pc->data = link; in sentinelReconnectInstance()
1947 redisAeAttach(server.el,link->pc); in sentinelReconnectInstance()
1948 redisAsyncSetConnectCallback(link->pc, in sentinelReconnectInstance()
1950 redisAsyncSetDisconnectCallback(link->pc, in sentinelReconnectInstance()
1952 sentinelSendAuthIfNeeded(ri,link->pc); in sentinelReconnectInstance()
1953 sentinelSetClientName(ri,link->pc,"pubsub"); in sentinelReconnectInstance()
1955 retval = redisAsyncCommand(link->pc, in sentinelReconnectInstance()
1961 instanceLinkCloseConnection(link,link->pc); in sentinelReconnectInstance()
1968 if (link->cc && (ri->flags & SRI_SENTINEL || link->pc)) in sentinelReconnectInstance()
3430 if (ri->link->pc && in sentinelCheckSubjectivelyDown()
3435 instanceLinkCloseConnection(ri->link,ri->link->pc); in sentinelCheckSubjectivelyDown()