update libchdr

[pcsx_rearmed.git] / deps / libchdr / deps / lzma-22.01 / include / MtDec.h

/* MtDec.h -- Multi-thread Decoder\r
2020-03-05 : Igor Pavlov : Public domain */\r
\r
#ifndef __MT_DEC_H\r
#define __MT_DEC_H\r
\r
#include "7zTypes.h"\r
\r
#ifndef _7ZIP_ST\r
#include "Threads.h"\r
#endif\r
\r
EXTERN_C_BEGIN\r
\r
#ifndef _7ZIP_ST\r
\r
#ifndef _7ZIP_ST\r
  #define MTDEC__THREADS_MAX 32\r
#else\r
  #define MTDEC__THREADS_MAX 1\r
#endif\r
\r
\r
typedef struct\r
{\r
  ICompressProgress *progress;\r
  SRes res;\r
  UInt64 totalInSize;\r
  UInt64 totalOutSize;\r
  CCriticalSection cs;\r
} CMtProgress;\r
\r
void MtProgress_Init(CMtProgress *p, ICompressProgress *progress);\r
SRes MtProgress_Progress_ST(CMtProgress *p);\r
SRes MtProgress_ProgressAdd(CMtProgress *p, UInt64 inSize, UInt64 outSize);\r
SRes MtProgress_GetError(CMtProgress *p);\r
void MtProgress_SetError(CMtProgress *p, SRes res);\r
\r
struct _CMtDec;\r
\r
typedef struct\r
{\r
  struct _CMtDec *mtDec;\r
  unsigned index;\r
  void *inBuf;\r
\r
  size_t inDataSize_Start; // size of input data in start block\r
  UInt64 inDataSize;       // total size of input data in all blocks\r
\r
  CThread thread;\r
  CAutoResetEvent canRead;\r
  CAutoResetEvent canWrite;\r
  void  *allocaPtr;\r
} CMtDecThread;\r
\r
void MtDecThread_FreeInBufs(CMtDecThread *t);\r
\r
\r
typedef enum\r
{\r
  MTDEC_PARSE_CONTINUE, // continue this block with more input data\r
  MTDEC_PARSE_OVERFLOW, // MT buffers overflow, need switch to single-thread\r
  MTDEC_PARSE_NEW,      // new block\r
  MTDEC_PARSE_END       // end of block threading. But we still can return to threading after Write(&needContinue)\r
} EMtDecParseState;\r
\r
typedef struct\r
{\r
  // in\r
  int startCall;\r
  const Byte *src;\r
  size_t srcSize;\r
      // in  : (srcSize == 0) is allowed\r
      // out : it's allowed to return less that actually was used ?\r
  int srcFinished;\r
\r
  // out\r
  EMtDecParseState state;\r
  BoolInt canCreateNewThread;\r
  UInt64 outPos; // check it (size_t)\r
} CMtDecCallbackInfo;\r
\r
\r
typedef struct\r
{\r
  void (*Parse)(void *p, unsigned coderIndex, CMtDecCallbackInfo *ci);\r
  \r
  // PreCode() and Code():\r
  // (SRes_return_result != SZ_OK) means stop decoding, no need another blocks\r
  SRes (*PreCode)(void *p, unsigned coderIndex);\r
  SRes (*Code)(void *p, unsigned coderIndex,\r
      const Byte *src, size_t srcSize, int srcFinished,\r
      UInt64 *inCodePos, UInt64 *outCodePos, int *stop);\r
  // stop - means stop another Code calls\r
\r
\r
  /* Write() must be called, if Parse() was called\r
      set (needWrite) if\r
      {\r
         && (was not interrupted by progress)\r
         && (was not interrupted in previous block)\r
      }\r
\r
    out:\r
      if (*needContinue), decoder still need to continue decoding with new iteration,\r
         even after MTDEC_PARSE_END\r
      if (*canRecode), we didn't flush current block data, so we still can decode current block later.\r
  */\r
  SRes (*Write)(void *p, unsigned coderIndex,\r
      BoolInt needWriteToStream,\r
      const Byte *src, size_t srcSize, BoolInt isCross,\r
      // int srcFinished,\r
      BoolInt *needContinue,\r
      BoolInt *canRecode);\r
\r
} IMtDecCallback2;\r
\r
\r
\r
typedef struct _CMtDec\r
{\r
  /* input variables */\r
  \r
  size_t inBufSize;        /* size of input block */\r
  unsigned numThreadsMax;\r
  // size_t inBlockMax;\r
  unsigned numThreadsMax_2;\r
\r
  ISeqInStream *inStream;\r
  // const Byte *inData;\r
  // size_t inDataSize;\r
\r
  ICompressProgress *progress;\r
  ISzAllocPtr alloc;\r
\r
  IMtDecCallback2 *mtCallback;\r
  void *mtCallbackObject;\r
\r
  \r
  /* internal variables */\r
  \r
  size_t allocatedBufsSize;\r
\r
  BoolInt exitThread;\r
  WRes exitThreadWRes;\r
\r
  UInt64 blockIndex;\r
  BoolInt isAllocError;\r
  BoolInt overflow;\r
  SRes threadingErrorSRes;\r
\r
  BoolInt needContinue;\r
\r
  // CAutoResetEvent finishedEvent;\r
\r
  SRes readRes;\r
  SRes codeRes;\r
\r
  BoolInt wasInterrupted;\r
\r
  unsigned numStartedThreads_Limit;\r
  unsigned numStartedThreads;\r
\r
  Byte *crossBlock;\r
  size_t crossStart;\r
  size_t crossEnd;\r
  UInt64 readProcessed;\r
  BoolInt readWasFinished;\r
  UInt64 inProcessed;\r
\r
  unsigned filledThreadStart;\r
  unsigned numFilledThreads;\r
\r
  #ifndef _7ZIP_ST\r
  BoolInt needInterrupt;\r
  UInt64 interruptIndex;\r
  CMtProgress mtProgress;\r
  CMtDecThread threads[MTDEC__THREADS_MAX];\r
  #endif\r
} CMtDec;\r
\r
\r
void MtDec_Construct(CMtDec *p);\r
void MtDec_Destruct(CMtDec *p);\r
\r
/*\r
MtDec_Code() returns:\r
  SZ_OK - in most cases\r
  MY_SRes_HRESULT_FROM_WRes(WRes_error) - in case of unexpected error in threading function\r
*/\r
  \r
SRes MtDec_Code(CMtDec *p);\r
Byte *MtDec_GetCrossBuff(CMtDec *p);\r
\r
int MtDec_PrepareRead(CMtDec *p);\r
const Byte *MtDec_Read(CMtDec *p, size_t *inLim);\r
\r
#endif\r
\r
EXTERN_C_END\r
\r
#endif\r