summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--receiver/msg-format.vala5
-rw-r--r--receiver/socket.vala105
2 files changed, 110 insertions, 0 deletions
diff --git a/receiver/msg-format.vala b/receiver/msg-format.vala
new file mode 100644
index 0000000..727707c
--- /dev/null
+++ b/receiver/msg-format.vala
@@ -0,0 +1,5 @@
+public enum Command {
+ SetEngineSpeed,
+ SetEngineSpeedAll,
+ Shutdown
+}
diff --git a/receiver/socket.vala b/receiver/socket.vala
new file mode 100644
index 0000000..27f02f7
--- /dev/null
+++ b/receiver/socket.vala
@@ -0,0 +1,105 @@
+/* Copyright 2012, Sebastian Reichel <sre@ring0.de>
+ *
+ * Permission to use, copy, modify, and/or distribute this software for any
+ * purpose with or without fee is hereby granted, provided that the above
+ * copyright notice and this permission notice appear in all copies.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
+ * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
+ * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
+ * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
+ * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
+ * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
+ * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
+ */
+
+public class RPCServer {
+ SocketService srv;
+
+ public RPCServer(uint16 port) throws Error {
+ srv = new SocketService();
+ srv.add_inet_port(port, null);
+ srv.incoming.connect(on_incoming_connection);
+ srv.start();
+ }
+
+ bool on_incoming_connection(SocketConnection con) {
+ stdout.printf("Got incoming connection\n");
+ process_request(con);
+ return true;
+ }
+
+ void process_request(SocketConnection con) {
+ var dis = new DataInputStream(con.input_stream);
+ var dos = new DataOutputStream(con.output_stream);
+ bool exit = false;
+
+ try {
+ while(!exit) {
+ size_t length;
+ string message = dis.read_line(out length);
+
+ if(length > 0) {
+ var pkg = new Variant.parsed(message);
+
+ var cmd = pkg.get_child_value(0).get_byte();
+ switch(cmd) {
+ case Command.SetEngineSpeed:
+ var engine = pkg.get_child_value(1).get_byte();
+ var speed = pkg.get_child_value(2).get_byte();
+ stdout.printf("set engine speed: %d = %d\n", engine, speed);
+ set_speed(engine, speed);
+ break;
+ case Command.SetEngineSpeedAll:
+ var speed = pkg.get_child_value(1).get_byte();
+ stdout.printf("set engine speed of all engines: %d\n", speed);
+ set_speed_all(speed);
+ break;
+ default:
+ stdout.printf("Unknown Command: %s\n".printf(pkg.print(false)));
+ break;
+ }
+
+ dos.put_string("OK\n");
+ } else {
+ exit = true;
+ }
+ }
+ } catch(Error e) {
+ stderr.printf("%s\n", e.message);
+ }
+ }
+
+ public signal void set_speed(uint8 engine, uint8 speed);
+ public signal void set_speed_all(uint8 speed);
+}
+
+public class Socket : Receiver {
+ int32 channel_data[4];
+ RPCServer srv;
+
+ public override uint8 size {
+ get { return (uint8) channel_data.length; }
+ }
+
+ public override void init(KeyFile cfg) throws Error {
+ uint16 port = (uint16) cfg.get_uint64("Socket", "port");
+ srv = new RPCServer(port);
+
+ srv.set_speed_all.connect((speed) => {channel_data[0] = speed;});
+ }
+
+ public override int32 get_value(uint8 channel) {
+ return channel_data[channel];
+ }
+
+ public override void set_value(uint8 channel, int32 value) {
+ /* TODO */
+ }
+}
+
+public Type register_plugin(Module module) {
+ // types are registered automatically
+ typeof(RPCServer);
+ return typeof(Socket);
+}