Commit 24c55768 authored by Marc Gravell's avatar Marc Gravell

damn, wrong state object!

parent 246603c9
...@@ -248,7 +248,7 @@ private void ReadImpl() ...@@ -248,7 +248,7 @@ private void ReadImpl()
var obj = new QueueDrainSyncLock(this); var obj = new QueueDrainSyncLock(this);
lock (obj) lock (obj)
{ {
ThreadPool.QueueUserWorkItem(HelpProcessItems, this); ThreadPool.QueueUserWorkItem(HelpProcessItems, obj);
ProcessItems(); ProcessItems();
if (!obj.Consume()) if (!obj.Consume())
{ // then our worker arrived and picked up work; we need { // then our worker arrived and picked up work; we need
...@@ -325,8 +325,8 @@ internal void Shutdown(SocketToken token) ...@@ -325,8 +325,8 @@ internal void Shutdown(SocketToken token)
static readonly WaitCallback HelpProcessItems = state => static readonly WaitCallback HelpProcessItems = state =>
{ {
QueueDrainSyncLock qdsl = (QueueDrainSyncLock)state; var qdsl = state as QueueDrainSyncLock;
if (qdsl.Consume()) if (qdsl != null && qdsl.Consume())
{ {
var mgr = qdsl.Manager; var mgr = qdsl.Manager;
mgr.ProcessItems(); mgr.ProcessItems();
......
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