queue/version.cpp at master · oceanwavewyt/queue · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
#include "version.h"
#include "file_env.h"

namespace levelque {
Version *Version::instance_ = NULL;

Version::Version():blockid_(1),interid_(1),filelist_(NULL){

}
Version::~Version(){

}

void Version::SetFilelist(FixFile *f)
{
	filelist_ = f;
}

void Version::Init(uint32_t blockid, uint32_t interid)
{
	blockid_ = blockid;
	interid_ = interid;
}

Version* Version::Instance()
{
	if(instance_) return instance_;
	instance_ = new Version();
	return instance_;
}


void Version::SetBlockId(uint32_t id)
{
	if(blockid_ != id) {
		interid_ = 1;
		if(filelist_) {
			filelist_->SetWriteInterid(interid_);
		}
	}
	blockid_ = id;
	if(filelist_) {
		filelist_->SetWriteBlock(blockid_);
	}
}

void Version::SetBlockId()
{
	blockid_++;
	cout << "SetBlockId: "<< blockid_ << endl;
	interid_ = 1;
	//if(filelist_) {

		filelist_->SetWriteBlock(blockid_);
		filelist_->SetWriteInterid(interid_);
	//}
}

void Version::SetBlockInterId()
{
	interid_++;
	if(filelist_) {
		filelist_->SetWriteInterid(interid_);
	}
}

uint32_t Version::GetBlockId()
{
	return blockid_;
}
uint32_t Version::GetInterId()
{
	interid_++;
	if(filelist_) {
		filelist_->SetWriteInterid(interid_);
	}
	return interid_;
}

void Version::SetBlockOffset(uint64_t offset)
{
	filelist_->SetWriteOffset(offset);
}

}