Removes implicit this.
This commit is contained in:
parent
04b4cfe75b
commit
83dcf536d8
533 changed files with 2804 additions and 2806 deletions
|
|
@ -28,7 +28,7 @@ namespace Server {
|
|||
|
||||
public BinaryMemoryWriter()
|
||||
: base( new MemoryStream( 512 ), true ) {
|
||||
this.stream = this.UnderlyingStream as MemoryStream;
|
||||
stream = UnderlyingStream as MemoryStream;
|
||||
}
|
||||
|
||||
private static byte[] indexBuffer;
|
||||
|
|
|
|||
|
|
@ -29,7 +29,7 @@ namespace Server {
|
|||
|
||||
public override void Save( SaveMetrics metrics, bool permitBackgroundWrite )
|
||||
{
|
||||
this.PermitBackgroundWrite = permitBackgroundWrite;
|
||||
PermitBackgroundWrite = permitBackgroundWrite;
|
||||
|
||||
Thread saveThread = new Thread( delegate() {
|
||||
SaveItems(metrics);
|
||||
|
|
|
|||
|
|
@ -53,7 +53,7 @@ namespace Server
|
|||
|
||||
public override void Save(SaveMetrics metrics, bool permitBackgroundWrite)
|
||||
{
|
||||
this._metrics = metrics;
|
||||
_metrics = metrics;
|
||||
|
||||
OpenFiles();
|
||||
|
||||
|
|
|
|||
|
|
@ -51,7 +51,7 @@ namespace Server {
|
|||
}
|
||||
|
||||
public void Commit() {
|
||||
owner.Commit( this, this.slot );
|
||||
owner.Commit( this, slot );
|
||||
}
|
||||
}
|
||||
|
||||
|
|
@ -93,14 +93,14 @@ namespace Server {
|
|||
throw new ArgumentNullException( "callback" );
|
||||
}
|
||||
|
||||
this.syncRoot = new object();
|
||||
syncRoot = new object();
|
||||
|
||||
this.active = new Chunk[concurrentWrites];
|
||||
this.pending = new Queue<Page>();
|
||||
active = new Chunk[concurrentWrites];
|
||||
pending = new Queue<Page>();
|
||||
|
||||
this.callback = callback;
|
||||
|
||||
this.idle = new ManualResetEvent( true );
|
||||
idle = new ManualResetEvent( true );
|
||||
}
|
||||
|
||||
private void Append( Page page ) {
|
||||
|
|
|
|||
|
|
@ -282,13 +282,13 @@ namespace Server {
|
|||
public Consumer( ParallelSaveStrategy owner, int bufferSize ) {
|
||||
this.owner = owner;
|
||||
|
||||
this.buffer = new ConsumableEntry[bufferSize];
|
||||
buffer = new ConsumableEntry[bufferSize];
|
||||
|
||||
for ( int i = 0; i < this.buffer.Length; ++i ) {
|
||||
this.buffer[i].writer = new BinaryMemoryWriter();
|
||||
for ( int i = 0; i < buffer.Length; ++i ) {
|
||||
buffer[i].writer = new BinaryMemoryWriter();
|
||||
}
|
||||
|
||||
this.completionEvent = new ManualResetEvent( false );
|
||||
completionEvent = new ManualResetEvent( false );
|
||||
|
||||
thread = new Thread( Processor );
|
||||
|
||||
|
|
|
|||
|
|
@ -40,7 +40,7 @@ namespace Server
|
|||
public QueuedMemoryWriter()
|
||||
: base(new MemoryStream(1024 * 1024), true)
|
||||
{
|
||||
this._memStream = this.UnderlyingStream as MemoryStream;
|
||||
_memStream = UnderlyingStream as MemoryStream;
|
||||
}
|
||||
|
||||
public void QueueForIndex(ISerializable serializable, int size)
|
||||
|
|
@ -57,7 +57,7 @@ namespace Server
|
|||
|
||||
public void CommitTo(SequentialFileWriter dataFile, SequentialFileWriter indexFile)
|
||||
{
|
||||
this.Flush();
|
||||
Flush();
|
||||
|
||||
int memLength = (int)_memStream.Position;
|
||||
|
||||
|
|
@ -115,7 +115,7 @@ namespace Server
|
|||
}
|
||||
}
|
||||
|
||||
this.Close(); //We're done with this writer.
|
||||
Close(); //We're done with this writer.
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -37,7 +37,7 @@ namespace Server {
|
|||
|
||||
this.metrics = metrics;
|
||||
|
||||
this.fileStream = FileOperations.OpenSequentialStream( path, FileMode.Create, FileAccess.Write, FileShare.None );
|
||||
fileStream = FileOperations.OpenSequentialStream( path, FileMode.Create, FileAccess.Write, FileShare.None );
|
||||
|
||||
fileQueue = new FileQueue(
|
||||
Math.Max( 1, FileOperations.Concurrency ),
|
||||
|
|
@ -61,7 +61,7 @@ namespace Server {
|
|||
chunk.Commit();
|
||||
} else {
|
||||
if ( writeCallback == null ) {
|
||||
writeCallback = this.OnWrite;
|
||||
writeCallback = OnWrite;
|
||||
}
|
||||
|
||||
fileStream.BeginWrite( chunk.Buffer, chunk.Offset, chunk.Size, writeCallback, chunk );
|
||||
|
|
@ -109,7 +109,7 @@ namespace Server {
|
|||
|
||||
public override bool CanWrite => true;
|
||||
|
||||
public override long Length => this.Position;
|
||||
public override long Length => Position;
|
||||
|
||||
public override int Read( byte[] buffer, int offset, int count ) {
|
||||
throw new InvalidOperationException();
|
||||
|
|
|
|||
|
|
@ -45,7 +45,7 @@ namespace Server {
|
|||
set => _permitBackgroundWrite = value;
|
||||
}
|
||||
|
||||
protected bool UseSequentialWriters => (StandardSaveStrategy.SaveType == SaveOption.Normal || !_permitBackgroundWrite);
|
||||
protected bool UseSequentialWriters => (SaveType == SaveOption.Normal || !_permitBackgroundWrite);
|
||||
|
||||
public override void Save(SaveMetrics metrics, bool permitBackgroundWrite)
|
||||
{
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue