[Acmcontester-developers] SF.net SVN: acmcontester:[374] ACMServer/trunk/ACMServer/Plugins/ MediatorPlugins/SocketServerGatePlugin/WorkingPool.cs

[<br...@us...>]

Revision: 374
          http://acmcontester.svn.sourceforge.net/acmcontester/?rev=374&view=rev
Author:   brus07
Date:     2008-09-25 07:49:52 +0000 (Thu, 25 Sep 2008)

Log Message:
-----------
Small refactoring

Modified Paths:
--------------
    ACMServer/trunk/ACMServer/Plugins/MediatorPlugins/SocketServerGatePlugin/WorkingPool.cs

Modified: ACMServer/trunk/ACMServer/Plugins/MediatorPlugins/SocketServerGatePlugin/WorkingPool.cs
===================================================================
--- ACMServer/trunk/ACMServer/Plugins/MediatorPlugins/SocketServerGatePlugin/WorkingPool.cs	2008-09-25 07:47:17 UTC (rev 373)
+++ ACMServer/trunk/ACMServer/Plugins/MediatorPlugins/SocketServerGatePlugin/WorkingPool.cs	2008-09-25 07:49:52 UTC (rev 374)
@@ -10,17 +10,17 @@
         internal delegate bool SebdDataDelegate(SystemMessage s);
         internal event SebdDataDelegate onSendData;
 
-
-        Dictionary<SystemMessage, object> poolWork = new Dictionary<SystemMessage, object>();
-        bool poolWorking = false;
-
         private bool OnSendData(SystemMessage sysMes)
         {
             if (onSendData != null)
                 return onSendData(sysMes);
+            //TODO: ne znaju sho same maje povertatysja u takomu vypadku
             return false;
         }
 
+        private Dictionary<SystemMessage, object> poolWork = new Dictionary<SystemMessage, object>();
+        private bool poolWorking = false;
+
         private void runPool()
         {
             if (poolWorking == true)
@@ -35,17 +35,17 @@
                         break;
                     foreach (SystemMessage sysMes in poolWork.Keys)
                     {
+                        //TODO: potribno zrobyty, shot pry posylci "poolWork" ne buv zalokanyj
                         if (OnSendData(sysMes) == true)
                         {
                             poolWork.Remove(sysMes);
-                            break;
                         }
                     }
                 }
             }
             poolWorking = false;
         }
-        private static void RunningPool(Object ob)
+        private static void StartPool(Object ob)
         {
             WorkingPool ssg = (WorkingPool)ob;
             ssg.runPool();
@@ -54,7 +54,7 @@
         {
             if (poolWorking == false)
             {
-                ThreadPool.QueueUserWorkItem(RunningPool, this);
+                ThreadPool.QueueUserWorkItem(StartPool, this);
             }
         }
 


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.