registerthread.cs

监控系统

using System;
using System.Threading;
using MonitorSystem.BasicClass;

namespace MonitorSystem.MonitorInterface
{
	/// <summary>
	/// 用于平台向监控中心注册，并处理各监控节点的注册请求。
	/// </summary>
	public class RegisterThread
	{
		private Thread m_Thread;
		private bool m_Pause;
		private bool m_Exit;

		private ConfigFile m_ConfigFile;

		private MonitorSystem.BasicClass.SystemLog m_SysLog=new MonitorSystem.BasicClass.SystemLog();

		public RegisterThread()
		{
			m_Pause = false;
			m_Exit = false;	
		}
		
		public void Init(ref ConfigFile iCfgFile )
		{
			m_ConfigFile = iCfgFile;
		}

		public void Run()
		{
			while(true)
			{
				while(m_Pause)
				{
					try
					{
						Thread.Sleep(1000);
					}
					catch(Exception)
					{						
					}
					continue;
				}
				if(m_Exit)
				{
					break;
				}

				char[] headflag = new Char[]{'O','P','E','N','E','T'};
				try
				{
					MonitorPlatform interReg = new MonitorPlatform();
					InterRegNodePackage RegNode = new InterRegNodePackage();
					InterRegNodeRespPackage RegNodeResp = new InterRegNodeRespPackage();
					NodeRegRespPackage NodeRegResp = new NodeRegRespPackage();

					//interReg.ListenPort = m_ConfigFile.PlatformPort;
	
					//接受节点的注册
					interReg.ReceiveRegNode();
					if(RegNode.CommandID == 0x00000001)
					{	
						//中心的节点注册
						interReg.RegInit(headflag,208,0x10000002,'0',001,0,null);
						interReg.RegPlatformNode();
						if(RegNodeResp.iResult == 0 && RegNodeResp.CommandID == 0x70000002
							&& RegNodeResp.PacketType == 1)
						{
							interReg.RegInit(headflag,656,0x80000001,'1',001,0,null);
							NodeRegResp.Result = 0;
							interReg.SendRegNodeResp();
						}
						interReg.RegInit(headflag,656,0x80000001,'1',001,0,null);
						NodeRegResp.Result = 1;
						interReg.SendRegNodeResp();
					}
				}
				catch(Exception e)
				{
					string msg = String.Format("注册节点错误.{0}", e.Message);
					m_SysLog.WriteToSysLog(0,msg);
				}

				if(m_Exit)
				{
					break;
				}
				try
				{
					//规则链表遍历完毕，线程休眠一分钟
					Thread.Sleep(100);
				}
				catch(Exception)
				{						
				}
								
			}			
		}

		public void Startup()
		{ 				
			m_Thread = new Thread(new ThreadStart(this.Run));
			// Start the thread
			m_Pause = false;
			m_Exit = false;		
			m_Thread.Start();			
		}
		public void Join()
		{
			if(m_Thread != null)
			{
				m_Thread.Interrupt();
				m_Thread.Join();
			}
			else
			{
				return;
			}
		}
		public bool IsAlive()
		{
			if(m_Thread != null)
			{
				return m_Thread.IsAlive;
			}
			else
			{
				return false;
			}
		}
		public void Suspend()
		{
			if(m_Pause == false)
				m_Pause = true;
		}
		public void Resume()
		{
			if(m_Pause == true)
				m_Pause = false;		
		}
		public void SetExit()
		{
			if(m_Exit == false)
				m_Exit = true;		
		}
	}
}