From 455ec5acf279f8e3cfbe84ad46886f0f045ca9a8 Mon Sep 17 00:00:00 2001
From: Michael DM Dryden <mdryden@chem.utoronto.ca>
Date: Tue, 16 May 2017 20:16:40 -0400
Subject: [PATCH] Switch to new communications protocol.
---
src/config/conf_board.h | 2 ++
src/experiment.c | 34 ++++++++++++++---------
src/experiment.h | 2 +-
src/main.c | 61 ++++++++++++++++++++++++++++++++++-------
src/settings.c | 6 ++--
src/settings.h | 2 +-
6 files changed, 79 insertions(+), 28 deletions(-)
diff --git a/src/config/conf_board.h b/src/config/conf_board.h
index 94192c6..37265f9 100644
--- a/src/config/conf_board.h
+++ b/src/config/conf_board.h
@@ -19,6 +19,8 @@
#define LED2 IOPORT_CREATE_PIN(PORTF,6)
#endif
+#define MAX_COMMAND_BYTES 64
+
// Default Settings (only used if EEPROM is empty)
#define SETTINGS_MAX5443_OFFSET 0
#define SETTINGS_TCS_ENABLED 1
diff --git a/src/experiment.c b/src/experiment.c
index 635a17a..ab6bc8b 100644
--- a/src/experiment.c
+++ b/src/experiment.c
@@ -20,6 +20,7 @@
#include "tcs.h"
#include "config/conf_board.h"
#include "shutter.h"
+#include <util/atomic.h>
//Public variable definitions
uint16_t g_gain = POT_GAIN_30k;
@@ -57,7 +58,7 @@ typedef void (*port_callback_t) (void);
static port_callback_t portd_int0_callback;
static port_callback_t portd_int1_callback;
-void experiment_handler(char command){
+void experiment_handler(char command[]){
static int16_t p1, p2, p3;
static uint16_t u1, u2, u3, u4;
static uint8_t p5, o1, o2, o3;
@@ -66,40 +67,41 @@ void experiment_handler(char command){
uint16_t tcs_data[] = {0,0,0,0};
uint16_t tcs_data1[] = {0,0,0,0};
double p6;
-
- switch (command){
+
+
+ switch (command[0]){
case 'A': //ADS Buffer/rate/PGA values from ads1255.h
- scanf("%hhx%hhx%hhx",&o1,&o2,&o3);
+ sscanf(command+1, "%hhx%hhx%hhx",&o1,&o2,&o3);
printf("#A: %x %x %x\n",o1,o2,o3);
ads1255_setup(o1, o2, o3);
break;
case 'G': //Gain
- scanf("%u%hhu",&g_gain, &g_short);
+ sscanf(command+1, "%u%hhu",&g_gain, &g_short);
printf("#G: %u %u\n", g_gain, g_short);
pot_set_gain(); //uses global g_gain, so no params
break;
case 'L': //LSV - start, stop, slope
- scanf("%u%u%i%i%i%i%u",&pct1,&pct2,&pcv1,&pcv2,&p1,&p2,&u1);
+ sscanf(command+1, "%u%u%i%i%i%i%u",&pct1,&pct2,&pcv1,&pcv2,&p1,&p2,&u1);
precond(pcv1,pct1,pcv2,pct2);
lsv_experiment(p1,p2,u1,2);
break;
case 'C': //CV - v1, v2, start, scans, slope
- scanf("%u%u%i%i%i%i%i%hhu%u",&pct1,&pct2,&pcv1,&pcv2,&p1,&p2,&p3,&p5,&u1);
+ sscanf(command+1, "%u%u%i%i%i%i%i%hhu%u",&pct1,&pct2,&pcv1,&pcv2,&p1,&p2,&p3,&p5,&u1);
precond(pcv1,pct1,pcv2,pct2);
cv_experiment(p1,p2,p3,p5,u1);
break;
case 'S': //SWV - start, stop, step size, pulse_height, frequency, scans
- scanf("%u%u%i%i%i%i%u%u%u%u",&pct1,&pct2,&pcv1,&pcv2,&p1,&p2,&u1,&u2,&u3,&u4);
+ sscanf(command+1, "%u%u%i%i%i%i%u%u%u%u",&pct1,&pct2,&pcv1,&pcv2,&p1,&p2,&u1,&u2,&u3,&u4);
precond(pcv1,pct1,pcv2,pct2);
swv_experiment(p1,p2,u1,u2,u3,u4);
break;
case 'D': //DPV - start, stop, step size, pulse_height, period, width
- scanf("%u%u%i%i%i%i%u%u%u%u",&pct1,&pct2,&pcv1,&pcv2,&p1,&p2,&u1,&u2,&u3,&u4);
+ sscanf(command+1, "%u%u%i%i%i%i%u%u%u%u",&pct1,&pct2,&pcv1,&pcv2,&p1,&p2,&u1,&u2,&u3,&u4);
precond(pcv1,pct1,pcv2,pct2);
dpv_experiment(p1,p2,u1,u2,u3,u4);
break;
@@ -110,13 +112,14 @@ void experiment_handler(char command){
#if BOARD_VER_MAJOR == 1 && BOARD_VER_MINOR >= 2
case 'P': //potentiometry - time, OCP/poteniometry
- scanf("%u%hhu",&pct1, &o1);
+ sscanf(command+1, "%u%hhu",&pct1, &o1);
pot_experiment(pct1, o1);
break;
#endif
case 'R': //CA - steps, step_dac[], step_seconds[]
- scanf("%hhu",&p5); //get number of steps
+ {
+ sscanf(command+1, "%hhu%hhu",&p5, &o1); //get number of steps
printf("#INFO: Steps: %u\n", p5);
//allocate arrays for steps
@@ -129,6 +132,9 @@ void experiment_handler(char command){
break;
}
+ //request additional parameters from computer
+ printf("@RQP %u\n", 2*(uint16_t)p5);
+
uint8_t i;
for (i=0; i<p5; i++){
@@ -141,7 +147,8 @@ void experiment_handler(char command){
printf("#INFO: Time: %u\n", step_seconds[i]);
}
- scanf("%hhu", &o1);
+ printf("@RCP %u\n", 2*(uint16_t)p5);
+
printf("#INFO: TCS_check: %hhu\n", o1);
if (o1 > 0) {
if (settings.settings.tcs_enabled > 0){
@@ -174,9 +181,10 @@ void experiment_handler(char command){
free(step_seconds);
break;
+ }
case 'Z': //Shutter sync
- scanf("%lg",&p6);
+ sscanf(command+1, "%lg", &p6);
shutter_cont(p6);
break;
diff --git a/src/experiment.h b/src/experiment.h
index 83e7fce..a410b82 100644
--- a/src/experiment.h
+++ b/src/experiment.h
@@ -86,7 +86,7 @@ extern uint8_t g_short;
extern uint8_t autogain_enable;
uint16_t set_timer_period(uint32_t period, volatile void *tc);
-void experiment_handler(char command);
+void experiment_handler(char command[]);
void pot_init(void);
void pot_set_gain(void);
void volt_exp_start(void);
diff --git a/src/main.c b/src/main.c
index d447e5c..de021da 100644
--- a/src/main.c
+++ b/src/main.c
@@ -15,25 +15,56 @@
#include <stdint.h>
#include "conf_board.h"
#include "ext_twi.h"
+#include <util/atomic.h>
//Internal function declarations
-int8_t command_handler(char command);
+static void command_handler(uint16_t bytes);
-int8_t command_handler(char command){
+static void command_handler(uint16_t bytes){
/**
* Deals with commands over USB
*
* Calls functions in
* @param command Command character input.
+ * @param bytes Number of command bytes to wait for
*/
-
+
+ if (bytes == 0) {
+ printf("@RCV 0\n");
+ return;
+ }
+ else if (bytes >= MAX_COMMAND_BYTES){
+ printf("@ERR Command too long\n");
+ return;
+ }
+
+ char command_buffer[MAX_COMMAND_BYTES];
+
+read_data:
+ while (!udi_cdc_is_rx_ready());
+ delay_ms(100);
+ if(!fgets(command_buffer, MAX_COMMAND_BYTES, stdin)){
+ printf("@ERR Could not read string\n");
+ return;
+ }
+
+ command_buffer[strcspn(command_buffer, "\r\n")] = 0;
+
+ if (strlen(command_buffer) == 0)
+ goto read_data;
+
+ printf("@RCV %u\n", strlen(command_buffer));
+ printf("#%s\n", command_buffer);
+
+ char command = command_buffer[0];
+
switch (command){
case 'E': //Experiment options
- experiment_handler(getchar());
+ experiment_handler(command_buffer+1);
break;
case 'S': //Settings options
- settings_handler(getchar());
+ settings_handler(command_buffer+1);
break;
case 'T': ;
@@ -62,8 +93,8 @@ int8_t command_handler(char command){
printf("@ERR Command %c not recognized\n", command);
return;
}
- printf("no\n\r");
- return 0;
+ printf("@DONE\n");
+ return;
}
int main(void){
@@ -121,15 +152,25 @@ int main(void){
udc_attach();
stdio_usb_enable();
+ uint16_t bytes_sent = 0;
+
program_loop:
#if BOARD_VER_MAJOR >= 1 && BOARD_VER_MINOR >= 2 && BOARD_VER_MICRO >=3
ioport_set_pin_level(LED1, 1);
#endif
- while(getchar() != '!');
- printf ("C\r\n");
+ while (getchar() != '!');
+ scanf("%u", &bytes_sent);
+
+
+// // Empty buffer
+// while (udi_cdc_is_rx_ready())
+// udi_cdc_getc();
+
+ printf ("@ACK %u\n", bytes_sent);
#if BOARD_VER_MAJOR >= 1 && BOARD_VER_MINOR >= 2 && BOARD_VER_MICRO >=3
ioport_set_pin_level(LED1, 0);
#endif
- command_handler(getchar());
+
+ command_handler(bytes_sent);
goto program_loop;
}
diff --git a/src/settings.c b/src/settings.c
index d2ee064..a03a25b 100644
--- a/src/settings.c
+++ b/src/settings.c
@@ -16,8 +16,8 @@
void update_firmware(void);
-void settings_handler(char command){
- switch (command){
+void settings_handler(char command[]){
+ switch (command[0]){
case 'D': //Reset defaults
settings_restore_defaults();
break;
@@ -31,7 +31,7 @@ void settings_handler(char command){
break;
case 'W': //Write new settings
- scanf("%i%hhu%u%i%i%i%i%i%i%i%lu%lu",
+ sscanf(command+1, "%i%hhu%u%i%i%i%i%i%i%i%lu%lu",
&settings.settings.max5443_offset,
&settings.settings.tcs_enabled,
&settings.settings.tcs_clear_threshold,
diff --git a/src/settings.h b/src/settings.h
index 98e53ca..b2b5091 100644
--- a/src/settings.h
+++ b/src/settings.h
@@ -38,7 +38,7 @@ union {
char temp_char[EEPROM_PAGE_SIZE]; //makes sure struct fills whole page
} settings;
-void settings_handler(char command);
+void settings_handler(char command[]);
void settings_read_eeprom(void);
void settings_write_eeprom(void);
void settings_restore_defaults(void);
--
GitLab