diff rvinterf/lowlevel/clientcmd.c @ 0:e7502631a0f9

initial import from freecalypso-sw rev 1033:5ab737ac3ad7
author Mychaela Falconia <falcon@freecalypso.org>
date Sat, 11 Jun 2016 00:13:35 +0000
parents
children
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/rvinterf/lowlevel/clientcmd.c	Sat Jun 11 00:13:35 2016 +0000
@@ -0,0 +1,89 @@
+/*
+ * This rvinterf module implements the handling of client commands.
+ */
+
+#include <sys/types.h>
+#include <stdio.h>
+#include <string.h>
+#include <strings.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include "../include/pktmux.h"
+#include "../include/limits.h"
+#include "../include/localsock.h"
+#include "client.h"
+
+void
+process_msg_from_client(cli)
+	struct client *cli;
+{
+	int c;
+
+	switch (cli->rx_buf[0]) {
+	case CLI2RVI_WANT_RVTRACE:
+		if (cli->rx_msglen != 9) {
+			send_local_msg_to_client(cli, "-Bad command length");
+			return;
+		}
+		c = cli->int_rvt_count;
+		if (c >= MAX_RVT_INTEREST) {
+			send_local_msg_to_client(cli,
+					"-Error: too many RVT interests");
+			return;
+		}
+		cli->int_rvt_mask[c] = cli->rx_buf[1] << 24 |
+					cli->rx_buf[2] << 16 |
+					cli->rx_buf[3] << 8 | cli->rx_buf[4];
+		cli->int_rvt_match[c] = cli->rx_buf[5] << 24 |
+					cli->rx_buf[6] << 16 |
+					cli->rx_buf[7] << 8 | cli->rx_buf[8];
+		cli->int_rvt_count++;
+		send_local_msg_to_client(cli, "+OK");
+		return;
+	case CLI2RVI_WANT_MUXPROTO:
+		if (cli->rx_msglen != 2) {
+			send_local_msg_to_client(cli, "-Bad command length");
+			return;
+		}
+		if (cli->rx_buf[1] < 0x12 || cli->rx_buf[1] > 0x1D) {
+			send_local_msg_to_client(cli,
+					"-Unsupported protocol MUX value");
+			return;
+		}
+		cli->int_proto[cli->rx_buf[1] - 0x12] = 1;
+		send_local_msg_to_client(cli, "+OK");
+		return;
+	case CLI2RVI_DROP_MUXPROTO:
+		if (cli->rx_msglen != 2) {
+			send_local_msg_to_client(cli, "-Bad command length");
+			return;
+		}
+		if (cli->rx_buf[1] < 0x12 || cli->rx_buf[1] > 0x1D) {
+			send_local_msg_to_client(cli,
+					"-Unsupported protocol MUX value");
+			return;
+		}
+		cli->int_proto[cli->rx_buf[1] - 0x12] = 0;
+		send_local_msg_to_client(cli, "+OK");
+		return;
+	case CLI2RVI_RESET_PACKET_RX:
+		cli->int_rvt_count = 0;
+		bzero(cli->int_proto, sizeof(cli->int_proto));
+		send_local_msg_to_client(cli, "+OK");
+		return;
+	case CLI2RVI_PKT_TO_TARGET:
+		c = cli->rx_msglen - 1;
+		if (c < 1 || c > MAX_PKT_TO_TARGET) {
+			send_local_msg_to_client(cli,
+						 "-Invalid Tx packet length");
+			return;
+		}
+		send_pkt_to_target(cli->rx_buf + 1, c);
+		log_sent_packet(cli->rx_buf + 1, c);
+		return;
+	case CLI2RVI_RAWBYTES_TO_TARGET:
+		/* To be implemented */
+	default:
+		send_local_msg_to_client(cli, "-Unimplemented command");
+	}
+}