13 |
[System.ComponentModel.DesignerCategory("Code")] |
[System.ComponentModel.DesignerCategory("Code")] |
14 |
class PumpService : System.ServiceProcess.ServiceBase |
class PumpService : System.ServiceProcess.ServiceBase |
15 |
{ |
{ |
16 |
|
public const int SECONDS_BETWEEN_RUN = 10; |
17 |
const int INTERVAL = 5; |
const int INTERVAL = 5; |
18 |
TimeSpan m_delay = new TimeSpan(0, 0, 0, INTERVAL, 0); |
TimeSpan m_delay = new TimeSpan(0, 0, 0, INTERVAL, 0); |
19 |
|
|
20 |
private Thread m_thread = null; |
private Thread m_thread = null; |
21 |
private static ManualResetEvent m_shutdownEvent = new ManualResetEvent(false); |
private static ManualResetEvent m_shutdownEvent = new ManualResetEvent(false); |
22 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
23 |
FilterController filterController = null; |
FilterController filterController = null; |
24 |
|
|
|
|
|
|
ServiceHost selfHost; |
|
|
|
|
25 |
|
|
26 |
protected void InitializeComponent() |
protected void InitializeComponent() |
27 |
{ |
{ |
101 |
count ++; |
count ++; |
102 |
|
|
103 |
int elapsed = INTERVAL * count; |
int elapsed = INTERVAL * count; |
104 |
if (elapsed >= 30) // only run every 30th second |
if (elapsed >= SECONDS_BETWEEN_RUN) // only run every SECONDS_BETWEEN_RUN'th second |
105 |
{ |
{ |
106 |
filterController.transportAllMessages(); |
filterController.transportAllMessages(); |
107 |
count = 0;//reset counter |
count = 0;//reset counter |
125 |
|
|
126 |
|
|
127 |
} |
} |
|
|
|
|
public class GrantningAuthorizationManager : ServiceAuthorizationManager |
|
|
{ |
|
|
protected override bool CheckAccessCore(OperationContext operationContext) |
|
|
{ |
|
|
return true; |
|
|
} |
|
|
} |
|
128 |
} |
} |