X-Git-Url: https://codewiz.org/gitweb?a=blobdiff_plain;f=app%2Ftriface%2Fprotocol.c;h=08910d0426e26b85b0caaaf6c7efa11f34bb9068;hb=cb475c2071d6be7048f8c5c06485b3cd8530708c;hp=50e0e3633dd5b95ab95a5e3e105d1cda8298e472;hpb=426bd82f4198f08f153ab222d71b8311194e5e39;p=bertos.git diff --git a/app/triface/protocol.c b/app/triface/protocol.c old mode 100755 new mode 100644 index 50e0e363..08910d04 --- a/app/triface/protocol.c +++ b/app/triface/protocol.c @@ -1,6 +1,31 @@ /** * \file * * @@ -14,19 +39,6 @@ * \author Bernardo Innocenti */ -/*#* - *#* $Log$ - *#* Revision 1.3 2006/06/13 19:07:31 marco - *#* Fixed a bug in protocol_reply. Simplified rpc. - *#* - *#* Revision 1.2 2006/06/12 21:37:02 marco - *#* implemented some commands (ver and sleep) - *#* - *#* Revision 1.1 2006/06/01 12:29:21 marco - *#* Add first simple protocol command (version request). - *#* - *#*/ - #include "protocol.h" #include @@ -37,10 +49,12 @@ #include #include +#include #include -#include +//#include +#include "cmd_ctor.h" // MAKE_CMD, REGISTER_CMD // DEBUG: set to 1 to force interactive mode #define FORCE_INTERACTIVE 1 @@ -61,6 +75,7 @@ static struct RLContext rl_ctx; /** * Send a NAK asking the host to send the current message again. * + * \param ser serial port handle to output to. * \param err human-readable description of the error for debug purposes. */ INLINE void NAK(Serial *ser, const char *err) @@ -76,32 +91,30 @@ INLINE void NAK(Serial *ser, const char *err) * Print args on s, with format specified in t->result_fmt. * Return number of valid arguments or -1 in case of error. */ -static int protocol_reply(Serial *s, const struct CmdTemplate *t, +static bool protocol_reply(Serial *s, const struct CmdTemplate *t, const parms *args) { unsigned short offset = strlen(t->arg_fmt) + 1; unsigned short nres = strlen(t->result_fmt); - if (nres > 0) + ser_printf(s, "0"); + for (unsigned short i = 0; i < nres; ++i) { - for (unsigned short i = 0; i < nres; ++i) + if (t->result_fmt[i] == 'd') { - if (t->result_fmt[i] == 'd') - { - ser_printf(s, "%ld", args[offset+i].l); - } - else if (t->result_fmt[i] == 's') - { - ser_printf(s, "%s ", args[offset+i].s); - } - else - { - return -1; - } + ser_printf(s, " %ld", args[offset+i].l); + } + else if (t->result_fmt[i] == 's') + { + ser_printf(s, " %s", args[offset+i].s); + } + else + { + abort(); } } - ser_print(s, "\r\n"); - return nres; + ser_printf(s, "\r\n"); + return true; } static void protocol_parse(Serial *ser, const char *buf) @@ -112,30 +125,27 @@ static void protocol_parse(Serial *ser, const char *buf) templ = parser_get_cmd_template(buf); if (!templ) { - NAK(ser, "Invalid command."); + ser_print(ser, "-1 Invalid command."); return; } parms args[PARSER_MAX_ARGS]; - /* Args Check. */ + /* Args Check. TODO: Handle different case. see doc/PROTOCOL . */ if (!parser_get_cmd_arguments(buf, templ, args)) { - NAK(ser, "Invalid arguments."); + ser_print(ser, "-2 Invalid arguments."); return; } /* Execute. */ - if (!parser_execute_cmd(templ, args)) + if(!parser_execute_cmd(templ, args)) { - NAK(ser, "Command failed."); + NAK(ser, "Error in executing command."); } - else + if (!protocol_reply(ser, templ, args)) { - if (protocol_reply(ser, templ, args) < 0) - { - NAK(ser, "Invalid return format."); - } + NAK(ser, "Invalid return format."); } return; } @@ -215,53 +225,40 @@ void protocol_run(Serial *ser) * */ -/* Version. */ - - -static ResultCode cmd_ver(parms *args) +/* Version. Example of declaring function and passing it to MAKE_CMD. */ +static int ver_fn(const char **str) { - args[1].s = VERS_TAG; + *str = VERS_TAG; return 0; } -const struct CmdTemplate cmd_ver_template = -{ - "ver", "", "s", cmd_ver, 0 -}; +MAKE_CMD(ver, "", "s", ver_fn(&args[1].s)) -/* Sleep. */ - -static ResultCode cmd_sleep(parms *args) -{ +/* Sleep. Example of declaring function body directly in macro call. */ +MAKE_CMD(sleep, "d", "", +({ timer_delay((mtime_t)args[1].l); - return 0; -} -const struct CmdTemplate cmd_sleep_template = -{ - "sleep", "d", "", cmd_sleep, 0 -}; + 0; +})) + +/* Ping. */ +MAKE_CMD(ping, "", "", +({ + 0; +})) /* Register commands. */ static void protocol_registerCmds(void) { -// parser_register_cmd(&CMD_HUNK_TEMPLATE(quit)); -// parser_register_cmd(&CMD_HUNK_TEMPLATE(exit)); -// parser_register_cmd(&CMD_HUNK_TEMPLATE(wait)); -// parser_register_cmd(&CMD_HUNK_TEMPLATE(delay)); -// parser_register_cmd(&CMD_HUNK_TEMPLATE(SYN)); -// parser_register_cmd(&CMD_HUNK_TEMPLATE(RST)); -// parser_register_cmd(&CMD_HUNK_TEMPLATE(skip_end)); -// parser_register_cmd(&CMD_HUNK_TEMPLATE(restart)); -// parser_register_cmd(&CMD_HUNK_TEMPLATE(ver)); -// parser_register_cmd(&CMD_HUNK_TEMPLATE(power_off)); - - parser_register_cmd(&cmd_ver_template); - parser_register_cmd(&cmd_sleep_template); + REGISTER_CMD(ver); + REGISTER_CMD(sleep); + REGISTER_CMD(ping); } + +/* Initialization: readline context, parser and register commands. */ void protocol_init(Serial *ser) { interactive = FORCE_INTERACTIVE; - // Initialize the readline context used for interactive mode rl_init_ctx(&rl_ctx); rl_setprompt(&rl_ctx, ">> "); rl_sethook_get(&rl_ctx, (getc_hook)ser_getchar, ser);