grk::Codec Class Reference

#include <Codec.h>

Classes
struct	TileTask

Public Member Functions
	Codec (grk::IStream *stream)
	~Codec ()
	Codec (const Codec &)=delete
Codec &	operator= (const Codec &)=delete
std::future< bool >	queueDecompressTile (uint16_t tile_index)

Static Public Member Functions
static Codec *	getImpl (grk_object *codec)

Public Attributes
grk_object	obj
ICompressor *	compressor_
IDecompressor *	decompressor_
std::unique_ptr< grk::IStream >	stream_

Private Member Functions
void	startWorkerThreadIfNeeded ()
void	stopWorkerThread ()
void	workerThread ()

Private Attributes
std::thread	worker_
std::queue< TileTask >	task_queue_
std::mutex	queue_mutex_
std::condition_variable	queue_cv_
std::atomic< bool >	stop_worker_
std::mutex	thread_start_mutex_
bool	thread_started_

Constructor & Destructor Documentation

Codec() [1/2]

grk::Codec::Codec ( grk::IStream * stream )

inlineexplicit

References compressor_, decompressor_, obj, stop_worker_, stream_, and thread_started_.

Referenced by Codec(), getImpl(), and operator=().

~Codec()

grk::Codec::~Codec ( )

inline

References compressor_, decompressor_, and stopWorkerThread().

Codec() [2/2]

grk::Codec::Codec ( const Codec & )

delete

References Codec().

Member Function Documentation

getImpl()

Codec * grk::Codec::getImpl ( grk_object * codec )

inlinestatic

References Codec().

Referenced by grk_compress(), grk_compress_finish(), grk_compress_frame(), grk_compress_get_compressed_length(), grk_compress_init(), grk_decompress(), grk_decompress_get_image(), grk_decompress_get_progression_state(), grk_decompress_get_sample_image(), grk_decompress_get_sample_tile_image(), grk_decompress_get_tile_image(), grk_decompress_init(), grk_decompress_num_samples(), grk_decompress_read_header(), grk_decompress_sample(), grk_decompress_schedule_swath_copy(), grk_decompress_set_band_callback(), grk_decompress_set_progression_state(), grk_decompress_tile(), grk_decompress_update(), grk_decompress_wait(), grk_decompress_wait_swath_copy(), grk_dump_codec(), grk_transcode(), grkStartCompress(), and grk::FileFormatJP2Compress::transcodeCodestream().

operator=()

Codec & grk::Codec::operator= ( const Codec & )

delete

References Codec().

queueDecompressTile()

std::future< bool > grk::Codec::queueDecompressTile ( uint16_t tile_index )

inline

References queue_cv_, queue_mutex_, startWorkerThreadIfNeeded(), and task_queue_.

startWorkerThreadIfNeeded()

void grk::Codec::startWorkerThreadIfNeeded ( )

inlineprivate

References thread_start_mutex_, thread_started_, worker_, and workerThread().

Referenced by queueDecompressTile().

stopWorkerThread()

void grk::Codec::stopWorkerThread ( )

inlineprivate

References queue_cv_, queue_mutex_, stop_worker_, and worker_.

Referenced by ~Codec().

workerThread()

void grk::Codec::workerThread ( )

inlineprivate

References decompressor_, grk::Codec::TileTask::promise, queue_cv_, queue_mutex_, stop_worker_, task_queue_, and grk::Codec::TileTask::tile_index.

Referenced by startWorkerThreadIfNeeded().

Member Data Documentation

compressor_

ICompressor* grk::Codec::compressor_

Referenced by Codec(), grk_compress_create(), and ~Codec().

decompressor_

IDecompressor* grk::Codec::decompressor_

Referenced by Codec(), grkDecompressCreate(), workerThread(), and ~Codec().

obj

grk_object grk::Codec::obj

Referenced by Codec(), grk_compress_create(), and grkDecompressCreate().

queue_cv_

std::condition_variable grk::Codec::queue_cv_

private

Referenced by queueDecompressTile(), stopWorkerThread(), and workerThread().

queue_mutex_

std::mutex grk::Codec::queue_mutex_

private

Referenced by queueDecompressTile(), stopWorkerThread(), and workerThread().

stop_worker_

std::atomic<bool> grk::Codec::stop_worker_

private

Referenced by Codec(), stopWorkerThread(), and workerThread().

stream_

std::unique_ptr<grk::IStream> grk::Codec::stream_

Referenced by Codec().

task_queue_

std::queue<TileTask> grk::Codec::task_queue_

private

Referenced by queueDecompressTile(), and workerThread().

thread_start_mutex_

std::mutex grk::Codec::thread_start_mutex_

private

Referenced by startWorkerThreadIfNeeded().

thread_started_

bool grk::Codec::thread_started_

private

Referenced by Codec(), and startWorkerThreadIfNeeded().

worker_

std::thread grk::Codec::worker_

private

Referenced by startWorkerThreadIfNeeded(), and stopWorkerThread().

---

The documentation for this class was generated from the following file:

• Codec.h