58 lines
1.0 KiB
C++
58 lines
1.0 KiB
C++
// Matt Wells, Jan 2014
|
|
|
|
#ifndef GB_REBALANCE_H
|
|
#define GB_REBALANCE_H
|
|
|
|
#include "collnum_t.h"
|
|
#include "RdbList.h"
|
|
#include "Msg4Out.h"
|
|
#include "Msg5.h"
|
|
#include "SafeBuf.h"
|
|
#include <inttypes.h>
|
|
|
|
class Rebalance {
|
|
|
|
public:
|
|
|
|
Rebalance();
|
|
|
|
const char *getNeedsRebalance ( ) ;
|
|
void rebalanceLoop ( ) ;
|
|
void scanLoop ( ) ;
|
|
bool scanRdb ( ) ;
|
|
bool gotList ( ) ;
|
|
bool saveRebalanceFile ( ) ;
|
|
|
|
//bool m_inRebalanceLoop;
|
|
int32_t m_numForeignRecs;
|
|
int64_t m_rebalanceCount;
|
|
int64_t m_scannedCount;
|
|
|
|
int32_t m_rdbNum;
|
|
collnum_t m_collnum;
|
|
collnum_t m_lastCollnum;
|
|
class Rdb *m_lastRdb;
|
|
int32_t m_lastPercent;
|
|
char m_nextKey[MAX_KEY_BYTES];
|
|
char m_endKey[MAX_KEY_BYTES];
|
|
bool m_needsRebalanceValid;
|
|
char m_needsRebalance; // may be -1
|
|
bool m_warnedUser;
|
|
bool m_userApproved;
|
|
bool m_isScanning;
|
|
int32_t m_blocked;
|
|
bool m_allowSave;
|
|
|
|
bool m_registered;
|
|
RdbList m_list;
|
|
SafeBuf m_posMetaList;
|
|
SafeBuf m_negMetaList;
|
|
Msg4 m_msg4a;
|
|
Msg4 m_msg4b;
|
|
Msg5 m_msg5;
|
|
};
|
|
|
|
extern Rebalance g_rebalance;
|
|
|
|
#endif // GB_REBALANCE_H
|