diff options
| -rw-r--r-- | src/common/include/message-buffer.h | 4 | ||||
| -rw-r--r-- | src/common/message-buffer.cpp | 6 | ||||
| -rw-r--r-- | src/server/service/service.cpp | 1 |
3 files changed, 9 insertions, 2 deletions
diff --git a/src/common/include/message-buffer.h b/src/common/include/message-buffer.h index 6e8830cf..cf740e04 100644 --- a/src/common/include/message-buffer.h +++ b/src/common/include/message-buffer.h @@ -1,5 +1,5 @@ /* - * Copyright (c) 2000 - 2016 Samsung Electronics Co., Ltd All Rights Reserved + * Copyright (c) 2000 - 2019 Samsung Electronics Co., Ltd All Rights Reserved * * Contact: Rafal Krypa <r.krypa@samsung.com> * @@ -49,6 +49,8 @@ public: void Push(const RawBuffer &data); + size_t SerializedSize(); + RawBuffer Pop(); bool Ready(); diff --git a/src/common/message-buffer.cpp b/src/common/message-buffer.cpp index 332dcc40..9b067383 100644 --- a/src/common/message-buffer.cpp +++ b/src/common/message-buffer.cpp @@ -1,5 +1,5 @@ /* - * Copyright (c) 2000 - 2014 Samsung Electronics Co., Ltd All Rights Reserved + * Copyright (c) 2000 - 2019 Samsung Electronics Co., Ltd All Rights Reserved * * Contact: Rafal Krypa <r.krypa@samsung.com> * @@ -32,6 +32,10 @@ void MessageBuffer::Push(const RawBuffer &data) { m_buffer.AppendCopy(&data[0], data.size()); } +size_t MessageBuffer::SerializedSize() { + return m_buffer.Size() + sizeof(size_t); +} + RawBuffer MessageBuffer::Pop() { size_t size = m_buffer.Size(); RawBuffer buffer; diff --git a/src/server/service/service.cpp b/src/server/service/service.cpp index cfcaedbf..d8818665 100644 --- a/src/server/service/service.cpp +++ b/src/server/service/service.cpp @@ -198,6 +198,7 @@ bool Service::processOne(const ConnectionID &conn, MessageBuffer &buffer, if (retval) { //send response + LogDebug("Writing response to client, size of serialized response: " << send.SerializedSize()); m_serviceManager->Write(conn, send.Pop()); } else { LogError("Closing socket because of error"); |