author | sandman <sandman> | 2002-12-10 22:15:30 (UTC) |
---|---|---|
committer | sandman <sandman> | 2002-12-10 22:15:30 (UTC) |
commit | 2173e57fcbd5d460fceb34a111845389dca56506 (patch) (unidiff) | |
tree | 462b451f7c75e3960472468c55ae0037595d1af1 | |
parent | 51f44c6a22971d6f60f5e36523d9efbeaa8aec55 (diff) | |
download | opie-2173e57fcbd5d460fceb34a111845389dca56506.zip opie-2173e57fcbd5d460fceb34a111845389dca56506.tar.gz opie-2173e57fcbd5d460fceb34a111845389dca56506.tar.bz2 |
don't use atd anymore - our atd is only simple shell script, so better get
rid of it.
-rw-r--r-- | library/alarmserver.cpp | 91 |
1 files changed, 74 insertions, 17 deletions
diff --git a/library/alarmserver.cpp b/library/alarmserver.cpp index 5e4dd18..2ea4025 100644 --- a/library/alarmserver.cpp +++ b/library/alarmserver.cpp | |||
@@ -38,7 +38,12 @@ | |||
38 | #include <stdlib.h> | 38 | #include <stdlib.h> |
39 | #include <unistd.h> | 39 | #include <unistd.h> |
40 | 40 | ||
41 | struct timerEventItem { | 41 | |
42 | #undef USE_ATD // not used anymore -- we run opie-alarm on suspend/resume | ||
43 | |||
44 | |||
45 | struct timerEventItem | ||
46 | { | ||
42 | time_t UTCtime; | 47 | time_t UTCtime; |
43 | QCString channel, message; | 48 | QCString channel, message; |
44 | int data; | 49 | int data; |
@@ -54,15 +59,20 @@ struct timerEventItem { | |||
54 | class TimerReceiverObject : public QObject | 59 | class TimerReceiverObject : public QObject |
55 | { | 60 | { |
56 | public: | 61 | public: |
57 | TimerReceiverObject() { } | 62 | TimerReceiverObject() |
58 | ~TimerReceiverObject() { } | 63 | { } |
64 | ~TimerReceiverObject() | ||
65 | { } | ||
59 | void resetTimer(); | 66 | void resetTimer(); |
60 | void setTimerEventItem(); | 67 | void setTimerEventItem(); |
61 | void deleteTimer(); | 68 | void deleteTimer(); |
62 | protected: | 69 | protected: |
63 | void timerEvent( QTimerEvent *te ); | 70 | void timerEvent( QTimerEvent *te ); |
71 | |||
72 | #ifdef USE_ATD | ||
64 | private: | 73 | private: |
65 | QString atfilename; | 74 | QString atfilename; |
75 | #endif | ||
66 | }; | 76 | }; |
67 | 77 | ||
68 | TimerReceiverObject *timerEventReceiver = NULL; | 78 | TimerReceiverObject *timerEventReceiver = NULL; |
@@ -115,7 +125,8 @@ static void saveState() | |||
115 | 125 | ||
116 | savefile.close(); | 126 | savefile.close(); |
117 | unlink( savefilename ); | 127 | unlink( savefilename ); |
118 | QDir d; d.rename(savefilename+".new",savefilename); | 128 | QDir d; |
129 | d.rename(savefilename + ".new", savefilename); | ||
119 | 130 | ||
120 | } | 131 | } |
121 | } | 132 | } |
@@ -148,7 +159,7 @@ void AlarmServer::initialize() | |||
148 | } | 159 | } |
149 | 160 | ||
150 | 161 | ||
151 | 162 | #ifdef USE_ATD | |
152 | 163 | ||
153 | static const char* atdir = "/var/spool/at/"; | 164 | static const char* atdir = "/var/spool/at/"; |
154 | 165 | ||
@@ -160,7 +171,8 @@ static bool triggerAtd( bool writeHWClock = FALSE ) | |||
160 | QMessageBox::critical( 0, QObject::tr( "Out of Space" ), | 171 | QMessageBox::critical( 0, QObject::tr( "Out of Space" ), |
161 | QObject::tr( "Unable to schedule alarm.\nFree some memory and try again." ) ); | 172 | QObject::tr( "Unable to schedule alarm.\nFree some memory and try again." ) ); |
162 | trigger.close(); | 173 | trigger.close(); |
163 | QFile::remove( trigger.name() ); | 174 | QFile::remove |
175 | ( trigger.name() ); | ||
164 | return FALSE; | 176 | return FALSE; |
165 | } | 177 | } |
166 | return TRUE; | 178 | return TRUE; |
@@ -168,19 +180,40 @@ static bool triggerAtd( bool writeHWClock = FALSE ) | |||
168 | return FALSE; | 180 | return FALSE; |
169 | } | 181 | } |
170 | 182 | ||
183 | #else | ||
184 | |||
185 | static bool writeResumeAt ( time_t wakeup ) | ||
186 | { | ||
187 | FILE *fp = ::fopen ( "/var/run/resumeat", "w" ); | ||
188 | |||
189 | if ( fp ) { | ||
190 | ::fprintf ( fp, "%d\n", (int) wakeup ); | ||
191 | ::fclose ( fp ); | ||
192 | } | ||
193 | else | ||
194 | qWarning ( "Failed to write wakeup time to /var/run/resumeat" ); | ||
195 | |||
196 | return ( fp ); | ||
197 | } | ||
198 | |||
199 | #endif | ||
200 | |||
171 | void TimerReceiverObject::deleteTimer() | 201 | void TimerReceiverObject::deleteTimer() |
172 | { | 202 | { |
203 | #ifdef USE_ATD | ||
173 | if ( !atfilename.isEmpty() ) { | 204 | if ( !atfilename.isEmpty() ) { |
174 | unlink( atfilename ); | 205 | unlink( atfilename ); |
175 | atfilename = QString::null; | 206 | atfilename = QString::null; |
176 | triggerAtd( FALSE ); | 207 | triggerAtd( FALSE ); |
177 | } | 208 | } |
209 | #else | ||
210 | writeResumeAt ( 0 ); | ||
211 | #endif | ||
178 | } | 212 | } |
179 | 213 | ||
180 | void TimerReceiverObject::resetTimer() | 214 | void TimerReceiverObject::resetTimer() |
181 | { | 215 | { |
182 | const int maxsecs = 2147000; | 216 | const int maxsecs = 2147000; |
183 | int total_written; | ||
184 | QDateTime nearest = TimeConversion::fromUTC(nearestTimerEvent->UTCtime); | 217 | QDateTime nearest = TimeConversion::fromUTC(nearestTimerEvent->UTCtime); |
185 | QDateTime now = QDateTime::currentDateTime(); | 218 | QDateTime now = QDateTime::currentDateTime(); |
186 | if ( nearest < now ) | 219 | if ( nearest < now ) |
@@ -196,11 +229,16 @@ void TimerReceiverObject::resetTimer() | |||
196 | // | 229 | // |
197 | int at_secs = TimeConversion::toUTC(nearest); | 230 | int at_secs = TimeConversion::toUTC(nearest); |
198 | // qDebug("reset timer to %d seconds from Epoch",at_secs); | 231 | // qDebug("reset timer to %d seconds from Epoch",at_secs); |
232 | |||
233 | #ifdef USE_ATD | ||
234 | |||
199 | QString fn = atdir + QString::number(at_secs) + "." | 235 | QString fn = atdir + QString::number(at_secs) + "." |
200 | + QString::number(getpid()); | 236 | + QString::number(getpid()); |
201 | if ( fn != atfilename ) { | 237 | if ( fn != atfilename ) { |
202 | QFile atfile(fn+".new"); | 238 | QFile atfile(fn+".new"); |
203 | if ( atfile.open(IO_WriteOnly|IO_Raw) ) { | 239 | if ( atfile.open(IO_WriteOnly|IO_Raw) ) { |
240 | int total_written; | ||
241 | |||
204 | // just wake up and delete the at file | 242 | // just wake up and delete the at file |
205 | QString cmd = "#!/bin/sh\nrm " + fn; | 243 | QString cmd = "#!/bin/sh\nrm " + fn; |
206 | total_written = atfile.writeBlock(cmd.latin1(),cmd.length()); | 244 | total_written = atfile.writeBlock(cmd.latin1(),cmd.length()); |
@@ -209,19 +247,27 @@ void TimerReceiverObject::resetTimer() | |||
209 | tr("Unable to schedule alarm.\n" | 247 | tr("Unable to schedule alarm.\n" |
210 | "Please free up space and try again") ); | 248 | "Please free up space and try again") ); |
211 | atfile.close(); | 249 | atfile.close(); |
212 | QFile::remove( atfile.name() ); | 250 | QFile::remove |
251 | ( atfile.name() ); | ||
213 | return; | 252 | return; |
214 | } | 253 | } |
215 | atfile.close(); | 254 | atfile.close(); |
216 | unlink( atfilename ); | 255 | unlink( atfilename ); |
217 | QDir d; d.rename(fn+".new",fn); | 256 | QDir d; |
257 | d.rename(fn + ".new", fn); | ||
218 | chmod(fn.latin1(),0755); | 258 | chmod(fn.latin1(),0755); |
219 | atfilename = fn; | 259 | atfilename = fn; |
220 | triggerAtd( FALSE ); | 260 | triggerAtd( FALSE ); |
221 | } else { | 261 | } |
262 | else { | ||
222 | qWarning("Cannot open atd file %s",fn.latin1()); | 263 | qWarning("Cannot open atd file %s",fn.latin1()); |
223 | } | 264 | } |
224 | } | 265 | } |
266 | #else | ||
267 | writeResumeAt ( at_secs ); | ||
268 | |||
269 | #endif | ||
270 | |||
225 | // Qt timers (does the actual alarm) | 271 | // Qt timers (does the actual alarm) |
226 | // from now in milliseconds | 272 | // from now in milliseconds |
227 | // | 273 | // |
@@ -242,11 +288,13 @@ void TimerReceiverObject::timerEvent( QTimerEvent * ) | |||
242 | e << TimeConversion::fromUTC( nearestTimerEvent->UTCtime ) | 288 | e << TimeConversion::fromUTC( nearestTimerEvent->UTCtime ) |
243 | << nearestTimerEvent->data; | 289 | << nearestTimerEvent->data; |
244 | #endif | 290 | #endif |
291 | |||
245 | timerEventList.remove( nearestTimerEvent ); | 292 | timerEventList.remove( nearestTimerEvent ); |
246 | needSave = TRUE; | 293 | needSave = TRUE; |
247 | } | 294 | } |
248 | setNearestTimerEvent(); | 295 | setNearestTimerEvent(); |
249 | } else { | 296 | } |
297 | else { | ||
250 | resetTimer(); | 298 | resetTimer(); |
251 | } | 299 | } |
252 | if ( needSave ) | 300 | if ( needSave ) |
@@ -313,17 +361,20 @@ void AlarmServer::addAlarm ( QDateTime when, const QCString& channel, | |||
313 | timerEventReceiver->killTimers(); | 361 | timerEventReceiver->killTimers(); |
314 | timerEventReceiver->resetTimer(); | 362 | timerEventReceiver->resetTimer(); |
315 | } | 363 | } |
316 | } else { | 364 | } |
365 | else { | ||
317 | nearestTimerEvent = newTimerEventItem; | 366 | nearestTimerEvent = newTimerEventItem; |
318 | timerEventReceiver->resetTimer(); | 367 | timerEventReceiver->resetTimer(); |
319 | } | 368 | } |
320 | if ( needSave ) | 369 | if ( needSave ) |
321 | saveState(); | 370 | saveState(); |
322 | } else { | 371 | } |
372 | else { | ||
323 | #ifndef QT_NO_COP | 373 | #ifndef QT_NO_COP |
324 | QCopEnvelope e( "QPE/System", "addAlarm(QDateTime,QCString,QCString,int)" ); | 374 | QCopEnvelope e( "QPE/System", "addAlarm(QDateTime,QCString,QCString,int)" ); |
325 | e << when << channel << message << data; | 375 | e << when << channel << message << data; |
326 | #endif | 376 | #endif |
377 | |||
327 | } | 378 | } |
328 | } | 379 | } |
329 | 380 | ||
@@ -355,13 +406,13 @@ void AlarmServer::deleteAlarm (QDateTime when, const QCString& channel, const QC | |||
355 | if ( ( (*it)->UTCtime == deleteTime || when.isNull() ) | 406 | if ( ( (*it)->UTCtime == deleteTime || when.isNull() ) |
356 | && ( channel.isNull() || (*it)->channel == channel ) | 407 | && ( channel.isNull() || (*it)->channel == channel ) |
357 | && ( message.isNull() || (*it)->message == message ) | 408 | && ( message.isNull() || (*it)->message == message ) |
358 | && ( data==-1 || (*it)->data == data ) ) | 409 | && ( data == -1 || (*it)->data == data ) ) { |
359 | { | ||
360 | // if it's first, then we need to update the timer | 410 | // if it's first, then we need to update the timer |
361 | if ( (*it) == nearestTimerEvent ) { | 411 | if ( (*it) == nearestTimerEvent ) { |
362 | timerEventList.remove(*it); | 412 | timerEventList.remove(*it); |
363 | setNearestTimerEvent(); | 413 | setNearestTimerEvent(); |
364 | } else { | 414 | } |
415 | else { | ||
365 | timerEventList.remove(*it); | 416 | timerEventList.remove(*it); |
366 | } | 417 | } |
367 | needSave = TRUE; | 418 | needSave = TRUE; |
@@ -372,11 +423,13 @@ void AlarmServer::deleteAlarm (QDateTime when, const QCString& channel, const QC | |||
372 | } | 423 | } |
373 | if ( needSave ) | 424 | if ( needSave ) |
374 | saveState(); | 425 | saveState(); |
375 | } else { | 426 | } |
427 | else { | ||
376 | #ifndef QT_NO_COP | 428 | #ifndef QT_NO_COP |
377 | QCopEnvelope e( "QPE/System", "deleteAlarm(QDateTime,QCString,QCString,int)" ); | 429 | QCopEnvelope e( "QPE/System", "deleteAlarm(QDateTime,QCString,QCString,int)" ); |
378 | e << when << channel << message << data; | 430 | e << when << channel << message << data; |
379 | #endif | 431 | #endif |
432 | |||
380 | } | 433 | } |
381 | } | 434 | } |
382 | 435 | ||
@@ -385,8 +438,12 @@ void AlarmServer::deleteAlarm (QDateTime when, const QCString& channel, const QC | |||
385 | */ | 438 | */ |
386 | void Global::writeHWClock() | 439 | void Global::writeHWClock() |
387 | { | 440 | { |
441 | #ifdef USE_ATD | ||
388 | if ( !triggerAtd( TRUE ) ) { | 442 | if ( !triggerAtd( TRUE ) ) { |
389 | // atd not running? set it ourselves | 443 | // atd not running? set it ourselves |
390 | system("/sbin/hwclock --systohc"); // ##### UTC? | 444 | system("/sbin/hwclock --systohc"); // ##### UTC? |
391 | } | 445 | } |
446 | #else | ||
447 | // hwclock is written on suspend | ||
448 | #endif | ||
392 | } | 449 | } |