* ipc_acessipcpipe.c
* - Acess2 /Devices/ipcpipe/ IPC Channel
*/
+#include "include/common.hpp"
#include "include/CIPCChannel_AcessIPCPipe.hpp"
#include <system_error>
#include <cerrno>
{
if( FD_ISSET(m_fd, &fds) )
{
+ ::std::vector<uint8_t> rxbuf(4096);
+ size_t len = _SysRead(m_fd, rxbuf.data(), rxbuf.capacity());
+ if( len == (size_t)-1 )
+ throw ::std::system_error(errno, ::std::system_category());
+ rxbuf.resize(len);
+ _SysDebug("CClient_AcessIPCPipe::HandleReceive - Rx %i/%i bytes", len, rxbuf.capacity());
+ //_SysDebugHex("CClient_AcessIPCPipe::HandleReceive", rxbuf.data(), len);
+
+ CDeserialiser msg(rxbuf);
+ ::AxWin::RecvMessage( msg );
}
return true;
}
throw ::std::length_error("CIPCChannel_AcessIPCPipe::Send");
}
_SysDebug("CIPCChannel_AcessIPCPipe::Send(%i bytes)", serialised.size());
+ //_SysDebugHex("CIPCChannel_AcessIPCPipe::Send", serialised.data(), serialised.size());
+
size_t rv = _SysWrite(m_fd, serialised.data(), serialised.size());
if( rv != serialised.size() ) {
throw ::std::system_error(errno, ::std::system_category());