void * CompressedFitsWriter::threadFunction ( void *  context )

staticprivate

the main function compressing the data

Definition at line 1406 of file fitsCompressor.cc.

References _mutex, CompressedFitsFile::_numThreads, CompressedFitsFile::_THREAD_COMPRESS_, CompressedFitsFile::_THREAD_EXIT_, CompressedFitsFile::_THREAD_WAIT_, CompressedFitsFile::_THREAD_WRITE_, CompressedFitsFile::_threadIndex, CompressedFitsFile::_threadStatus, compressBuffer(), and writeCompressedDataToDisk().

Referenced by open().

{
    CompressedFitsWriter* myself =static_cast<CompressedFitsWriter*>(context);

    uint32_t myID = 0;
    pthread_mutex_lock(&(myself->_mutex));
    myID = myself->_threadIndex++;
    pthread_mutex_unlock(&(myself->_mutex));
    uint32_t threadToWaitForBeforeWriting = (myID == 0) ? myself->_numThreads-1 : myID-1;

    while (myself->_threadStatus[myID] != _THREAD_EXIT_)
    {
        while (myself->_threadStatus[myID] == _THREAD_WAIT_)
            usleep(100000);
        if (myself->_threadStatus[myID] != _THREAD_COMPRESS_)
            continue;
        uint32_t numBytes = myself->compressBuffer(myID);
        myself->_threadStatus[myID] = _THREAD_WRITE_;

        //wait for the previous data to be written
        while (myself->_threadIndex != threadToWaitForBeforeWriting)
            usleep(1000);
        //do the actual writing to disk
        pthread_mutex_lock(&(myself->_mutex));
        myself->writeCompressedDataToDisk(myID, numBytes);
        myself->_threadIndex = myID;
        pthread_mutex_unlock(&(myself->_mutex));
        myself->_threadStatus[myID] = _THREAD_WAIT_;
    }
    return NULL;
}

Here is the call graph for this function:

Here is the caller graph for this function: