Eric Jung
/
GMMP_mbed
Important changes to repositories hosted on mbed.com
Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.
To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.
It is also possible to export all your personal repositories from the account settings page.
Fork of
GMMP_mbed
by 
SKTelecom_ThingPlug
Diff: Operation/Reg/GMMP_Reg.cpp
- Revision:
- 0:7e575e5f88ec
diff -r 000000000000 -r 7e575e5f88ec Operation/Reg/GMMP_Reg.cpp
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/Operation/Reg/GMMP_Reg.cpp Sun Aug 09 14:11:35 2015 +0000
@@ -0,0 +1,172 @@
+#include "GMMP_Reg.h"
+
+//Request
+int GMMP_GW_Reg_Req(GwRegist_Req* pRegist_Req)
+{
+ debugln("GMMP_GW_Reg_Req()");
+ if(pRegist_Req == NULL)
+ {
+ return SERVER_INFO_NOT_FOUND;
+ }
+
+ if(CheckSocket() != 0)
+ {
+ return SERVER_INFO_NOT_FOUND;
+ }
+
+ return WriteTCP( (char*)pRegist_Req, sizeof(GwRegist_Req) );
+}
+
+int GMMP_GW_Reg_Rsp(GwRegist_Rsp* pRegist_Rsp)
+{
+ if(pRegist_Rsp == NULL)
+ {
+ return SERVER_INFO_NOT_FOUND;
+ }
+
+ if(CheckSocket() != 0)
+ {
+ return SERVER_INFO_NOT_FOUND;
+ }
+
+ int nRet = ReadTCP( (char*)&pRegist_Rsp->header , sizeof(pRegist_Rsp->header) );
+ if(nRet != GMMP_SUCCESS)
+ {
+ return nRet;
+ }
+
+ ConvertShort cvtshort;
+ cvtshort.sU8 = 0;
+ memcpy(cvtshort.usShort, pRegist_Rsp->header.usMessageLength, sizeof(pRegist_Rsp->header.usMessageLength) );
+
+ int nReadSize = ltobs(cvtshort.sU8)- sizeof(pRegist_Rsp->header);
+
+ return ReadTCP( (char*)&pRegist_Rsp->body, nReadSize);
+}
+
+int GMMP_Device_Reg_Req(DeviceRegist_Req* pRegist_Req)
+{
+ if(pRegist_Req == NULL)
+ {
+ return SERVER_INFO_NOT_FOUND;
+ }
+
+ if(CheckSocket() != 0)
+ {
+ return SERVER_INFO_NOT_FOUND;
+ }
+
+ return WriteTCP( (char*)pRegist_Req, sizeof(DeviceRegist_Req) );
+}
+
+int GMMP_Device_Reg_Rsp(DeviceRegist_Rsp* pRegist_Rsp)
+{
+ if(pRegist_Rsp == NULL)
+ {
+ return SERVER_INFO_NOT_FOUND;
+ }
+
+ if(CheckSocket() != 0)
+ {
+ return SERVER_INFO_NOT_FOUND;
+ }
+
+ int nRet = ReadTCP( (char*)&pRegist_Rsp->header , sizeof(pRegist_Rsp->header) );
+ if(nRet != GMMP_SUCCESS)
+ {
+ return nRet;
+ }
+
+ ConvertShort cvtshort;
+ cvtshort.sU8 = 0;
+ memcpy(cvtshort.usShort, pRegist_Rsp->header.usMessageLength, sizeof(pRegist_Rsp->header.usMessageLength) );
+
+ int nReadSize = ltobs(cvtshort.sU8)- sizeof(pRegist_Rsp->header);
+
+ return ReadTCP( (char*)&pRegist_Rsp->body, nReadSize);
+}
+
+
+int GMMP_GW_DeReg_Req(GwDeRegist_Req* pDeRegist_Req)
+{
+ if(pDeRegist_Req == NULL)
+ {
+ return SERVER_INFO_NOT_FOUND;
+ }
+
+ if(CheckSocket() != 0)
+ {
+ return SERVER_INFO_NOT_FOUND;
+ }
+
+ return WriteTCP( (char*)pDeRegist_Req, sizeof(GwDeRegist_Req) );
+}
+
+int GMMP_GW_DeReg_Rsp(GwDeRegist_Rsp* pDeRegist_Rsp)
+{
+ if(pDeRegist_Rsp == NULL)
+ {
+ return SERVER_INFO_NOT_FOUND;
+ }
+
+ if(CheckSocket() != 0)
+ {
+ return SERVER_INFO_NOT_FOUND;
+ }
+
+ int nRet = ReadTCP( (char*)&pDeRegist_Rsp->header , sizeof(pDeRegist_Rsp->header) );
+ if(nRet != GMMP_SUCCESS)
+ {
+ return nRet;
+ }
+
+ ConvertShort cvtshort;
+ cvtshort.sU8 = 0;
+ memcpy(cvtshort.usShort, pDeRegist_Rsp->header.usMessageLength, sizeof(pDeRegist_Rsp->header.usMessageLength) );
+
+ int nReadSize = ltobs(cvtshort.sU8)- sizeof(pDeRegist_Rsp->header);
+
+ return ReadTCP( (char*)&pDeRegist_Rsp->body, nReadSize);
+}
+
+int GMMP_Device_DeReg_Req(DeviceDeRegist_Req* pDeRegist_Req)
+{
+ if(pDeRegist_Req == NULL)
+ {
+ return SERVER_INFO_NOT_FOUND;
+ }
+
+ if(CheckSocket() != 0)
+ {
+ return SERVER_INFO_NOT_FOUND;
+ }
+
+ return WriteTCP( (char*)pDeRegist_Req, sizeof(DeviceDeRegist_Req) );
+}
+
+int GMMP_Device_DeReg_Rsp(DeviceDeRegist_Rsp* pDeRegist_Req)
+{
+ if(pDeRegist_Req == NULL)
+ {
+ return SERVER_INFO_NOT_FOUND;
+ }
+
+ if(CheckSocket() != 0)
+ {
+ return SERVER_INFO_NOT_FOUND;
+ }
+
+ int nRet = ReadTCP( (char*)&pDeRegist_Req->header , sizeof(pDeRegist_Req->header) );
+ if(nRet != GMMP_SUCCESS)
+ {
+ return nRet;
+ }
+
+ ConvertShort cvtshort;
+ cvtshort.sU8 = 0;
+ memcpy(cvtshort.usShort, pDeRegist_Req->header.usMessageLength, sizeof(pDeRegist_Req->header.usMessageLength) );
+
+ int nReadSize = ltobs(cvtshort.sU8)- sizeof(pDeRegist_Req->header);
+
+ return ReadTCP( (char*)&pDeRegist_Req->body, nReadSize);
+}