adjusted buffer sizes

This commit is contained in:
IMback
2017-11-07 22:44:41 +01:00
parent 6d0a63de87
commit 7edc2108a7

View File

@ -143,16 +143,16 @@ int main(int argc, char* argv[])
std::thread acceptThread(acceptThreadFunction, &servSock, &clientSockets); std::thread acceptThread(acceptThreadFunction, &servSock, &clientSockets);
char buffer[256]; char buffer[4096];
signal(SIGINT, intHandler); signal(SIGINT, intHandler);
//signal(SIGTERM, intHandler); signal(SIGTERM, intHandler);
std::cout<<"starting loop\n"; std::cout<<"starting loop\n";
while(!stop) while(!stop)
{ {
int readlen = sRead(serial, buffer, 256); int readlen = sRead(serial, buffer, 4096);
//std::cout<<clientSockets.size()<<std::endl; //std::cout<<clientSockets.size()<<std::endl;
for(unsigned int i = 0; i < clientSockets.size(); i++) for(unsigned int i = 0; i < clientSockets.size(); i++)
{ {
@ -161,19 +161,20 @@ int main(int argc, char* argv[])
if(readlen > 0) if(readlen > 0)
{ {
std::cout<<"sending: "; std::cout<<"bcst: ";
for( int j = 0; j < readlen; j++ )std::cout<<buffer[j]; for( int j = 0; j < readlen; j++ )std::cout<<buffer[j];
clientSockets[i]->send(buffer, readlen); clientSockets[i]->send(buffer, readlen);
std::cout<<std::endl; std::cout<<std::endl;
} }
char inBuffer[256]; char inBuffer[2048];
int reclen = clientSockets[i]->recv(inBuffer, 256); int reclen = clientSockets[i]->recv(inBuffer, 2048);
if( reclen > 0 ) if( reclen > 0 )
{ {
std::cout<<"rec "<<reclen<<'\n'; std::cout<<"rec: ";
for( int j = 0; j < reclen; j++ )std::cout<<inBuffer[j]; for( int j = 0; j < reclen; j++ )std::cout<<inBuffer[j];
sWrite(serial, inBuffer, reclen); sWrite(serial, inBuffer, reclen);
std::cout<<std::endl;
} }
else if(reclen == 0) else if(reclen == 0)
{ {