refactor unix socket

unstable
Tom Early 4 years ago
parent a58660a2f8
commit 8440adab12

@ -81,6 +81,11 @@ bool CUnixDgramReader::Receive(STCPacket *pack, unsigned timeout) const
return false; return false;
} }
return Read(pack);
}
bool CUnixDgramReader::Read(STCPacket *pack) const
{
auto len = read(fd, pack, sizeof(STCPacket)); auto len = read(fd, pack, sizeof(STCPacket));
if (len != sizeof(STCPacket)) { if (len != sizeof(STCPacket)) {
std::cerr << "Received transcoder packet is wrong size: " << len << " but should be " << sizeof(STCPacket) << std::endl; std::cerr << "Received transcoder packet is wrong size: " << len << " but should be " << sizeof(STCPacket) << std::endl;

@ -28,6 +28,7 @@ public:
CUnixDgramReader(); CUnixDgramReader();
~CUnixDgramReader(); ~CUnixDgramReader();
bool Open(const char *path); bool Open(const char *path);
bool Read(STCPacket *pack) const;
bool Receive(STCPacket *pack, unsigned timeout) const; bool Receive(STCPacket *pack, unsigned timeout) const;
void Close(); void Close();
int GetFD() const; int GetFD() const;

Loading…
Cancel
Save

Powered by TurnKey Linux.