Lines Matching refs:p_stream
199 void OPJ_CALLCONV opj_stream_destroy(opj_stream_t* p_stream) in opj_stream_destroy() argument
201 opj_stream_private_t* l_stream = (opj_stream_private_t*) p_stream; in opj_stream_destroy()
213 void OPJ_CALLCONV opj_stream_set_read_function(opj_stream_t* p_stream, in opj_stream_set_read_function() argument
216 opj_stream_private_t* l_stream = (opj_stream_private_t*) p_stream; in opj_stream_set_read_function()
225 void OPJ_CALLCONV opj_stream_set_seek_function(opj_stream_t* p_stream, in opj_stream_set_seek_function() argument
228 opj_stream_private_t* l_stream = (opj_stream_private_t*) p_stream; in opj_stream_set_seek_function()
236 void OPJ_CALLCONV opj_stream_set_write_function(opj_stream_t* p_stream, in opj_stream_set_write_function() argument
239 opj_stream_private_t* l_stream = (opj_stream_private_t*) p_stream; in opj_stream_set_write_function()
248 void OPJ_CALLCONV opj_stream_set_skip_function(opj_stream_t* p_stream, in opj_stream_set_skip_function() argument
251 opj_stream_private_t* l_stream = (opj_stream_private_t*) p_stream; in opj_stream_set_skip_function()
260 void OPJ_CALLCONV opj_stream_set_user_data(opj_stream_t* p_stream, in opj_stream_set_user_data() argument
263 opj_stream_private_t* l_stream = (opj_stream_private_t*) p_stream; in opj_stream_set_user_data()
271 void OPJ_CALLCONV opj_stream_set_user_data_length(opj_stream_t* p_stream, in opj_stream_set_user_data_length() argument
274 opj_stream_private_t* l_stream = (opj_stream_private_t*) p_stream; in opj_stream_set_user_data_length()
281 OPJ_SIZE_T opj_stream_read_data(opj_stream_private_t * p_stream, in opj_stream_read_data() argument
285 if (p_stream->m_bytes_in_buffer >= p_size) { in opj_stream_read_data()
286 memcpy(p_buffer, p_stream->m_current_data, p_size); in opj_stream_read_data()
287 p_stream->m_current_data += p_size; in opj_stream_read_data()
288 p_stream->m_bytes_in_buffer -= p_size; in opj_stream_read_data()
290 p_stream->m_byte_offset += (OPJ_OFF_T)p_size; in opj_stream_read_data()
295 if (p_stream->m_status & OPJ_STREAM_STATUS_END) { in opj_stream_read_data()
296 l_read_nb_bytes += p_stream->m_bytes_in_buffer; in opj_stream_read_data()
297 memcpy(p_buffer, p_stream->m_current_data, p_stream->m_bytes_in_buffer); in opj_stream_read_data()
298 p_stream->m_current_data += p_stream->m_bytes_in_buffer; in opj_stream_read_data()
299 p_stream->m_byte_offset += (OPJ_OFF_T)p_stream->m_bytes_in_buffer; in opj_stream_read_data()
300 p_stream->m_bytes_in_buffer = 0; in opj_stream_read_data()
305 if (p_stream->m_bytes_in_buffer) { in opj_stream_read_data()
306 l_read_nb_bytes += p_stream->m_bytes_in_buffer; in opj_stream_read_data()
307 memcpy(p_buffer, p_stream->m_current_data, p_stream->m_bytes_in_buffer); in opj_stream_read_data()
308 p_stream->m_current_data = p_stream->m_stored_data; in opj_stream_read_data()
309 p_buffer += p_stream->m_bytes_in_buffer; in opj_stream_read_data()
310 p_size -= p_stream->m_bytes_in_buffer; in opj_stream_read_data()
311 p_stream->m_byte_offset += (OPJ_OFF_T)p_stream->m_bytes_in_buffer; in opj_stream_read_data()
312 p_stream->m_bytes_in_buffer = 0; in opj_stream_read_data()
317 p_stream->m_current_data = p_stream->m_stored_data; in opj_stream_read_data()
322 if (p_size < p_stream->m_buffer_size) { in opj_stream_read_data()
324 p_stream->m_bytes_in_buffer = p_stream->m_read_fn(p_stream->m_stored_data, in opj_stream_read_data()
325 p_stream->m_buffer_size, p_stream->m_user_data); in opj_stream_read_data()
327 if (p_stream->m_bytes_in_buffer == (OPJ_SIZE_T) - 1) { in opj_stream_read_data()
331 p_stream->m_bytes_in_buffer = 0; in opj_stream_read_data()
332 p_stream->m_status |= OPJ_STREAM_STATUS_END; in opj_stream_read_data()
335 } else if (p_stream->m_bytes_in_buffer < p_size) { in opj_stream_read_data()
337 l_read_nb_bytes += p_stream->m_bytes_in_buffer; in opj_stream_read_data()
338 memcpy(p_buffer, p_stream->m_current_data, p_stream->m_bytes_in_buffer); in opj_stream_read_data()
339 p_stream->m_current_data = p_stream->m_stored_data; in opj_stream_read_data()
340 p_buffer += p_stream->m_bytes_in_buffer; in opj_stream_read_data()
341 p_size -= p_stream->m_bytes_in_buffer; in opj_stream_read_data()
342 p_stream->m_byte_offset += (OPJ_OFF_T)p_stream->m_bytes_in_buffer; in opj_stream_read_data()
343 p_stream->m_bytes_in_buffer = 0; in opj_stream_read_data()
346 memcpy(p_buffer, p_stream->m_current_data, p_size); in opj_stream_read_data()
347 p_stream->m_current_data += p_size; in opj_stream_read_data()
348 p_stream->m_bytes_in_buffer -= p_size; in opj_stream_read_data()
349 p_stream->m_byte_offset += (OPJ_OFF_T)p_size; in opj_stream_read_data()
354 p_stream->m_bytes_in_buffer = p_stream->m_read_fn(p_buffer, p_size, in opj_stream_read_data()
355 p_stream->m_user_data); in opj_stream_read_data()
357 if (p_stream->m_bytes_in_buffer == (OPJ_SIZE_T) - 1) { in opj_stream_read_data()
361 p_stream->m_bytes_in_buffer = 0; in opj_stream_read_data()
362 p_stream->m_status |= OPJ_STREAM_STATUS_END; in opj_stream_read_data()
365 } else if (p_stream->m_bytes_in_buffer < p_size) { in opj_stream_read_data()
367 l_read_nb_bytes += p_stream->m_bytes_in_buffer; in opj_stream_read_data()
368 p_stream->m_current_data = p_stream->m_stored_data; in opj_stream_read_data()
369 p_buffer += p_stream->m_bytes_in_buffer; in opj_stream_read_data()
370 p_size -= p_stream->m_bytes_in_buffer; in opj_stream_read_data()
371 p_stream->m_byte_offset += (OPJ_OFF_T)p_stream->m_bytes_in_buffer; in opj_stream_read_data()
372 p_stream->m_bytes_in_buffer = 0; in opj_stream_read_data()
375 l_read_nb_bytes += p_stream->m_bytes_in_buffer; in opj_stream_read_data()
376 p_stream->m_byte_offset += (OPJ_OFF_T)p_stream->m_bytes_in_buffer; in opj_stream_read_data()
377 p_stream->m_current_data = p_stream->m_stored_data; in opj_stream_read_data()
378 p_stream->m_bytes_in_buffer = 0; in opj_stream_read_data()
385 OPJ_SIZE_T opj_stream_write_data(opj_stream_private_t * p_stream, in opj_stream_write_data() argument
393 if (p_stream->m_status & OPJ_STREAM_STATUS_ERROR) { in opj_stream_write_data()
398 l_remaining_bytes = p_stream->m_buffer_size - p_stream->m_bytes_in_buffer; in opj_stream_write_data()
402 memcpy(p_stream->m_current_data, p_buffer, p_size); in opj_stream_write_data()
404 p_stream->m_current_data += p_size; in opj_stream_write_data()
405 p_stream->m_bytes_in_buffer += p_size; in opj_stream_write_data()
407 p_stream->m_byte_offset += (OPJ_OFF_T)p_size; in opj_stream_write_data()
416 memcpy(p_stream->m_current_data, p_buffer, l_remaining_bytes); in opj_stream_write_data()
418 p_stream->m_current_data = p_stream->m_stored_data; in opj_stream_write_data()
422 p_stream->m_bytes_in_buffer += l_remaining_bytes; in opj_stream_write_data()
423 p_stream->m_byte_offset += (OPJ_OFF_T)l_remaining_bytes; in opj_stream_write_data()
426 if (! opj_stream_flush(p_stream, p_event_mgr)) { in opj_stream_write_data()
433 OPJ_BOOL opj_stream_flush(opj_stream_private_t * p_stream, in opj_stream_flush() argument
439 p_stream->m_current_data = p_stream->m_stored_data; in opj_stream_flush()
441 while (p_stream->m_bytes_in_buffer) { in opj_stream_flush()
443 l_current_write_nb_bytes = p_stream->m_write_fn(p_stream->m_current_data, in opj_stream_flush()
444 p_stream->m_bytes_in_buffer, in opj_stream_flush()
445 p_stream->m_user_data); in opj_stream_flush()
448 p_stream->m_status |= OPJ_STREAM_STATUS_ERROR; in opj_stream_flush()
454 p_stream->m_current_data += l_current_write_nb_bytes; in opj_stream_flush()
455 p_stream->m_bytes_in_buffer -= l_current_write_nb_bytes; in opj_stream_flush()
458 p_stream->m_current_data = p_stream->m_stored_data; in opj_stream_flush()
463 OPJ_OFF_T opj_stream_read_skip(opj_stream_private_t * p_stream, in opj_stream_read_skip() argument
471 if (p_stream->m_bytes_in_buffer >= (OPJ_SIZE_T)p_size) { in opj_stream_read_skip()
472 p_stream->m_current_data += p_size; in opj_stream_read_skip()
475 p_stream->m_bytes_in_buffer -= (OPJ_SIZE_T)p_size; in opj_stream_read_skip()
477 p_stream->m_byte_offset += l_skip_nb_bytes; in opj_stream_read_skip()
482 if (p_stream->m_status & OPJ_STREAM_STATUS_END) { in opj_stream_read_skip()
483 l_skip_nb_bytes += (OPJ_OFF_T)p_stream->m_bytes_in_buffer; in opj_stream_read_skip()
484 p_stream->m_current_data += p_stream->m_bytes_in_buffer; in opj_stream_read_skip()
485 p_stream->m_bytes_in_buffer = 0; in opj_stream_read_skip()
486 p_stream->m_byte_offset += l_skip_nb_bytes; in opj_stream_read_skip()
491 if (p_stream->m_bytes_in_buffer) { in opj_stream_read_skip()
492 l_skip_nb_bytes += (OPJ_OFF_T)p_stream->m_bytes_in_buffer; in opj_stream_read_skip()
493 p_stream->m_current_data = p_stream->m_stored_data; in opj_stream_read_skip()
494 p_size -= (OPJ_OFF_T)p_stream->m_bytes_in_buffer; in opj_stream_read_skip()
495 p_stream->m_bytes_in_buffer = 0; in opj_stream_read_skip()
503 if ((OPJ_UINT64)(p_stream->m_byte_offset + l_skip_nb_bytes + p_size) > in opj_stream_read_skip()
504 p_stream->m_user_data_length) { in opj_stream_read_skip()
507 p_stream->m_byte_offset += l_skip_nb_bytes; in opj_stream_read_skip()
508 l_skip_nb_bytes = (OPJ_OFF_T)(p_stream->m_user_data_length - in opj_stream_read_skip()
509 (OPJ_UINT64)p_stream->m_byte_offset); in opj_stream_read_skip()
511 opj_stream_read_seek(p_stream, (OPJ_OFF_T)p_stream->m_user_data_length, in opj_stream_read_skip()
513 p_stream->m_status |= OPJ_STREAM_STATUS_END; in opj_stream_read_skip()
520 l_current_skip_nb_bytes = p_stream->m_skip_fn(p_size, p_stream->m_user_data); in opj_stream_read_skip()
524 p_stream->m_status |= OPJ_STREAM_STATUS_END; in opj_stream_read_skip()
525 p_stream->m_byte_offset += l_skip_nb_bytes; in opj_stream_read_skip()
533 p_stream->m_byte_offset += l_skip_nb_bytes; in opj_stream_read_skip()
538 OPJ_OFF_T opj_stream_write_skip(opj_stream_private_t * p_stream, in opj_stream_write_skip() argument
545 if (p_stream->m_status & OPJ_STREAM_STATUS_ERROR) { in opj_stream_write_skip()
550 l_is_written = opj_stream_flush(p_stream, p_event_mgr); in opj_stream_write_skip()
552 p_stream->m_status |= OPJ_STREAM_STATUS_ERROR; in opj_stream_write_skip()
553 p_stream->m_bytes_in_buffer = 0; in opj_stream_write_skip()
560 l_current_skip_nb_bytes = p_stream->m_skip_fn(p_size, p_stream->m_user_data); in opj_stream_write_skip()
565 p_stream->m_status |= OPJ_STREAM_STATUS_ERROR; in opj_stream_write_skip()
566 p_stream->m_byte_offset += l_skip_nb_bytes; in opj_stream_write_skip()
574 p_stream->m_byte_offset += l_skip_nb_bytes; in opj_stream_write_skip()
579 OPJ_OFF_T opj_stream_tell(const opj_stream_private_t * p_stream) in opj_stream_tell() argument
581 return p_stream->m_byte_offset; in opj_stream_tell()
584 OPJ_OFF_T opj_stream_get_number_byte_left(const opj_stream_private_t * p_stream) in opj_stream_get_number_byte_left() argument
586 assert(p_stream->m_byte_offset >= 0); in opj_stream_get_number_byte_left()
587 assert(p_stream->m_user_data_length >= (OPJ_UINT64)p_stream->m_byte_offset); in opj_stream_get_number_byte_left()
588 return p_stream->m_user_data_length ? in opj_stream_get_number_byte_left()
589 (OPJ_OFF_T)(p_stream->m_user_data_length) - p_stream->m_byte_offset : in opj_stream_get_number_byte_left()
593 OPJ_OFF_T opj_stream_skip(opj_stream_private_t * p_stream, OPJ_OFF_T p_size, in opj_stream_skip() argument
597 return p_stream->m_opj_skip(p_stream, p_size, p_event_mgr); in opj_stream_skip()
600 OPJ_BOOL opj_stream_read_seek(opj_stream_private_t * p_stream, OPJ_OFF_T p_size, in opj_stream_read_seek() argument
604 p_stream->m_current_data = p_stream->m_stored_data; in opj_stream_read_seek()
605 p_stream->m_bytes_in_buffer = 0; in opj_stream_read_seek()
607 if (!(p_stream->m_seek_fn(p_size, p_stream->m_user_data))) { in opj_stream_read_seek()
608 p_stream->m_status |= OPJ_STREAM_STATUS_END; in opj_stream_read_seek()
612 p_stream->m_status &= (~OPJ_STREAM_STATUS_END); in opj_stream_read_seek()
613 p_stream->m_byte_offset = p_size; in opj_stream_read_seek()
620 OPJ_BOOL opj_stream_write_seek(opj_stream_private_t * p_stream, in opj_stream_write_seek() argument
623 if (! opj_stream_flush(p_stream, p_event_mgr)) { in opj_stream_write_seek()
624 p_stream->m_status |= OPJ_STREAM_STATUS_ERROR; in opj_stream_write_seek()
628 p_stream->m_current_data = p_stream->m_stored_data; in opj_stream_write_seek()
629 p_stream->m_bytes_in_buffer = 0; in opj_stream_write_seek()
631 if (! p_stream->m_seek_fn(p_size, p_stream->m_user_data)) { in opj_stream_write_seek()
632 p_stream->m_status |= OPJ_STREAM_STATUS_ERROR; in opj_stream_write_seek()
635 p_stream->m_byte_offset = p_size; in opj_stream_write_seek()
641 OPJ_BOOL opj_stream_seek(opj_stream_private_t * p_stream, OPJ_OFF_T p_size, in opj_stream_seek() argument
645 return p_stream->m_opj_seek(p_stream, p_size, p_event_mgr); in opj_stream_seek()
648 OPJ_BOOL opj_stream_has_seek(const opj_stream_private_t * p_stream) in opj_stream_has_seek() argument
650 return p_stream->m_seek_fn != opj_stream_default_seek; in opj_stream_has_seek()