X-Git-Url: http://git.droids-corp.org/?a=blobdiff_plain;ds=sidebyside;f=commands.c;h=cf060fc902fc3d77eca8c26e5f87b8b09d614b33;hb=3abe93f4b90cf10d3d29dcb48e90dd65353e0bc5;hp=54e56d70fc88a04ebac813d34ec9b1822dea9b97;hpb=a53014b7f52462e163a7d7ac64866aa75977422f;p=protos%2Fxbee-avr.git

diff --git a/commands.c b/commands.c
index 54e56d7..cf060fc 100644
--- a/commands.c
+++ b/commands.c
@@ -36,14 +36,15 @@
 #include <parse_num.h>
 #include <uart.h>
 #include <xbee.h>
+#include <callout.h>
 
-#include "callout.h"
 #include "parse_atcmd.h"
 #include "parse_neighbor.h"
 #include "parse_monitor.h"
 
 #include "spi_servo.h"
 #include "rc_proto.h"
+#include "xbee_user.h"
 #include "main.h"
 #include "cmdline.h"
 #include "beep.h"
@@ -532,9 +533,15 @@ struct cmd_sendmsg_result {
 static void cmd_sendmsg_parsed(void *parsed_result, void *data)
 {
 	struct cmd_sendmsg_result *res = parsed_result;
+	struct xbee_msg msg;
 
 	(void)data;
-	xbeeapp_send_msg(res->addr, res->data, strlen(res->data), 1);
+
+	msg.iovlen = 1;
+	msg.iov[0].buf = res->data;
+	msg.iov[0].len = strlen(res->data);
+
+	xbeeapp_send_msg(res->addr, &msg, 1);
 }
 
 const char PROGMEM str_sendmsg[] = "sendmsg";
@@ -675,9 +682,15 @@ struct cmd_sendmsg_name_result {
 static void cmd_sendmsg_name_parsed(void *parsed_result, void *data)
 {
 	struct cmd_sendmsg_name_result *res = parsed_result;
+	struct xbee_msg msg;
 
 	(void)data;
-	xbeeapp_send_msg(res->neigh->addr, res->data, strlen(res->data), 1);
+
+	msg.iovlen = 1;
+	msg.iov[0].buf = res->data;
+	msg.iov[0].len = strlen(res->data);
+
+	xbeeapp_send_msg(res->neigh->addr, &msg, 1);
 }
 
 const parse_token_string_t PROGMEM cmd_sendmsg_name_sendmsg_name =
@@ -740,18 +753,18 @@ static void cmd_range_parsed(void *parsed_result, void *data)
 			return;
 		}
 		range_cur_count = range_count;
-		callout_init(&range_event, range_cb, NULL, 0);
-		callout_schedule(&xbeeboard.mainloop_cm,
-			&range_event, 0); /* immediate */
+		callout_init(&range_event, range_cb, NULL, LOW_PRIO);
 		range_running = 1;
+		callout_schedule(&xbeeboard.intr_cm,
+			&range_event, 0); /* immediate */
 	}
 	else if (!strcmp(res->action, "end")) {
 		if (range_running == 0) {
 			printf_P(PSTR("not running\r\n"));
 			return;
 		}
+		callout_stop(&xbeeboard.intr_cm, &range_event);
 		range_running = 0;
-		callout_stop(&xbeeboard.mainloop_cm, &range_event);
 	}
 }
 
@@ -990,11 +1003,11 @@ static void cmd_monitor_parsed(void *parsed_result, void *data)
 			printf_P(PSTR("no regs to be monitored\r\n"));
 			return;
 		}
-		callout_init(&monitor_event, monitor_cb, NULL, 0);
-		callout_schedule(&xbeeboard.mainloop_cm,
-			&monitor_event, 0); /* immediate */
+		callout_init(&monitor_event, monitor_cb, NULL, 1);
 		monitor_running = 1;
 		monitor_current = LIST_FIRST(&xbee_monitor_list);
+		callout_schedule(&xbeeboard.intr_cm,
+			&monitor_event, 0); /* immediate */
 		printf_P(PSTR("monitor cb: %S %s\r\n"),
 			 monitor_current->desc,
 			 monitor_current->atcmd);
@@ -1005,8 +1018,8 @@ static void cmd_monitor_parsed(void *parsed_result, void *data)
 			printf_P(PSTR("not running\r\n"));
 			return;
 		}
+		callout_stop(&xbeeboard.intr_cm, &monitor_event);
 		monitor_running = 0;
-		callout_stop(&xbeeboard.mainloop_cm, &monitor_event);
 	}
 }
 
@@ -1169,7 +1182,7 @@ static void cmd_monitor_del_parsed(void *parsed_result, void *data)
 	monitor_count --;
 	if (monitor_count == 0) {
 		printf_P(PSTR("Disable monitoring, no more event\r\n"));
-		callout_stop(&xbeeboard.mainloop_cm, &monitor_event);
+		callout_stop(&xbeeboard.intr_cm, &monitor_event);
 		monitor_running = 0;
 		return;
 	}
@@ -1247,6 +1260,11 @@ static void cmd_raw_parsed(void *parsed_result, void *data)
 {
 	(void)parsed_result;
 	(void)data;
+
+	if (range_running || monitor_running) {
+		printf_P(PSTR("stop running range or monitor first\r\n"));
+		return;
+	}
 	printf_P(PSTR("switched to raw mode, CTRL-D to exit\r\n"));
 	rdline_stop(&xbeeboard.rdl); /* don't display prompt when return */
 	xbee_raw = 1;