mirror of https://github.com/SixLabors/ImageSharp
committed by
GitHub
16 changed files with 2056 additions and 1827 deletions
@ -1,101 +0,0 @@ |
|||
// <copyright file="GrayImage.cs" company="James Jackson-South">
|
|||
// Copyright (c) James Jackson-South and contributors.
|
|||
// Licensed under the Apache License, Version 2.0.
|
|||
// </copyright>
|
|||
|
|||
namespace ImageSharp.Formats.Jpg |
|||
{ |
|||
/// <summary>
|
|||
/// Represents a grayscale image
|
|||
/// </summary>
|
|||
internal class GrayImage |
|||
{ |
|||
/// <summary>
|
|||
/// Initializes a new instance of the <see cref="GrayImage"/> class.
|
|||
/// </summary>
|
|||
/// <param name="width">The width.</param>
|
|||
/// <param name="height">The height.</param>
|
|||
public GrayImage(int width, int height) |
|||
{ |
|||
this.Width = width; |
|||
this.Height = height; |
|||
this.Pixels = new byte[width * height]; |
|||
this.Stride = width; |
|||
this.Offset = 0; |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Prevents a default instance of the <see cref="GrayImage"/> class from being created.
|
|||
/// </summary>
|
|||
private GrayImage() |
|||
{ |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Gets or sets the pixels.
|
|||
/// </summary>
|
|||
public byte[] Pixels { get; set; } |
|||
|
|||
/// <summary>
|
|||
/// Gets or sets the stride.
|
|||
/// </summary>
|
|||
public int Stride { get; set; } |
|||
|
|||
/// <summary>
|
|||
/// Gets or sets the horizontal position.
|
|||
/// </summary>
|
|||
public int X { get; set; } |
|||
|
|||
/// <summary>
|
|||
/// Gets or sets the vertical position.
|
|||
/// </summary>
|
|||
public int Y { get; set; } |
|||
|
|||
/// <summary>
|
|||
/// Gets or sets the width.
|
|||
/// </summary>
|
|||
public int Width { get; set; } |
|||
|
|||
/// <summary>
|
|||
/// Gets or sets the height.
|
|||
/// </summary>
|
|||
public int Height { get; set; } |
|||
|
|||
/// <summary>
|
|||
/// Gets or sets the offset
|
|||
/// </summary>
|
|||
public int Offset { get; set; } |
|||
|
|||
/// <summary>
|
|||
/// Gets an image made up of a subset of the originals pixels.
|
|||
/// </summary>
|
|||
/// <param name="x">The x-coordinate of the image.</param>
|
|||
/// <param name="y">The y-coordinate of the image.</param>
|
|||
/// <param name="width">The width.</param>
|
|||
/// <param name="height">The height.</param>
|
|||
/// <returns>
|
|||
/// The <see cref="GrayImage"/>.
|
|||
/// </returns>
|
|||
public GrayImage Subimage(int x, int y, int width, int height) |
|||
{ |
|||
return new GrayImage |
|||
{ |
|||
Width = width, |
|||
Height = height, |
|||
Pixels = this.Pixels, |
|||
Stride = this.Stride, |
|||
Offset = (y * this.Stride) + x |
|||
}; |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Gets the row offset at the given position
|
|||
/// </summary>
|
|||
/// <param name="y">The y-coordinate of the image.</param>
|
|||
/// <returns>The <see cref="int"/></returns>
|
|||
public int GetRowOffset(int y) |
|||
{ |
|||
return this.Offset + (y * this.Stride); |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,135 @@ |
|||
// <copyright file="JpegPixelArea.cs" company="James Jackson-South">
|
|||
// Copyright (c) James Jackson-South and contributors.
|
|||
// Licensed under the Apache License, Version 2.0.
|
|||
// </copyright>
|
|||
namespace ImageSharp.Formats.Jpg |
|||
{ |
|||
using System.Buffers; |
|||
using System.Runtime.CompilerServices; |
|||
|
|||
/// <summary>
|
|||
/// Represents an area of a Jpeg subimage (channel)
|
|||
/// </summary>
|
|||
internal struct JpegPixelArea |
|||
{ |
|||
/// <summary>
|
|||
/// Initializes a new instance of the <see cref="JpegPixelArea" /> struct from existing data.
|
|||
/// </summary>
|
|||
/// <param name="pixels">The pixel array</param>
|
|||
/// <param name="striede">The stride</param>
|
|||
/// <param name="offset">The offset</param>
|
|||
public JpegPixelArea(byte[] pixels, int striede, int offset) |
|||
{ |
|||
this.Stride = striede; |
|||
this.Pixels = pixels; |
|||
this.Offset = offset; |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Gets the pixels.
|
|||
/// </summary>
|
|||
public byte[] Pixels { get; private set; } |
|||
|
|||
/// <summary>
|
|||
/// Gets a value indicating whether the instance has been initalized. (Is not default(JpegPixelArea))
|
|||
/// </summary>
|
|||
public bool IsInitialized => this.Pixels != null; |
|||
|
|||
/// <summary>
|
|||
/// Gets or the stride.
|
|||
/// </summary>
|
|||
public int Stride { get; } |
|||
|
|||
/// <summary>
|
|||
/// Gets or the offset.
|
|||
/// </summary>
|
|||
public int Offset { get; } |
|||
|
|||
/// <summary>
|
|||
/// Gets a <see cref="MutableSpan{T}" /> of bytes to the pixel area
|
|||
/// </summary>
|
|||
public MutableSpan<byte> Span => new MutableSpan<byte>(this.Pixels, this.Offset); |
|||
|
|||
private static ArrayPool<byte> BytePool => ArrayPool<byte>.Shared; |
|||
|
|||
/// <summary>
|
|||
/// Returns the pixel at (x, y)
|
|||
/// </summary>
|
|||
/// <param name="x">The x index</param>
|
|||
/// <param name="y">The y index</param>
|
|||
/// <returns>The pixel value</returns>
|
|||
public byte this[int x, int y] |
|||
{ |
|||
[MethodImpl(MethodImplOptions.AggressiveInlining)] |
|||
get |
|||
{ |
|||
return this.Pixels[(y * this.Stride) + x]; |
|||
} |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Creates a new instance of the <see cref="JpegPixelArea" /> struct.
|
|||
/// Pixel array will be taken from a pool, this instance will be the owner of it's pixel data, therefore
|
|||
/// <see cref="ReturnPooled" /> should be called when the instance is no longer needed.
|
|||
/// </summary>
|
|||
/// <param name="width">The width.</param>
|
|||
/// <param name="height">The height.</param>
|
|||
/// <returns>A <see cref="JpegPixelArea" /> with pooled data</returns>
|
|||
public static JpegPixelArea CreatePooled(int width, int height) |
|||
{ |
|||
int size = width * height; |
|||
var pixels = BytePool.Rent(size); |
|||
return new JpegPixelArea(pixels, width, 0); |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Returns <see cref="Pixels" /> to the pool
|
|||
/// </summary>
|
|||
public void ReturnPooled() |
|||
{ |
|||
if (this.Pixels == null) |
|||
{ |
|||
return; |
|||
} |
|||
|
|||
BytePool.Return(this.Pixels); |
|||
this.Pixels = null; |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Gets the subarea that belongs to the Block8x8 defined by block indices
|
|||
/// </summary>
|
|||
/// <param name="bx">The block X index</param>
|
|||
/// <param name="by">The block Y index</param>
|
|||
/// <returns>The subarea offseted by block indices</returns>
|
|||
public JpegPixelArea GetOffsetedSubAreaForBlock(int bx, int by) |
|||
{ |
|||
int offset = this.Offset + (8 * ((by * this.Stride) + bx)); |
|||
return new JpegPixelArea(this.Pixels, this.Stride, offset); |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Gets the row offset at the given position
|
|||
/// </summary>
|
|||
/// <param name="y">The y-coordinate of the image.</param>
|
|||
/// <returns>The <see cref="int" /></returns>
|
|||
public int GetRowOffset(int y) |
|||
{ |
|||
return this.Offset + (y * this.Stride); |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Load values to the pixel area from the given <see cref="Block8x8F" />.
|
|||
/// Level shift [-128.0, 128.0] floating point color values by +128, clip them to [0, 255], and convert them to
|
|||
/// <see cref="byte" /> values
|
|||
/// </summary>
|
|||
/// <param name="block">The block holding the color values</param>
|
|||
/// <param name="temp">Temporal block provided by the caller</param>
|
|||
[MethodImpl(MethodImplOptions.AggressiveInlining)] |
|||
public unsafe void LoadColorsFrom(Block8x8F* block, Block8x8F* temp) |
|||
{ |
|||
// Level shift by +128, clip to [0, 255], and write to dst.
|
|||
block->CopyColorsTo(new MutableSpan<byte>(this.Pixels, this.Offset), this.Stride, temp); |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,755 @@ |
|||
// <copyright file="JpegScanDecoder.cs" company="James Jackson-South">
|
|||
// Copyright (c) James Jackson-South and contributors.
|
|||
// Licensed under the Apache License, Version 2.0.
|
|||
// </copyright>
|
|||
|
|||
// ReSharper disable InconsistentNaming
|
|||
namespace ImageSharp.Formats.Jpg |
|||
{ |
|||
using System; |
|||
using System.Runtime.CompilerServices; |
|||
using System.Runtime.InteropServices; |
|||
|
|||
/// <summary>
|
|||
/// Encapsulates the impementation of Jpeg SOS decoder.
|
|||
/// See JpegScanDecoder.md!
|
|||
/// </summary>
|
|||
internal unsafe struct JpegScanDecoder |
|||
{ |
|||
/// <summary>
|
|||
/// Number of MCU-s (Minimum Coded Units) in the image along the X axis
|
|||
/// </summary>
|
|||
public int XNumberOfMCUs; |
|||
|
|||
/// <summary>
|
|||
/// Number of MCU-s (Minimum Coded Units) in the image along the Y axis
|
|||
/// </summary>
|
|||
public int YNumberOfMCUs; |
|||
|
|||
/// <summary>
|
|||
/// The AC table index
|
|||
/// </summary>
|
|||
private const int AcTableIndex = 1; |
|||
|
|||
/// <summary>
|
|||
/// The DC table index
|
|||
/// </summary>
|
|||
private const int DcTableIndex = 0; |
|||
|
|||
/// <summary>
|
|||
/// X coordinate of the current block, in units of 8x8. (The third block in the first row has (bx, by) = (2, 0))
|
|||
/// </summary>
|
|||
private int bx; |
|||
|
|||
/// <summary>
|
|||
/// Y coordinate of the current block, in units of 8x8. (The third block in the first row has (bx, by) = (2, 0))
|
|||
/// </summary>
|
|||
private int by; |
|||
|
|||
// zigStart and zigEnd are the spectral selection bounds.
|
|||
// ah and al are the successive approximation high and low values.
|
|||
// The spec calls these values Ss, Se, Ah and Al.
|
|||
// For progressive JPEGs, these are the two more-or-less independent
|
|||
// aspects of progression. Spectral selection progression is when not
|
|||
// all of a block's 64 DCT coefficients are transmitted in one pass.
|
|||
// For example, three passes could transmit coefficient 0 (the DC
|
|||
// component), coefficients 1-5, and coefficients 6-63, in zig-zag
|
|||
// order. Successive approximation is when not all of the bits of a
|
|||
// band of coefficients are transmitted in one pass. For example,
|
|||
// three passes could transmit the 6 most significant bits, followed
|
|||
// by the second-least significant bit, followed by the least
|
|||
// significant bit.
|
|||
// For baseline JPEGs, these parameters are hard-coded to 0/63/0/0.
|
|||
|
|||
/// <summary>
|
|||
/// Start index of the zig-zag selection bound
|
|||
/// </summary>
|
|||
private int zigStart; |
|||
|
|||
/// <summary>
|
|||
/// End index of the zig-zag selection bound
|
|||
/// </summary>
|
|||
private int zigEnd; |
|||
|
|||
/// <summary>
|
|||
/// Successive approximation high value
|
|||
/// </summary>
|
|||
private int ah; |
|||
|
|||
/// <summary>
|
|||
/// Successive approximation high and low value
|
|||
/// </summary>
|
|||
private int al; |
|||
|
|||
/// <summary>
|
|||
/// The number of component scans
|
|||
/// </summary>
|
|||
private int componentScanCount; |
|||
|
|||
/// <summary>
|
|||
/// End-of-Band run, specified in section G.1.2.2.
|
|||
/// </summary>
|
|||
private ushort eobRun; |
|||
|
|||
/// <summary>
|
|||
/// The <see cref="ComputationData"/> buffer
|
|||
/// </summary>
|
|||
private ComputationData data; |
|||
|
|||
/// <summary>
|
|||
/// Pointers to elements of <see cref="data"/>
|
|||
/// </summary>
|
|||
private DataPointers pointers; |
|||
|
|||
/// <summary>
|
|||
/// Initializes the default instance after creation.
|
|||
/// </summary>
|
|||
/// <param name="p">Pointer to <see cref="JpegScanDecoder"/> on the stack</param>
|
|||
/// <param name="decoder">The <see cref="JpegDecoderCore"/> instance</param>
|
|||
/// <param name="remaining">The remaining bytes in the segment block.</param>
|
|||
public static void Init(JpegScanDecoder* p, JpegDecoderCore decoder, int remaining) |
|||
{ |
|||
p->data = ComputationData.Create(); |
|||
p->pointers = new DataPointers(&p->data); |
|||
p->InitImpl(decoder, remaining); |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Reads the blocks from the <see cref="JpegDecoderCore"/>-s stream, and processes them into the corresponding <see cref="JpegPixelArea"/> instances.
|
|||
/// </summary>
|
|||
/// <param name="decoder">The <see cref="JpegDecoderCore"/> instance</param>
|
|||
public void ProcessBlocks(JpegDecoderCore decoder) |
|||
{ |
|||
int blockCount = 0; |
|||
int mcu = 0; |
|||
byte expectedRst = JpegConstants.Markers.RST0; |
|||
|
|||
for (int my = 0; my < this.YNumberOfMCUs; my++) |
|||
{ |
|||
for (int mx = 0; mx < this.XNumberOfMCUs; mx++) |
|||
{ |
|||
for (int i = 0; i < this.componentScanCount; i++) |
|||
{ |
|||
int compIndex = this.pointers.Scan[i].Index; |
|||
int hi = decoder.ComponentArray[compIndex].HorizontalFactor; |
|||
int vi = decoder.ComponentArray[compIndex].VerticalFactor; |
|||
|
|||
for (int j = 0; j < hi * vi; j++) |
|||
{ |
|||
// The blocks are traversed one MCU at a time. For 4:2:0 chroma
|
|||
// subsampling, there are four Y 8x8 blocks in every 16x16 MCU.
|
|||
// For a baseline 32x16 pixel image, the Y blocks visiting order is:
|
|||
// 0 1 4 5
|
|||
// 2 3 6 7
|
|||
// For progressive images, the interleaved scans (those with component count > 1)
|
|||
// are traversed as above, but non-interleaved scans are traversed left
|
|||
// to right, top to bottom:
|
|||
// 0 1 2 3
|
|||
// 4 5 6 7
|
|||
// Only DC scans (zigStart == 0) can be interleave AC scans must have
|
|||
// only one component.
|
|||
// To further complicate matters, for non-interleaved scans, there is no
|
|||
// data for any blocks that are inside the image at the MCU level but
|
|||
// outside the image at the pixel level. For example, a 24x16 pixel 4:2:0
|
|||
// progressive image consists of two 16x16 MCUs. The interleaved scans
|
|||
// will process 8 Y blocks:
|
|||
// 0 1 4 5
|
|||
// 2 3 6 7
|
|||
// The non-interleaved scans will process only 6 Y blocks:
|
|||
// 0 1 2
|
|||
// 3 4 5
|
|||
if (this.componentScanCount != 1) |
|||
{ |
|||
this.bx = (hi * mx) + (j % hi); |
|||
this.by = (vi * my) + (j / hi); |
|||
} |
|||
else |
|||
{ |
|||
int q = this.XNumberOfMCUs * hi; |
|||
this.bx = blockCount % q; |
|||
this.by = blockCount / q; |
|||
blockCount++; |
|||
if (this.bx * 8 >= decoder.ImageWidth || this.by * 8 >= decoder.ImageHeight) |
|||
{ |
|||
continue; |
|||
} |
|||
} |
|||
|
|||
int qtIndex = decoder.ComponentArray[compIndex].Selector; |
|||
|
|||
// TODO: Reading & processing blocks should be done in 2 separate loops. The second one could be parallelized. The first one could be async.
|
|||
this.data.QuantiazationTable = decoder.QuantizationTables[qtIndex]; |
|||
|
|||
// Load the previous partially decoded coefficients, if applicable.
|
|||
if (decoder.IsProgressive) |
|||
{ |
|||
int blockIndex = ((this.by * this.XNumberOfMCUs) * hi) + this.bx; |
|||
this.data.Block = decoder.ProgCoeffs[compIndex][blockIndex]; |
|||
} |
|||
else |
|||
{ |
|||
this.data.Block.Clear(); |
|||
} |
|||
|
|||
this.ProcessBlockImpl(decoder, i, compIndex, hi); |
|||
} |
|||
|
|||
// for j
|
|||
} |
|||
|
|||
// for i
|
|||
mcu++; |
|||
|
|||
if (decoder.RestartInterval > 0 && mcu % decoder.RestartInterval == 0 && mcu < this.XNumberOfMCUs * this.YNumberOfMCUs) |
|||
{ |
|||
// A more sophisticated decoder could use RST[0-7] markers to resynchronize from corrupt input,
|
|||
// but this one assumes well-formed input, and hence the restart marker follows immediately.
|
|||
decoder.ReadFull(decoder.Temp, 0, 2); |
|||
if (decoder.Temp[0] != 0xff || decoder.Temp[1] != expectedRst) |
|||
{ |
|||
throw new ImageFormatException("Bad RST marker"); |
|||
} |
|||
|
|||
expectedRst++; |
|||
if (expectedRst == JpegConstants.Markers.RST7 + 1) |
|||
{ |
|||
expectedRst = JpegConstants.Markers.RST0; |
|||
} |
|||
|
|||
// Reset the Huffman decoder.
|
|||
decoder.Bits = default(Bits); |
|||
|
|||
// Reset the DC components, as per section F.2.1.3.1.
|
|||
this.ResetDc(); |
|||
|
|||
// Reset the progressive decoder state, as per section G.1.2.2.
|
|||
this.eobRun = 0; |
|||
} |
|||
} |
|||
|
|||
// for mx
|
|||
} |
|||
} |
|||
|
|||
private void ResetDc() |
|||
{ |
|||
Unsafe.InitBlock(this.pointers.Dc, default(byte), sizeof(int) * JpegDecoderCore.MaxComponents); |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// The implementation part of <see cref="Init"/> as an instance method.
|
|||
/// </summary>
|
|||
/// <param name="decoder">The <see cref="JpegDecoderCore"/></param>
|
|||
/// <param name="remaining">The remaining bytes</param>
|
|||
private void InitImpl(JpegDecoderCore decoder, int remaining) |
|||
{ |
|||
if (decoder.ComponentCount == 0) |
|||
{ |
|||
throw new ImageFormatException("Missing SOF marker"); |
|||
} |
|||
|
|||
if (remaining < 6 || 4 + (2 * decoder.ComponentCount) < remaining || remaining % 2 != 0) |
|||
{ |
|||
throw new ImageFormatException("SOS has wrong length"); |
|||
} |
|||
|
|||
decoder.ReadFull(decoder.Temp, 0, remaining); |
|||
this.componentScanCount = decoder.Temp[0]; |
|||
|
|||
int scanComponentCountX2 = 2 * this.componentScanCount; |
|||
if (remaining != 4 + scanComponentCountX2) |
|||
{ |
|||
throw new ImageFormatException("SOS length inconsistent with number of components"); |
|||
} |
|||
|
|||
int totalHv = 0; |
|||
|
|||
for (int i = 0; i < this.componentScanCount; i++) |
|||
{ |
|||
this.ProcessScanImpl(decoder, i, ref this.pointers.Scan[i], ref totalHv); |
|||
} |
|||
|
|||
// Section B.2.3 states that if there is more than one component then the
|
|||
// total H*V values in a scan must be <= 10.
|
|||
if (decoder.ComponentCount > 1 && totalHv > 10) |
|||
{ |
|||
throw new ImageFormatException("Total sampling factors too large."); |
|||
} |
|||
|
|||
this.zigEnd = Block8x8F.ScalarCount - 1; |
|||
|
|||
if (decoder.IsProgressive) |
|||
{ |
|||
this.zigStart = decoder.Temp[1 + scanComponentCountX2]; |
|||
this.zigEnd = decoder.Temp[2 + scanComponentCountX2]; |
|||
this.ah = decoder.Temp[3 + scanComponentCountX2] >> 4; |
|||
this.al = decoder.Temp[3 + scanComponentCountX2] & 0x0f; |
|||
|
|||
if ((this.zigStart == 0 && this.zigEnd != 0) || this.zigStart > this.zigEnd |
|||
|| this.zigEnd >= Block8x8F.ScalarCount) |
|||
{ |
|||
throw new ImageFormatException("Bad spectral selection bounds"); |
|||
} |
|||
|
|||
if (this.zigStart != 0 && this.componentScanCount != 1) |
|||
{ |
|||
throw new ImageFormatException("Progressive AC coefficients for more than one component"); |
|||
} |
|||
|
|||
if (this.ah != 0 && this.ah != this.al + 1) |
|||
{ |
|||
throw new ImageFormatException("Bad successive approximation values"); |
|||
} |
|||
} |
|||
|
|||
// XNumberOfMCUs and YNumberOfMCUs are the number of MCUs (Minimum Coded Units) in the image.
|
|||
int h0 = decoder.ComponentArray[0].HorizontalFactor; |
|||
int v0 = decoder.ComponentArray[0].VerticalFactor; |
|||
this.XNumberOfMCUs = (decoder.ImageWidth + (8 * h0) - 1) / (8 * h0); |
|||
this.YNumberOfMCUs = (decoder.ImageHeight + (8 * v0) - 1) / (8 * v0); |
|||
|
|||
if (decoder.IsProgressive) |
|||
{ |
|||
for (int i = 0; i < this.componentScanCount; i++) |
|||
{ |
|||
int compIndex = this.pointers.Scan[i].Index; |
|||
if (decoder.ProgCoeffs[compIndex] == null) |
|||
{ |
|||
int size = this.XNumberOfMCUs * this.YNumberOfMCUs * decoder.ComponentArray[compIndex].HorizontalFactor |
|||
* decoder.ComponentArray[compIndex].VerticalFactor; |
|||
|
|||
decoder.ProgCoeffs[compIndex] = new Block8x8F[size]; |
|||
} |
|||
} |
|||
} |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Process the current block at (<see cref="bx"/>, <see cref="by"/>)
|
|||
/// </summary>
|
|||
/// <param name="decoder">The decoder</param>
|
|||
/// <param name="i">The index of the scan</param>
|
|||
/// <param name="compIndex">The component index</param>
|
|||
/// <param name="hi">Horizontal sampling factor at the given component index</param>
|
|||
private void ProcessBlockImpl(JpegDecoderCore decoder, int i, int compIndex, int hi) |
|||
{ |
|||
var b = this.pointers.Block; |
|||
|
|||
int huffmannIdx = (AcTableIndex * HuffmanTree.ThRowSize) + this.pointers.Scan[i].AcTableSelector; |
|||
if (this.ah != 0) |
|||
{ |
|||
this.Refine(decoder, ref decoder.HuffmanTrees[huffmannIdx], 1 << this.al); |
|||
} |
|||
else |
|||
{ |
|||
int zig = this.zigStart; |
|||
if (zig == 0) |
|||
{ |
|||
zig++; |
|||
|
|||
// Decode the DC coefficient, as specified in section F.2.2.1.
|
|||
byte value = |
|||
decoder.DecodeHuffman( |
|||
ref decoder.HuffmanTrees[(DcTableIndex * HuffmanTree.ThRowSize) + this.pointers.Scan[i].DcTableSelector]); |
|||
if (value > 16) |
|||
{ |
|||
throw new ImageFormatException("Excessive DC component"); |
|||
} |
|||
|
|||
int deltaDC = decoder.Bits.ReceiveExtend(value, decoder); |
|||
this.pointers.Dc[compIndex] += deltaDC; |
|||
|
|||
// b[0] = dc[compIndex] << al;
|
|||
Block8x8F.SetScalarAt(b, 0, this.pointers.Dc[compIndex] << this.al); |
|||
} |
|||
|
|||
if (zig <= this.zigEnd && this.eobRun > 0) |
|||
{ |
|||
this.eobRun--; |
|||
} |
|||
else |
|||
{ |
|||
// Decode the AC coefficients, as specified in section F.2.2.2.
|
|||
for (; zig <= this.zigEnd; zig++) |
|||
{ |
|||
byte value = decoder.DecodeHuffman(ref decoder.HuffmanTrees[huffmannIdx]); |
|||
byte val0 = (byte)(value >> 4); |
|||
byte val1 = (byte)(value & 0x0f); |
|||
if (val1 != 0) |
|||
{ |
|||
zig += val0; |
|||
if (zig > this.zigEnd) |
|||
{ |
|||
break; |
|||
} |
|||
|
|||
int ac = decoder.Bits.ReceiveExtend(val1, decoder); |
|||
|
|||
// b[Unzig[zig]] = ac << al;
|
|||
Block8x8F.SetScalarAt(b, this.pointers.Unzig[zig], ac << this.al); |
|||
} |
|||
else |
|||
{ |
|||
if (val0 != 0x0f) |
|||
{ |
|||
this.eobRun = (ushort)(1 << val0); |
|||
if (val0 != 0) |
|||
{ |
|||
this.eobRun |= (ushort)decoder.DecodeBits(val0); |
|||
} |
|||
|
|||
this.eobRun--; |
|||
break; |
|||
} |
|||
|
|||
zig += 0x0f; |
|||
} |
|||
} |
|||
} |
|||
} |
|||
|
|||
if (decoder.IsProgressive) |
|||
{ |
|||
if (this.zigEnd != Block8x8F.ScalarCount - 1 || this.al != 0) |
|||
{ |
|||
// We haven't completely decoded this 8x8 block. Save the coefficients.
|
|||
// this.ProgCoeffs[compIndex][((@by * XNumberOfMCUs) * hi) + bx] = b.Clone();
|
|||
decoder.ProgCoeffs[compIndex][((this.by * this.XNumberOfMCUs) * hi) + this.bx] = *b; |
|||
|
|||
// At this point, we could execute the rest of the loop body to dequantize and
|
|||
// perform the inverse DCT, to save early stages of a progressive image to the
|
|||
// *image.YCbCr buffers (the whole point of progressive encoding), but in Go,
|
|||
// the jpeg.Decode function does not return until the entire image is decoded,
|
|||
// so we "continue" here to avoid wasted computation.
|
|||
return; |
|||
} |
|||
} |
|||
|
|||
// Dequantize, perform the inverse DCT and store the block to the image.
|
|||
Block8x8F.UnZig(b, this.pointers.QuantiazationTable, this.pointers.Unzig); |
|||
|
|||
DCT.TransformIDCT(ref *b, ref *this.pointers.Temp1, ref *this.pointers.Temp2); |
|||
|
|||
var destChannel = decoder.GetDestinationChannel(compIndex); |
|||
var destArea = destChannel.GetOffsetedSubAreaForBlock(this.bx, this.by); |
|||
destArea.LoadColorsFrom(this.pointers.Temp1, this.pointers.Temp2); |
|||
} |
|||
|
|||
private void ProcessScanImpl(JpegDecoderCore decoder, int i, ref Scan currentScan, ref int totalHv) |
|||
{ |
|||
// Component selector.
|
|||
int cs = decoder.Temp[1 + (2 * i)]; |
|||
int compIndex = -1; |
|||
for (int j = 0; j < decoder.ComponentCount; j++) |
|||
{ |
|||
// Component compv = ;
|
|||
if (cs == decoder.ComponentArray[j].Identifier) |
|||
{ |
|||
compIndex = j; |
|||
} |
|||
} |
|||
|
|||
if (compIndex < 0) |
|||
{ |
|||
throw new ImageFormatException("Unknown component selector"); |
|||
} |
|||
|
|||
currentScan.Index = (byte)compIndex; |
|||
|
|||
this.ProcessComponentImpl(decoder, i, ref currentScan, ref totalHv, ref decoder.ComponentArray[compIndex]); |
|||
} |
|||
|
|||
private void ProcessComponentImpl( |
|||
JpegDecoderCore decoder, |
|||
int i, |
|||
ref Scan currentScan, |
|||
ref int totalHv, |
|||
ref Component currentComponent) |
|||
{ |
|||
// Section B.2.3 states that "the value of Cs_j shall be different from
|
|||
// the values of Cs_1 through Cs_(j-1)". Since we have previously
|
|||
// verified that a frame's component identifiers (C_i values in section
|
|||
// B.2.2) are unique, it suffices to check that the implicit indexes
|
|||
// into comp are unique.
|
|||
for (int j = 0; j < i; j++) |
|||
{ |
|||
if (currentScan.Index == this.pointers.Scan[j].Index) |
|||
{ |
|||
throw new ImageFormatException("Repeated component selector"); |
|||
} |
|||
} |
|||
|
|||
totalHv += currentComponent.HorizontalFactor * currentComponent.VerticalFactor; |
|||
|
|||
currentScan.DcTableSelector = (byte)(decoder.Temp[2 + (2 * i)] >> 4); |
|||
if (currentScan.DcTableSelector > HuffmanTree.MaxTh) |
|||
{ |
|||
throw new ImageFormatException("Bad DC table selector value"); |
|||
} |
|||
|
|||
currentScan.AcTableSelector = (byte)(decoder.Temp[2 + (2 * i)] & 0x0f); |
|||
if (currentScan.AcTableSelector > HuffmanTree.MaxTh) |
|||
{ |
|||
throw new ImageFormatException("Bad AC table selector value"); |
|||
} |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Decodes a successive approximation refinement block, as specified in section G.1.2.
|
|||
/// </summary>
|
|||
/// <param name="decoder">The decoder instance</param>
|
|||
/// <param name="h">The Huffman tree</param>
|
|||
/// <param name="delta">The low transform offset</param>
|
|||
private void Refine(JpegDecoderCore decoder, ref HuffmanTree h, int delta) |
|||
{ |
|||
Block8x8F* b = this.pointers.Block; |
|||
|
|||
// Refining a DC component is trivial.
|
|||
if (this.zigStart == 0) |
|||
{ |
|||
if (this.zigEnd != 0) |
|||
{ |
|||
throw new ImageFormatException("Invalid state for zig DC component"); |
|||
} |
|||
|
|||
bool bit = decoder.DecodeBit(); |
|||
if (bit) |
|||
{ |
|||
int stuff = (int)Block8x8F.GetScalarAt(b, 0); |
|||
|
|||
// int stuff = (int)b[0];
|
|||
stuff |= delta; |
|||
|
|||
// b[0] = stuff;
|
|||
Block8x8F.SetScalarAt(b, 0, stuff); |
|||
} |
|||
|
|||
return; |
|||
} |
|||
|
|||
// Refining AC components is more complicated; see sections G.1.2.2 and G.1.2.3.
|
|||
int zig = this.zigStart; |
|||
if (this.eobRun == 0) |
|||
{ |
|||
for (; zig <= this.zigEnd; zig++) |
|||
{ |
|||
bool done = false; |
|||
int z = 0; |
|||
byte val = decoder.DecodeHuffman(ref h); |
|||
int val0 = val >> 4; |
|||
int val1 = val & 0x0f; |
|||
|
|||
switch (val1) |
|||
{ |
|||
case 0: |
|||
if (val0 != 0x0f) |
|||
{ |
|||
this.eobRun = (ushort)(1 << val0); |
|||
if (val0 != 0) |
|||
{ |
|||
this.eobRun |= (ushort)decoder.DecodeBits(val0); |
|||
} |
|||
|
|||
done = true; |
|||
} |
|||
|
|||
break; |
|||
case 1: |
|||
z = delta; |
|||
bool bit = decoder.DecodeBit(); |
|||
if (!bit) |
|||
{ |
|||
z = -z; |
|||
} |
|||
|
|||
break; |
|||
default: |
|||
throw new ImageFormatException("Unexpected Huffman code"); |
|||
} |
|||
|
|||
if (done) |
|||
{ |
|||
break; |
|||
} |
|||
|
|||
zig = this.RefineNonZeroes(decoder, zig, val0, delta); |
|||
if (zig > this.zigEnd) |
|||
{ |
|||
throw new ImageFormatException($"Too many coefficients {zig} > {this.zigEnd}"); |
|||
} |
|||
|
|||
if (z != 0) |
|||
{ |
|||
// b[Unzig[zig]] = z;
|
|||
Block8x8F.SetScalarAt(b, this.pointers.Unzig[zig], z); |
|||
} |
|||
} |
|||
} |
|||
|
|||
if (this.eobRun > 0) |
|||
{ |
|||
this.eobRun--; |
|||
this.RefineNonZeroes(decoder, zig, -1, delta); |
|||
} |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Refines non-zero entries of b in zig-zag order.
|
|||
/// If <paramref name="nz" /> >= 0, the first <paramref name="nz" /> zero entries are skipped over.
|
|||
/// </summary>
|
|||
/// <param name="decoder">The decoder</param>
|
|||
/// <param name="zig">The zig-zag start index</param>
|
|||
/// <param name="nz">The non-zero entry</param>
|
|||
/// <param name="delta">The low transform offset</param>
|
|||
/// <returns>The <see cref="int" /></returns>
|
|||
private int RefineNonZeroes(JpegDecoderCore decoder, int zig, int nz, int delta) |
|||
{ |
|||
var b = this.pointers.Block; |
|||
for (; zig <= this.zigEnd; zig++) |
|||
{ |
|||
int u = this.pointers.Unzig[zig]; |
|||
float bu = Block8x8F.GetScalarAt(b, u); |
|||
|
|||
// TODO: Are the equality comparsions OK with floating point values? Isn't an epsilon value necessary?
|
|||
if (bu == 0) |
|||
{ |
|||
if (nz == 0) |
|||
{ |
|||
break; |
|||
} |
|||
|
|||
nz--; |
|||
continue; |
|||
} |
|||
|
|||
bool bit = decoder.DecodeBit(); |
|||
if (!bit) |
|||
{ |
|||
continue; |
|||
} |
|||
|
|||
if (bu >= 0) |
|||
{ |
|||
// b[u] += delta;
|
|||
Block8x8F.SetScalarAt(b, u, bu + delta); |
|||
} |
|||
else |
|||
{ |
|||
// b[u] -= delta;
|
|||
Block8x8F.SetScalarAt(b, u, bu - delta); |
|||
} |
|||
} |
|||
|
|||
return zig; |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Holds the "large" data blocks needed for computations
|
|||
/// </summary>
|
|||
[StructLayout(LayoutKind.Sequential)] |
|||
public struct ComputationData |
|||
{ |
|||
/// <summary>
|
|||
/// The main input block
|
|||
/// </summary>
|
|||
public Block8x8F Block; |
|||
|
|||
/// <summary>
|
|||
/// Temporal block 1 to store intermediate and/or final computation results
|
|||
/// </summary>
|
|||
public Block8x8F Temp1; |
|||
|
|||
/// <summary>
|
|||
/// Temporal block 2 to store intermediate and/or final computation results
|
|||
/// </summary>
|
|||
public Block8x8F Temp2; |
|||
|
|||
/// <summary>
|
|||
/// The quantization table as <see cref="Block8x8F"/>
|
|||
/// </summary>
|
|||
public Block8x8F QuantiazationTable; |
|||
|
|||
/// <summary>
|
|||
/// The jpeg unzig data
|
|||
/// </summary>
|
|||
public UnzigData Unzig; |
|||
|
|||
/// <summary>
|
|||
/// The no-idea-what's this data
|
|||
/// </summary>
|
|||
public fixed byte ScanData[3 * JpegDecoderCore.MaxComponents]; |
|||
|
|||
/// <summary>
|
|||
/// The DC component values
|
|||
/// </summary>
|
|||
public fixed int Dc[JpegDecoderCore.MaxComponents]; |
|||
|
|||
/// <summary>
|
|||
/// Creates and initializes a new <see cref="ComputationData"/> instance
|
|||
/// </summary>
|
|||
/// <returns>The <see cref="ComputationData"/></returns>
|
|||
public static ComputationData Create() |
|||
{ |
|||
ComputationData data = default(ComputationData); |
|||
data.Unzig = UnzigData.Create(); |
|||
return data; |
|||
} |
|||
} |
|||
|
|||
/// <summary>
|
|||
/// Contains pointers to the memory regions of <see cref="ComputationData"/> so they can be easily passed around to pointer based utility methods of <see cref="Block8x8F"/>
|
|||
/// </summary>
|
|||
public struct DataPointers |
|||
{ |
|||
/// <summary>
|
|||
/// Pointer to <see cref="ComputationData.Block"/>
|
|||
/// </summary>
|
|||
public Block8x8F* Block; |
|||
|
|||
/// <summary>
|
|||
/// Pointer to <see cref="ComputationData.Temp1"/>
|
|||
/// </summary>
|
|||
public Block8x8F* Temp1; |
|||
|
|||
/// <summary>
|
|||
/// Pointer to <see cref="ComputationData.Temp2"/>
|
|||
/// </summary>
|
|||
public Block8x8F* Temp2; |
|||
|
|||
/// <summary>
|
|||
/// Pointer to <see cref="ComputationData.QuantiazationTable"/>
|
|||
/// </summary>
|
|||
public Block8x8F* QuantiazationTable; |
|||
|
|||
/// <summary>
|
|||
/// Pointer to <see cref="ComputationData.Unzig"/> as int*
|
|||
/// </summary>
|
|||
public int* Unzig; |
|||
|
|||
/// <summary>
|
|||
/// Pointer to <see cref="ComputationData.ScanData"/> as Scan*
|
|||
/// </summary>
|
|||
public Scan* Scan; |
|||
|
|||
/// <summary>
|
|||
/// Pointer to <see cref="ComputationData.Dc"/>
|
|||
/// </summary>
|
|||
public int* Dc; |
|||
|
|||
/// <summary>
|
|||
/// Initializes a new instance of the <see cref="DataPointers" /> struct.
|
|||
/// </summary>
|
|||
/// <param name="basePtr">The pointer pointing to <see cref="ComputationData"/></param>
|
|||
public DataPointers(ComputationData* basePtr) |
|||
{ |
|||
this.Block = &basePtr->Block; |
|||
this.Temp1 = &basePtr->Temp1; |
|||
this.Temp2 = &basePtr->Temp2; |
|||
this.QuantiazationTable = &basePtr->QuantiazationTable; |
|||
this.Unzig = basePtr->Unzig.Data; |
|||
this.Scan = (Scan*)basePtr->ScanData; |
|||
this.Dc = basePtr->Dc; |
|||
} |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,25 @@ |
|||
## JpegScanDecoder |
|||
Encapsulates the impementation of the Jpeg top-to bottom scan decoder triggered by the `SOS` marker. |
|||
The implementation is optimized to hold most of the necessary data in a single value type, which is intended to be used as an on-stack object. |
|||
|
|||
#### Benefits: |
|||
- Maximized locality of reference by keeping most of the operation data on the stack |
|||
- Reaching this without long parameter lists, most of the values describing the state of the decoder algorithm |
|||
are members of the `JpegScanDecoder` struct |
|||
- Most of the logic related to Scan decoding is refactored & simplified now to live in the methods of `JpegScanDecoder` |
|||
- The first step is done towards separating the stream reading from block processing. They can be refactored later to be executed in two disctinct loops. |
|||
- The input processing loop can be `async` |
|||
- The block processing loop can be parallelized |
|||
|
|||
#### Data layout |
|||
|
|||
|JpegScanDecoder | |
|||
|-------------------| |
|||
|Variables | |
|||
|ComputationData | |
|||
|DataPointers | |
|||
|
|||
- **ComputationData** holds the "large" data blocks needed for computations (Mostly `Block8x8F`-s) |
|||
- **DataPointers** contains pointers to the memory regions of `ComponentData` so they can be easily passed around to pointer based utility methods of `Block8x8F` |
|||
|
|||
|
|||
@ -0,0 +1,31 @@ |
|||
// <copyright file="Scan.cs" company="James Jackson-South">
|
|||
// Copyright (c) James Jackson-South and contributors.
|
|||
// Licensed under the Apache License, Version 2.0.
|
|||
// </copyright>
|
|||
|
|||
namespace ImageSharp.Formats.Jpg |
|||
{ |
|||
using System.Runtime.InteropServices; |
|||
|
|||
/// <summary>
|
|||
/// Represents a component scan
|
|||
/// </summary>
|
|||
[StructLayout(LayoutKind.Sequential)] |
|||
internal struct Scan |
|||
{ |
|||
/// <summary>
|
|||
/// Gets or sets the component index.
|
|||
/// </summary>
|
|||
public byte Index; |
|||
|
|||
/// <summary>
|
|||
/// Gets or sets the DC table selector
|
|||
/// </summary>
|
|||
public byte DcTableSelector; |
|||
|
|||
/// <summary>
|
|||
/// Gets or sets the AC table selector
|
|||
/// </summary>
|
|||
public byte AcTableSelector; |
|||
} |
|||
} |
|||
File diff suppressed because it is too large
@ -0,0 +1,65 @@ |
|||
namespace ImageSharp.Tests |
|||
{ |
|||
using ImageSharp.Formats.Jpg; |
|||
|
|||
using Xunit; |
|||
using Xunit.Abstractions; |
|||
|
|||
public class YCbCrImageTests |
|||
{ |
|||
public YCbCrImageTests(ITestOutputHelper output) |
|||
{ |
|||
this.Output = output; |
|||
} |
|||
|
|||
private ITestOutputHelper Output { get; } |
|||
|
|||
private void PrintChannel(string name, JpegPixelArea channel) |
|||
{ |
|||
this.Output.WriteLine($"{name}: Stride={channel.Stride}"); |
|||
} |
|||
|
|||
[Theory] |
|||
[InlineData(YCbCrImage.YCbCrSubsampleRatio.YCbCrSubsampleRatio410, 4, 2)] |
|||
[InlineData(YCbCrImage.YCbCrSubsampleRatio.YCbCrSubsampleRatio411, 4, 1)] |
|||
[InlineData(YCbCrImage.YCbCrSubsampleRatio.YCbCrSubsampleRatio420, 2, 2)] |
|||
[InlineData(YCbCrImage.YCbCrSubsampleRatio.YCbCrSubsampleRatio422, 2, 1)] |
|||
[InlineData(YCbCrImage.YCbCrSubsampleRatio.YCbCrSubsampleRatio440, 1, 2)] |
|||
[InlineData(YCbCrImage.YCbCrSubsampleRatio.YCbCrSubsampleRatio444, 1, 1)] |
|||
public void CalculateChrominanceSize(int ratioValue, int expectedDivX, int expectedDivY) |
|||
{ |
|||
YCbCrImage.YCbCrSubsampleRatio ratio = (YCbCrImage.YCbCrSubsampleRatio)ratioValue; |
|||
|
|||
//this.Output.WriteLine($"RATIO: {ratio}");
|
|||
Size size = YCbCrImage.CalculateChrominanceSize(400, 400, ratio); |
|||
//this.Output.WriteLine($"Ch Size: {size}");
|
|||
|
|||
Assert.Equal(new Size(400/expectedDivX, 400/expectedDivY), size); |
|||
} |
|||
|
|||
[Theory] |
|||
[InlineData(YCbCrImage.YCbCrSubsampleRatio.YCbCrSubsampleRatio410, 4)] |
|||
[InlineData(YCbCrImage.YCbCrSubsampleRatio.YCbCrSubsampleRatio411, 4)] |
|||
[InlineData(YCbCrImage.YCbCrSubsampleRatio.YCbCrSubsampleRatio420, 2)] |
|||
[InlineData(YCbCrImage.YCbCrSubsampleRatio.YCbCrSubsampleRatio422, 2)] |
|||
[InlineData(YCbCrImage.YCbCrSubsampleRatio.YCbCrSubsampleRatio440, 1)] |
|||
[InlineData(YCbCrImage.YCbCrSubsampleRatio.YCbCrSubsampleRatio444, 1)] |
|||
public void Create(int ratioValue, int expectedCStrideDiv) |
|||
{ |
|||
YCbCrImage.YCbCrSubsampleRatio ratio = (YCbCrImage.YCbCrSubsampleRatio)ratioValue; |
|||
|
|||
this.Output.WriteLine($"RATIO: {ratio}"); |
|||
|
|||
var img = new YCbCrImage(400, 400, ratio); |
|||
|
|||
//this.PrintChannel("Y", img.YChannel);
|
|||
//this.PrintChannel("Cb", img.CbChannel);
|
|||
//this.PrintChannel("Cr", img.CrChannel);
|
|||
|
|||
Assert.Equal(img.YChannel.Stride, 400); |
|||
Assert.Equal(img.CbChannel.Stride, 400 / expectedCStrideDiv); |
|||
Assert.Equal(img.CrChannel.Stride, 400 / expectedCStrideDiv); |
|||
} |
|||
|
|||
} |
|||
} |
|||
Loading…
Reference in new issue