core/vil1/file_formats/vil1_jpeg_compressor.cxx

Go to the documentation of this file.

// This is core/vil1/file_formats/vil1_jpeg_compressor.cxx
#ifdef VCL_NEEDS_PRAGMA_INTERFACE
#pragma implementation
#endif
//:
// \file
// \author fsm

#include "vil1_jpeg_compressor.h"
#include "vil1_jpeg_destination_mgr.h"
#include <vil1/vil1_stream.h>
#include <vcl_iostream.h>

vil1_jpeg_compressor::vil1_jpeg_compressor(vil1_stream *s)
  : stream(s)
  , ready(false)
{
  stream->ref();

  // setup the standard error handler in the jpeg library
  jobj.err = jpeg_std_error(&jerr);

  // Zero just in case..
  jobj.next_scanline = 0;

  // construct the compression object :
  jpeg_create_compress(&jobj);

  // set the data destination
  vil1_jpeg_stream_dst_set(&jobj, stream);
}

bool vil1_jpeg_compressor::write_scanline(unsigned line, JSAMPLE const *scanline) {
  if (!ready) {
    // rewind the stream
    vil1_jpeg_stream_dst_rewind(&jobj, stream);

    //
    jobj.next_scanline = 0;

    // set colorspace of input image. FIXME.
    switch (jobj.input_components) {
    case 1:
      jobj.in_color_space = JCS_GRAYSCALE;
      break;
    case 3:
      jobj.in_color_space = JCS_RGB;
      break;
    default:
      vcl_cerr << __FILE__ " : urgh!\n";
      return false;
    }

    jpeg_set_defaults(&jobj);

    // start compression
    bool write_all_tables = true;
    jpeg_start_compress (&jobj, write_all_tables);

    //
    ready = true;
  }

  //
  if (line != jobj.next_scanline) {
    vcl_cerr << "scanlines must be written in order\n";
    return false;
  }

  // write the scanline
  { JSAMPLE *tmp = const_cast<JSAMPLE*>(scanline);
  jpeg_write_scanlines(&jobj, &tmp, 1); }

  // finish if the last scanline is written
  if (line == jobj.image_height - 1) {
    jpeg_finish_compress(&jobj);
    ready = false;
  }

  return true;
}

vil1_jpeg_compressor::~vil1_jpeg_compressor() {
  // finish compression if necessary
  if (ready)
    jpeg_finish_compress(&jobj);

  // destroy the compression object
  jpeg_destroy_compress(&jobj);

  //
  stream->unref();
  stream = 0;
}

---