141 lines
7.4 KiB
C
141 lines
7.4 KiB
C
#ifndef E502TSTP_H
|
||
#define E502TSTP_H
|
||
|
||
#include "x502api.h"
|
||
#include <stdbool.h>
|
||
|
||
#ifdef __cplusplus
|
||
extern "C" {
|
||
#endif
|
||
|
||
/** @addtogroup tstpfunc_list Функции для работы с метками времени
|
||
@{ **/
|
||
|
||
/***************************************************************************//**
|
||
@addtogroup tstptype_list Константы и перечисления
|
||
@{
|
||
*****************************************************************************/
|
||
|
||
#define TSP_NSEC_PER_SEC (1000000000)
|
||
|
||
#define TSP_WRD1_SSEC_LEN (24)
|
||
#define TSP_WRD2_SSEC_LEN (7)
|
||
#define TSP_WRD2_SEC_LEN (19)
|
||
#define TSP_WRD3_SEC_LEN (13)
|
||
#define TSP_SSEC_WIDTH (31)
|
||
|
||
|
||
#define TSP_WRD_NUM(wrd) (((wrd) >> 26) & 3)
|
||
#define TSP_WRD0_ADC_CLK_NUM_MASK (0x3ffffff)
|
||
#define TSP_WRD1_LOCK_MASK (1 << 25)
|
||
#define TSP_WRD1_FMARK_MASK (1 << 24)
|
||
#define TSP_WRD1_SSEC_MASK ((1 << TSP_WRD1_SSEC_LEN) - 1)
|
||
#define TSP_WRD2_SEC_MASK (0x3ffff80)
|
||
#define TSP_WRD2_SSEC_MASK ((1 << TSP_WRD2_SSEC_LEN) - 1)
|
||
#define TSP_WRD2_SECSSEC_MASK ((1 << (TSP_WRD2_SEC_LEN + TSP_WRD2_SSEC_LEN)) - 1)
|
||
#define TSP_WRD3_SEC_MASK ((1 << TSP_WRD3_SEC_LEN) - 1)
|
||
|
||
#define TSP_WRD1_IS_FMARK(wrd) (!!((wrd) & TSP_WRD1_FMARK_MASK))
|
||
#define TSP_WRD1_IS_LOCK(wrd) (!!((wrd) & TSP_WRD1_LOCK_MASK))
|
||
#define TSP_WRD1_GET_SSEC(wrd) ((wrd) & TSP_WRD1_SSEC_MASK)
|
||
#define TSP_WRD2_GET_SECSSEC(wrd) ((uint64_t)((wrd) & TSP_WRD2_SECSSEC_MASK) << TSP_WRD1_SSEC_LEN)
|
||
#define TSP_WRD2_GET_SSEC(wrd) ((wrd) & TSP_WRD2_SSEC_MASK)
|
||
#define TSP_WRD3_GET_SEC(wrd) ((uint64_t)((wrd) & TSP_WRD3_SEC_MASK) << (TSP_WRD1_SSEC_LEN + TSP_WRD2_SSEC_LEN + TSP_WRD2_SEC_LEN))
|
||
#define SSEC_MAX (0x7fffffff)
|
||
#define TSTP_SSEC_TO_NSEC(time) (time > 0 ? ((uint32_t)((((double)((time) & SSEC_MAX)) / (1U << TSP_SSEC_WIDTH)) * TSP_NSEC_PER_SEC)) : ((uint32_t)((((double)((time*(-1)) & SSEC_MAX)) / (1U << TSP_SSEC_WIDTH)) * TSP_NSEC_PER_SEC)))
|
||
#define TSTP_SECSSEC_TO_SEC(time) (time > 0 ? (uint32_t)((time) >> TSP_SSEC_WIDTH) : (uint32_t)((time * -1) >> TSP_SSEC_WIDTH))
|
||
#define TSTP_SECSSEC_TO_SEC_DOUBLE(time) (((double)(time)) / (1U << TSP_SSEC_WIDTH))
|
||
#define TSTP_SEC_TO_SSEC(time) (((uint64_t)(time)) << TSP_SSEC_WIDTH)
|
||
|
||
/** Тип данных для хранения времени
|
||
* Время хранится в секундах прошедшее с начала этой эпохи (00:00:00 UTC, 1 Января 1970 года)
|
||
* Дробный формат хранения 32.31: 32 целых бит, 31 дробных бит,
|
||
* старшие 32 бита - секунды, младшие 31 бит сабсекунды = 1 / (1<<31) секунд
|
||
+ сабсекунды,
|
||
*/
|
||
typedef uint64_t t_x502_tstptime;
|
||
|
||
/** Структура для хранения контекста при обработке потока слов "на ввод" с включенными метками времени */
|
||
typedef struct {
|
||
/** значение слов последней метки времени */
|
||
uint32_t wrd[4];
|
||
/** частота АЦП */
|
||
uint32_t adc_freq;
|
||
/** частота DIN */
|
||
uint32_t din_freq;
|
||
/** время первой метки времени */
|
||
t_x502_tstptime tstp_start_time;
|
||
/** признак, что первая метка времени получена */
|
||
bool tstp_mark_rcvd;
|
||
/** значение текущего обрабатываемого слова */
|
||
uint32_t cur_wrd;
|
||
/** кол-во обработанных слов из потока */
|
||
uint32_t processed_wrds;
|
||
/** кол-во слов АЦП после последней метки времени */
|
||
uint32_t adcwrds_after_tstp;
|
||
/** кол-во слов DIN после последней метки времени */
|
||
uint32_t dinwrds_after_tstp;
|
||
/** общее кол-во слов после последней метки времени */
|
||
uint32_t wrds_after_tstp;
|
||
/** время последней метки времени */
|
||
t_x502_tstptime last_tstp_time;
|
||
} t_x502_tstp_state;
|
||
|
||
/** @} */
|
||
|
||
/***************************************************************************//**
|
||
@addtogroup func_tstp Функции для работы с метками времени
|
||
@{
|
||
*******************************************************************************/
|
||
|
||
/***************************************************************************//**
|
||
@brief Инициализация tstp_state, в нем хранится текущий контекст для операций с метками времени из потока "на ввод"
|
||
|
||
Данная функция инициализирует структуру в которой хранится контекст для работы с метками времени
|
||
Необходимо указывать на частоту АЦП и DIN т.к. время для слов между двумя метками
|
||
будет считаться в зависимости от частоты.
|
||
|
||
@param[in] tstp_state Указатель на существующую струтуру t_x502_tstp_state
|
||
@param[in] adc_freq Частота АЦП
|
||
@param[in] din_freq Частота DIN
|
||
*******************************************************************************/
|
||
X502_EXPORT(void) X502_tstp_init(t_x502_tstp_state *tstp_state, uint32_t adc_freq, uint32_t din_freq);
|
||
|
||
/** @brief Обработать очередное слово wrd из потока "на ввод"
|
||
*
|
||
* Функция должна быть вызвана только один раз и последовательно для каждого слова полученного из X502_Recv
|
||
*
|
||
* @param[in] tstp_state Указатель на струтуру t_x502_tstp_state предварительно инициализированную через tstp_init()
|
||
* @param[in] wrd Слово из потока "на ввод"
|
||
*/
|
||
X502_EXPORT(void) X502_tstp_process_wrd(t_x502_tstp_state *tstp_state, uint32_t wrd);
|
||
|
||
/** @brief Узнать время текущего обработанного слова
|
||
*
|
||
* Узнать время текущего слова которое до этого было обработано функцией tstp_process_wrd()
|
||
* Формат времени: 32бита - секунды, 31 бит сабсекунды = 1 / (1<<31) секунд
|
||
*
|
||
* @param[in] tstp_state Указатель на струтуру t_x502_tstp_state предварительно инициализированную через tstp_init()
|
||
* @param[in] ret Указатель на t_x502_tstptime по которому будет сохранено расчитанное значение времени для текущего слова
|
||
*/
|
||
X502_EXPORT(void) X502_tstp_get_curwrd_time(t_x502_tstp_state *tstp_state, t_x502_tstptime *ret);
|
||
|
||
/** @brief Возвращает признак того что часы синхронизированы
|
||
*
|
||
* Возвращает признак "захват PTP" для текущего обработанного слова
|
||
*
|
||
* @param[in] tstp_state Указатель на струтуру t_x502_tstp_state предварительно инициализированную через tstp_init()
|
||
*
|
||
* @return true: присутствует признак "захват PTP" для текущего обработанного слова, false: признак "захват PTP" отсутствует
|
||
*/
|
||
X502_EXPORT(bool) X502_tstp_get_lock(t_x502_tstp_state *tstp_state);
|
||
|
||
/** @} */
|
||
/** @} */
|
||
|
||
#ifdef __cplusplus
|
||
}
|
||
#endif
|
||
|
||
#endif //E502TSTP_H
|