diff options
author | Kevin Rocard <kevinx.rocard@intel.com> | 2014-04-25 15:11:12 +0200 |
---|---|---|
committer | Mattijs Korpershoek <mattijsx.korpershoek@intel.com> | 2014-06-25 10:52:29 +0200 |
commit | e874c2575c1203648e71426cd34f747cbd34b2b4 (patch) | |
tree | e0d57fb36c4c77aeaca67f0f8b06d527fb82afbc /remote-processor/Message.cpp | |
parent | ef8d727ca0eb346af951d15d84ba6f2b9564adf5 (diff) | |
download | external_parameter-framework-e874c2575c1203648e71426cd34f747cbd34b2b4.zip external_parameter-framework-e874c2575c1203648e71426cd34f747cbd34b2b4.tar.gz external_parameter-framework-e874c2575c1203648e71426cd34f747cbd34b2b4.tar.bz2 |
remote-proccessor detect partial message reception
BZ: 190038
Client disconnection during message reception is normal if no part of the
message as been receive yet.
Client disconnection in the middle of a packet reception is not normal
but was not differentiated from the behaviour described above.
Do not consider client disconnection on first read as an error.
Consider it as an error on the followings.
Change-Id: I34b50ba0af800f9e1fcdb51996b1b2f02a23cb3f
Signed-off-by: Kevin Rocard <kevinx.rocard@intel.com>
Signed-off-by: Mattijs Korpershoek <mattijsx.korpershoek@intel.com>
Diffstat (limited to 'remote-processor/Message.cpp')
-rw-r--r-- | remote-processor/Message.cpp | 35 |
1 files changed, 20 insertions, 15 deletions
diff --git a/remote-processor/Message.cpp b/remote-processor/Message.cpp index db24d80..8591847 100644 --- a/remote-processor/Message.cpp +++ b/remote-processor/Message.cpp @@ -124,7 +124,7 @@ uint32_t CMessage::getRemainingDataSize() const } // Send/Receive -bool CMessage::serialize(CSocket* pSocket, bool bOut, string& strError) +CMessage::Result CMessage::serialize(CSocket* pSocket, bool bOut, string& strError) { if (bOut) { @@ -142,8 +142,10 @@ bool CMessage::serialize(CSocket* pSocket, bool bOut, string& strError) if (!pSocket->write(&uiSyncWord, sizeof(uiSyncWord))) { - strError += string("Sync write failed: ") + strerror(errno); - return false; + if (pSocket->hasPeerDisconnected()) { + return peerDisconnected; + } + return error; } // Size @@ -152,21 +154,21 @@ bool CMessage::serialize(CSocket* pSocket, bool bOut, string& strError) if (!pSocket->write(&uiSize, sizeof(uiSize))) { strError += string("Size write failed: ") + strerror(errno); - return false; + return error; } // Msg Id if (!pSocket->write(&_ucMsgId, sizeof(_ucMsgId))) { strError += string("Msg write failed: ") + strerror(errno); - return false; + return error; } // Data if (!pSocket->write(_pucData, _uiDataSize)) { strError = string("Data write failed: ") + strerror(errno); - return false; + return error; } // Checksum @@ -175,7 +177,7 @@ bool CMessage::serialize(CSocket* pSocket, bool bOut, string& strError) if (!pSocket->write(&ucChecksum, sizeof(ucChecksum))) { strError = string("Checksum write failed: ") + strerror(errno); - return false; + return error; } } else { @@ -185,14 +187,17 @@ bool CMessage::serialize(CSocket* pSocket, bool bOut, string& strError) if (!pSocket->read(&uiSyncWord, sizeof(uiSyncWord))) { strError = string("Sync read failed: ") + strerror(errno); - return false; + if (pSocket->hasPeerDisconnected()) { + return peerDisconnected; + } + return error; } // Check Sync word if (uiSyncWord != SYNC_WORD) { strError = "Sync word incorrect"; - return false; + return error; } // Size @@ -201,14 +206,14 @@ bool CMessage::serialize(CSocket* pSocket, bool bOut, string& strError) if (!pSocket->read(&uiSize, sizeof(uiSize))) { strError = string("Size read failed: ") + strerror(errno); - return false; + return error; } // Msg Id if (!pSocket->read(&_ucMsgId, sizeof(_ucMsgId))) { strError = string("Msg id read failed: ") + strerror(errno); - return false; + return error; } // Data @@ -220,7 +225,7 @@ bool CMessage::serialize(CSocket* pSocket, bool bOut, string& strError) if (!pSocket->read(_pucData, _uiDataSize)) { strError = string("Data read failed: ") + strerror(errno); - return false; + return error; } // Checksum @@ -229,20 +234,20 @@ bool CMessage::serialize(CSocket* pSocket, bool bOut, string& strError) if (!pSocket->read(&ucChecksum, sizeof(ucChecksum))) { strError = string("Checksum read failed: ") + strerror(errno); - return false; + return error; } // Compare if (ucChecksum != computeChecksum()) { strError = "Received checksum != computed checksum"; - return false; + return error; } // Collect data in derived collectReceivedData(); } - return true; + return success; } // Checksum |