NCEPLIBS-g2c 2.1.0
Loading...
Searching...
No Matches
decenc_openjpeg.c
Go to the documentation of this file.
1
6/* Copyright 2005-2019 ECMWF.
7 *
8 * This software is licensed under the terms of the Apache Licence
9 * Version 2.0 which can be obtained at
10 * http://www.apache.org/licenses/LICENSE-2.0.
11 *
12 * In applying this licence, ECMWF does not waive the privileges and
13 * immunities granted to it by virtue of its status as an
14 * intergovernmental organisation nor does it submit to any
15 * jurisdiction.
16 */
17
18#if !defined USE_JPEG2000 && defined USE_OPENJPEG
19
20#include "grib2_int.h"
21#include "openjpeg.h"
22
23#include <assert.h>
24#include <stdio.h>
25#include <stdlib.h>
26#include <string.h>
27
36static void
37openjpeg_warning(const char *msg, void *client_data)
38{
39 (void)client_data;
40 fprintf(stderr, "openjpeg: %s", msg);
41}
42
51static void
52openjpeg_error(const char *msg, void *client_data)
53{
54 (void)client_data;
55 fprintf(stderr, "openjpeg: %s", msg);
56}
57
66static void
67openjpeg_info(const char *msg, void *client_data)
68{
69 (void)msg;
70 (void)client_data;
71 /* fprintf(stderr,"openjpeg: %s",msg); */
72}
73
74/* opj_* Helper code from
75 * https://groups.google.com/forum/#!topic/openjpeg/8cebr0u7JgY
76 */
77/* These routines are added to use memory instead of a file for input and output */
78/* struct need to treat memory as a stream */
79typedef struct
80{
81 OPJ_UINT8 *pData; /* our data */
82 OPJ_SIZE_T dataSize; /* how big is our data */
83 OPJ_SIZE_T offset; /* where we are currently in our data */
84} opj_memory_stream;
85
97static OPJ_SIZE_T
98opj_memory_stream_read(void *buffer, OPJ_SIZE_T nb_bytes, void *p_user_data)
99{
100 opj_memory_stream *mstream = (opj_memory_stream *)p_user_data; /* Our data */
101 OPJ_SIZE_T nb_bytes_read = nb_bytes; /* Amount to move to buffer */
102
103 /* Check if the current offset is outside our data buffer */
104 if (mstream->offset >= mstream->dataSize)
105 return (OPJ_SIZE_T)-1;
106
107 /* Check if we are reading more than we have */
108 if (nb_bytes > (mstream->dataSize - mstream->offset))
109 nb_bytes_read = mstream->dataSize - mstream->offset;
110
111 memcpy(buffer, &(mstream->pData[mstream->offset]), nb_bytes_read);
112 mstream->offset += nb_bytes_read; /* Update the pointer to the new location */
113 return nb_bytes_read;
114}
115
127static OPJ_SIZE_T
128opj_memory_stream_write(void *buffer, OPJ_SIZE_T nb_bytes, void *user_data)
129{
130 opj_memory_stream *mstream = (opj_memory_stream *)user_data; /* our data */
131 OPJ_SIZE_T nb_bytes_write = nb_bytes; /* Amount to move to buffer */
132
133 /* Check if the current offset is outside our data buffer */
134 if (mstream->offset >= mstream->dataSize)
135 return (OPJ_SIZE_T)-1;
136
137 /* Check if we are writing more than we have space for */
138 if (nb_bytes > (mstream->dataSize - mstream->offset))
139 nb_bytes_write = mstream->dataSize - mstream->offset;
140
141 /* Copy the data from the internal buffer */
142 memcpy(&(mstream->pData[mstream->offset]), buffer, nb_bytes_write);
143 mstream->offset += nb_bytes_write; /* Update the pointer to the new location */
144 return nb_bytes_write;
145}
146
157static OPJ_OFF_T
158opj_memory_stream_skip(OPJ_OFF_T nb_bytes, void *user_data)
159{
160 opj_memory_stream *mstream = (opj_memory_stream *)user_data;
161 OPJ_SIZE_T l_nb_bytes;
162
163 if (nb_bytes < 0)
164 return -1; /* No skipping backwards */
165 l_nb_bytes = (OPJ_SIZE_T)nb_bytes; /* Allowed because it is positive */
166 /* Do not allow jumping past the end */
167 if (l_nb_bytes > mstream->dataSize - mstream->offset)
168 l_nb_bytes = mstream->dataSize - mstream->offset;
169 mstream->offset += l_nb_bytes;
170 return (OPJ_OFF_T)l_nb_bytes; /* Return how far we jumped */
171}
172
183static OPJ_BOOL
184opj_memory_stream_seek(OPJ_OFF_T nb_bytes, void *user_data)
185{
186 opj_memory_stream *mstream = (opj_memory_stream *)user_data;
187
188 if (nb_bytes < 0)
189 return OPJ_FALSE; /* Not before the buffer */
190 if (nb_bytes > (OPJ_OFF_T)mstream->dataSize)
191 return OPJ_FALSE; /* Not after the buffer */
192 mstream->offset = (OPJ_SIZE_T)nb_bytes; /* Move to new position */
193 return OPJ_TRUE;
194}
195
203static void
204opj_memory_stream_do_nothing(void *p_user_data)
205{
206 OPJ_ARG_NOT_USED(p_user_data);
207}
208
219static opj_stream_t *
220opj_stream_create_default_memory_stream(opj_memory_stream *memoryStream, OPJ_BOOL is_read_stream)
221{
222 opj_stream_t *stream;
223
224 if (!(stream = opj_stream_default_create(is_read_stream)))
225 return (NULL);
226 /* Set how to work with the frame buffer */
227 if (is_read_stream)
228 opj_stream_set_read_function(stream, opj_memory_stream_read);
229 else
230 opj_stream_set_write_function(stream, opj_memory_stream_write);
231
232 opj_stream_set_seek_function(stream, opj_memory_stream_seek);
233 opj_stream_set_skip_function(stream, opj_memory_stream_skip);
234 opj_stream_set_user_data(stream, memoryStream, opj_memory_stream_do_nothing);
235 opj_stream_set_user_data_length(stream, memoryStream->dataSize);
236 return stream;
237}
238
260int
261g2c_dec_jpeg2000(char *injpc, size_t bufsize, int *outfld)
262{
263 return dec_jpeg2000(injpc, bufsize, (g2int *)outfld);
264}
265
287int
288dec_jpeg2000(char *injpc, g2int bufsize, g2int *outfld)
289{
290 int iret = 0;
291 OPJ_INT32 mask;
292
293 opj_stream_t *stream = NULL;
294 opj_image_t *image = NULL;
295 opj_codec_t *codec = NULL;
296
297 /* set decoding parameters to default values */
298 opj_dparameters_t parameters = {
299 0,
300 }; /* decompression parameters */
301 opj_set_default_decoder_parameters(&parameters);
302 parameters.decod_format = 1; /* JP2_FMT */
303
304 /* get a decoder handle */
305 codec = opj_create_decompress(OPJ_CODEC_J2K);
306
307 /* catch events using our callbacks */
308 opj_set_info_handler(codec, openjpeg_info, NULL);
309 opj_set_warning_handler(codec, openjpeg_warning, NULL);
310 opj_set_error_handler(codec, openjpeg_error, NULL);
311
312 /* initialize our memory stream */
313 opj_memory_stream mstream;
314 mstream.pData = (OPJ_UINT8 *)injpc;
315 mstream.dataSize = (OPJ_SIZE_T)bufsize;
316 mstream.offset = 0;
317 /* open a byte stream from memory stream */
318 stream = opj_stream_create_default_memory_stream(&mstream, OPJ_STREAM_READ);
319
320 /* setup the decoder decoding parameters using user parameters */
321 if (!opj_setup_decoder(codec, &parameters))
322 {
323 fprintf(stderr, "openjpeg: failed to setup decoder");
324 iret = -3;
325 goto cleanup;
326 }
327 if (!opj_read_header(stream, codec, &image))
328 {
329 fprintf(stderr, "openjpeg: failed to read the header");
330 iret = -3;
331 goto cleanup;
332 }
333 if (!opj_decode(codec, stream, image))
334 {
335 fprintf(stderr, "openjpeg: failed to decode");
336 iret = -3;
337 goto cleanup;
338 }
339
340 if ((image->numcomps != 1) || (image->x1 * image->y1) == 0)
341 {
342 iret = -3;
343 goto cleanup;
344 }
345
346 assert(image->comps[0].sgnd == 0);
347 assert(image->comps[0].prec < sizeof(mask) * 8 - 1);
348
349 mask = (1 << image->comps[0].prec) - 1;
350
351 for (unsigned int i = 0; i < image->comps[0].w * image->comps[0].h; i++)
352 outfld[i] = (g2int)(image->comps[0].data[i] & mask);
353
354 if (!opj_end_decompress(codec, stream))
355 {
356 fprintf(stderr, "openjpeg: failed in opj_end_decompress");
357 iret = -3;
358 }
359
360cleanup:
361 /* close the byte stream */
362 if (codec)
363 opj_destroy_codec(codec);
364 if (stream)
365 opj_stream_destroy(stream);
366 if (image)
367 opj_image_destroy(image);
368
369 return iret;
370}
371
405int
406g2c_enc_jpeg2000(unsigned char *cin, int width, int height, int nbits,
407 int ltype, int ratio, int retry, char *outjpc,
408 size_t jpclen)
409{
410 g2int width8 = width, height8 = height, nbits8 = nbits, ltype8 = ltype;
411 g2int ratio8 = ratio, retry8 = retry, jpclen8 = jpclen;
412
413 return enc_jpeg2000(cin, width8, height8, nbits8, ltype8, ratio8, retry8,
414 outjpc, jpclen8);
415}
416
450int
451enc_jpeg2000(unsigned char *cin, g2int width, g2int height, g2int nbits,
452 g2int ltype, g2int ratio, g2int retry, char *outjpc,
453 g2int jpclen)
454{
455 (void)retry;
456 int iret = 0;
457 int nbytes = 0;
458 const int numcomps = 1;
459 g2int *ifld = NULL;
460
461 opj_codec_t *codec = NULL;
462 opj_image_t *image = NULL;
463 opj_stream_t *stream = NULL;
464
465 /* set encoding parameters to default values */
466 opj_cparameters_t parameters = {
467 0,
468 }; /* compression parameters */
469 opj_set_default_encoder_parameters(&parameters);
470
471 parameters.tcp_numlayers = 1;
472 parameters.cp_disto_alloc = 1;
473 if (ltype == 1)
474 {
475 assert(ratio != 255);
476 parameters.tcp_rates[0] = 1.0f / (float)ratio;
477 }
478
479 /* By default numresolution = 6 (must be between 1 and 32)
480 * This may be too large for some of our datasets, eg. 1xn, so adjust ...
481 */
482 parameters.numresolution = 6;
483 while ((width < (1 << (parameters.numresolution - 1))) ||
484 (height < (1 << (parameters.numresolution - 1))))
485 {
486 parameters.numresolution--;
487 }
488
489 /* initialize image component */
490 opj_image_cmptparm_t cmptparm = {
491 0,
492 };
493 cmptparm.prec = (OPJ_UINT32)nbits;
494 cmptparm.sgnd = 0;
495 cmptparm.dx = 1;
496 cmptparm.dy = 1;
497 cmptparm.w = (OPJ_UINT32)width;
498 cmptparm.h = (OPJ_UINT32)height;
499
500 /* create the image */
501 image = opj_image_create(numcomps, &cmptparm, OPJ_CLRSPC_GRAY);
502 if (!image)
503 {
504 iret = -3;
505 goto cleanup;
506 }
507 image->x0 = 0;
508 image->y0 = 0;
509 image->x1 = (OPJ_UINT32)width;
510 image->y1 = (OPJ_UINT32)height;
511
512 assert(cmptparm.prec <= sizeof(image->comps[0].data[0]) * 8 - 1); /* BR: -1 because I don't know what happens if the sign bit is set */
513
514 ifld = malloc(width * height * sizeof(g2int));
515 nbytes = (nbits + 7) / 8;
516 gbits(cin, ifld, 0, nbytes * 8, 0, width * height);
517 /* Simple packing */
518 for (int i = 0; i < width * height; i++)
519 {
520 image->comps[0].data[i] = ifld[i];
521 }
522 free(ifld);
523
524 /* get a J2K compressor handle */
525 codec = opj_create_compress(OPJ_CODEC_J2K);
526
527 opj_set_info_handler(codec, openjpeg_info, NULL);
528 opj_set_warning_handler(codec, openjpeg_warning, NULL);
529 opj_set_error_handler(codec, openjpeg_error, NULL);
530
531 /* setup the encoder parameters using the current image and user parameters */
532 if (!opj_setup_encoder(codec, &parameters, image))
533 {
534 fprintf(stderr, "openjpeg: failed to setup encoder");
535 iret = -3;
536 goto cleanup;
537 }
538
539 /* open a byte stream for writing */
540 opj_memory_stream mstream;
541 mstream.pData = (OPJ_UINT8 *)outjpc;
542 mstream.offset = 0;
543 mstream.dataSize = (OPJ_SIZE_T)jpclen;
544 stream = opj_stream_create_default_memory_stream(&mstream, OPJ_STREAM_WRITE);
545 if (!stream)
546 {
547 fprintf(stderr, "openjpeg: failed create default memory stream");
548 iret = -3;
549 goto cleanup;
550 }
551
552 if (!opj_start_compress(codec, image, stream))
553 {
554 fprintf(stderr, "openjpeg: failed to setup encoder");
555 iret = -3;
556 goto cleanup;
557 }
558
559 /* encode image */
560 if (!opj_encode(codec, stream))
561 {
562 fprintf(stderr, "openjpeg: opj_encode failed");
563 iret = -3;
564 goto cleanup;
565 }
566
567 if (!opj_end_compress(codec, stream))
568 {
569 fprintf(stderr, "openjpeg: opj_end_compress failed");
570 iret = -3;
571 goto cleanup;
572 }
573 iret = (int)mstream.offset;
574
575cleanup:
576 if (codec)
577 opj_destroy_codec(codec);
578 if (stream)
579 opj_stream_destroy(stream);
580 if (image)
581 opj_image_destroy(image);
582
583 return iret;
584}
585
586#endif
int g2c_dec_jpeg2000(char *injpc, size_t bufsize, int *outfld)
Decode a JPEG2000 code stream specified in the JPEG2000 Part-1 standard (i.e., ISO/IEC 15444-1) using...
int g2c_enc_jpeg2000(unsigned char *cin, int width, int height, int nbits, int ltype, int ratio, int retry, char *outjpc, size_t jpclen)
Encode a grayscale image into a JPEG2000 code stream specified in the JPEG2000 Part-1 standard (i....
int dec_jpeg2000(char *injpc, g2int bufsize, g2int *outfld)
Decode a JPEG2000 code stream specified in the JPEG2000 Part-1 standard (i.e., ISO/IEC 15444-1) using...
int enc_jpeg2000(unsigned char *cin, g2int width, g2int height, g2int nbits, g2int ltype, g2int ratio, g2int retry, char *outjpc, g2int jpclen)
Encode a grayscale image into a JPEG2000 code stream specified in the JPEG2000 Part-1 standard (i....
void gbits(unsigned char *in, g2int *iout, g2int iskip, g2int nbits, g2int nskip, g2int n)
Unpack arbitrary size values from a packed bit string, right justifying each value in the unpacked io...
Definition gbits.c:57
int64_t g2int
Long integer type.
Definition grib2.h:32
Header file with internal function prototypes NCEPLIBS-g2c library.