1. 配置文件：ximeadll加入 getBufferPolicy 和 getAcqBufferSize；

2. 增大内存池的大小，以便100帧写一次硬盘；
3. 增加ximea报错代码：10/11，将报错代码添加时间写入文件；

Header_Files/MemoryPool.h

@@ -26,7 +26,7 @@
 #include <climits>
 #include <cstddef>
 
-template <typename T, size_t BlockSize = 16368000>
+template <typename T, size_t BlockSize = 409200000>
 class MemoryPool
 {
   public:

Header_Files/configfile.h

@@ -37,6 +37,9 @@ public:
     bool getGainOffset(float &gain, float &offset);
     bool getSN(QString &SN);
 
+    bool getBufferPolicy(int &bufferPolicy);
+    bool getAcqBufferSize(int &acqBufferSize);
+
     bool createConfigFile();
     bool updateConfigFile();
 

Header_Files/ximeaimager.h

@@ -25,6 +25,8 @@
 #include <fstream>
 #include <unistd.h>
 #include <exception>
+#include <fcntl.h>
+#include <sys/mman.h>
 
 #include <QObject>
 #include <QDateTime>
@@ -62,7 +64,7 @@ public:
     DataBuffer();
     ~DataBuffer();
 
-    unsigned short data[425600];//304*1400=425600，为了兼容所有设置spectral bin和spatial bin
+    unsigned short data[41040000];//1368*300*100=41040000，为了兼容所有设置spectral bin和spatial bin
 
 private:
 
@@ -98,12 +100,13 @@ Q_OBJECT
 
 public:
     WriteData2Disk();
-    void setParm(queue<DataBuffer *> * q, QString baseFileName, int frameSizeInByte, MemoryPool<DataBuffer> * pool, rgbImage * rgbImage);
+    void setParm(queue<DataBuffer *> * q, QString baseFileName, int frameSizeInByte, int number_WriteDisk, MemoryPool<DataBuffer> * pool, rgbImage * rgbImage);
 
 private:
     queue<DataBuffer *> * m_q;
     QString m_QbaseFileName;
     int m_iFrameSizeInByte;
+    int m_iNumber_WriteDisk;
     MemoryPool<DataBuffer> * m_pool;
 
     rgbImage * m_rgbImage;
@@ -139,6 +142,7 @@ public:
 
     void stopRecord();
     int getFrameCounter();
+    void writeXiApiErrorCodes(QString filePath, int xiApiErrorCodes);
 
     int getMaxValueOfOneFrame(unsigned short * data, int numberOfPixel);
 

Source_Files/configfile.cpp

@@ -222,6 +222,50 @@ bool Configfile::getSN(QString &SN)
     }
 }
 
+bool Configfile::getBufferPolicy(int &bufferPolicy)
+{
+    const Setting& root = cfg.getRoot();
+    const Setting &ximeadll = root["ximeadll"];
+
+    try
+    {
+        if(!(ximeadll.lookupValue("buffer_policy", bufferPolicy)
+        ))
+        {
+            return false;
+        }
+    }
+    catch(const SettingNotFoundException &nfex)
+    {
+        cerr << "No 'spectralBin' setting in configuration file." << endl;
+        return false;
+    }
+
+    return true;
+}
+
+bool Configfile::getAcqBufferSize(int &acqBufferSize)
+{
+    const Setting& root = cfg.getRoot();
+    const Setting &ximeadll = root["ximeadll"];
+
+    try
+    {
+        if(!(ximeadll.lookupValue("acq_buffer_size", acqBufferSize)
+        ))
+        {
+            return false;
+        }
+    }
+    catch(const SettingNotFoundException &nfex)
+    {
+        cerr << "No 'spectralBin' setting in configuration file." << endl;
+        return false;
+    }
+
+    return true;
+}
+
 bool Configfile::createConfigFile()
 {
     using namespace std;
@@ -279,6 +323,11 @@ bool Configfile::createConfigFile()
     gainOffsetSpectralBin2.add("offset", Setting::TypeFloat) = -299.46126663407176;
 
 
+    Setting &ximeadll = root.add("ximeadll", Setting::TypeGroup);
+    ximeadll.add("buffer_policy", Setting::TypeInt) = 0;
+    ximeadll.add("acq_buffer_size", Setting::TypeInt) = 400;
+
+
     // Write out the new configuration.
     QString output_file = "/media/nvme/300TC/config/ximea.cfg";
     try

Source_Files/ximeaimager.cpp

@@ -89,6 +89,18 @@ void XimeaImager::openImger()
 //            m_imager.setEffectiveWindowRoi(offsetx_roi, width_roi);
 //        }
 
+        int bufferPolicy, acqBufferSize;
+        ret1 = m_configfile.getBufferPolicy(bufferPolicy);
+        if (ret1)
+        {
+            m_imager.setBufferPolicy(bufferPolicy);
+        }
+        ret1 = m_configfile.getAcqBufferSize(acqBufferSize);
+        if (ret1)
+        {
+            m_imager.setAcqBufferSize(acqBufferSize);
+        }
+
         setFramerate(100);
 
         //经验证：frameSizeManual和frameSizeAuto相等
@@ -490,14 +502,20 @@ void XimeaImager::startRecord(double TimeDifferenceBetweensOSAndSbg,QString base
 
         QString timesFileName=m_baseFileName+".times";
         FILE *hHimesFile=fopen(timesFileName.toStdString().c_str(),"w+");
+//        ofstream timesFile(timesFileName.toStdString());
+
         std::cout << "曝光时间为：" << getExposureTime()/1000 << "ms" <<std::endl;
 
         using namespace std;
 //        ofstream timesFileHandle(timesFileName.toStdString()+"_ofstream");
 
-        writeData2Disk->setParm(q,m_baseFileName,m_iFrameSizeInByte, m_pool, m_rgbImage);
+        int number_WriteDisk = 100;
+        writeData2Disk->setParm(q,m_baseFileName,m_iFrameSizeInByte, number_WriteDisk, m_pool, m_rgbImage);
         emit startWriteDiskSignal();
 
+        int indexofbuff;
+        DataBuffer * buffer;
+
         m_imager.start();
         struct timeval timeStart, timeEnd;
         double runTime=0;
@@ -505,6 +523,7 @@ void XimeaImager::startRecord(double TimeDifferenceBetweensOSAndSbg,QString base
         while (m_bRecordControl)
         {
             unsigned short *x=m_imager.get_frame(m_buffer);
+            m_iFrameCounter+=1;
 
             //fwrite(m_buffer,2,getBandCount()*getSampleCount(),hFile);
 //            fwrite(m_imager.m_image.bp,static_cast<int>(m_imager.m_image.bp_size),1,hFile);
@@ -512,56 +531,66 @@ void XimeaImager::startRecord(double TimeDifferenceBetweensOSAndSbg,QString base
             //sync();//强制系统将系统文件缓冲的内容写入磁盘
 
 
+            indexofbuff = m_iFrameCounter % number_WriteDisk;
 
-            r_qtx.lock();
+            if (indexofbuff == 1)
-            DataBuffer * buffer = m_pool->newElement();
+            {
-            r_qtx.unlock();
+                r_qtx.lock();
-//            m_pool->construct(buffer);
+                buffer = m_pool->newElement();
+                r_qtx.unlock();
+            }
 
-//            memcpy(buffer->data,(unsigned short *)m_imager.m_image.bp,m_iFrameSizeInByte/2);
+            if (indexofbuff == 0)
-            memcpy((void *)buffer->data,m_imager.m_image.bp,m_iFrameSizeInByte);
+            {
+                memcpy((void *)buffer->data + (number_WriteDisk - 1) * m_iFrameSizeInByte,m_imager.m_image.bp,m_iFrameSizeInByte);
+            }
+            else
+            {
+                memcpy((void *)buffer->data + (indexofbuff - 1) * m_iFrameSizeInByte,m_imager.m_image.bp,m_iFrameSizeInByte);
+            }
 
-            r_qtx.lock();
+            if (indexofbuff == 0)
-            q->push(buffer);
+            {
-            r_qtx.unlock();//
+                r_qtx.lock();
-
+                q->push(buffer);
-//            std::cout<<"XimeaImager::startRecord，队列长度为："<< q->size() <<std::endl;//
+                r_qtx.unlock();
-
+            }
-//            fwrite(buffer,1,m_iFrameSizeInByte,hFile);
-
-            m_iFrameCounter+=1;
 
             double sbgTime=getSbgTime(TimeDifferenceBetweensOSAndSbg);
 
             fprintf(hHimesFile,"%f\n",sbgTime);
-            //fwrite(&sbgTime,sizeof(double),1,hHimesFile);
+//            fwrite(&sbgTime,sizeof(double),1,hHimesFile);
+//            timesFile<<sbgTime<< "\n";
 
 //            timesFileHandle << sbgTime << "\n";
-//            std::cout<<"XimeaImager::startRecord---std::cout: "<<sbgTime<<std::endl;
-
-//            unsigned char pixel = *(unsigned char*)image.bp;//Default value: XI_MONO8
-//            unsigned short pixel =*(unsigned short*)image.bp;//XI_RAW16
-//            printf("Image %d (%dx%d) received from camera. First pixel value: %d\n", m_iFrameCounter, (int)image.width, (int)image.height, pixel);
         }
         gettimeofday(&timeEnd, NULL);
         runTime = (timeEnd.tv_sec - timeStart.tv_sec ) + (double)(timeEnd.tv_usec -timeStart.tv_usec)/1000000;
         m_imager.stop();
 
-        double frameInTheory=runTime * getFramerate();
+        m_iFrameCounter = m_iFrameCounter - indexofbuff;
-        double frameLossed=frameInTheory - m_iFrameCounter;
+        if (indexofbuff != 0)
-        double frameLossRate=frameLossed / frameInTheory;
+        {
+            m_pool->deleteElement(buffer);
+        }
+
+        double frameInTheory=runTime * getFramerate() - indexofbuff;
+
+        double frameLossed=m_imager.m_image.acq_nframe - indexofbuff - m_iFrameCounter;
+        double frameLossRate=frameLossed / (m_imager.m_image.acq_nframe - indexofbuff);
 
         std::cout<<"当前采集文件为: "<<baseFileName.toStdString()<<std::endl;
         std::cout<<"采集时间为: "<<runTime<< "s" <<std::endl;
         std::cout<<"当前帧率为: "<<getFramerate() << "hz" <<std::endl;
         std::cout<<"每秒数据量为: "<<getFramerate()*m_iFrameSizeInByte/(1024*1024)<<"MB"<<std::endl;
-        std::cout<<"理论采集帧数为: "<<frameInTheory<<std::endl;
+        std::cout<<"理论采集帧数为: "<<m_imager.m_image.acq_nframe - indexofbuff<<std::endl;
         std::cout<<"实际采集帧数为："<<m_iFrameCounter<<std::endl;
         std::cout<<"丢失帧数为: "<<frameLossed<<std::endl;
         std::cout<<"丢帧率为: "<<frameLossRate * 100<< "%" <<std::endl;
 
         fclose(hHimesFile);
 //        timesFileHandle.close();
+//        timesFile.close();
 
         timeStr = formatTimeStr(timeFormat);
         printf("停止采集：%s!\n", timeStr.toStdString().c_str());
@@ -701,6 +730,18 @@ void XimeaImager::processXiApiErrorCodes(int xiApiErrorCodes)
         m_iImagerState=xiApiErrorCodes;
         emit ximeaImageStatus(m_iImagerState);
 
+        break;
+    case 10:
+        std::cout<<"XimeaImager::processXiApiErrorCodes-----------:Timeout!"<<std::endl;
+        m_iImagerState=xiApiErrorCodes;
+        emit ximeaImageStatus(m_iImagerState);
+
+        break;
+    case 11:
+        std::cout<<"XimeaImager::processXiApiErrorCodes-----------:Invalid arguments supplied!"<<std::endl;
+        m_iImagerState=xiApiErrorCodes;
+        emit ximeaImageStatus(m_iImagerState);
+
         break;
     case 12:
         std::cout<<"XimeaImager::processXiApiErrorCodes-----------:Not supported!"<<std::endl;
@@ -727,20 +768,26 @@ void XimeaImager::processXiApiErrorCodes(int xiApiErrorCodes)
 
         break;
     default:
-        QString ximeaError="ximeaError.txt";
-        ofstream ximeaErrorFile(ximeaError.toStdString().c_str(),ios::app);
-
-        ximeaErrorFile<< xiApiErrorCodes << "\n";
-        std::cout<<"XimeaImager::processXiApiErrorCodes-----------:未处理ximea异常代码："<< xiApiErrorCodes <<std::endl;
-
-        ximeaErrorFile.close();
-
-
-
         m_iImagerState=99;
         emit ximeaImageStatus(m_iImagerState);
         break;
     }
+
+    writeXiApiErrorCodes("/media/nvme/300TC/ximeaError.txt", xiApiErrorCodes);
+}
+
+void XimeaImager::writeXiApiErrorCodes(QString filePath, int xiApiErrorCodes)
+{
+    ofstream ximeaErrorFile(filePath.toStdString().c_str(),ios::app);
+
+    char * timeFormat="%Y%m%d_%H%M%S";
+    QString timeStr = formatTimeStr(timeFormat);
+
+    ximeaErrorFile<< timeStr.toStdString().c_str() << ": " << xiApiErrorCodes << "\n";
+
+    std::cout<<"XimeaImager::writeXiApiErrorCodes-----------:xiApiErrorCodes: "<<timeStr.toStdString().c_str()<< ": " << xiApiErrorCodes<<std::endl;
+
+    ximeaErrorFile.close();
 }
 
 void XimeaImager::stopRecord()
@@ -809,7 +856,7 @@ void WriteData2Disk::write2Disk()
 
     int sleepCounters=1;
     int frameCounter = 0;
-    unsigned short * dataBuffer = new unsigned short[m_iFrameSizeInByte/2];
+    unsigned short * dataBuffer = new unsigned short[m_iFrameSizeInByte/2*m_iNumber_WriteDisk];
     while(true)
     {
         r_qtx.lock();
@@ -817,7 +864,7 @@ void WriteData2Disk::write2Disk()
         r_qtx.unlock();
         if(bempty)
         {
-            QThread::msleep(sleepCounters * sleepCounters * 10);
+            QThread::msleep(sleepCounters * sleepCounters * m_iNumber_WriteDisk);
 //            std::cout<<"WriteData2Disk::write2Disk-----------------------队列第几次为空：" << sleepCounters <<std::endl;
             sleepCounters++;
 
@@ -833,7 +880,7 @@ void WriteData2Disk::write2Disk()
 
         r_qtx.lock();
         DataBuffer * buffer = m_q->front();
-        memcpy(dataBuffer,buffer->data,m_iFrameSizeInByte);
+        memcpy(dataBuffer,buffer->data,m_iFrameSizeInByte*m_iNumber_WriteDisk);
 //        m_pool->destroy(m_q->front());
         m_pool->deleteElement(buffer);
         m_q->pop();
@@ -844,21 +891,22 @@ void WriteData2Disk::write2Disk()
 
 
 //        std::cout<<"WriteData2Disk::write2Disk-----------------------正在写磁盘!" << m_pool->max_size() <<std::endl;//
-        fwrite(dataBuffer,1,m_iFrameSizeInByte, hFile);
+        fwrite(dataBuffer,1,m_iFrameSizeInByte*m_iNumber_WriteDisk, hFile);
         frameCounter++;
     }
     m_rgbImage->m_VideoWriter.release();
     fclose(hFile);
 
     std::cout<<"WriteData2Disk::write2Disk-----------------------写磁盘线程将退出，内存池可达到的最多元素数：" << m_pool->max_size() <<std::endl;
-    std::cout<<"WriteData2Disk::write2Disk-----------------------写磁盘线程将退出，共写帧数：" << frameCounter <<std::endl;
+    std::cout<<"WriteData2Disk::write2Disk-----------------------写磁盘线程将退出，共写帧数：" << frameCounter*m_iNumber_WriteDisk <<std::endl;
 }
 
-void WriteData2Disk::setParm(queue<DataBuffer *> * q, QString baseFileName, int frameSizeInByte, MemoryPool<DataBuffer> * pool, rgbImage * rgbImage)
+void WriteData2Disk::setParm(queue<DataBuffer *> * q, QString baseFileName, int frameSizeInByte, int number_WriteDisk, MemoryPool<DataBuffer> * pool, rgbImage * rgbImage)
 {
     m_q = q;
     m_QbaseFileName = baseFileName;
     m_iFrameSizeInByte = frameSizeInByte;
+    m_iNumber_WriteDisk = number_WriteDisk;
 
     m_pool = pool;