/* gpsutils.c -- code shared between low-level and high-level interfaces * * This file is Copyright (c) 2010-2018 by the GPSD project * SPDX-License-Identifier: BSD-2-clause */ /* The strptime prototype is not provided unless explicitly requested. * We also need to set the value high enough to signal inclusion of * newer features (like clock_gettime). See the POSIX spec for more info: * http://pubs.opengroup.org/onlinepubs/9699919799/functions/V2_chap02.html#tag_15_02_01_02 */ #define _XOPEN_SOURCE 600 #if !defined(_POSIX_C_SOURCE) || _POSIX_C_SOURCE < 200112L /* pselect() needs _POSIX_C_SOURCE >= 200112L */ #define _POSIX_C_SOURCE 200112L #endif /* strlcpy() seems to need _DARWIN_C_SOURCE and/or __DARWIN_C_LEVEL */ #define __DARWIN_C_LEVEL _POSIX_C_SOURCE #define _DARWIN_C_SOURCE #include #include #include #include #include #include #include /* for to have a pselect(2) prototype a la POSIX */ #include #include /* for to have a pselect(2) prototype a la SuS */ #include #include "gps.h" #include "libgps.h" #include "os_compat.h" #include "timespec.h" #ifdef USE_QT #include #include #endif /* * Berkeley implementation of strtod(), inlined to avoid locale problems * with the decimal point and stripped down to an atof()-equivalent. */ double safe_atof(const char *string) /* Takes a decimal ASCII floating-point number, optionally * preceded by white space. Must have form "-I.FE-X", * where I is the integer part of the mantissa, F is * the fractional part of the mantissa, and X is the * exponent. Either of the signs may be "+", "-", or * omitted. Either I or F may be omitted, or both. * The decimal point isn't necessary unless F is * present. The "E" may actually be an "e". E and X * may both be omitted (but not just one). */ { static int maxExponent = 511; /* Largest possible base 10 exponent. Any * exponent larger than this will already * produce underflow or overflow, so there's * no need to worry about additional digits. */ static double powersOf10[] = { /* Table giving binary powers of 10. Entry */ 10., /* is 10^2^i. Used to convert decimal */ 100., /* exponents into floating-point numbers. */ 1.0e4, 1.0e8, 1.0e16, 1.0e32, 1.0e64, 1.0e128, 1.0e256 }; bool sign, expSign = false; double fraction, dblExp, *d; register const char *p; register int c; int exp = 0; /* Exponent read from "EX" field. */ int fracExp = 0; /* Exponent that derives from the fractional * part. Under normal circumstatnces, it is * the negative of the number of digits in F. * However, if I is very long, the last digits * of I get dropped (otherwise a long I with a * large negative exponent could cause an * unnecessary overflow on I alone). In this * case, fracExp is incremented one for each * dropped digit. */ int mantSize; /* Number of digits in mantissa. */ int decPt; /* Number of mantissa digits BEFORE decimal * point. */ const char *pExp; /* Temporarily holds location of exponent * in string. */ /* * Strip off leading blanks and check for a sign. */ p = string; while (isspace((unsigned char) *p)) { p += 1; } if (*p == '-') { sign = true; p += 1; } else { if (*p == '+') { p += 1; } sign = false; } /* * Count the number of digits in the mantissa (including the decimal * point), and also locate the decimal point. */ decPt = -1; for (mantSize = 0; ; mantSize += 1) { c = *p; if (!isdigit(c)) { if ((c != '.') || (decPt >= 0)) { break; } decPt = mantSize; } p += 1; } /* * Now suck up the digits in the mantissa. Use two integers to * collect 9 digits each (this is faster than using floating-point). * If the mantissa has more than 18 digits, ignore the extras, since * they can't affect the value anyway. */ pExp = p; p -= mantSize; if (decPt < 0) { decPt = mantSize; } else { mantSize -= 1; /* One of the digits was the point. */ } if (mantSize > 18) { fracExp = decPt - 18; mantSize = 18; } else { fracExp = decPt - mantSize; } if (mantSize == 0) { fraction = 0.0; //p = string; goto done; } else { int frac1, frac2; frac1 = 0; for ( ; mantSize > 9; mantSize -= 1) { c = *p; p += 1; if (c == '.') { c = *p; p += 1; } frac1 = 10*frac1 + (c - '0'); } frac2 = 0; for (; mantSize > 0; mantSize -= 1) { c = *p; p += 1; if (c == '.') { c = *p; p += 1; } frac2 = 10*frac2 + (c - '0'); } fraction = (1.0e9 * frac1) + frac2; } /* * Skim off the exponent. */ p = pExp; if ((*p == 'E') || (*p == 'e')) { p += 1; if (*p == '-') { expSign = true; p += 1; } else { if (*p == '+') { p += 1; } expSign = false; } while (isdigit((unsigned char) *p)) { exp = exp * 10 + (*p - '0'); p += 1; } } if (expSign) { exp = fracExp - exp; } else { exp = fracExp + exp; } /* * Generate a floating-point number that represents the exponent. * Do this by processing the exponent one bit at a time to combine * many powers of 2 of 10. Then combine the exponent with the * fraction. */ if (exp < 0) { expSign = true; exp = -exp; } else { expSign = false; } if (exp > maxExponent) { exp = maxExponent; errno = ERANGE; } dblExp = 1.0; for (d = powersOf10; exp != 0; exp >>= 1, d += 1) { if (exp & 01) { dblExp *= *d; } } if (expSign) { fraction /= dblExp; } else { fraction *= dblExp; } done: if (sign) { return -fraction; } return fraction; } #define MONTHSPERYEAR 12 /* months per calendar year */ void gps_clear_fix(struct gps_fix_t *fixp) /* stuff a fix structure with recognizable out-of-band values */ { memset(fixp, 0, sizeof(struct gps_fix_t)); fixp->altitude = NAN; fixp->climb = NAN; fixp->epc = NAN; fixp->epd = NAN; fixp->eph = NAN; fixp->eps = NAN; fixp->ept = NAN; fixp->epv = NAN; fixp->epx = NAN; fixp->epy = NAN; fixp->latitude = NAN; fixp->longitude = NAN; fixp->magnetic_track = NAN; fixp->mode = MODE_NOT_SEEN; fixp->sep = NAN; fixp->speed = NAN; fixp->time = NAN; fixp->track = NAN; /* clear ECEF too */ fixp->ecef.x = NAN; fixp->ecef.y = NAN; fixp->ecef.z = NAN; fixp->ecef.vx = NAN; fixp->ecef.vy = NAN; fixp->ecef.vz = NAN; fixp->ecef.pAcc = NAN; fixp->ecef.vAcc = NAN; } void gps_clear_att(struct attitude_t *attp) /* stuff an attitude structure with recognizable out-of-band values */ { memset(attp, 0, sizeof(struct attitude_t)); attp->pitch = NAN; attp->roll = NAN; attp->yaw = NAN; attp->dip = NAN; attp->mag_len = NAN; attp->mag_x = NAN; attp->mag_y = NAN; attp->mag_z = NAN; attp->acc_len = NAN; attp->acc_x = NAN; attp->acc_y = NAN; attp->acc_z = NAN; attp->gyro_x = NAN; attp->gyro_y = NAN; attp->temp = NAN; attp->depth = NAN; } void gps_clear_dop( struct dop_t *dop) { dop->xdop = dop->ydop = dop->vdop = dop->tdop = dop->hdop = dop->pdop = dop->gdop = NAN; } void gps_merge_fix(struct gps_fix_t *to, gps_mask_t transfer, struct gps_fix_t *from) /* merge new data into an old fix */ { if ((NULL == to) || (NULL == from)) return; if ((transfer & TIME_SET) != 0) to->time = from->time; if ((transfer & LATLON_SET) != 0) { to->latitude = from->latitude; to->longitude = from->longitude; } if ((transfer & MODE_SET) != 0) to->mode = from->mode; if ((transfer & ALTITUDE_SET) != 0) to->altitude = from->altitude; if ((transfer & TRACK_SET) != 0) to->track = from->track; if ((transfer & MAGNETIC_TRACK_SET) != 0) to->magnetic_track = from->magnetic_track; if ((transfer & SPEED_SET) != 0) to->speed = from->speed; if ((transfer & CLIMB_SET) != 0) to->climb = from->climb; if ((transfer & TIMERR_SET) != 0) to->ept = from->ept; if (0 != isfinite(from->epx) && 0 != isfinite(from->epy)) { to->epx = from->epx; to->epy = from->epy; } if (0 != isfinite(from->epd)) { to->epd = from->epd; } if (0 != isfinite(from->eph)) { to->eph = from->eph; } if (0 != isfinite(from->eps)) { to->eps = from->eps; } if (0 != isfinite(from->sep)) { to->sep = from->sep; } if (0 != isfinite(from->epv)) { to->epv = from->epv; } if ((transfer & SPEEDERR_SET) != 0) to->eps = from->eps; if ((transfer & ECEF_SET) != 0) { to->ecef.x = from->ecef.x; to->ecef.y = from->ecef.y; to->ecef.z = from->ecef.z; to->ecef.pAcc = from->ecef.pAcc; } if ((transfer & VECEF_SET) != 0) { to->ecef.vx = from->ecef.vx; to->ecef.vy = from->ecef.vy; to->ecef.vz = from->ecef.vz; to->ecef.vAcc = from->ecef.vAcc; } if ('\0' != from->datum[0]) { strlcpy(to->datum, from->datum, sizeof(to->datum)); } if (0 != from->qErr) { to->qErr = from->qErr; } } /* NOTE: timestamp_t is a double, so this is only precise to * near microSec. Do not use near PPS which is nanoSec precise */ timestamp_t timestamp(void) { struct timespec ts; (void)clock_gettime(CLOCK_REALTIME, &ts); return (timestamp_t)(ts.tv_sec + ts.tv_nsec * 1e-9); } /* mkgmtime(tm) * convert struct tm, as UTC, to seconds since Unix epoch * This differs from mktime() from libc. * mktime() takes struct tm as localtime. */ time_t mkgmtime(register struct tm * t) { register int year; register time_t result; static const int cumdays[MONTHSPERYEAR] = { 0, 31, 59, 90, 120, 151, 181, 212, 243, 273, 304, 334 }; year = 1900 + t->tm_year + t->tm_mon / MONTHSPERYEAR; result = (year - 1970) * 365 + cumdays[t->tm_mon % MONTHSPERYEAR]; result += (year - 1968) / 4; result -= (year - 1900) / 100; result += (year - 1600) / 400; if ((year % 4) == 0 && ((year % 100) != 0 || (year % 400) == 0) && (t->tm_mon % MONTHSPERYEAR) < 2) result--; result += t->tm_mday - 1; result *= 24; result += t->tm_hour; result *= 60; result += t->tm_min; result *= 60; result += t->tm_sec; /* this is UTC, no DST * if (t->tm_isdst == 1) * result -= 3600; */ return (result); } timestamp_t iso8601_to_unix(char *isotime) /* ISO8601 UTC to Unix UTC, no leapsecond correction. */ { #ifndef __clang_analyzer__ #ifndef USE_QT char *dp = NULL; double usec = 0; struct tm tm; memset(&tm,0,sizeof(tm)); #ifdef HAVE_STRPTIME dp = strptime(isotime, "%Y-%m-%dT%H:%M:%S", &tm); #else /* Fallback for systems without strptime (i.e. Windows) This is a simplistic conversion for iso8601 strings only, rather than embedding a full copy of strptime() that handles all formats */ double sec; unsigned int tmp; // Thus avoiding needing to test for (broken) negative date/time numbers in token reading - only need to check the upper range bool failed = false; char *isotime_tokenizer = strdup(isotime); if (isotime_tokenizer) { char *tmpbuf; char *pch = strtok_r(isotime_tokenizer, "-T:", &tmpbuf); int token_number = 0; while (pch != NULL) { token_number++; // Give up if encountered way too many tokens. if (token_number > 10) { failed = true; break; } switch (token_number) { case 1: // Year token tmp = atoi(pch); if (tmp < 9999) tm.tm_year = tmp - 1900; // Adjust to tm year else failed = true; break; case 2: // Month token tmp = atoi(pch); if (tmp < 13) tm.tm_mon = tmp - 1; // Month indexing starts from zero else failed = true; break; case 3: // Day token tmp = atoi(pch); if (tmp < 32) tm.tm_mday = tmp; else failed = true; break; case 4: // Hour token tmp = atoi(pch); if (tmp < 24) tm.tm_hour = tmp; else failed = true; break; case 5: // Minute token tmp = atoi(pch); if (tmp < 60) tm.tm_min = tmp; else failed = true; break; case 6: // Seconds token sec = safe_atof(pch); // NB To handle timestamps with leap seconds if (sec >= 0.0 && sec < 61.5 ) { tm.tm_sec = (unsigned int)sec; // Truncate to get integer value usec = sec - (unsigned int)sec; // Get the fractional part (if any) } else failed = true; break; default: break; } pch = strtok_r(NULL, "-T:", &tmpbuf); } free(isotime_tokenizer); // Split may result in more than 6 tokens if the TZ has any t's in it // So check that we've seen enough tokens rather than an exact number if (token_number < 6) failed = true; } if (failed) memset(&tm,0,sizeof(tm)); else { // When successful this normalizes tm so that tm_yday is set // and thus tm is valid for use with other functions if (mktime(&tm) == (time_t)-1) // Failed mktime - so reset the timestamp memset(&tm,0,sizeof(tm)); } #endif if (dp != NULL && *dp == '.') usec = strtod(dp, NULL); /* * It would be nice if we could say mktime(&tm) - timezone + usec instead, * but timezone is not available at all on some BSDs. Besides, when working * with historical dates the value of timezone after an ordinary tzset(3) * can be wrong; you have to do a redirect through the IANA historical * timezone database to get it right. */ return (timestamp_t)mkgmtime(&tm) + usec; #else double usec = 0; QString t(isotime); QDateTime d = QDateTime::fromString(isotime, Qt::ISODate); QStringList sl = t.split("."); if (sl.size() > 1) usec = sl[1].toInt() / pow(10., (double)sl[1].size()); return (timestamp_t)(d.toTime_t() + usec); #endif #endif /* __clang_analyzer__ */ } /* Unix UTC time to ISO8601, no timezone adjustment */ /* example: 2007-12-11T23:38:51.033Z */ char *unix_to_iso8601(timestamp_t fixtime, char isotime[], size_t len) { struct tm when; double integral, fractional; time_t intfixtime; char timestr[30]; char fractstr[10]; if (!isfinite(fixtime)) { return strncpy(isotime, "NaN", len); } fractional = modf(fixtime, &integral); /* snprintf rounding of %3f can get ugly, so pre-round */ if ( 0.999499999 < fractional) { /* round up */ integral++; /* give the fraction a nudge to ensure rounding */ fractional += 0.0005; } intfixtime = (time_t) integral; #ifdef HAVE_GMTIME_R (void)gmtime_r(&intfixtime, &when); #else /* Fallback to try with gmtime_s - primarily for Windows */ (void)gmtime_s(&when, &intfixtime); #endif (void)strftime(timestr, sizeof(timestr), "%Y-%m-%dT%H:%M:%S", &when); /* * Do not mess casually with the number of decimal digits in the * format! Most GPSes report over serial links at 0.01s or 0.001s * precision. */ (void)snprintf(fractstr, sizeof(fractstr), "%.3f", fractional); /* add fractional part, ignore leading 0; "0.2" -> ".2" */ (void)snprintf(isotime, len, "%s%sZ",timestr, strchr(fractstr,'.')); return isotime; } #define Deg2Rad(n) ((n) * DEG_2_RAD) /* Distance in meters between two points specified in degrees, optionally with initial and final bearings. */ double earth_distance_and_bearings(double lat1, double lon1, double lat2, double lon2, double *ib, double *fb) { /* * this is a translation of the javascript implementation of the * Vincenty distance formula by Chris Veness. See * http://www.movable-type.co.uk/scripts/latlong-vincenty.html */ double a, b, f; // WGS-84 ellipsoid params double L, L_P, U1, U2, s_U1, c_U1, s_U2, c_U2; double uSq, A, B, d_S, lambda; // cppcheck-suppress variableScope double s_L, c_L, s_A, C; double c_S, S, s_S, c_SqA, c_2SM; int i = 100; a = WGS84A; b = WGS84B; f = 1 / WGS84F; L = Deg2Rad(lon2 - lon1); U1 = atan((1 - f) * tan(Deg2Rad(lat1))); U2 = atan((1 - f) * tan(Deg2Rad(lat2))); s_U1 = sin(U1); c_U1 = cos(U1); s_U2 = sin(U2); c_U2 = cos(U2); lambda = L; do { s_L = sin(lambda); c_L = cos(lambda); s_S = sqrt((c_U2 * s_L) * (c_U2 * s_L) + (c_U1 * s_U2 - s_U1 * c_U2 * c_L) * (c_U1 * s_U2 - s_U1 * c_U2 * c_L)); if (s_S == 0) return 0; c_S = s_U1 * s_U2 + c_U1 * c_U2 * c_L; S = atan2(s_S, c_S); s_A = c_U1 * c_U2 * s_L / s_S; c_SqA = 1 - s_A * s_A; c_2SM = c_S - 2 * s_U1 * s_U2 / c_SqA; if (0 == isfinite(c_2SM)) c_2SM = 0; C = f / 16 * c_SqA * (4 + f * (4 - 3 * c_SqA)); L_P = lambda; lambda = L + (1 - C) * f * s_A * (S + C * s_S * (c_2SM + C * c_S * (2 * c_2SM * c_2SM - 1))); } while ((fabs(lambda - L_P) > 1.0e-12) && (--i > 0)); if (i == 0) return NAN; // formula failed to converge uSq = c_SqA * ((a * a) - (b * b)) / (b * b); A = 1 + uSq / 16384 * (4096 + uSq * (-768 + uSq * (320 - 175 * uSq))); B = uSq / 1024 * (256 + uSq * (-128 + uSq * (74 - 47 * uSq))); d_S = B * s_S * (c_2SM + B / 4 * (c_S * (-1 + 2 * c_2SM * c_2SM) - B / 6 * c_2SM * (-3 + 4 * s_S * s_S) * (-3 + 4 * c_2SM * c_2SM))); if (ib != NULL) *ib = atan2(c_U2 * sin(lambda), c_U1 * s_U2 - s_U1 * c_U2 * cos(lambda)); if (fb != NULL) *fb = atan2(c_U1 * sin(lambda), c_U1 * s_U2 * cos(lambda) - s_U1 * c_U2); return (WGS84B * A * (S - d_S)); } /* Distance in meters between two points specified in degrees. */ double earth_distance(double lat1, double lon1, double lat2, double lon2) { return earth_distance_and_bearings(lat1, lon1, lat2, lon2, NULL, NULL); } bool nanowait(int fd, int nanoseconds) { fd_set fdset; struct timespec to; FD_ZERO(&fdset); FD_SET(fd, &fdset); to.tv_sec = nanoseconds / NS_IN_SEC; to.tv_nsec = nanoseconds % NS_IN_SEC; return pselect(fd + 1, &fdset, NULL, NULL, &to, NULL) == 1; } /* Accept a datum code, return matching string * * There are a ton of these, only a few are here * */ void datum_code_string(int code, char *buffer, size_t len) { const char *datum_str; switch (code) { case 0: datum_str = "WGS84"; break; case 21: datum_str = "WGS84"; break; case 178: datum_str = "Tokyo Mean"; break; case 179: datum_str = "Tokyo-Japan"; break; case 180: datum_str = "Tokyo-Korea"; break; case 181: datum_str = "Tokyo-Okinawa"; break; case 182: datum_str = "PZ90.11"; break; case 999: datum_str = "User Defined"; break; default: datum_str = NULL; break; } if (NULL == datum_str) { /* Fake it */ snprintf(buffer, len, "%d", code); } else { strlcpy(buffer, datum_str, len); } } /* end */