mls

1. OnStart

1.1. MainThread

1.1.1. DAL.Instance.GetDBVersion()

1.1.2. m_writer = new DBWriterService(threadCount)

1.1.2.1. initiate services

1.1.2.1.1. m_incomeQueue = new Queue<AbsMsg>(); m_incomeEventQueue = new Queue<CIVEventLogEntry>(); m_OrphanMonitors = new OrphanMonitors();

1.1.2.2. OnStart = this.StartQAnalyze();

1.1.2.2.1. m_oTaskMonitor = new Task[m_threadCount];

1.1.2.2.2. Action<object> act = new Action<object>(QThread); this.HandleQ(threadID); this.HandleQEvent(); DAL.Instance.UpdConnStatus(evt.MonitorID, evt.Status);

1.1.3. sRawPath = ConfigManager.Instance["DriverRawPath"].ToString()

1.1.4. CreateFolderMons

1.1.5. new CollectorService(bUseAutoDisconnect, bSaveRaw, sRawPath);

1.1.5.1. OnStart: m_okeppAlive = new Task(new Action(KeepAliveThread));

1.1.5.1.1. string serverName = Environment.MachineName; m_statusLockIsFree.Reset(); DAL.Instance.UpdateKeepAliveAndGetRunStatus(serverName, 1);

1.1.5.2. m_oTaskMonitor = new Task(new Action(WorkThread));

1.1.5.2.1. this.ReloadMonitorList(cpyCurrStatus.DriversGroup); this.InitDrivers(cpyCurrStatus.DriversGroup); this.ConnectDrivers(true); this.ConnectDrivers(false);

1.1.5.3. OnStop:DisconnectDrivers(true);

1.1.6. m_collector.OnDataReady += Collector_OnDataReady; m_collector.OnMonitorInfo += Collector_OnMonitorInfo; m_collector.OnEventLog += Collector_OnEventLog;

1.1.6.1. Collector_OnEventLog m_writer.EnqueueEvent(info);

1.1.6.2. Collector_OnMonitorInfo DAL.Instance.UpdDriverMonitorInfo(info.DrvID, info.GetJson());

1.1.6.3. Collector_OnDataReady m_writer.Enqueue(msg);

2. TestDbPDFInsert

2.1. contents= C:\inetpub\wwwroot\civ\pdf\0_10Z1993649_34_201512101051_201512101051_201512102342.pdf

2.2. DAL.Instance.AddPDF(1, contents);

2.3. List<byte[]> res = DAL.Instance.GETPDF(1)

2.4. write res[i] to C:\inetpub\wwwroot\civ\pdf\1_{i}.pdf

3. TestMonitorSave

3.1. Add Nitor1 file monitor from @"C:\wa\CIV.MMS\DemoFiles\HP50\2016_8_4_12_33_byte.txt"

3.2. add Nitor2 tibbo HP50 monitor from "10.0.0.19"

3.3. Add Nitor3 file monitor from DEMO IP

4. OnStop

4.1. m_collector.StopService();

4.2. m_writer.StopService();