detectors/slsDetectorPackage
25
0
Fork 0
mirror of https://github.com/slsdetectorgroup/slsDetectorPackage.git synced 2025-06-11 12:27:14 +02:00
Code Issues Actions Packages Releases Activity

changed buffer size and max input queue in kernel

Browse Source 
git-svn-id: file:///afs/psi.ch/project/sls_det_software/svn/slsDetectorSoftware@648 951219d9-93cf-4727-9268-0efd64621fa3
This commit is contained in:
l_maliakal_d
2013-08-06 15:23:05 +00:00
parent 4728ce7218
commit ad6b9e3617
2 changed files with 20 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
slsDetectorSoftware/MySocketTCP/genericSocket.h
View File

@ -221,9 +221,9 @@ enum communicationProtocol{
val = SOCKET_BUFFER_SIZE;
if((p == UDP) && (setsockopt(socketDescriptor, SOL_SOCKET, SO_RCVBUF, &val, sizeof(int)) == -1))
{
cerr << "Cannot set socket receive buffer size" << endl;
socketDescriptor=-1;
return;
cerr << "WARNING:Could not set socket receive buffer size" << endl;
//socketDescriptor=-1;
//return;
}

20
slsDetectorSoftware/slsReceiver/slsReceiverFunctionList.cpp
View File

@ -307,11 +307,11 @@ int slsReceiverFunctionList::startReceiver(char message[]){
if (pthread_setschedparam(listening_thread, policy, &listen_param) == EPERM)
cout << "ERROR: Could not prioritize threads. You need to be super user for that." << endl;
cout << "WARNING: Could not prioritize threads. You need to be super user for that." << endl;
if (pthread_setschedparam(writing_thread, policy, &write_param) == EPERM)
cout << "ERROR: Could not prioritize threads. You need to be super user for that." << endl;
cout << "WARNING: Could not prioritize threads. You need to be super user for that." << endl;
if (pthread_setschedparam(pthread_self(),5 , &tcp_param) == EPERM)
cout << "ERROR: Could not prioritize threads. You need to be super user for that." << endl;
cout << "WARNING: Could not prioritize threads. You need to be super user for that." << endl;
//pthread_getschedparam(pthread_self(),&policy,&tcp_param);
@ -391,6 +391,20 @@ int slsReceiverFunctionList::startListening(){
// very end of the program.
do {
//to increase socket receiver buffer size and max length of input queue by changing kernel settings
if(system("echo $((100*1024*1024)) > /proc/sys/net/core/rmem_max"))
cout << "\nWARNING: Could not change socket receiver buffer size in file /proc/sys/net/core/rmem_max" << endl;
else if(system("echo 250000 > /proc/sys/net/core/netdev_max_backlog"))
cout << "\nWARNING: Could not change max length of input queue in file /proc/sys/net/core/netdev_max_backlog" << endl;
/** permanent setting heiner
net.core.rmem_max = 104857600 # 100MiB
net.core.netdev_max_backlog = 250000
sysctl -p
// from the manual
sysctl -w net.core.rmem_max=16777216
sysctl -w net.core.netdev_max_backlog=250000
*/
//creating udp socket
if (strchr(eth,'.')!=NULL) strcpy(eth,"");