common/rfb/JpegEncoder.cxx

/* Copyright (C) 2007 Constantin Kaplinsky.  All Rights Reserved.
 *    
 * This is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 * 
 * This software is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 * 
 * You should have received a copy of the GNU General Public License
 * along with this software; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307,
 * USA.
 */

#include <rfb/JpegEncoder.h>
#include <rdr/OutStream.h>
#include <rfb/encodings.h>
#include <rfb/LogWriter.h>

#ifdef HAVE_DMEDIA
#include <rfb/IrixDMJpegCompressor.h>
#endif

using namespace rfb;

static LogWriter vlog("JpegEncoder");

BoolParameter JpegEncoder::useHardwareJPEG
("UseHardwareJPEG",
 "Use hardware-accelerated JPEG compressor for video if available",
 true);

const int JpegEncoder::qualityMap[10] = {
  2, 10, 15, 25, 37, 50, 60, 70, 80, 90
};

JpegEncoder::JpegEncoder(SMsgWriter* writer_) : writer(writer_), jcomp(0)
{
#ifdef HAVE_DMEDIA
  if (useHardwareJPEG) {
    vlog.debug("trying IRIX DM JPEG compressor");
    IrixDMJpegCompressor *irixComp = new IrixDMJpegCompressor;
    if (irixComp->isValid()) {
      vlog.debug("initialized IRIX DM JPEG compressor successfully");
      jcomp = irixComp;
    } else {
      vlog.error("warning: could not create IRIX DM JPEG compressor");
      delete irixComp;
    }
  }
#else
  if (useHardwareJPEG) {
    vlog.info("no hardware JPEG compressor available");
  }
#endif
  if (!jcomp) {
    vlog.debug("using software JPEG compressor");
    jcomp = new StandardJpegCompressor;
  }
  jcomp->setQuality(qualityMap[6]);
}

JpegEncoder::~JpegEncoder()
{
  delete jcomp;
}

void JpegEncoder::setQualityLevel(int level)
{
  if (level < 0) {
    level = 0;
  } else if (level > 9) {
    level = 9;
  }
  jcomp->setQuality(qualityMap[level]);
}

bool JpegEncoder::writeRect(PixelBuffer* pb, const Rect& r)
{
  int serverBitsPerPixel = pb->getPF().bpp;
  int clientBitsPerPixel = writer->bpp();

  // FIXME: Implement JPEG compression for (serverBitsPerPixel == 16).
  // FIXME: Check that all color components are actually 8 bits wide.
  if (serverBitsPerPixel != 32 || clientBitsPerPixel < 16) {
    // FIXME: Make sure this return value is checked properly.
    return false;
  }

  writer->startRect(r, encodingTight);
  rdr::OutStream* os = writer->getOutStream();

  // Get access to pixel data
  int stride;
  const rdr::U32* pixels = (const rdr::U32 *)pb->getPixelsR(r, &stride);
  const PixelFormat& fmt = pb->getPF();

  // Encode data
  jcomp->compress(pixels, &fmt, r.width(), r.height(), stride);

  // Write Tight-encoded header and JPEG data.
  os->writeU8(0x09 << 4);
  os->writeCompactLength(jcomp->getDataLength());
  os->writeBytes(jcomp->getDataPtr(), jcomp->getDataLength());

  writer->endRect();

  return true;
}