Browse Source

Recovering from the bad JPX images (#1145)

notmasteryet 13 years ago
parent
commit
2fa6e025f2
  1. 460
      src/jpx.js

460
src/jpx.js

@ -1052,7 +1052,7 @@ var JpxImage = (function JpxImageClosure() {
} }
r = 0; r = 0;
} }
error('JPX error: Out of packets'); throw 'Out of packets';
}; };
} }
function ResolutionLayerComponentPositionIterator(context) { function ResolutionLayerComponentPositionIterator(context) {
@ -1091,7 +1091,7 @@ var JpxImage = (function JpxImageClosure() {
} }
l = 0; l = 0;
} }
error('JPX error: Out of packets'); throw 'Out of packets';
}; };
} }
function buildPackets(context) { function buildPackets(context) {
@ -1187,7 +1187,7 @@ var JpxImage = (function JpxImageClosure() {
new ResolutionLayerComponentPositionIterator(context); new ResolutionLayerComponentPositionIterator(context);
break; break;
default: default:
error('JPX error: Unsupported progression order ' + progressionOrder); throw 'Unsupported progression order ' + progressionOrder;
} }
} }
function parseTilePackets(context, data, offset, dataLength) { function parseTilePackets(context, data, offset, dataLength) {
@ -1553,6 +1553,7 @@ var JpxImage = (function JpxImageClosure() {
} }
function JpxImage() { function JpxImage() {
this.failOnCorruptedImage = false;
} }
JpxImage.prototype = { JpxImage.prototype = {
load: function jpxImageLoad(url) { load: function jpxImageLoad(url) {
@ -1612,237 +1613,244 @@ var JpxImage = (function JpxImageClosure() {
}, },
parseCodestream: function jpxImageParseCodestream(data, start, end) { parseCodestream: function jpxImageParseCodestream(data, start, end) {
var context = {}; var context = {};
var position = start; try {
while (position < end) { var position = start;
var code = readUint16(data, position); while (position < end) {
position += 2; var code = readUint16(data, position);
position += 2;
var length = 0, j;
switch (code) { var length = 0, j;
case 0xFF4F: // Start of codestream (SOC) switch (code) {
context.mainHeader = true; case 0xFF4F: // Start of codestream (SOC)
break; context.mainHeader = true;
case 0xFFD9: // End of codestream (EOC) break;
break; case 0xFFD9: // End of codestream (EOC)
case 0xFF51: // Image and tile size (SIZ) break;
length = readUint16(data, position); case 0xFF51: // Image and tile size (SIZ)
var siz = {}; length = readUint16(data, position);
siz.Xsiz = readUint32(data, position + 4); var siz = {};
siz.Ysiz = readUint32(data, position + 8); siz.Xsiz = readUint32(data, position + 4);
siz.XOsiz = readUint32(data, position + 12); siz.Ysiz = readUint32(data, position + 8);
siz.YOsiz = readUint32(data, position + 16); siz.XOsiz = readUint32(data, position + 12);
siz.XTsiz = readUint32(data, position + 20); siz.YOsiz = readUint32(data, position + 16);
siz.YTsiz = readUint32(data, position + 24); siz.XTsiz = readUint32(data, position + 20);
siz.XTOsiz = readUint32(data, position + 28); siz.YTsiz = readUint32(data, position + 24);
siz.YTOsiz = readUint32(data, position + 32); siz.XTOsiz = readUint32(data, position + 28);
var componentsCount = readUint16(data, position + 36); siz.YTOsiz = readUint32(data, position + 32);
siz.Csiz = componentsCount; var componentsCount = readUint16(data, position + 36);
var components = []; siz.Csiz = componentsCount;
j = position + 38; var components = [];
for (var i = 0; i < componentsCount; i++) { j = position + 38;
var component = { for (var i = 0; i < componentsCount; i++) {
precision: (data[j] & 0x7F) + 1, var component = {
isSigned: !!(data[j] & 0x80), precision: (data[j] & 0x7F) + 1,
XRsiz: data[j + 1], isSigned: !!(data[j] & 0x80),
YRsiz: data[j + 1] XRsiz: data[j + 1],
}; YRsiz: data[j + 1]
calculateComponentDimensions(component, siz); };
components.push(component); calculateComponentDimensions(component, siz);
} components.push(component);
context.SIZ = siz;
context.components = components;
calculateTileGrids(context, components);
context.QCC = [];
context.COC = [];
break;
case 0xFF5C: // Quantization default (QCD)
length = readUint16(data, position);
var qcd = {};
j = position + 2;
var sqcd = data[j++];
var spqcdSize, scalarExpounded;
switch (sqcd & 0x1F) {
case 0:
spqcdSize = 8;
scalarExpounded = true;
break;
case 1:
spqcdSize = 16;
scalarExpounded = false;
break;
case 2:
spqcdSize = 16;
scalarExpounded = true;
break;
default:
error('JPX error: Invalid SQcd value ' + sqcd);
}
qcd.noQuantization = spqcdSize == 8;
qcd.scalarExpounded = scalarExpounded;
qcd.guardBits = sqcd >> 5;
var spqcds = [];
while (j < length + position) {
var spqcd = {};
if (spqcdSize == 8) {
spqcd.epsilon = data[j++] >> 3;
spqcd.mu = 0;
} else {
spqcd.epsilon = data[j] >> 3;
spqcd.mu = ((data[j] & 0x7) << 8) | data[j + 1];
j += 2;
} }
spqcds.push(spqcd); context.SIZ = siz;
} context.components = components;
qcd.SPqcds = spqcds; calculateTileGrids(context, components);
if (context.mainHeader) context.QCC = [];
context.QCD = qcd; context.COC = [];
else { break;
context.currentTile.QCD = qcd; case 0xFF5C: // Quantization default (QCD)
context.currentTile.QCC = []; length = readUint16(data, position);
} var qcd = {};
break; j = position + 2;
case 0xFF5D: // Quantization component (QCC) var sqcd = data[j++];
length = readUint16(data, position); var spqcdSize, scalarExpounded;
var qcc = {}; switch (sqcd & 0x1F) {
j = position + 2; case 0:
var cqcc; spqcdSize = 8;
if (context.SIZ.Csiz < 257) scalarExpounded = true;
cqcc = data[j++]; break;
else { case 1:
cqcc = readUint16(data, j); spqcdSize = 16;
j += 2; scalarExpounded = false;
} break;
var sqcd = data[j++]; case 2:
var spqcdSize, scalarExpounded; spqcdSize = 16;
switch (sqcd & 0x1F) { scalarExpounded = true;
case 0: break;
spqcdSize = 8; default:
scalarExpounded = true; throw 'Invalid SQcd value ' + sqcd;
break; }
case 1: qcd.noQuantization = spqcdSize == 8;
spqcdSize = 16; qcd.scalarExpounded = scalarExpounded;
scalarExpounded = false; qcd.guardBits = sqcd >> 5;
break; var spqcds = [];
case 2: while (j < length + position) {
spqcdSize = 16; var spqcd = {};
scalarExpounded = true; if (spqcdSize == 8) {
break; spqcd.epsilon = data[j++] >> 3;
default: spqcd.mu = 0;
error('JPX error: Invalid SQcd value ' + sqcd); } else {
} spqcd.epsilon = data[j] >> 3;
qcc.noQuantization = spqcdSize == 8; spqcd.mu = ((data[j] & 0x7) << 8) | data[j + 1];
qcc.scalarExpounded = scalarExpounded; j += 2;
qcc.guardBits = sqcd >> 5; }
var spqcds = []; spqcds.push(spqcd);
while (j < length + position) { }
var spqcd = {}; qcd.SPqcds = spqcds;
if (spqcdSize == 8) { if (context.mainHeader)
spqcd.epsilon = data[j++] >> 3; context.QCD = qcd;
spqcd.mu = 0; else {
} else { context.currentTile.QCD = qcd;
spqcd.epsilon = data[j] >> 3; context.currentTile.QCC = [];
spqcd.mu = ((data[j] & 0x7) << 8) | data[j + 1]; }
break;
case 0xFF5D: // Quantization component (QCC)
length = readUint16(data, position);
var qcc = {};
j = position + 2;
var cqcc;
if (context.SIZ.Csiz < 257)
cqcc = data[j++];
else {
cqcc = readUint16(data, j);
j += 2; j += 2;
} }
spqcds.push(spqcd); var sqcd = data[j++];
} var spqcdSize, scalarExpounded;
qcc.SPqcds = spqcds; switch (sqcd & 0x1F) {
if (context.mainHeader) case 0:
context.QCC[cqcc] = qcc; spqcdSize = 8;
else scalarExpounded = true;
context.currentTile.QCC[cqcc] = qcc; break;
break; case 1:
case 0xFF52: // Coding style default (COD) spqcdSize = 16;
length = readUint16(data, position); scalarExpounded = false;
var cod = {}; break;
j = position + 2; case 2:
var scod = data[j++]; spqcdSize = 16;
cod.entropyCoderWithCustomPrecincts = !!(scod & 1); scalarExpounded = true;
cod.sopMarkerUsed = !!(scod & 2); break;
cod.ephMarkerUsed = !!(scod & 4); default:
var codingStyle = {}; throw 'Invalid SQcd value ' + sqcd;
cod.progressionOrder = data[j++]; }
cod.layersCount = readUint16(data, j); qcc.noQuantization = spqcdSize == 8;
j += 2; qcc.scalarExpounded = scalarExpounded;
cod.multipleComponentTransform = data[j++]; qcc.guardBits = sqcd >> 5;
var spqcds = [];
cod.decompositionLevelsCount = data[j++];
cod.xcb = (data[j++] & 0xF) + 2;
cod.ycb = (data[j++] & 0xF) + 2;
var blockStyle = data[j++];
cod.selectiveArithmeticCodingBypass = !!(blockStyle & 1);
cod.resetContextProbabilities = !!(blockStyle & 2);
cod.terminationOnEachCodingPass = !!(blockStyle & 4);
cod.verticalyStripe = !!(blockStyle & 8);
cod.predictableTermination = !!(blockStyle & 16);
cod.segmentationSymbolUsed = !!(blockStyle & 32);
cod.transformation = data[j++];
if (cod.entropyCoderWithCustomPrecincts) {
var precinctsSizes = {};
while (j < length + position) { while (j < length + position) {
var precinctsSize = data[j]; var spqcd = {};
precinctsSizes.push({ if (spqcdSize == 8) {
PPx: precinctsSize & 0xF, spqcd.epsilon = data[j++] >> 3;
PPy: precinctsSize >> 4 spqcd.mu = 0;
}); } else {
spqcd.epsilon = data[j] >> 3;
spqcd.mu = ((data[j] & 0x7) << 8) | data[j + 1];
j += 2;
}
spqcds.push(spqcd);
}
qcc.SPqcds = spqcds;
if (context.mainHeader)
context.QCC[cqcc] = qcc;
else
context.currentTile.QCC[cqcc] = qcc;
break;
case 0xFF52: // Coding style default (COD)
length = readUint16(data, position);
var cod = {};
j = position + 2;
var scod = data[j++];
cod.entropyCoderWithCustomPrecincts = !!(scod & 1);
cod.sopMarkerUsed = !!(scod & 2);
cod.ephMarkerUsed = !!(scod & 4);
var codingStyle = {};
cod.progressionOrder = data[j++];
cod.layersCount = readUint16(data, j);
j += 2;
cod.multipleComponentTransform = data[j++];
cod.decompositionLevelsCount = data[j++];
cod.xcb = (data[j++] & 0xF) + 2;
cod.ycb = (data[j++] & 0xF) + 2;
var blockStyle = data[j++];
cod.selectiveArithmeticCodingBypass = !!(blockStyle & 1);
cod.resetContextProbabilities = !!(blockStyle & 2);
cod.terminationOnEachCodingPass = !!(blockStyle & 4);
cod.verticalyStripe = !!(blockStyle & 8);
cod.predictableTermination = !!(blockStyle & 16);
cod.segmentationSymbolUsed = !!(blockStyle & 32);
cod.transformation = data[j++];
if (cod.entropyCoderWithCustomPrecincts) {
var precinctsSizes = {};
while (j < length + position) {
var precinctsSize = data[j];
precinctsSizes.push({
PPx: precinctsSize & 0xF,
PPy: precinctsSize >> 4
});
}
cod.precinctsSizes = precinctsSizes;
} }
cod.precinctsSizes = precinctsSizes;
}
if (cod.sopMarkerUsed || cod.ephMarkerUsed ||
cod.selectiveArithmeticCodingBypass ||
cod.resetContextProbabilities ||
cod.terminationOnEachCodingPass ||
cod.verticalyStripe || cod.predictableTermination ||
cod.segmentationSymbolUsed)
error('JPX error: Unsupported COD options: ' + uneval(cod));
if (context.mainHeader)
context.COD = cod;
else {
context.currentTile.COD = cod;
context.currentTile.COC = [];
}
break;
case 0xFF90: // Start of tile-part (SOT)
length = readUint16(data, position);
var tile = {};
tile.index = readUint16(data, position + 2);
tile.length = readUint32(data, position + 4);
tile.dataEnd = tile.length + position - 2;
tile.partIndex = data[position + 8];
tile.partsCount = data[position + 9];
context.mainHeader = false;
if (tile.partIndex == 0) {
// reset component specific settings
tile.COD = context.COD;
tile.COC = context.COC.slice(0); // clone of the global COC
tile.QCD = context.QCD;
tile.QCC = context.QCC.slice(0); // clone of the global COC
}
context.currentTile = tile;
break;
case 0xFF93: // Start of data (SOD)
var tile = context.currentTile;
if (tile.partIndex == 0) {
initializeTile(context, tile.index);
buildPackets(context);
}
// moving to the end of the data if (cod.sopMarkerUsed || cod.ephMarkerUsed ||
length = tile.dataEnd - position; cod.selectiveArithmeticCodingBypass ||
cod.resetContextProbabilities ||
cod.terminationOnEachCodingPass ||
cod.verticalyStripe || cod.predictableTermination ||
cod.segmentationSymbolUsed)
throw 'Unsupported COD options: ' + uneval(cod);
if (context.mainHeader)
context.COD = cod;
else {
context.currentTile.COD = cod;
context.currentTile.COC = [];
}
break;
case 0xFF90: // Start of tile-part (SOT)
length = readUint16(data, position);
var tile = {};
tile.index = readUint16(data, position + 2);
tile.length = readUint32(data, position + 4);
tile.dataEnd = tile.length + position - 2;
tile.partIndex = data[position + 8];
tile.partsCount = data[position + 9];
context.mainHeader = false;
if (tile.partIndex == 0) {
// reset component specific settings
tile.COD = context.COD;
tile.COC = context.COC.slice(0); // clone of the global COC
tile.QCD = context.QCD;
tile.QCC = context.QCC.slice(0); // clone of the global COC
}
context.currentTile = tile;
break;
case 0xFF93: // Start of data (SOD)
var tile = context.currentTile;
if (tile.partIndex == 0) {
initializeTile(context, tile.index);
buildPackets(context);
}
parseTilePackets(context, data, position, length); // moving to the end of the data
break; length = tile.dataEnd - position;
case 0xFF64: // Comment (COM)
length = readUint16(data, position); parseTilePackets(context, data, position, length);
// skipping content break;
break; case 0xFF64: // Comment (COM)
default: length = readUint16(data, position);
error('JPX error: Unknown codestream code: ' + code.toString(16)); // skipping content
break;
default:
throw 'Unknown codestream code: ' + code.toString(16);
}
position += length;
} }
position += length; } catch (e) {
if (this.failOnCorruptedImage)
error('JPX error: ' + e);
else
warn('JPX error: ' + e + '. Trying to recover');
} }
this.tiles = transformComponents(context); this.tiles = transformComponents(context);
this.width = context.SIZ.Xsiz - context.SIZ.XOsiz; this.width = context.SIZ.Xsiz - context.SIZ.XOsiz;

Loading…
Cancel
Save