프로젝트

일반

사용자정보

통계
| 브랜치(Branch): | 개정판:

markus / ConvertService / ServiceBase / Markus.Service.Station / StationService / ServiceStationTask.cs @ 6f6e7dbf

이력 | 보기 | 이력해설 | 다운로드 (10.2 KB)

1 53c9637d taeseongkim
using Markus.Service.Interface;
2
using Markus.Message;
3
using System;
4
using System.Collections.Generic;
5
using System.Diagnostics;
6
using System.Linq;
7
using System.Text;
8
using System.Threading;
9
using System.Threading.Tasks;
10
using System.Management;
11
using static Markus.Service.Extensions.Encrypt;
12
using Markus.Service.Extensions;
13
using Markus.Service.Helper;
14
15
namespace Markus.Service
16
{
17
    /// <summary>
18
    /// 컨버터 큐 처리 
19
    /// </summary>
20
    public partial class ServiceStation
21
    {
22
        /// <summary>
23
        /// 컨버터 실행중인 item
24
        /// </summary>
25
        private static List<ConvertItem> AliveConvertQueue = new List<ConvertItem>();
26
27
        /// <summary>
28
        /// 컨버터 프로세스 실행
29
        /// </summary>
30
        /// <param name="convertitem"></param>
31
        public bool ConvertProcessStart(ConvertItem convertitem)
32
        {
33
            bool result = false;
34
            try
35
            {
36
           
37
                Process ConvertProcess = new Process();
38
39
                ProcessContext processSendData = new ProcessContext
40
                {
41
                    ConvertID = convertitem.ConvertID,
42
                    ConnectionString = MarkusDBConnectionString,
43
                    ServiceStationUri = gServiceHostAddress.ToString(),
44
                    OriginFilePath = convertitem.OriginfilePath,
45
                    SaveDirectory = convertitem.ConvertPath,
46
                    TempDirectory = DownloadTempFolder,
47 8feb21df taeseongkim
                    ReleaseWorkMemory = ReleaseWorkMemory,
48 53c9637d taeseongkim
                    MultiThreadMaxPages = MultiThreadMaxPages,
49
                    MinFontSize = MinFontSize,
50 2091a7e5 taeseongkim
                    SendStatusInterval = SaveStatusInterval,
51
                    UseResolution = UseResolution
52 53c9637d taeseongkim
                };
53
54
                var sendData = ObjectToBytesStringConvert.ObjectToBytesString(processSendData);
55
                
56
                ProcessStartInfo startInfo = new ProcessStartInfo
57
                {
58
                    UseShellExecute = false,
59
                    FileName = "Markus.Service.ConvertProcess.exe",
60
                    WindowStyle = ProcessWindowStyle.Hidden,
61
                    CreateNoWindow = true,
62
                    ErrorDialog = false,
63
                    RedirectStandardError = false,
64
                    Arguments = $"{convertitem.ConvertID.ToString()} {AESEncrypter.Encrypt(sendData)}"
65
                    //Arguments = $"{convertitem.ConvertID.ToString()} {convertitem.ProjectNumber} {AESEncrypter.Encrypt(MarkusDBConnectionString)} {gServiceHostAddress} {DownloadTempFolder} {MultiThreadMaxPages}"
66
                };
67
68
                ConvertProcess.StartInfo = startInfo;
69
                ConvertProcess.EnableRaisingEvents = false;
70
71
                System.Diagnostics.Debug.WriteLine("convert process run : " + startInfo.Arguments);
72
73
74
                if (ConvertProcess.Start())
75
                {
76
                    try
77
                    {
78
                        var processAffinity = ProcessorAffinityList.Except(AliveConvertQueue.Select(f => (long)f.ProcessorAffinity));
79
80
                        if (processAffinity.Count() > 0)
81
                        {
82
                            convertitem.ProcessorAffinity = processAffinity.First();
83
84
                            //int bitMask = 1 << (convertitem.ProcessorAffinity - 1);
85
                            //bitMask |= 1 << (anotherUserSelection - 1); / //  프로세스 두개 이상 선택
86
87
                            ConvertProcess.ProcessorAffinity = new IntPtr(convertitem.ProcessorAffinity);
88
89
                        }
90
                        else
91
                        {
92
                            // 모두 사용중일때 점유율이 작은 걸로 사용
93
                            var CurrentProcessAffinity = AliveConvertQueue.Select(f =>f.ProcessorAffinity).Distinct();
94
95
                            var affinity = CurrentProcessAffinity.Min();
96
97
                            convertitem.ProcessorAffinity = affinity;
98
                            ConvertProcess.ProcessorAffinity = new IntPtr(affinity);
99
                        }
100
                    }
101
                    catch (Exception ex)
102
                    {
103
                        System.Diagnostics.Debug.WriteLine(ex);
104
                    }
105
        
106
107
                    ServiceStation.AliveConvertQueue.Add(convertitem);
108
                    result = true;
109
                }
110
            }
111
            catch (Exception ex)
112
            {
113
                throw new Exception("ConvertThread " + $"{convertitem.ConvertID.ToString()} {convertitem.ProjectNumber} {AESEncrypter.Encrypt(MarkusDBConnectionString)} {gServiceHostAddress} {DownloadTempFolder} {MultiThreadMaxPages}", ex.InnerException);
114
            }
115
            finally
116
            {
117
                //GC.WaitForPendingFinalizers();
118
                //GC.Collect(2);
119
                //GC.Collect(2);
120
            }
121
122
            return result;
123
        }
124 0157b158 taeseongkim
    
125 53c9637d taeseongkim
        /// <summary>
126
        /// DB에 있는 대기중인 Item을 가져온다.
127
        /// </summary>
128
        public void setDataBaseWaitingList()
129
        {
130 0157b158 taeseongkim
            using (DataBase.ConvertDatabase database = new DataBase.ConvertDatabase(MarkusDBConnectionString))
131 53c9637d taeseongkim
            {
132 0157b158 taeseongkim
                var convertItems = database.GetWaitConvertItems(this.RunProjectList, StationServiceList.Sum(f=>f.Properties.PROCESS_COUNT));
133
134
                foreach (var convert in convertItems)
135 53c9637d taeseongkim
                {
136 0157b158 taeseongkim
                    if (convert.STATUS > (int)StatusCodeType.None)
137
                    {
138
                        database.SetCleanUpItem(convert.ID);
139
                    }
140
141
                    PassConvertItem(convert.PROJECT_NO, convert.ID);
142 53c9637d taeseongkim
                }
143
            }
144 0157b158 taeseongkim
        }
145 53c9637d taeseongkim
146 6f6e7dbf taeseongkim
        private void ReflashSubService()
147 0157b158 taeseongkim
        {
148 6f6e7dbf taeseongkim
            foreach (var subservice in StationServiceList)
149 0157b158 taeseongkim
            {
150
                try
151
                {
152 6f6e7dbf taeseongkim
                    var result = subservice.Service.AliveConvertList();
153 0157b158 taeseongkim
154 6f6e7dbf taeseongkim
                    subservice.ConvertItems = result.ToList();
155
                    subservice.AliveCount = result.Count();
156 0157b158 taeseongkim
                }
157
                catch (Exception ex)
158
                {
159 6f6e7dbf taeseongkim
                    logger.Error($"ReflashSubService error - Service ID : {subservice.Properties.ID} ", ex);
160
                }
161
            }
162
        }
163
164
        private void PassConvertItem(string ProjectNo,string ConvertID)
165
        {
166
167
            ReflashSubService();
168
169
            try
170
            {
171
172
                if (StationServiceList.SelectMany(x => x.ConvertItems).Count(c => c.ProjectNumber == ProjectNo && c.ConvertID == ConvertID) == 0)
173
                {
174
                    var station = StationServiceList.OrderBy(x => x.AliveCount).FirstOrDefault();
175
176
                    if (station != null)
177
                    {
178
                        var result = station.Service.ConvertAdd(ProjectNo, ConvertID);
179
                        logger.Info($"PassConvertItem - Service ID : {station.Properties.ID} ConvertID : {ConvertID}");
180
                    }
181 0157b158 taeseongkim
                }
182
            }
183 6f6e7dbf taeseongkim
            catch (Exception ex)
184
            {
185
                logger.Error($"setDataBaseWaitingList", ex);
186
            }
187 0157b158 taeseongkim
        }
188
189
        private void CleanUpItems()
190
        {
191 53c9637d taeseongkim
            using (DataBase.ConvertDatabase database = new DataBase.ConvertDatabase(MarkusDBConnectionString))
192
            {
193 0157b158 taeseongkim
                var items = database.GetConvertingItems(RunProjectList);
194 53c9637d taeseongkim
195 0157b158 taeseongkim
                List<StationService.ConvertItem> aliveItems = new List<StationService.ConvertItem>();
196
197
                foreach (var item in StationServiceList)
198 53c9637d taeseongkim
                {
199 0157b158 taeseongkim
                    try
200
                    {
201
                        aliveItems.AddRange(item.Service.AliveConvertList());
202
                    }
203
                    catch (Exception)
204 53c9637d taeseongkim
                    {
205
                    }
206
                }
207 0157b158 taeseongkim
208
                foreach (var item in items)
209 53c9637d taeseongkim
                {
210 0157b158 taeseongkim
                    if(aliveItems.Count(x=>x.ConvertID == item.ID) == 0)
211
                    {
212
                        database.SetCleanUpItem(item.ID);
213
                    }
214 53c9637d taeseongkim
                }
215
            }
216
        }
217
218 0157b158 taeseongkim
219 53c9637d taeseongkim
        public void Stopprocess()
220
        {
221
            var process = Process.GetProcessesByName("Markus.Service.ConvertProcess");
222
223
            for (int i = process.Count() - 1; i >= 0 ; i--)
224
            {
225
                try
226
                {
227
                    Console.WriteLine($"{i} Process Kill");
228
                    process[i].Kill();
229
                }
230
                catch (Exception ex)
231
                {
232
                    System.Diagnostics.Debug.WriteLine(ex.ToString());
233
                }
234
            }
235
        }
236
237
        /// <summary>
238
        /// finish가 호출되고 살아있는 프로세스라고 추정됨
239
        /// </summary>
240
        public void DeadLockProcessKill()
241
        {
242
            var process = Process.GetProcessesByName("Markus.Service.ConvertProcess");
243
244
            for (int i = process.Count() - 1; i >= 0; i--)
245
            {
246
                try
247
                {
248
                    var commandLines = process[i].Arguments().CommandLine;
249
250
                    if (commandLines.Count() > 0)
251
                    {
252
                        if (ServiceStation.AliveConvertQueue.Count(f => f.ConvertID == commandLines[0]) == 0)
253
                        {
254
                            process[i].Kill();
255
                        }
256
                    }
257
                }
258
                catch (Exception ex)
259
                {
260
                    System.Diagnostics.Debug.WriteLine(ex.ToString());
261
                }
262
            }
263
        }
264
265
        private void ConvertFinish(ConvertItem convertitem)
266
        {
267
            try
268
            {
269
                System.Diagnostics.Debug.WriteLine("Convert Finish : " + convertitem.ConvertID);
270
271
                System.Diagnostics.Debug.WriteLine("ServiceStation.AliveConvertQueue.Count() : " + ServiceStation.AliveConvertQueue.Count());
272
                
273
                ServiceStation.AliveConvertQueue.Remove(convertitem);
274
275
                System.Diagnostics.Debug.WriteLine("ServiceStation.AliveConvertQueue.Count() : " + ServiceStation.AliveConvertQueue.Count());
276
277 0157b158 taeseongkim
                //if (ServiceStation.AliveConvertQueue.Count() < MultiProcessCount)
278
                //{
279
                //    setDataBaseWaitingList();
280
                //}
281 53c9637d taeseongkim
            }
282
            catch (Exception ex)
283
            {
284
                logger.Error("ConvertFinish Error",ex);
285
            }
286
        }
287
    }
288
}