Function cancelReplicationHandshake

src/replication.cpp:3868–3904

This function aborts a non blocking replication attempt if there is one * in progress, by canceling the non-blocking connect attempt or * the initial bulk transfer. * * If there was a replication handshake in progress 1 is returned and * the replication state (g_pserver->repl_state) set to REPL_STATE_CONNECT. * * Otherwise zero is returned and no operation is performed at all. */

 *
 * Otherwise zero is returned and no operation is performed at all. */
int cancelReplicationHandshake(redisMaster *mi, int reconnect) {
    if (mi->bulkreadBuffer != nullptr) {
        sdsfree(mi->bulkreadBuffer);
        mi->bulkreadBuffer = nullptr;
    }
    if (mi->parseState) {
        delete mi->parseState;
        mi->parseState = nullptr;
    }
    if (mi->bulkreadBuffer) {
        sdsfree(mi->bulkreadBuffer);
        mi->bulkreadBuffer = nullptr;
    }

    if (mi->repl_state == REPL_STATE_TRANSFER) {
        replicationAbortSyncTransfer(mi);
        mi->repl_state = REPL_STATE_CONNECT;
    } else if (mi->repl_state == REPL_STATE_CONNECTING ||
               slaveIsInHandshakeState(mi))
    {
        undoConnectWithMaster(mi);
        mi->repl_state = REPL_STATE_CONNECT;
    } else {
        return 0;
    }

    if (!reconnect || g_pserver->fActiveReplica)
        return 1;

    /* try to re-connect without waiting for replicationCron, this is needed
     * for the "diskless loading short read" test. */
    serverLog(LL_NOTICE,"Reconnecting to MASTER %s:%d after failure",
        mi->masterhost, mi->masterport);
    connectWithMaster(mi);

    return 1;
}

void disconnectMaster(redisMaster *mi)
{