Commit 0713119d authored by Marc Gravell's avatar Marc Gravell

so apparently using inline schedulers is just a terrible idea

parent ed3e6e14
...@@ -86,7 +86,7 @@ private SocketManager(string name, bool useHighPrioritySocketThreads, int worker ...@@ -86,7 +86,7 @@ private SocketManager(string name, bool useHighPrioritySocketThreads, int worker
priority: useHighPrioritySocketThreads ? ThreadPriority.AboveNormal : ThreadPriority.Normal); priority: useHighPrioritySocketThreads ? ThreadPriority.AboveNormal : ThreadPriority.Normal);
SendPipeOptions = new PipeOptions( SendPipeOptions = new PipeOptions(
pool: defaultPipeOptions.Pool, pool: defaultPipeOptions.Pool,
readerScheduler: _schedulerPool, // copying from the outbound Pipe to the socket should happen on the worker, to release the lock ASAP readerScheduler: _schedulerPool,
writerScheduler: _schedulerPool, writerScheduler: _schedulerPool,
pauseWriterThreshold: defaultPipeOptions.PauseWriterThreshold, pauseWriterThreshold: defaultPipeOptions.PauseWriterThreshold,
resumeWriterThreshold: defaultPipeOptions.ResumeWriterThreshold, resumeWriterThreshold: defaultPipeOptions.ResumeWriterThreshold,
...@@ -94,7 +94,7 @@ private SocketManager(string name, bool useHighPrioritySocketThreads, int worker ...@@ -94,7 +94,7 @@ private SocketManager(string name, bool useHighPrioritySocketThreads, int worker
useSynchronizationContext: false); useSynchronizationContext: false);
ReceivePipeOptions = new PipeOptions( ReceivePipeOptions = new PipeOptions(
pool: defaultPipeOptions.Pool, pool: defaultPipeOptions.Pool,
readerScheduler: PipeScheduler.Inline, // let the IO thread stomp all over the place on the receives readerScheduler: _schedulerPool,
writerScheduler: _schedulerPool, writerScheduler: _schedulerPool,
pauseWriterThreshold: Receive_PauseWriterThreshold, pauseWriterThreshold: Receive_PauseWriterThreshold,
resumeWriterThreshold: Receive_ResumeWriterThreshold, resumeWriterThreshold: Receive_ResumeWriterThreshold,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment