Fixed Sub

mqtt.SYM

@@ -1,4 +1,4 @@
-;Version=2
-;ProjectId=154213
-;Checksum=0
-;Filesize=0
+;Version=2
+;ProjectId=1464572
+;Checksum=0
+;Filesize=0

mqtt.c

@@ -1,121 +1,95 @@
-#include "C:\Users\wim\Source\spikes\mqtt\mqtt.h"
-
-
-/* The implemenation templates */
-BOOL BUFFERinit(BUFFERtyp* inst, BOOL bRetain)
-{
-	int j, k, l; /* Loop counters */
-	for (j = 0; j < 1501; j++)
-	{
-			(*((inst->DATA) + j)) = 0;
-	}
-	inst->IPOS = 0UL;
-	return bRetain;
-}
-
-BOOL _BUFFER_CONCAT(BUFFERtyp *PTparam, BUFFERtyp *PTCONTACTparam)
-{
-}
-
-BOOL _BUFFER_PUSH(BUFFERtyp *PTparam, BYTE INparam)
-{
-}
-
-BOOL _BUFFER_PUSH_STRING(BUFFERtyp *PTparam, char* INparam, BOOL INCLUDE_LENGTHparam)
-{
-}
-
-BOOL _BUFFER_SET(BUFFERtyp *PTparam, BYTE INparam, WORD POSparam)
-{
-}
-
-BOOL FIXEDHEADERinit(FIXEDHEADERtyp* inst, BOOL bRetain)
-{
-	int j, k, l; /* Loop counters */
-	inst->BMESSAGETYPE = 0;
-	inst->XDUP_FLAG = FALSE;
-	inst->XQOS = 0;
-	inst->XRETAIN = FALSE;
-	return bRetain;
-}
-
-BOOL CREATE_MESSAGE(BUFFERtyp *PTparam, FIXEDHEADERtyp FIXEDHEADERparam, BUFFERtyp VARIABLEHEADERparam, BUFFERtyp PAYLOADparam)
-{
-}
-
-BOOL ENCODE_REMAINING_LENGTH(BUFFERtyp *PTparam, DWORD LENGTHparam)
-{
-}
-
-BOOL CONNECTFLAGSinit(CONNECTFLAGStyp* inst, BOOL bRetain)
-{
-	int j, k, l; /* Loop counters */
-	inst->XUSERNAME = FALSE;
-	inst->XPASSWORD = FALSE;
-	inst->XWILLRETAIN = FALSE;
-	inst->XWILLQOS1 = FALSE;
-	inst->XWILLQOS2 = FALSE;
-	inst->XWILLFLAG = FALSE;
-	inst->XCLEANSESSION = FALSE;
-	return bRetain;
-}
-
-void MQTT_CLIENT(MQTT_CLIENTtyp* inst)
-{
-}
-
-BOOL MQTT_CLIENTinit(MQTT_CLIENTtyp* inst, BOOL bRetain)
-{
-	int j, k, l; /* Loop counters */
-	/* Initializing Function Block components */
-	inst->VERSION = 3;
-	inst->RESERVED = 0;
-	inst->CONNECT = 1;
-	inst->CONNACK = 2;
-	inst->PUBLISH = 3;
-	inst->PUBACK = 4;
-	inst->PUBREC = 5;
-	inst->PUBREL = 6;
-	inst->PUBCOMP = 7;
-	inst->SUBSCRIBE = 8;
-	inst->SUBACK = 9;
-	inst->UNSUBSCRIBE = 10;
-	inst->UNSUBACK = 11;
-	inst->PINGREQ = 12;
-	inst->PINGRESP = 13;
-	inst->DISCONNECT = 14;
-	inst->RESERVED2 = 15;
-	inst->CONNECTED = 30;
-	inst->NOT_CONNECTED = 40;
-	inst->TIMEOUT = 50;
-	inst->WAIT_RESPONSE = 60;
-	inst->CONNECTION_TIMEOUT = 10000UL;
-	BUFFERinitmac(&inst->SENDBUFFER, bRetain);
-	BUFFERinitmac(&inst->RECEIVEBUFFER, bRetain);
-	FIXEDHEADERinitmac(&inst->FIXEDHEADER, bRetain);
-	BUFFERinitmac(&inst->VARIABLEHEADER, bRetain);
-	BUFFERinitmac(&inst->PAYLOAD, bRetain);
-	CONNECTFLAGSinitmac(&inst->CONNECTFLAGS, bRetain);
-	TCP_CLIENTinitmac(&inst->TCPCLIENT, bRetain);
-	inst->XTCPCONNECTED = FALSE;
-	inst->XSTARTSEND = FALSE;
-	inst->DIRECEIVECOUNT = 0L;
-	TONinitmac(&inst->CONNECTIONTIMER, bRetain);
-	inst->XTIMEOUT = FALSE;
-	inst->INCOMINGMESSAGETYPE = 0;
-	inst->ESTATE = 0;
-	inst->XSTARTTIMER = FALSE;
-	(*pstrcpy)(inst->STOPIC, "");
-	(*pstrcpy)(inst->SPAYLOAD, "");
-	inst->XCONNECTED = FALSE;
-	if (bRetain)
-		return bRetain;
-
-	/* Initalize the retain variables only if bRetain is FALSE */
-	return bRetain;
-}
-
-void PLC_PRG(void)
-{
-}
-
+#include "C:\users\oedemis\Desktop\Master\implementations\Clients\ownimplementation\own\mqtt.h"
+
+
+/* The implemenation templates */
+BOOL BUFFERinit(BUFFERtyp* inst, BOOL bRetain)
+{
+	int j; /* Loop counter */
+	for (j = 0; j < 1501; j++)
+	{
+			(*((inst->DATA) + j)) = 0;
+	}
+	inst->IPOS = 0UL;
+	return bRetain;
+}
+
+BOOL FIXEDHEADERinit(FIXEDHEADERtyp* inst, BOOL bRetain)
+{
+	inst->BMESSAGETYPE = 0;
+	inst->XDUP_FLAG = FALSE;
+	inst->XQOS = 0;
+	inst->XRETAIN = FALSE;
+	return bRetain;
+}
+
+BOOL CONNECTFLAGSinit(CONNECTFLAGStyp* inst, BOOL bRetain)
+{
+	inst->XUSERNAME = FALSE;
+	inst->XPASSWORD = FALSE;
+	inst->XWILLRETAIN = FALSE;
+	inst->XWILLQOS1 = FALSE;
+	inst->XWILLQOS2 = FALSE;
+	inst->XWILLFLAG = FALSE;
+	inst->XCLEANSESSION = FALSE;
+	return bRetain;
+}
+
+void MQTT_CLIENT(MQTT_CLIENTtyp* inst)
+{
+}
+
+BOOL MQTT_CLIENTinit(MQTT_CLIENTtyp* inst, BOOL bRetain)
+{
+	/* Initializing Function Block components */
+	inst->VERSION = 3;
+	inst->RESERVED = 0;
+	inst->CONNECT = 1;
+	inst->CONNACK = 2;
+	inst->PUBLISH = 3;
+	inst->PUBACK = 4;
+	inst->PUBREC = 5;
+	inst->PUBREL = 6;
+	inst->PUBCOMP = 7;
+	inst->SUBSCRIBE = 8;
+	inst->SUBACK = 9;
+	inst->UNSUBSCRIBE = 10;
+	inst->UNSUBACK = 11;
+	inst->PINGREQ = 12;
+	inst->PINGRESP = 13;
+	inst->DISCONNECT = 14;
+	inst->RESERVED2 = 15;
+	inst->CONNECTED = 30;
+	inst->NOT_CONNECTED = 40;
+	inst->TIMEOUT = 50;
+	inst->WAIT_RESPONSE = 60;
+	inst->CONNECTION_TIMEOUT = 10000UL;
+	BUFFERinitmac(&inst->SENDBUFFER, bRetain);
+	BUFFERinitmac(&inst->RECEIVEBUFFER, bRetain);
+	FIXEDHEADERinitmac(&inst->FIXEDHEADER, bRetain);
+	BUFFERinitmac(&inst->VARIABLEHEADER, bRetain);
+	BUFFERinitmac(&inst->PAYLOAD, bRetain);
+	CONNECTFLAGSinitmac(&inst->CONNECTFLAGS, bRetain);
+	TCP_CLIENTinitmac(&inst->TCPCLIENT, bRetain);
+	inst->XTCPCONNECTED = FALSE;
+	inst->XSTARTSEND = FALSE;
+	inst->DIRECEIVECOUNT = 0L;
+	TONinitmac(&inst->CONNECTIONTIMER, bRetain);
+	inst->XTIMEOUT = FALSE;
+	inst->INCOMINGMESSAGETYPE = 0;
+	inst->ESTATE = 0;
+	inst->XSTARTTIMER = FALSE;
+	(*pstrcpy)(inst->STOPIC, "");
+	(*pstrcpy)(inst->SPAYLOAD, "");
+	(*pstrcpy)(inst->SIP, "");
+	inst->WPORTNUMBER = 0;
+	(*pstrcpy)(inst->SUSERNAME, "");
+	(*pstrcpy)(inst->SPASSWORD, "");
+	inst->XCONNECTED = FALSE;
+	inst->XBUSY = FALSE;
+	if (bRetain)
+		return bRetain;
+
+	/* Initalize the retain variables only if bRetain is FALSE */
+	return bRetain;
+}
+