ParallelBZip2OutputStream

: Stream : MarshalByRefObject : Object

Pathfinding.Ionic.BZip2.ParallelBZip2OutputStream, Pathfinding.Ionic.Zip.Reduced 0x00B8 (184 B) inherited 0x0028 Pathfinding.Ionic.Zip.Reduced.dll

0x00x00B8

Members 25

Show inherited members

Offset	Size	Name	Type	Flags	Default
	0x04	BufferPairsPerCore	int	PrivateStatic+1 flags	—
	0x04	_maxWorkers	int	Private	—
	0x01	firstWriteDone	bool	Private	—
0x002D	0x03	padding / unreflected
	0x04	lastFilled	int	Private	—
	0x04	lastWritten	int	Private	—
	0x04	latestCompressed	int	Private	—
	0x04	currentlyFilling	int	Private	—
	0x08	pendingException	Exception	Private	—
	0x01	handlingException	bool	Private	—
	0x01	emitting	bool	Private	—
0x004A	0x06	padding / unreflected
	0x08	toWrite	Queue<System.Int32>	Private	—
	0x08	toFill	Queue<System.Int32>	Private	—
	0x08	pool	List<Pathfinding.Ionic.BZip2.WorkItem>	Private	—
	0x08	latestLock	object	Private	—
	0x08	eLock	object	Private	—
	0x08	outputLock	object	Private	—
	0x08	newlyCompressedBlob	AutoResetEvent	Private	—
	0x08	totalBytesWrittenIn	long	Private	—
	0x08	totalBytesWrittenOut	long	Private	—
	0x01	leaveOpen	bool	Private	—
0x0099	0x03	padding / unreflected
	0x04	combinedCRC	uint	Private	—
	0x08	output	Stream	Private	—
	0x08	bw	BitWriter	Private	—
	0x04	blockSize100k	int	Private	—
	0x04	desiredTrace	TraceBits	Private	—

Inherited from Stream 3

Offset	Size	Name	Type	Flags	Default
	0x08	Null	Stream	PublicStatic+1 flags	—
0x0008	0x10	padding / unreflected
	0x08	_activeReadWriteTask	ReadWriteTask	Private+1 flags	—
	0x08	_asyncActiveSemaphore	SemaphoreSlim	Private+1 flags	—

Inherited from MarshalByRefObject 1

Offset	Size	Name	Type	Flags	Default
	0x08	_identity	object	Private+1 flags	—

Functions 28

Signature	Flags	Params
void .ctor(Stream output)	Public+1 flags	0x08
void .ctor(Stream output, int blockSize)	Public+1 flags	0x08
void .ctor(Stream output, bool leaveOpen)	Public+1 flags	0x08
void .ctor(Stream output, int blockSize, bool leaveOpen)	Public+1 flags	0x08
void .cctor()	PrivateStatic+1 flags	0x00
void InitializePoolOfWorkItems()	Private	0x00
int get_MaxWorkers()	Public+1 flags	0x04
void set_MaxWorkers(int value)	Public+1 flags	0x04
void Close()	Public+1 flags	0x00
void FlushOutput(bool lastInput)	Private	0x01
void Flush()	Public+1 flags	0x00
void EmitHeader()	Private	0x00
void EmitTrailer()	Private	0x00
int get_BlockSize()	Public+1 flags	0x04
void Write(const byte[]& buffer, int offset, int count)	Public+1 flags	0x08
void EmitPendingBuffers(bool doAll, bool mustWait)	Private	0x01
void CompressOne(object wi)	Private	0x08
bool get_CanRead()	Public+2 flags	0x01
bool get_CanSeek()	Public+2 flags	0x01
bool get_CanWrite()	Public+2 flags	0x01
long get_Length()	Public+2 flags	0x08
long get_Position()	Public+2 flags	0x08
void set_Position(long value)	Public+2 flags	0x08
long get_BytesWrittenOut()	Public+1 flags	0x08
long Seek(long offset, const SeekOrigin& origin)	Public+1 flags	0x08
void SetLength(long value)	Public+1 flags	0x08
int Read(const byte[]& buffer, int offset, int count)	Public+1 flags	0x08
void TraceOutput(const TraceBits& bits, const string& format, const object[]& varParams)	Private	0x08

// Pathfinding.Ionic.BZip2.ParallelBZip2OutputStream, Pathfinding.Ionic.Zip.Reduced
// size 0x00B8 (184), inherited 0x0028
class ParallelBZip2OutputStream : public Stream
{
public:
    int BufferPairsPerCore;                            // 0x0000(0x04) Private Static InitOnly
    int _maxWorkers;                                   // 0x0028(0x04) Private
    bool firstWriteDone;                               // 0x002C(0x01) Private
    uint8 pad_0[0x03];                             // 0x002D(0x03)
    int lastFilled;                                    // 0x0030(0x04) Private
    int lastWritten;                                   // 0x0034(0x04) Private
    int latestCompressed;                              // 0x0038(0x04) Private
    int currentlyFilling;                              // 0x003C(0x04) Private
    Exception pendingException;                        // 0x0040(0x08) Private
    bool handlingException;                            // 0x0048(0x01) Private
    bool emitting;                                     // 0x0049(0x01) Private
    uint8 pad_1[0x06];                             // 0x004A(0x06)
    Queue<System.Int32> toWrite;                       // 0x0050(0x08) Private
    Queue<System.Int32> toFill;                        // 0x0058(0x08) Private
    List<Pathfinding.Ionic.BZip2.WorkItem> pool;       // 0x0060(0x08) Private
    object latestLock;                                 // 0x0068(0x08) Private
    object eLock;                                      // 0x0070(0x08) Private
    object outputLock;                                 // 0x0078(0x08) Private
    AutoResetEvent newlyCompressedBlob;                // 0x0080(0x08) Private
    long totalBytesWrittenIn;                          // 0x0088(0x08) Private
    long totalBytesWrittenOut;                         // 0x0090(0x08) Private
    bool leaveOpen;                                    // 0x0098(0x01) Private
    uint8 pad_2[0x03];                             // 0x0099(0x03)
    uint combinedCRC;                                  // 0x009C(0x04) Private
    Stream output;                                     // 0x00A0(0x08) Private
    BitWriter bw;                                      // 0x00A8(0x08) Private
    int blockSize100k;                                 // 0x00B0(0x04) Private
    TraceBits desiredTrace;                            // 0x00B4(0x04) Private

    void .ctor(Stream output); // 0x1d47590 [Public SpecialName]
    void .ctor(Stream output, int blockSize); // 0x1d47610 [Public SpecialName]
    void .ctor(Stream output, bool leaveOpen); // 0x1d47630 [Public SpecialName]
    void .ctor(Stream output, int blockSize, bool leaveOpen); // 0x1d476c0 [Public SpecialName]
    void .cctor(); // 0x1d47550 [Private Static SpecialName]
    void InitializePoolOfWorkItems(); // 0x1d46b00 [Private]
    int get_MaxWorkers(); // 0x45ff00 [Public SpecialName]
    void set_MaxWorkers(int value); // 0x1d47bc0 [Public SpecialName]
    void Close(); // 0x1d45cd0 [Public Virtual]
    void FlushOutput(bool lastInput); // 0x1d46990 [Private]
    void Flush(); // 0x1d46a40 [Public Virtual]
    void EmitHeader(); // 0x1d46030 [Private]
    void EmitTrailer(); // 0x1d466d0 [Private]
    int get_BlockSize(); // 0xb9c9c0 [Public SpecialName]
    void Write(byte[] buffer, int offset, int count); // 0x1d47080 [Public Virtual]
    void EmitPendingBuffers(bool doAll, bool mustWait); // 0x1d460f0 [Private]
    void CompressOne(object wi); // 0x1d45de0 [Private]
    bool get_CanRead(); // 0x45ea60 [Public Virtual SpecialName]
    bool get_CanSeek(); // 0x45ea60 [Public Virtual SpecialName]
    bool get_CanWrite(); // 0x1d47b00 [Public Virtual SpecialName]
    long get_Length(); // 0x1d47b80 [Public Virtual SpecialName]
    long get_Position(); // 0x497b60 [Public Virtual SpecialName]
    void set_Position(long value); // 0x1d47c40 [Public Virtual SpecialName]
    long get_BytesWrittenOut(); // 0x542860 [Public SpecialName]
    long Seek(long offset, SeekOrigin origin); // 0x1d46ed0 [Public Virtual]
    void SetLength(long value); // 0x1d46f10 [Public Virtual]
    int Read(byte[] buffer, int offset, int count); // 0x1d46e90 [Public Virtual]
    void TraceOutput(TraceBits bits, string format, object[] varParams); // 0x1d46f50 [Private]
};