Merge pull request #461 from negativeExponent/libchdr

[pcsx_rearmed.git] / deps / lzma-16.04 / C / MtCoder.h

/* MtCoder.h -- Multi-thread Coder\r
2009-11-19 : Igor Pavlov : Public domain */\r
\r
#ifndef __MT_CODER_H\r
#define __MT_CODER_H\r
\r
#include "Threads.h"\r
\r
EXTERN_C_BEGIN\r
\r
typedef struct\r
{\r
  CThread thread;\r
  CAutoResetEvent startEvent;\r
  CAutoResetEvent finishedEvent;\r
  int stop;\r
  \r
  THREAD_FUNC_TYPE func;\r
  LPVOID param;\r
  THREAD_FUNC_RET_TYPE res;\r
} CLoopThread;\r
\r
void LoopThread_Construct(CLoopThread *p);\r
void LoopThread_Close(CLoopThread *p);\r
WRes LoopThread_Create(CLoopThread *p);\r
WRes LoopThread_StopAndWait(CLoopThread *p);\r
WRes LoopThread_StartSubThread(CLoopThread *p);\r
WRes LoopThread_WaitSubThread(CLoopThread *p);\r
\r
#ifndef _7ZIP_ST\r
#define NUM_MT_CODER_THREADS_MAX 32\r
#else\r
#define NUM_MT_CODER_THREADS_MAX 1\r
#endif\r
\r
typedef struct\r
{\r
  UInt64 totalInSize;\r
  UInt64 totalOutSize;\r
  ICompressProgress *progress;\r
  SRes res;\r
  CCriticalSection cs;\r
  UInt64 inSizes[NUM_MT_CODER_THREADS_MAX];\r
  UInt64 outSizes[NUM_MT_CODER_THREADS_MAX];\r
} CMtProgress;\r
\r
SRes MtProgress_Set(CMtProgress *p, unsigned index, UInt64 inSize, UInt64 outSize);\r
\r
struct _CMtCoder;\r
\r
typedef struct\r
{\r
  struct _CMtCoder *mtCoder;\r
  Byte *outBuf;\r
  size_t outBufSize;\r
  Byte *inBuf;\r
  size_t inBufSize;\r
  unsigned index;\r
  CLoopThread thread;\r
\r
  Bool stopReading;\r
  Bool stopWriting;\r
  CAutoResetEvent canRead;\r
  CAutoResetEvent canWrite;\r
} CMtThread;\r
\r
typedef struct\r
{\r
  SRes (*Code)(void *p, unsigned index, Byte *dest, size_t *destSize,\r
      const Byte *src, size_t srcSize, int finished);\r
} IMtCoderCallback;\r
\r
typedef struct _CMtCoder\r
{\r
  size_t blockSize;\r
  size_t destBlockSize;\r
  unsigned numThreads;\r
  \r
  ISeqInStream *inStream;\r
  ISeqOutStream *outStream;\r
  ICompressProgress *progress;\r
  ISzAlloc *alloc;\r
\r
  IMtCoderCallback *mtCallback;\r
  CCriticalSection cs;\r
  SRes res;\r
\r
  CMtProgress mtProgress;\r
  CMtThread threads[NUM_MT_CODER_THREADS_MAX];\r
} CMtCoder;\r
\r
void MtCoder_Construct(CMtCoder* p);\r
void MtCoder_Destruct(CMtCoder* p);\r
SRes MtCoder_Code(CMtCoder *p);\r
\r
EXTERN_C_END\r
\r
#endif\r