masterserver

type ChunkServerChan struct {
	// contains filtered or unexported fields
}

type ChunkServerInfo struct {
	ChunkHandle []string
	Used        []uint32
	Name        string
}

type ClientInfo struct {
	Token string
	UUID  string

	// TODO: Save previous response
	GetTokenResp *pb.GetTokenResp
}

type HandleMetaData struct {
	// unique chunk handle of the chunk
	ChunkHandle string

	// the IP address of Primary chunk server of the chunk
	PrimaryChunkServer string

	// IP address of backup chunk server for this chunk
	BackupAddress []string

	// Already used size in bytes
	Used uint

	FileName string
}

type MasterServer struct {
	pb.UnimplementedMasterServer

	FileMutex            sync.Mutex
	CSToHandleMutex      sync.Mutex
	ChunkServerLoadMutex sync.Mutex

	// a mapping from File name to A slice of HandleMetaData
	Files map[string][]*HandleMetaData

	// a mapping from chunk handle to HandleMetaData
	HandleToMeta map[string]*HandleMetaData

	// a map from the unique Token(Host:Port) of ChunkServer to its Used (sort on value Used)
	ChunkServerLoad map[string]uint

	// a mapping from ChunkServer to all HandleMetaData it has
	CSToHandle map[string][]*HandleMetaData

	// a map record hearbeat channel
	HeartBeatMap map[string]*ChunkServerChan

	// globally unique server name
	ServerName string

	// base directory to store chunk files
	BasePath string

	HBMutex sync.Mutex

	CSRegisterMutex sync.Mutex

	DB *redis.Client

	AppendFileMutex sync.Mutex
}

type Pair struct {
	// contains filtered or unexported fields
}

type SnapshotTimer struct {
	DB       *redis.Client
	Interval int
	Srv      *MasterServer
}