Modernization Fixes & Updates to Default Values (#3)
This commit is contained in:
parent
445eddff68
commit
dcf64091b1
768 changed files with 10507 additions and 14196 deletions
|
|
@ -35,7 +35,7 @@ namespace Server
|
|||
|
||||
protected override int BufferSize => 512;
|
||||
|
||||
public int CommitTo(SequentialFileWriter dataFile, SequentialFileWriter indexFile, int typeCode, int serial)
|
||||
public int CommitTo(SequentialFileWriter dataFile, SequentialFileWriter indexFile, int typeCode, uint serial)
|
||||
{
|
||||
Flush();
|
||||
|
||||
|
|
|
|||
|
|
@ -81,7 +81,7 @@ namespace Server
|
|||
WaitHandle.WaitAll(
|
||||
Array.ConvertAll<Consumer, WaitHandle>(
|
||||
consumers,
|
||||
delegate(Consumer input) { return input.completionEvent; }
|
||||
input => input.completionEvent
|
||||
)
|
||||
);
|
||||
|
||||
|
|
|
|||
|
|
@ -73,11 +73,6 @@ namespace Server
|
|||
{
|
||||
IndexInfo info = _orderedIndexInfo[i];
|
||||
|
||||
int typeCode = info.typeCode;
|
||||
int serial = info.serial;
|
||||
int length = info.size;
|
||||
|
||||
|
||||
indexBuffer[0] = (byte)info.typeCode;
|
||||
indexBuffer[1] = (byte)(info.typeCode >> 8);
|
||||
indexBuffer[2] = (byte)(info.typeCode >> 16);
|
||||
|
|
@ -115,7 +110,7 @@ namespace Server
|
|||
{
|
||||
public int size;
|
||||
public int typeCode;
|
||||
public int serial;
|
||||
public uint serial;
|
||||
}
|
||||
}
|
||||
}
|
||||
Loading…
Add table
Add a link
Reference in a new issue