mirror of
https://github.com/slsdetectorgroup/slsDetectorPackage.git
synced 2025-05-04 20:00:04 +02:00
debugging output change
This commit is contained in:
parent
1e55577fc2
commit
6d8fcaa423
@ -103,8 +103,8 @@ enum communicationProtocol{
|
|||||||
nsent(0),
|
nsent(0),
|
||||||
total_sent(0)// sender (client): where to? ip
|
total_sent(0)// sender (client): where to? ip
|
||||||
{
|
{
|
||||||
memset(&serverAddress, 0, sizeof(sockaddr_in));
|
//memset(&serverAddress, 0, sizeof(sockaddr_in));
|
||||||
memset(&clientAddress, 0, sizeof(sockaddr_in));
|
//memset(&clientAddress, 0, sizeof(sockaddr_in));
|
||||||
// serverAddress = {0};
|
// serverAddress = {0};
|
||||||
// clientAddress = {0};
|
// clientAddress = {0};
|
||||||
// strcpy(hostname,host_ip_or_name);
|
// strcpy(hostname,host_ip_or_name);
|
||||||
@ -162,8 +162,8 @@ enum communicationProtocol{
|
|||||||
nsent(0),
|
nsent(0),
|
||||||
total_sent(0)
|
total_sent(0)
|
||||||
{
|
{
|
||||||
memset(&serverAddress, 0, sizeof(sockaddr_in));
|
//memset(&serverAddress, 0, sizeof(sockaddr_in));
|
||||||
memset(&clientAddress, 0, sizeof(sockaddr_in));
|
// memset(&clientAddress, 0, sizeof(sockaddr_in));
|
||||||
// serverAddress = {0};
|
// serverAddress = {0};
|
||||||
// clientAddress = {0};
|
// clientAddress = {0};
|
||||||
/* // you can specify an IP address: */
|
/* // you can specify an IP address: */
|
||||||
|
@ -1564,7 +1564,7 @@ void UDPStandardImplementation::startReadout(){
|
|||||||
//wait so that all packets which take time has arrived
|
//wait so that all packets which take time has arrived
|
||||||
usleep(5000);
|
usleep(5000);
|
||||||
/********************************************/
|
/********************************************/
|
||||||
//usleep(10000000);
|
//usleep(1000000);
|
||||||
//usleep(2000000);
|
//usleep(2000000);
|
||||||
|
|
||||||
pthread_mutex_lock(&status_mutex);
|
pthread_mutex_lock(&status_mutex);
|
||||||
@ -1860,9 +1860,9 @@ int UDPStandardImplementation::startWriting(){
|
|||||||
//cout<<"writer gonna pop from fifo:"<<i<<endl;
|
//cout<<"writer gonna pop from fifo:"<<i<<endl;
|
||||||
fifo[i]->pop(wbuf[i]);
|
fifo[i]->pop(wbuf[i]);
|
||||||
numpackets = (uint16_t)(*((uint16_t*)wbuf[i]));
|
numpackets = (uint16_t)(*((uint16_t*)wbuf[i]));
|
||||||
//#ifdef VERYDEBUG
|
#ifdef VERYDEBUG
|
||||||
cout << ithread << " numpackets:" << dec << numpackets << "for fifo :"<< i << endl;
|
cout << ithread << " numpackets:" << dec << numpackets << "for fifo :"<< i << endl;
|
||||||
//#endif
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
#ifdef VERYDEBUG
|
#ifdef VERYDEBUG
|
||||||
@ -2109,9 +2109,9 @@ int i;
|
|||||||
#endif
|
#endif
|
||||||
pthread_mutex_unlock(&(status_mutex));
|
pthread_mutex_unlock(&(status_mutex));
|
||||||
|
|
||||||
//#ifdef VERYDEBUG
|
#ifdef VERYDEBUG
|
||||||
cout << ithread << ": Frames listened to " << dec << ((totalListeningFrameCount[ithread]*numListeningThreads)/packetsPerFrame) << endl;
|
cout << ithread << ": Frames listened to " << dec << ((totalListeningFrameCount[ithread]*numListeningThreads)/packetsPerFrame) << endl;
|
||||||
//#endif
|
#endif
|
||||||
|
|
||||||
//waiting for all listening threads to be done, to print final count of frames listened to
|
//waiting for all listening threads to be done, to print final count of frames listened to
|
||||||
if(ithread == 0){
|
if(ithread == 0){
|
||||||
|
Loading…
x
Reference in New Issue
Block a user