X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=modules%2Frpc%2Fsrc%2Fgeneric_rpc_connection.cpp;fp=modules_wearable%2Frpc%2Fsrc%2Fgeneric_rpc_connection.cpp;h=dbf790c09170192d9cc3d376bec3a591b5f59b37;hb=3a034abb4dca58ff0940687d8dd2b829ce2e226f;hp=6b16f2824677d2e559be79f452a882c23df87a27;hpb=58be0971049907f3166ce56a6ad509769565158f;p=framework%2Fweb%2Fwrt-commons.git diff --git a/modules_wearable/rpc/src/generic_rpc_connection.cpp b/modules/rpc/src/generic_rpc_connection.cpp similarity index 88% rename from modules_wearable/rpc/src/generic_rpc_connection.cpp rename to modules/rpc/src/generic_rpc_connection.cpp index 6b16f28..dbf790c 100644 --- a/modules_wearable/rpc/src/generic_rpc_connection.cpp +++ b/modules/rpc/src/generic_rpc_connection.cpp @@ -21,8 +21,7 @@ */ #include #include -#include -#include +#include #include #include @@ -56,22 +55,22 @@ GenericRPCConnection::GenericRPCConnection( AbstractWaitableInputOutput *inputOutput) : m_inputOutput(inputOutput) { - LogPedantic("Opening generic RPC..."); + WrtLogD("Opening generic RPC..."); WaitableInputOutputExecutionContextSupport::Open(inputOutput); - LogPedantic("Generic RPC opened"); + WrtLogD("Generic RPC opened"); } GenericRPCConnection::~GenericRPCConnection() { // Ensure RPC is closed - LogPedantic("Closing generic RPC..."); + WrtLogD("Closing generic RPC..."); WaitableInputOutputExecutionContextSupport::Close(); - LogPedantic("Generic RPC closed"); + WrtLogD("Generic RPC closed"); } void GenericRPCConnection::AsyncCall(const RPCFunction &function) { - LogPedantic("Executing async call"); + WrtLogD("Executing async call"); // Create binary call BinaryQueue serializedCall = function.Serialize(); @@ -98,7 +97,7 @@ void GenericRPCConnection::AsyncCall(const RPCFunction &function) void GenericRPCConnection::Ping() { - LogPedantic("Executing ping call"); + WrtLogD("Executing ping call"); // Append buffers Protocol::AsyncCall call; @@ -121,7 +120,7 @@ void GenericRPCConnection::Ping() void GenericRPCConnection::OnInputStreamRead() { - LogPedantic("Interpreting " << m_inputStream.Size() << " bytes buffer"); + WrtLogD("Interpreting %i bytes buffer", m_inputStream.Size()); // Enough bytes to read at least one header ? if (m_inputStream.Size() >= sizeof(Protocol::Header)) { @@ -133,7 +132,7 @@ void GenericRPCConnection::OnInputStreamRead() if (m_inputStream.Size() >= sizeof(Protocol::Header) + header.size) { - LogPedantic("Will parse packet of type: " << header.type); + WrtLogD("Will parse packet of type: %i", header.type); // Allocate new packet (header + real packet data) void *binaryPacket = malloc( @@ -164,9 +163,7 @@ void GenericRPCConnection::OnInputStreamRead() // ...but just remove protocol header call.Consume(sizeof(Protocol::Header)); - LogPedantic( - "Async call of size: " << header.size << - " parsed"); + WrtLogD("Async call of size: %i parsed", header.size); // Call async call event listeners DPL::Event::EventSupport