]> git.stg.codes - stg.git/blob - projects/stargazer/stg_timer.cpp
Ticket 37. In the if() construction for the changePolicyTimeout
[stg.git] / projects / stargazer / stg_timer.cpp
1 #include "stg_timer.h"
2
3 #include "stg/common.h"
4
5 #include <ctime>
6 #include <cstring>
7 #include <csignal>
8
9 #include <pthread.h>
10
11 void * StgTimer(void *);
12
13 static int nonstop;
14 static pthread_t thrStgTimer;
15 static bool isTimerRunning = false;
16 volatile time_t stgTime;
17
18 #ifdef STG_TIMER_DEBUG
19 const int TIME_SPEED = 1;
20 /*
21  1  - 1x  speed
22  2  - 2x  speed
23  5  - 5x  speed
24  10 - 10x speed
25  */
26
27 const int START_TIME = 2;
28 /*
29  0 - as is
30  1 - start before new day (3 min before)   29.11.2005 23:57:00
31  2 - start before new month (3 min before) 30.11.2005 23:57:00
32  */
33 #endif
34
35 //-----------------------------------------------------------------------------
36 void * StgTimer(void *)
37 {
38 #ifdef STG_TIMER_DEBUG
39 struct tm lt;
40 memset(&lt, 0, sizeof(lt));
41
42 lt.tm_year = 2016 - 1900; // 2005
43 lt.tm_mon  = 7 - 1;      // Nov
44 lt.tm_hour = 23;          // 23 h
45 lt.tm_min = 57;           // 50 min
46 lt.tm_sec = 0;            // 00 sec
47 lt.tm_isdst = -1;
48
49 switch (START_TIME)
50     {
51     case 0:
52         stgTime = time(NULL);
53         break;
54
55     case 1:
56         lt.tm_mday = 29;
57         stgTime = mktime(&lt);
58         break;
59
60     case 2:
61         lt.tm_mday = 31;
62         stgTime = mktime(&lt);
63         break;
64     }
65 #else
66 stgTime = time(NULL);
67 #endif
68
69 sigset_t signalSet;
70 sigfillset(&signalSet);
71 pthread_sigmask(SIG_BLOCK, &signalSet, NULL);
72
73 nonstop = 1;
74 isTimerRunning = true;
75 while (nonstop)
76     {
77     #ifdef STG_TIMER_DEBUG
78     struct timespec ts;
79     if (TIME_SPEED == 1)
80         {
81         ts.tv_sec = 1;
82         ts.tv_nsec = 0;
83         }
84     else
85         {
86         ts.tv_sec = 0;
87         ts.tv_nsec = 1000000000 / TIME_SPEED;
88         }
89     nanosleep(&ts, NULL);
90     stgTime++;
91     #else
92     struct timespec ts = {0, 500000000};
93     nanosleep(&ts, NULL);
94     stgTime = time(NULL);
95     #endif
96     }
97 isTimerRunning = false;
98
99 return NULL;
100 }
101 //-----------------------------------------------------------------------------
102 int RunStgTimer()
103 {
104 static int a = 0;
105 isTimerRunning = false;
106
107 if (a == 0)
108     if (pthread_create(&thrStgTimer, NULL, &StgTimer, NULL))
109         {
110         isTimerRunning = false;
111         return -1;
112         }
113
114 a = 1;
115 return 0;
116 }
117 //-----------------------------------------------------------------------------
118 void StopStgTimer()
119 {
120 nonstop = 0;
121 pthread_join(thrStgTimer, NULL); // Cleanup thread resources
122 printfd(__FILE__, "STG_TIMER stopped\n");
123 }
124 //-----------------------------------------------------------------------------
125 bool IsStgTimerRunning()
126 {
127 return isTimerRunning;
128 }
129 //-----------------------------------------------------------------------------
130 int stgUsleep(unsigned long t)
131 {
132 #ifdef STG_TIMER_DEBUG
133 struct timespec ts = {static_cast<time_t>((t / TIME_SPEED) / 1000000), static_cast<long>(((t / TIME_SPEED) % 1000000) * 1000)};
134 return nanosleep(&ts, NULL);
135 #else
136 struct timespec ts = {static_cast<time_t>(t / 1000000), static_cast<long>((t % 1000000) * 1000)};
137 return nanosleep(&ts, NULL);
138 #endif
139 }
140 //-----------------------------------------------------------------------------
141 void WaitTimer()
142 {
143     for (int i = 0; i < 5 && !isTimerRunning; i++)
144         stgUsleep(200000);
145 }
146 //-----------------------------------------------------------------------------