From 56f5bddb7e2a6267bdfeddf8de601a057aef802f Mon Sep 17 00:00:00 2001 From: Jan Breuer <jan.breuer@jaybee.cz> Date: 周六, 05 12月 2015 23:13:34 +0800 Subject: [PATCH] Extend expression.c tests --- libscpi/src/error.c | 111 ++++++++++++++++++++++++++----------------------------- 1 files changed, 53 insertions(+), 58 deletions(-) diff --git a/libscpi/src/error.c b/libscpi/src/error.c index be98d79..9afd0f4 100644 --- a/libscpi/src/error.c +++ b/libscpi/src/error.c @@ -39,26 +39,41 @@ #include "scpi/parser.h" #include "scpi/ieee488.h" #include "scpi/error.h" -#include "scpi-def.h" /* this file is needed for the user provided SCPI errors */ #include "fifo_private.h" - -/* basic FIFO */ -static scpi_fifo_t local_error_queue; - /** * Initialize error queue * @param context - scpi context */ -void SCPI_ErrorInit(scpi_t * context) { - /* - * // FreeRTOS - * context->error_queue = (scpi_error_queue_t)xQueueCreate(100, sizeof(int16_t)); - */ +void SCPI_ErrorInit(scpi_t * context, int16_t * data, int16_t size) { + fifo_init(&context->error_queue, data, size); +} - /* basic FIFO */ - context->error_queue = (scpi_error_queue_t)&local_error_queue; - fifo_init((scpi_fifo_t *)context->error_queue); +/** + * Emit no error + * @param context scpi context + */ +static void SCPI_ErrorEmitEmpty(scpi_t * context) { + if ((SCPI_ErrorCount(context) == 0) && (SCPI_RegGet(context, SCPI_REG_STB) & STB_QMA)) { + SCPI_RegClearBits(context, SCPI_REG_STB, STB_QMA); + + if (context->interface && context->interface->error) { + context->interface->error(context, 0); + } + } +} + +/** + * Emit error + * @param context scpi context + * @param err Error to emit + */ +static void SCPI_ErrorEmit(scpi_t * context, int16_t err) { + SCPI_RegSetBits(context, SCPI_REG_STB, STB_QMA); + + if (context->interface && context->interface->error) { + context->interface->error(context, err); + } } /** @@ -66,13 +81,9 @@ * @param context - scpi context */ void SCPI_ErrorClear(scpi_t * context) { - /* - * // FreeRTOS - * xQueueReset((xQueueHandle)context->error_queue); - */ + fifo_clear(&context->error_queue); - /* basic FIFO */ - fifo_clear((scpi_fifo_t *)context->error_queue); + SCPI_ErrorEmitEmpty(context); } /** @@ -83,15 +94,9 @@ int16_t SCPI_ErrorPop(scpi_t * context) { int16_t result = 0; - /* - * // FreeRTOS - * if (pdFALSE == xQueueReceive((xQueueHandle)context->error_queue, &result, 0)) { - * result = 0; - * } - */ + fifo_remove(&context->error_queue, &result); - /* basic FIFO */ - fifo_remove((scpi_fifo_t *)context->error_queue, &result); + SCPI_ErrorEmitEmpty(context); return result; } @@ -104,25 +109,16 @@ int32_t SCPI_ErrorCount(scpi_t * context) { int16_t result = 0; - /* - * // FreeRTOS - * result = uxQueueMessagesWaiting((xQueueHandle)context->error_queue); - */ - - /* basic FIFO */ - fifo_count((scpi_fifo_t *)context->error_queue, &result); + fifo_count(&context->error_queue, &result); return result; } static void SCPI_ErrorAddInternal(scpi_t * context, int16_t err) { - /* - * // FreeRTOS - * xQueueSend((xQueueHandle)context->error_queue, &err, 0); - */ - - /* basic FIFO */ - fifo_add((scpi_fifo_t *)context->error_queue, err); + if (!fifo_add(&context->error_queue, err)) { + fifo_remove_last(&context->error_queue, NULL); + fifo_add(&context->error_queue, SCPI_ERROR_QUEUE_OVERFLOW); + } } struct error_reg { @@ -137,7 +133,7 @@ {-100, -199, ESR_CER}, /* Command error (e.g. syntax error) ch 21.8.9 */ {-200, -299, ESR_EER}, /* Execution Error (e.g. range error) ch 21.8.10 */ {-300, -399, ESR_DER}, /* Device specific error -300, -399 ch 21.8.11 */ - { 1,32767, ESR_DER}, /* Device designer provided specific error 1, 32767 ch 21.8.11 */ + { 1, 32767, ESR_DER}, /* Device designer provided specific error 1, 32767 ch 21.8.11 */ {-400, -499, ESR_QER}, /* Query error -400, -499 ch 21.8.12 */ {-500, -599, ESR_PON}, /* Power on event -500, -599 ch 21.8.13 */ {-600, -699, ESR_URQ}, /* User Request Event -600, -699 ch 21.8.14 */ @@ -156,17 +152,15 @@ SCPI_ErrorAddInternal(context, err); - for(i = 0; i < ERROR_DEFS_N; i++) { + for (i = 0; i < ERROR_DEFS_N; i++) { if ((err <= errs[i].from) && (err >= errs[i].to)) { SCPI_RegSetBits(context, SCPI_REG_ESR, errs[i].bit); } } - if (context) { - if (context->interface && context->interface->error) { - context->interface->error(context, err); - } + SCPI_ErrorEmit(context, err); + if (context) { context->cmd_error = TRUE; } } @@ -179,19 +173,20 @@ const char * SCPI_ErrorTranslate(int16_t err) { switch (err) { case 0: return "No error"; -#if ((USED_SCPI_ERROR_LIST == ERR_SCPI_MINIMUM) || (USED_SCPI_ERROR_LIST == ERR_SCPI_FULL)) - #define X(def, val, str) case def: return str; - LIST_OF_ERRORS - #undef X -#elif ((USED_SCPI_ERROR_LIST == ERR_SCPI_MIN_PLUS_USER) || (USED_SCPI_ERROR_LIST == ERR_SCPI_FULL_PLUS_USER)) - #define X(def, val, str) case def: return str; - LIST_OF_ERRORS - LIST_OF_USER_ERRORS - #undef X +#define X(def, val, str) case def: return str; +#if USE_FULL_ERROR_LIST +#define XE X #else -#error no SCPI error list defined! +#define XE(def, val, str) #endif - default: return "Unknown error"; + LIST_OF_ERRORS + +#if USE_USER_ERROR_LIST + LIST_OF_USER_ERRORS +#endif +#undef X +#undef XE + default: return "Unknown error"; } } -- Gitblit v1.9.1