Home | History | Annotate | Download | only in C 
      1 /* LzFindMt.h -- multithreaded Match finder for LZ algorithms
      2 2015-05-03 : Igor Pavlov : Public domain */
      3 
      4 #ifndef __LZ_FIND_MT_H
      5 #define __LZ_FIND_MT_H
      6 
      7 #include "LzFind.h"
      8 #include "Threads.h"
      9 
     10 EXTERN_C_BEGIN
     11 
     12 #define kMtHashBlockSize (1 << 13)
     13 #define kMtHashNumBlocks (1 << 3)
     14 #define kMtHashNumBlocksMask (kMtHashNumBlocks - 1)
     15 
     16 #define kMtBtBlockSize (1 << 14)
     17 #define kMtBtNumBlocks (1 << 6)
     18 #define kMtBtNumBlocksMask (kMtBtNumBlocks - 1)
     19 
     20 typedef struct _CMtSync
     21 {
     22   Bool wasCreated;
     23   Bool needStart;
     24   Bool exit;
     25   Bool stopWriting;
     26 
     27   CThread thread;
     28   CAutoResetEvent canStart;
     29   CAutoResetEvent wasStarted;
     30   CAutoResetEvent wasStopped;
     31   CSemaphore freeSemaphore;
     32   CSemaphore filledSemaphore;
     33   Bool csWasInitialized;
     34   Bool csWasEntered;
     35   CCriticalSection cs;
     36   UInt32 numProcessedBlocks;
     37 } CMtSync;
     38 
     39 typedef UInt32 * (*Mf_Mix_Matches)(void *p, UInt32 matchMinPos, UInt32 *distances);
     40 
     41 /* kMtCacheLineDummy must be >= size_of_CPU_cache_line */
     42 #define kMtCacheLineDummy 128
     43 
     44 typedef void (*Mf_GetHeads)(const Byte *buffer, UInt32 pos,
     45   UInt32 *hash, UInt32 hashMask, UInt32 *heads, UInt32 numHeads, const UInt32 *crc);
     46 
     47 typedef struct _CMatchFinderMt
     48 {
     49   /* LZ */
     50   const Byte *pointerToCurPos;
     51   UInt32 *btBuf;
     52   UInt32 btBufPos;
     53   UInt32 btBufPosLimit;
     54   UInt32 lzPos;
     55   UInt32 btNumAvailBytes;
     56 
     57   UInt32 *hash;
     58   UInt32 fixedHashSize;
     59   UInt32 historySize;
     60   const UInt32 *crc;
     61 
     62   Mf_Mix_Matches MixMatchesFunc;
     63 
     64   /* LZ + BT */
     65   CMtSync btSync;
     66   Byte btDummy[kMtCacheLineDummy];
     67 
     68   /* BT */
     69   UInt32 *hashBuf;
     70   UInt32 hashBufPos;
     71   UInt32 hashBufPosLimit;
     72   UInt32 hashNumAvail;
     73 
     74   CLzRef *son;
     75   UInt32 matchMaxLen;
     76   UInt32 numHashBytes;
     77   UInt32 pos;
     78   const Byte *buffer;
     79   UInt32 cyclicBufferPos;
     80   UInt32 cyclicBufferSize; /* it must be historySize + 1 */
     81   UInt32 cutValue;
     82 
     83   /* BT + Hash */
     84   CMtSync hashSync;
     85   /* Byte hashDummy[kMtCacheLineDummy]; */
     86 
     87   /* Hash */
     88   Mf_GetHeads GetHeadsFunc;
     89   CMatchFinder *MatchFinder;
     90 } CMatchFinderMt;
     91 
     92 void MatchFinderMt_Construct(CMatchFinderMt *p);
     93 void MatchFinderMt_Destruct(CMatchFinderMt *p, ISzAlloc *alloc);
     94 SRes MatchFinderMt_Create(CMatchFinderMt *p, UInt32 historySize, UInt32 keepAddBufferBefore,
     95     UInt32 matchMaxLen, UInt32 keepAddBufferAfter, ISzAlloc *alloc);
     96 void MatchFinderMt_CreateVTable(CMatchFinderMt *p, IMatchFinder *vTable);
     97 void MatchFinderMt_ReleaseStream(CMatchFinderMt *p);
     98 
     99 EXTERN_C_END
    100 
    101 #endif
    102