ESP32-PaxCounter/src/timekeeper.cpp

241 lines
7.0 KiB
C++
Raw Normal View History

2019-02-24 01:44:55 +01:00
#include "timekeeper.h"
2019-02-21 23:17:01 +01:00
// Local logging tag
2019-02-27 00:52:27 +01:00
static const char TAG[] = __FILE__;
2019-02-21 23:17:01 +01:00
2019-02-24 15:08:41 +01:00
// symbol to display current time source
const char timeSetSymbols[] = {'G', 'R', 'L', '?'};
Ticker timesyncer;
2019-02-24 23:13:15 +01:00
void timeSync() { xTaskNotify(irqHandlerTask, TIMESYNC_IRQ, eSetBits); }
2019-03-02 13:32:02 +01:00
time_t timeProvider(void) {
2019-02-21 23:17:01 +01:00
2019-02-25 00:26:46 +01:00
time_t t = 0;
2019-02-21 23:17:01 +01:00
#ifdef HAS_GPS
2019-02-27 22:40:58 +01:00
t = get_gpstime(); // fetch recent time from last NEMA record
if (t) {
#ifdef HAS_RTC
2019-02-27 22:40:58 +01:00
set_rtctime(t); // calibrate RTC
#endif
2019-02-27 22:40:58 +01:00
timeSource = _gps;
2019-03-03 17:35:08 +01:00
timesyncer.attach(TIME_SYNC_INTERVAL * 60, timeSync); // regular repeat
2019-03-02 13:32:02 +01:00
return t;
2019-02-27 22:40:58 +01:00
}
2019-02-21 23:17:01 +01:00
#endif
2019-02-23 23:39:45 +01:00
2019-02-24 13:47:18 +01:00
// no GPS -> fallback to RTC time while trying lora sync
2019-02-24 01:44:55 +01:00
#ifdef HAS_RTC
2019-02-27 22:40:58 +01:00
t = get_rtctime();
if (t) {
timeSource = _rtc;
2019-03-03 17:35:08 +01:00
timesyncer.attach(60, timeSync); // short retry
2019-02-27 22:40:58 +01:00
}
2019-02-22 23:17:28 +01:00
#endif
2019-02-21 23:17:01 +01:00
2019-03-06 23:21:46 +01:00
// kick off asychronous DB timesync if we have
#ifdef DBTIMESYNC
send_DBtime_req();
// kick off asychronous lora sync if we have
2019-03-06 23:21:46 +01:00
#elif defined HAS_LORA && defined TIME_SYNC_LORA
2019-02-27 22:40:58 +01:00
LMIC_requestNetworkTime(user_request_network_time_callback, &userUTCTime);
2019-02-21 23:17:01 +01:00
#endif
2019-03-03 17:35:08 +01:00
if (!t) {
2019-02-27 22:40:58 +01:00
timeSource = _unsynced;
2019-03-03 17:35:08 +01:00
timesyncer.attach(60, timeSync); // short retry
}
2019-02-24 23:13:15 +01:00
2019-03-02 13:32:02 +01:00
return t;
} // timeProvider()
2019-02-21 23:17:01 +01:00
// helper function to setup a pulse per second for time synchronisation
2019-02-24 01:44:55 +01:00
uint8_t timepulse_init() {
2019-02-21 23:17:01 +01:00
// use time pulse from GPS as time base with fixed 1Hz frequency
#ifdef GPS_INT
2019-02-27 22:40:58 +01:00
// setup external interupt pin for rising edge GPS INT
2019-02-21 23:17:01 +01:00
pinMode(GPS_INT, INPUT_PULLDOWN);
// setup external rtc 1Hz clock as pulse per second clock
ESP_LOGI(TAG, "Timepulse: external (GPS)");
return 1; // success
// use pulse from on board RTC chip as time base with fixed frequency
#elif defined RTC_INT
2019-02-27 22:40:58 +01:00
// setup external interupt pin for falling edge RTC INT
2019-02-21 23:17:01 +01:00
pinMode(RTC_INT, INPUT_PULLUP);
// setup external rtc 1Hz clock as pulse per second clock
if (I2C_MUTEX_LOCK()) {
Rtc.SetSquareWavePinClockFrequency(DS3231SquareWaveClock_1Hz);
Rtc.SetSquareWavePin(DS3231SquareWavePin_ModeClock);
I2C_MUTEX_UNLOCK();
ESP_LOGI(TAG, "Timepulse: external (RTC)");
return 1; // success
} else {
2019-02-22 22:28:35 +01:00
ESP_LOGE(TAG, "RTC initialization error, I2C bus busy");
2019-02-21 23:17:01 +01:00
return 0; // failure
}
return 1; // success
#else
// use ESP32 hardware timer as time base with adjustable frequency
2019-03-03 17:35:08 +01:00
ppsIRQ = timerBegin(1, 8000, true); // set 80 MHz prescaler to 1/10000 sec
2019-03-03 12:57:00 +01:00
timerAlarmWrite(ppsIRQ, 10000, true); // 1000ms
2019-02-21 23:17:01 +01:00
ESP_LOGI(TAG, "Timepulse: internal (ESP32 hardware timer)");
return 1; // success
#endif
} // timepulse_init
void timepulse_start(void) {
#ifdef GPS_INT // start external clock gps pps line
attachInterrupt(digitalPinToInterrupt(GPS_INT), CLOCKIRQ, RISING);
#elif defined RTC_INT // start external clock rtc
attachInterrupt(digitalPinToInterrupt(RTC_INT), CLOCKIRQ, FALLING);
#else // start internal clock esp32 hardware timer
2019-03-03 12:57:00 +01:00
timerAttachInterrupt(ppsIRQ, &CLOCKIRQ, true);
timerAlarmEnable(ppsIRQ);
2019-02-21 23:17:01 +01:00
#endif
}
// interrupt service routine triggered by either pps or esp32 hardware timer
void IRAM_ATTR CLOCKIRQ(void) {
2019-02-27 22:40:58 +01:00
2019-03-02 20:58:06 +01:00
BaseType_t xHigherPriorityTaskWoken;
SyncToPPS(); // calibrates UTC systime, see Time.h
2019-03-02 20:58:06 +01:00
xHigherPriorityTaskWoken = pdFALSE;
2019-03-02 13:32:02 +01:00
2019-02-21 23:17:01 +01:00
if (ClockTask != NULL)
xTaskNotifyFromISR(ClockTask, uint32_t(now()), eSetBits,
2019-03-02 20:58:06 +01:00
&xHigherPriorityTaskWoken);
2019-02-27 22:40:58 +01:00
2019-02-21 23:17:01 +01:00
#if defined GPS_INT || defined RTC_INT
2019-03-02 20:58:06 +01:00
xSemaphoreGiveFromISR(TimePulse, &xHigherPriorityTaskWoken);
2019-02-21 23:17:01 +01:00
TimePulseTick = !TimePulseTick; // flip ticker
#endif
2019-02-27 22:40:58 +01:00
2019-03-02 20:58:06 +01:00
// yield only if we should
if (xHigherPriorityTaskWoken)
portYIELD_FROM_ISR();
2019-02-21 23:17:01 +01:00
}
2019-02-22 22:28:35 +01:00
// helper function to check plausibility of a time
2019-03-02 13:32:02 +01:00
time_t timeIsValid(time_t const t) {
2019-02-22 22:28:35 +01:00
// is it a time in the past? we use compile date to guess
return (t >= compiledUTC() ? t : 0);
2019-02-22 22:28:35 +01:00
}
// helper function to convert compile time to UTC time
time_t compiledUTC(void) {
2019-03-02 13:32:02 +01:00
static time_t t = myTZ.toUTC(RtcDateTime(__DATE__, __TIME__).Epoch32Time());
return t;
2019-02-22 22:28:35 +01:00
}
// helper function to convert gps date/time into time_t
2019-02-23 23:39:45 +01:00
time_t tmConvert(uint16_t YYYY, uint8_t MM, uint8_t DD, uint8_t hh, uint8_t mm,
uint8_t ss) {
2019-02-22 22:28:35 +01:00
tmElements_t tm;
2019-02-22 23:17:28 +01:00
tm.Year = CalendarYrToTm(YYYY); // year offset from 1970 in time.h
2019-02-22 22:28:35 +01:00
tm.Month = MM;
tm.Day = DD;
tm.Hour = hh;
tm.Minute = mm;
tm.Second = ss;
return makeTime(tm);
}
// helper function to calculate serial transmit time
TickType_t tx_Ticks(uint32_t framesize, unsigned long baud, uint32_t config,
int8_t rxPin, int8_t txPins) {
uint32_t databits = ((config & 0x0c) >> 2) + 5;
uint32_t stopbits = ((config & 0x20) >> 5) + 1;
uint32_t txTime = (databits + stopbits + 2) * framesize * 1000.0 / baud;
// +1 ms margin for the startbit +1 ms for pending processing time
return round(txTime);
}
2019-02-21 23:17:01 +01:00
#if defined HAS_IF482 || defined HAS_DCF77
#if defined HAS_DCF77 && defined HAS_IF482
#error You must define at most one of IF482 or DCF77!
#endif
void clock_init(void) {
// setup clock output interface
#ifdef HAS_IF482
IF482.begin(HAS_IF482);
#elif defined HAS_DCF77
pinMode(HAS_DCF77, OUTPUT);
#endif
2019-03-02 20:01:27 +01:00
userUTCTime = now();
xTaskCreatePinnedToCore(clock_loop, // task function
"clockloop", // name of task
2048, // stack size of task
(void *)&userUTCTime, // start time as task parameter
4, // priority of the task
&ClockTask, // task handle
1); // CPU core
2019-02-21 23:17:01 +01:00
assert(ClockTask); // has clock task started?
} // clock_init
2019-03-02 20:01:27 +01:00
void clock_loop(void *taskparameter) { // ClockTask
2019-02-21 23:17:01 +01:00
2019-03-02 20:01:27 +01:00
// caveat: don't use now() in this task, it will cause a race condition
// due to concurrent access to i2c bus for setting rtc via SyncProvider!
2019-02-21 23:17:01 +01:00
2019-03-02 21:25:22 +01:00
#define nextsec(t) (t + 1) // next second
#define nextmin(t) (t + DCF77_FRAME_SIZE + 1) // next minute
2019-02-21 23:17:01 +01:00
2019-03-02 20:01:27 +01:00
uint32_t printtime;
time_t t = *((time_t *)taskparameter); // UTC time seconds
2019-02-21 23:17:01 +01:00
2019-02-24 01:44:55 +01:00
// preload first DCF frame before start
2019-02-21 23:17:01 +01:00
#ifdef HAS_DCF77
2019-02-24 01:44:55 +01:00
uint8_t *DCFpulse; // pointer on array with DCF pulse bits
2019-03-02 20:01:27 +01:00
DCFpulse = DCF77_Frame(nextmin(t));
2019-02-21 23:17:01 +01:00
#endif
2019-03-02 20:01:27 +01:00
// output the next second's pulse after timepulse arrived
2019-02-21 23:17:01 +01:00
for (;;) {
2019-03-02 13:32:02 +01:00
xTaskNotifyWait(0x00, ULONG_MAX, &printtime,
2019-02-21 23:17:01 +01:00
portMAX_DELAY); // wait for timepulse
2019-03-02 20:01:27 +01:00
// no confident time -> we suppress clock output
2019-02-24 23:13:15 +01:00
if (timeStatus() == timeNotSet)
2019-02-21 23:17:01 +01:00
continue;
2019-03-02 20:01:27 +01:00
t = time_t(printtime); // UTC time seconds
2019-02-21 23:17:01 +01:00
#if defined HAS_IF482
2019-03-02 21:54:55 +01:00
IF482_Pulse(nextsec(t));
2019-02-21 23:17:01 +01:00
#elif defined HAS_DCF77
if (second(t) == DCF77_FRAME_SIZE - 1) // is it time to load new frame?
2019-03-02 20:01:27 +01:00
DCFpulse = DCF77_Frame(nextmin(t)); // generate frame for next minute
2019-02-21 23:17:01 +01:00
2019-03-02 20:58:06 +01:00
if (minute(nextmin(t)) == // do we still have a recent frame?
DCFpulse[DCF77_FRAME_SIZE]) // (timepulses could be missed!)
DCF77_Pulse(t, DCFpulse); // then output current second's pulse
2019-02-27 22:40:58 +01:00
else
2019-03-02 20:01:27 +01:00
continue; // no recent frame -> we suppress clock output
2019-02-21 23:17:01 +01:00
#endif
} // for
} // clock_loop()
#endif // HAS_IF482 || defined HAS_DCF77