git-svn-id: svn://db.shs.com.ru/libs@94 a8b55f48-bf90-11e4-a774-851b48703e85

kx_utils/kx_protocol_c.h

@@ -0,0 +1,126 @@
+#ifndef KX_PROTOCOL_C_H
+#define KX_PROTOCOL_C_H
+
+#include "piprotocol.h"
+
+
+#pragma pack (push, 1)
+
+
+struct KX_C_Header {
+	uchar type;
+	uchar addr_to;
+};
+
+
+
+struct KX_C_Command: KX_C_Header {
+	KX_C_Command() {command = -1;}
+	int command;
+	uint checksum;
+};
+
+
+struct KX_C_Event: KX_C_Header {
+	KX_C_Event() {event = -1;}
+	PISystemTime time;
+	int event;
+	uint checksum;
+};
+
+
+#pragma pack (pop)
+
+
+// Client side
+
+class KX_Protocol_C: public PIProtocol
+{
+	PIOBJECT_SUBCLASS(KX_Protocol_C, PIProtocol)
+public:
+	KX_Protocol_C(const PIString & config, const PIString & name = "c"): PIProtocol(config, name, &from_buff, 2, &(from_buff.command), sizeof(from_buff) - 2, &to_pult, sizeof(to_pult)) {
+		PIConfig conf(config, PIIODevice::ReadOnly);
+		PIConfig::Entry ce = conf.getValue(name);
+		to_pult.type = from_buff.type = ce.getValue("type", 0xC);
+		to_pult.addr_to = ce.getValue("addr_pult", 0x15);
+		from_buff.addr_to = ce.getValue("addr_c", 0x75);
+		from_pult = from_buff;
+		packetExtractor()->setSplitMode(PIPacketExtractor::Header);
+		packetExtractor()->setHeader(PIByteArray(&from_buff, 2));
+		startReceive();
+	}
+
+	void sendEvent(int ev) {
+		to_pult.time = PISystemTime::current();
+		to_pult.event = ev;
+		send();
+	}
+	EVENT1(commandReceived, int, command)
+
+	KX_C_Command from_pult;
+	KX_C_Event to_pult;
+
+private:
+	bool validate() {
+		if (checksum_i(&from_buff, sizeof(from_buff) - 4) != from_buff.checksum) return false;
+		from_pult = from_buff;
+		commandReceived(from_pult.command);
+		return true;
+	}
+	bool aboutSend() {
+		to_pult.checksum = checksum_i(&to_pult, sizeof(to_pult) - 4);
+		return true;
+	}
+	
+	KX_C_Command from_buff;
+	
+};
+
+
+
+// Pult side
+
+class __KX_Protocol_C: public PIProtocol
+{
+	PIOBJECT_SUBCLASS(__KX_Protocol_C, PIProtocol)
+public:
+	__KX_Protocol_C(const PIString & config, const PIString & name): PIProtocol(config, name, &from_buff, 2, &(from_buff.time), sizeof(from_buff) - 2, &to_c, sizeof(to_c)) {
+		PIConfig conf(config, PIIODevice::ReadOnly);
+		PIConfig::Entry ce = conf.getValue(name);
+		to_c.type = from_buff.type = ce.getValue("type", 0xC);
+		to_c.addr_to = ce.getValue("addr_c", 0x75);
+		from_buff.addr_to = ce.getValue("addr_pult", 0x15);
+		from_c = from_buff;
+		packetExtractor()->setSplitMode(PIPacketExtractor::Header);
+		packetExtractor()->setHeader(PIByteArray(&from_buff, 2));
+		startReceive();
+	}
+
+	void sendCommand(int cmd) {
+		to_c.command = cmd;
+		send();
+	}
+	EVENT2(eventReceived, int, event, PISystemTime, time)
+
+	KX_C_Event from_c;
+	KX_C_Command to_c;
+
+private:
+	bool validate() {
+		if (checksum_i(&from_buff, sizeof(from_buff) - 4) != from_buff.checksum) return false;
+		from_c = from_buff;
+		eventReceived(from_c.event, from_c.time);
+		return true;
+	}
+	bool aboutSend() {
+		//piCout << "send command" << to_c.command;
+		to_c.checksum = checksum_i(&to_c, sizeof(to_c) - 4);
+		return true;
+	}
+	
+	KX_C_Event from_buff;
+	
+};
+
+
+#endif // KX_PROTOCOL_C_H