mirror of
https://github.com/slsdetectorgroup/slsDetectorPackage.git
synced 2025-04-26 08:10:02 +02:00
changing socket buffer size
git-svn-id: file:///afs/psi.ch/project/sls_det_software/svn/slsDetectorSoftware@646 951219d9-93cf-4727-9268-0efd64621fa3
This commit is contained in:
parent
d1a3cf8ed8
commit
215a17ce2c
@ -73,6 +73,7 @@ using namespace std;
|
|||||||
|
|
||||||
#define DEFAULT_PACKET_SIZE 1286
|
#define DEFAULT_PACKET_SIZE 1286
|
||||||
#define DEFAULT_PACKETS_PER_FRAME 2
|
#define DEFAULT_PACKETS_PER_FRAME 2
|
||||||
|
#define SOCKET_BUFFER_SIZE (100*1024*1024) //100MB
|
||||||
#define DEFAULT_PORTNO 1952
|
#define DEFAULT_PORTNO 1952
|
||||||
#define DEFAULT_BACKLOG 5
|
#define DEFAULT_BACKLOG 5
|
||||||
#define DEFAULT_UDP_PORTNO 50001
|
#define DEFAULT_UDP_PORTNO 50001
|
||||||
@ -208,26 +209,29 @@ enum communicationProtocol{
|
|||||||
|
|
||||||
|
|
||||||
// reuse port
|
// reuse port
|
||||||
int yes=1;
|
int val=1;
|
||||||
if (setsockopt(socketDescriptor,SOL_SOCKET,SO_REUSEADDR,&yes,sizeof(int)) == -1) {
|
if (setsockopt(socketDescriptor,SOL_SOCKET,SO_REUSEADDR,&val,sizeof(int)) == -1) {
|
||||||
cerr << "setsockopt" << endl;
|
cerr << "setsockopt" << endl;
|
||||||
socketDescriptor=-1;
|
socketDescriptor=-1;
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
//increase buffer size if its udp
|
||||||
|
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;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
if(bind(socketDescriptor,(struct sockaddr *) &serverAddress,sizeof(serverAddress))<0){
|
if(bind(socketDescriptor,(struct sockaddr *) &serverAddress,sizeof(serverAddress))<0){
|
||||||
cerr << "Can not bind socket "<< endl;
|
cerr << "Can not bind socket "<< endl;
|
||||||
socketDescriptor=-1;
|
socketDescriptor=-1;
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
//increase buffer size if its udp
|
|
||||||
if((communicationProtocol == UDP) && (setsockopt(sockfd, SOL_SOCKET, SO_RCVBUF, &SOCKET_BUFFER_SIZE, sizeof(int)) == -1))
|
|
||||||
{
|
|
||||||
cerr << "Cannot set socket receive buffer size" << endl;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
if (getProtocol()==SOCK_STREAM)
|
if (getProtocol()==SOCK_STREAM)
|
||||||
listen(socketDescriptor, DEFAULT_BACKLOG);
|
listen(socketDescriptor, DEFAULT_BACKLOG);
|
||||||
|
@ -19,8 +19,6 @@
|
|||||||
#define MAXDET 100
|
#define MAXDET 100
|
||||||
/** header length for data :gotthard*/
|
/** header length for data :gotthard*/
|
||||||
#define HEADERLENGTH 12
|
#define HEADERLENGTH 12
|
||||||
/** udp socket buffer size - 100MB*/
|
|
||||||
#define SOCKET_BUFFER_SIZE (100*1024*1024)
|
|
||||||
|
|
||||||
/** maximum rois */
|
/** maximum rois */
|
||||||
#define MAX_ROIS 100
|
#define MAX_ROIS 100
|
||||||
|
Loading…
x
Reference in New Issue
Block a user