syncSnapshot.h

/*
 * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
 *
 * This program is free software: you can use, redistribute, and/or modify
 * it under the terms of the GNU Affero General Public License, version 3
 * or later ("AGPL"), as published by the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */

#ifndef _TD_LIBS_SYNC_SNAPSHOT_H
#define _TD_LIBS_SYNC_SNAPSHOT_H

#ifdef __cplusplus
extern "C" {
#endif

#include <stdint.h>
#include <stdio.h>
#include <stdlib.h>
#include "cJSON.h"
#include "syncInt.h"
#include "syncMessage.h"
#include "taosdef.h"

#define SYNC_SNAPSHOT_SEQ_INVALID -1
#define SYNC_SNAPSHOT_SEQ_FORCE_CLOSE -2
#define SYNC_SNAPSHOT_SEQ_BEGIN 0
#define SYNC_SNAPSHOT_SEQ_END 0x7FFFFFFF

#define SYNC_SNAPSHOT_RETRY_MS 5000

typedef struct SSyncSnapshotSender {
  bool       start;
  int32_t    seq;
  int32_t    ack;
  void      *pReader;
  void      *pCurrentBlock;
  int32_t    blockLen;
  SSnapshot  snapshot;
  int64_t    sendingMS;
  SSyncNode *pSyncNode;
  int32_t    replicaIndex;
  SyncTerm   term;
} SSyncSnapshotSender;

SSyncSnapshotSender *snapshotSenderCreate(SSyncNode *pSyncNode, int32_t replicaIndex);
void                 snapshotSenderDestroy(SSyncSnapshotSender *pSender);
void                 snapshotSenderStart(SSyncSnapshotSender *pSender);
void                 snapshotSenderStop(SSyncSnapshotSender *pSender);
int32_t              snapshotSend(SSyncSnapshotSender *pSender);
cJSON               *snapshotSender2Json(SSyncSnapshotSender *pSender);
char                *snapshotSender2Str(SSyncSnapshotSender *pSender);

typedef struct SSyncSnapshotReceiver {
  bool start;

  int32_t  ack;
  void    *pWriter;
  void    *pCurrentBlock;
  int32_t  blockLen;
  SyncTerm term;

  SSyncNode *pSyncNode;
  int32_t    replicaIndex;
} SSyncSnapshotReceiver;

SSyncSnapshotReceiver *snapshotReceiverCreate(SSyncNode *pSyncNode, int32_t replicaIndex);
void                   snapshotReceiverDestroy(SSyncSnapshotReceiver *pReceiver);
void                   snapshotReceiverStart(SSyncSnapshotReceiver *pReceiver);
void                   snapshotReceiverStop(SSyncSnapshotReceiver *pReceiver);
cJSON                 *snapshotReceiver2Json(SSyncSnapshotReceiver *pReceiver);
char                  *snapshotReceiver2Str(SSyncSnapshotReceiver *pReceiver);

int32_t syncNodeOnSnapshotSendCb(SSyncNode *ths, SyncSnapshotSend *pMsg);
int32_t syncNodeOnSnapshotRspCb(SSyncNode *ths, SyncSnapshotRsp *pMsg);

#ifdef __cplusplus
}
#endif

#endif /*_TD_LIBS_SYNC_SNAPSHOT_H*/