platformcheckthread.cs

监控系统

using System;
using System.IO;
using System.Threading;
using MonitorSystem.BasicClass;
using MonitorSystem.LogFileModule;

namespace MonitorSystem.MonitorCenter
{
	/// <summary>
	/// PlatformCheckThread 的摘要说明。
	/// </summary>
	public class PlatformCheckThread
	{
		private Thread m_Thread;
		private bool m_Pause;
		private bool m_Exit;

		private RecordQueue m_queRecord;
		private SystemLog m_SysLog;
		private ConfigFile m_CfgFile;

		public PlatformCheckThread()
		{
			m_Pause = false;
			m_Exit = false;
			m_SysLog=new SystemLog();
		}



		public void Init(ref RecordQueue queRecord,ConfigFile iCfgFile)
		{
			m_queRecord = queRecord;
			m_CfgFile = iCfgFile;
		}

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

				try
				{
					//心跳检测间隔时间
					Thread.Sleep(m_CfgFile.PlatformCheckTimeSpan);
				}
				catch(Exception)
				{						
				}
				
				try
				{
					//检查节点监控日志是否上传
					for(int i=0; i<CenterService.m_bPlatformCheck.Length; i++)
					{
						if(CenterService.m_bPlatformCheck[i]==false)
						{
							LogFile logRecord = new LogFile();
							logRecord.iInterfaceAction = new int[1];
							logRecord.strInActionParam = new String[1];

							logRecord.strDateTime = System.DateTime.Now.ToString();
							logRecord.iPlatformID = Convert.ToInt32(m_CfgFile.PlatformID[i]);
							logRecord.iNodeID = -1;
							logRecord.iTypeID = 99;
							logRecord.iRuleID = 0;
							logRecord.strRuleName = "平台心跳检测";
							logRecord.strValue = "-1";
							logRecord.iStatus = 4;
							logRecord.iInterfaceAction[0] = 1;
							logRecord.strInActionParam[0] = "";

							//将记录入待处理记录队列
							this.m_queRecord.Enqueue(logRecord);

						}
							
						//将心跳检测参数设为初始值
						CenterService.m_bPlatformCheck[i] = false;

					}
				}
				catch(Exception ex)
				{
					string msg=String.Format("平台心跳检查失败：{0}",ex.Message);
					m_SysLog.WriteToSysLog(msg);
				}
				if(m_Exit)
				{
					break;
				}
			}
		}

		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;		
		}
	}
}