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
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
#include "bu/nids.h"
#include "bu/stream.h"
#include "bu/nidsstream.h"
#include <stdio.h>
Bu::Nids::Nids( Bu::Stream &sStore ) :
sStore( sStore )
{
printf("Stream caps:\n"
" canRead: %s\n"
" canWrite: %s\n"
" isReadable: %s\n"
" isWritable: %s\n"
" isSeekable: %s\n"
" isBlocking: %s\n"
" isEOS: %s\n"
" isOpen: %s\n",
sStore.canRead()?"yes":"no",
sStore.canWrite()?"yes":"no",
sStore.isReadable()?"yes":"no",
sStore.isWritable()?"yes":"no",
sStore.isSeekable()?"yes":"no",
sStore.isBlocking()?"yes":"no",
sStore.isEOS()?"yes":"no",
sStore.isOpen()?"yes":"no"
);
printf("sizeof(Block) = %db\n", sizeof(Block) );
}
Bu::Nids::~Nids()
{
}
void Bu::Nids::initialize( int iBlockSize, int iPreAllocate )
{
char cBuf = 0;
int iBuf = 0;
// Magic number
sStore.write( "\xFF\xC3\x99\xBD", 4 );
// Version (0)
sStore.write( &cBuf, 1 );
// Bytes per int
cBuf = 4;
sStore.write( &cBuf, 1 );
// The size of each block and the number of blocks we're pre-allocating
sStore.write( &iBlockSize, 4 );
sStore.write( &iPreAllocate, 4 );
// The number of used blocks
sStore.write( &iBuf, 4 );
// Reserved space
sStore.write( "\x00\x00\x00\x00\x00\x00\x00", 7 );
this->iBlockSize = iBlockSize;
this->iBlocks = iPreAllocate;
this->iBlockStart = sStore.tell();
bsBlockUsed.setSize( iPreAllocate, true );
printf("%d blocks, %db each, %db block offset\n",
iBlocks, iBlockSize, iBlockStart );
char *block = new char[iBlockSize];
memset( block, 0, iBlockSize );
for( int j = 0; j < iPreAllocate; j++ )
{
sStore.write( block, iBlockSize );
}
}
int Bu::Nids::createStream( int iPreAllocate )
{
for( int j = 0; j < iBlocks; j++ )
{
if( !bsBlockUsed.getBit( j ) )
{
Block b = { j, blockUnused, blockUnused, 0, 0 };
bsBlockUsed.setBit( j );
sStore.setPos( iBlockStart+(iBlockSize*j) );
sStore.write( &b, sizeof(b) );
}
}
return 0;
}
void Bu::Nids::deleteStream( int iID )
{
}
Bu::NidsStream Bu::Nids::openStream( int iID )
{
return NidsStream( *this );
}
void Bu::Nids::extendStream( int iID, int iBlockCount )
{
}
void Bu::Nids::getBlock( int iIndex, Bu::Nids::Block *pBlock )
{
sStore.setPos( iBlockStart + (iBlockSize*iIndex) );
sStore.read( pBlock, iBlockSize );
}
void Bu::Nids::setBlock( int iIndex, Bu::Nids::Block *pBlock )
{
sStore.setPos( iBlockStart + (iBlockSize*iIndex) );
sStore.write( pBlock, iBlockSize );
}
|
