ImagePool.cpp 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131
  1. #include "ImagePool.h"
  2. ImagePoolEx::ImagePoolEx()
  3. {
  4. //OEM层需要进行细节上的设置.
  5. m_pFullImageQueue = NULL;
  6. m_pPrevImageData = NULL;
  7. }
  8. ImagePoolEx::~ImagePoolEx()
  9. {
  10. ClearPool();
  11. }
  12. bool ImagePoolEx::SetMaxBlockSize(const char *pQueName, DWORD BlockSize, DWORD FulBlockCount, DWORD PrevBlockSize, DWORD PrevBlockCount)
  13. {
  14. bool ret = true;
  15. string PrevQueName = pQueName;
  16. PrevQueName += "Prv";
  17. if (BlockSize)
  18. {
  19. //m_pFullImageQueue = (void*)new CShareMemory_Circle();
  20. //if (((CShareMemory_Circle*)m_pFullImageQueue)->Create(pQueName, BlockSize, FulBlockCount, SM_READWRITE) < 0)
  21. //{
  22. // //printf ("Create Full Pool Failed.%s\n", pQueName);
  23. // return false;
  24. //}
  25. }
  26. if (PrevBlockSize)
  27. {
  28. //m_pPrevImageData = (void*)new CShareMemory_Circle();
  29. //if (((CShareMemory_Circle*)m_pPrevImageData)->Create(PrevQueName.c_str(), PrevBlockSize, PrevBlockCount, SM_READWRITE) < 0)
  30. //{
  31. // //printf ("Create Prev Pool Failed.%s\n", PrevQueName.c_str ());
  32. // return false;
  33. //}
  34. }
  35. //try open
  36. if (m_pFullImageQueue)
  37. {
  38. //if (((CShareMemory_Circle*) m_pFullImageQueue)->Open (pQueName, SM_READWRITE) < 0)
  39. //{
  40. // //printf ("Open Full Pool Failed.%s\n", pQueName);
  41. // return false;
  42. //}
  43. }
  44. if (m_pPrevImageData)
  45. {
  46. //if (((CShareMemory_Circle*) m_pPrevImageData)->Open (PrevQueName.c_str (), SM_READWRITE) < 0)
  47. //{
  48. // //printf ("Open Prev Pool Failed.%s\n", PrevQueName.c_str ());
  49. // return false;
  50. //}
  51. //else
  52. //{
  53. //}
  54. }
  55. return ret;
  56. }
  57. unsigned long ImagePoolEx::AddFrameWithHead(BLOCK_IMAGE_TYPE Type, string &imageHead, char* pFrameBuff, DWORD FrameSize)
  58. {
  59. unsigned long id = UnvalidSMBid;
  60. /*if (Type == PREV_BLOCK_IMG)
  61. {
  62. if (m_pPrevImageData)
  63. {
  64. id = ((CShareMemory_Circle*)m_pPrevImageData)->PushRaw(imageHead, pFrameBuff, FrameSize, true);
  65. }
  66. }
  67. else
  68. {
  69. if (m_pFullImageQueue)
  70. {
  71. id = ((CShareMemory_Circle*)m_pFullImageQueue)->PushRaw(imageHead, pFrameBuff, FrameSize, true);
  72. }
  73. }*/
  74. return id;
  75. }
  76. void ImagePoolEx::ClearPool()
  77. {
  78. /*if (m_pFullImageQueue)
  79. {
  80. ((CShareMemory_Circle*)m_pFullImageQueue)->Clear();
  81. delete (CShareMemory_Circle*)m_pFullImageQueue;
  82. m_pFullImageQueue = NULL;
  83. }
  84. if (m_pPrevImageData)
  85. {
  86. ((CShareMemory_Circle*)m_pPrevImageData)->Clear();
  87. delete (CShareMemory_Circle*)m_pPrevImageData;
  88. m_pPrevImageData = NULL;
  89. }*/
  90. }