detectors/slsDetectorPackage
25
0
Fork 0
mirror of https://github.com/slsdetectorgroup/slsDetectorPackage.git synced 2025-05-01 18:30:05 +02:00
Code Issues Actions Packages Releases Activity

reverted semaphore

Browse Source 
git-svn-id: file:///afs/psi.ch/project/sls_det_software/svn/slsDetectorSoftware@733 951219d9-93cf-4727-9268-0efd64621fa3
This commit is contained in:
l_maliakal_d 2014-02-06 17:05:09 +00:00
parent 83405b70c8
commit fcacc79f7b
4 changed files with 2 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
slsDetectorSoftware/multiSlsDetector/multiSlsDetector.cpp
View File

@ -1365,7 +1365,6 @@ int* multiSlsDetector::readFrame(){
} }
} }
dataQueue.push(retval); dataQueue.push(retval);
sem_post(&queue_mutex);
return retval; return retval;
}; };
@ -1401,7 +1400,6 @@ int* multiSlsDetector::readAll(){
//std::cout << "-" << flush; //std::cout << "-" << flush;
#endif #endif
dataQueue.push(retval); dataQueue.push(retval);
sem_post(&queue_mutex);
} }
for (int id=0; id<thisMultiDetector->numberOfDetectors; id++) { for (int id=0; id<thisMultiDetector->numberOfDetectors; id++) {
if (detectors[id]) { if (detectors[id]) {
@ -1442,7 +1440,6 @@ int* multiSlsDetector::startAndReadAll(){
//std::cout << "-" << flush; //std::cout << "-" << flush;
#endif #endif
dataQueue.push(retval); dataQueue.push(retval);
sem_post(&queue_mutex);
} }
for (int id=0; id<thisMultiDetector->numberOfDetectors; id++) { for (int id=0; id<thisMultiDetector->numberOfDetectors; id++) {
@ -1533,7 +1530,6 @@ slsDetectorDefs::runStatus multiSlsDetector::getRunStatus() {
int* multiSlsDetector::popDataQueue() { int* multiSlsDetector::popDataQueue() {
int *retval=NULL; int *retval=NULL;
sem_wait(&queue_mutex);
if( !dataQueue.empty() ) { if( !dataQueue.empty() ) {
retval=dataQueue.front(); retval=dataQueue.front();
dataQueue.pop(); dataQueue.pop();
@ -1553,7 +1549,6 @@ detectorData* multiSlsDetector::popFinalDataQueue() {
void multiSlsDetector::resetDataQueue() { void multiSlsDetector::resetDataQueue() {
int *retval=NULL; int *retval=NULL;
while( !dataQueue.empty() ) { while( !dataQueue.empty() ) {
sem_wait(&queue_mutex);
retval=dataQueue.front(); retval=dataQueue.front();
dataQueue.pop(); dataQueue.pop();
delete [] retval; delete [] retval;

3
slsDetectorSoftware/slsDetector/slsDetector.cpp
View File

@ -3237,7 +3237,6 @@ int* slsDetector::readFrame(){
retval=getDataFromDetector(); retval=getDataFromDetector();
if (retval) { if (retval) {
dataQueue.push(retval); dataQueue.push(retval);
sem_post(&queue_mutex);
controlSocket->Disconnect(); controlSocket->Disconnect();
} }
} }
@ -3334,7 +3333,6 @@ int* slsDetector::readAll(){
//std::cout << "-" << flush ; //std::cout << "-" << flush ;
#endif #endif
dataQueue.push(retval); dataQueue.push(retval);
sem_post(&queue_mutex);
} }
controlSocket->Disconnect(); controlSocket->Disconnect();
} }
@ -3395,7 +3393,6 @@ int* slsDetector::startAndReadAll(){
//std::cout<< "-" << flush; //std::cout<< "-" << flush;
#endif #endif
dataQueue.push(retval); dataQueue.push(retval);
sem_post(&queue_mutex);
} }
controlSocket->Disconnect(); controlSocket->Disconnect();

4
slsDetectorSoftware/slsDetectorAnalysis/postProcessing.cpp
View File

@ -37,7 +37,7 @@ postProcessing::postProcessing(): expTime(NULL), ang(NULL), val(NULL), err(NULL)
rawDataReady = 0; rawDataReady = 0;
pRawDataArg = 0; pRawDataArg = 0;
sem_init(&queue_mutex,0,0); /* sem_init(&queue_mutex,0,0);*/
#ifdef VERBOSE #ifdef VERBOSE
registerDataCallback(&defaultDataReadyFunc, NULL); registerDataCallback(&defaultDataReadyFunc, NULL);
@ -583,7 +583,6 @@ int* postProcessing::popDataQueue() {
cout << "Pop data queue lock" << endl; cout << "Pop data queue lock" << endl;
#endif #endif
sem_wait(&queue_mutex);
pthread_mutex_lock(&mp); pthread_mutex_lock(&mp);
if( !dataQueue.empty() ) { if( !dataQueue.empty() ) {
retval=dataQueue.front(); retval=dataQueue.front();
@ -612,7 +611,6 @@ void postProcessing::resetDataQueue() {
int *retval=NULL; int *retval=NULL;
pthread_mutex_lock(&mp); pthread_mutex_lock(&mp);
while( !dataQueue.empty() ) { while( !dataQueue.empty() ) {
sem_wait(&queue_mutex);
retval=dataQueue.front(); retval=dataQueue.front();
dataQueue.pop(); dataQueue.pop();
delete [] retval; delete [] retval;

2
slsDetectorSoftware/slsDetectorAnalysis/postProcessing.h
View File

@ -296,7 +296,7 @@ s
int queuesize; int queuesize;
/** queue mutex */ /** queue mutex */
sem_t queue_mutex; /*sem_t queue_mutex;*/
/** /**