generic-library/poco
1
0
Fork 0
mirror of https://github.com/pocoproject/poco.git synced 2025-01-19 00:46:03 +01:00
Code Issues Projects Releases Wiki Activity

more test fixes

Browse Source
This commit is contained in:
Alex Fabijanic 2018-04-27 20:05:35 -05:00
parent f0fed91a0e
commit 47833b6a59
1 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
Net/testsuite/src/SocketReactorTest.cpp
View File

@ -70,6 +70,7 @@ namespace
{
_socket.sendBytes(buffer, n);
}
else delete this;
}
void onShutdown(ShutdownNotification* pNf)
@ -122,12 +123,14 @@ namespace
_str.write(buffer, n);
_data += _str.str();
_str.str("");
if ((_once && _data.size() >= 1024) ||
(!_once && _data.size() >= 4096))
{
_reactor.stop();
delete this;
}
}
else
{
checkReadableObserverCount(1);
_reactor.removeEventHandler(_socket, Observer<ClientServiceHandler, ReadableNotification>(*this, &ClientServiceHandler::onReadable));
checkReadableObserverCount(0);
if (_once || _data.size() == 4096) _reactor.stop();
delete this;
}
}
@ -321,8 +324,8 @@ namespace
void onReadable(ReadableNotification* pNf)
{
pNf->release();
char buffer[8] = {0};
int n = _socket.receiveBytes(&buffer[0], sizeof(buffer) - 1);
char buffer[64];
int n = _socket.receiveBytes(&buffer[0], sizeof(buffer));
if (n > 0)
{
_data[_pos].append(buffer, n);