detectors/slsDetectorPackage
25
0
Fork 0
mirror of https://github.com/slsdetectorgroup/slsDetectorPackage.git synced 2025-04-22 22:40:02 +02:00
Code Issues Actions Packages Releases Activity

included threaded 0 as a possibility

Browse Source
This commit is contained in:
Dhanya Maliakal 2017-09-20 17:07:51 +02:00
parent 3a79f0ad9b
commit fda9c85bb3
1 changed files with 9 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
slsDetectorSoftware/slsDetectorAnalysis/postProcessing.cpp
View File

@ -521,16 +521,11 @@ void* postProcessing::processData(int delflag) {
int ifp; int ifp;
while(true){ while(true){
//cout.flush(); // set only in startThread
//cout<<flush; if (*threadedProcessing==0)
usleep(100 * 1000); //20ms need this else connecting error to receiver (too fast) setTotalProgress();
if (checkJoinThread()){
break;
}
// to exit acquire by typing q
ifp=kbhit(); ifp=kbhit();
if (ifp!=0){ if (ifp!=0){
c=fgetc(stdin); c=fgetc(stdin);
@ -541,7 +536,6 @@ void* postProcessing::processData(int delflag) {
} }
//get progress //get progress
pthread_mutex_lock(&mg); pthread_mutex_lock(&mg);
if(setReceiverOnline() == ONLINE_FLAG){ if(setReceiverOnline() == ONLINE_FLAG){
@ -557,16 +551,17 @@ void* postProcessing::processData(int delflag) {
cout << "caught:" << caught << endl; cout << "caught:" << caught << endl;
#endif #endif
} }
// exiting loop
if (*threadedProcessing==0)
break;
if (checkJoinThread()){ if (checkJoinThread()){
break; break;
} }
usleep(200 * 1000); //20ms need this else connecting error to receiver (too fast)
} }
} }
} }
return 0; return 0;