• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java Check类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.tukaani.xz.check.Check的典型用法代码示例。如果您正苦于以下问题:Java Check类的具体用法?Java Check怎么用?Java Check使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



Check类属于org.tukaani.xz.check包,在下文中一共展示了Check类的9个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: SingleXZInputStream

import org.tukaani.xz.check.Check; //导入依赖的package包/类
SingleXZInputStream(InputStream in, int memoryLimit, boolean verifyCheck,
                    byte[] streamHeader) throws IOException {
    this.in = in;
    this.memoryLimit = memoryLimit;
    this.verifyCheck = verifyCheck;
    streamHeaderFlags = DecoderUtil.decodeStreamHeader(streamHeader);
    check = Check.getInstance(streamHeaderFlags.checkType);
}
 
开发者ID:dbrant,项目名称:zimdroid,代码行数:9,代码来源:SingleXZInputStream.java


示例2: initialize

import org.tukaani.xz.check.Check; //导入依赖的package包/类
private void initialize(InputStream in, int memoryLimit,
                        byte[] streamHeader) throws IOException {
    this.in = in;
    this.memoryLimit = memoryLimit;
    streamHeaderFlags = DecoderUtil.decodeStreamHeader(streamHeader);
    check = Check.getInstance(streamHeaderFlags.checkType);
}
 
开发者ID:eclipse,项目名称:packagedrone,代码行数:8,代码来源:SingleXZInputStream.java


示例3: initialize

import org.tukaani.xz.check.Check; //导入依赖的package包/类
private void initialize(InputStream in, int memoryLimit, byte[] streamHeader)
		throws IOException {
	this.in = in;
	this.memoryLimit = memoryLimit;
	streamHeaderFlags = DecoderUtil.decodeStreamHeader(streamHeader);
	check = Check.getInstance(streamHeaderFlags.checkType);
}
 
开发者ID:anadon,项目名称:JLS,代码行数:8,代码来源:SingleXZInputStream.java


示例4: seek

import org.tukaani.xz.check.Check; //导入依赖的package包/类
/**
 * Does the actual seeking. This is also called when <code>read</code>
 * needs a new Block to decode.
 */
private void seek() throws IOException {
    // If seek(long) wasn't called, we simply need to get the next Block
    // from the same Stream. If there are no more Blocks in this Stream,
    // then we behave as if seek(long) had been called.
    if (!seekNeeded) {
        if (curBlockInfo.hasNext()) {
            curBlockInfo.setNext();
            initBlockDecoder();
            return;
        }

        seekPos = curPos;
    }

    seekNeeded = false;

    // Check if we are seeking to or past the end of the file.
    if (seekPos >= uncompressedSize) {
        curPos = seekPos;
        blockDecoder = null;
        endReached = true;
        return;
    }

    endReached = false;

    // Locate the Block that contains the uncompressed target position.
    locateBlockByPos(curBlockInfo, seekPos);

    // Seek in the underlying stream and create a new Block decoder
    // only if really needed. We can skip it if the current position
    // is already in the correct Block and the target position hasn't
    // been decompressed yet.
    //
    // NOTE: If curPos points to the beginning of this Block, it's
    // because it was left there after decompressing an earlier Block.
    // In that case, decoding of the current Block hasn't been started
    // yet. (Decoding of a Block won't be started until at least one
    // byte will also be read from it.)
    if (!(curPos > curBlockInfo.uncompressedOffset && curPos <= seekPos)) {
        // Seek to the beginning of the Block.
        in.seek(curBlockInfo.compressedOffset);

        // Since it is possible that this Block is from a different
        // Stream than the previous Block, initialize a new Check.
        check = Check.getInstance(curBlockInfo.getCheckType());

        // Create a new Block decoder.
        initBlockDecoder();
        curPos = curBlockInfo.uncompressedOffset;
    }

    // If the target wasn't at a Block boundary, decompress and throw
    // away data to reach the target position.
    if (seekPos > curPos) {
        // NOTE: The "if" below is there just in case. In this situation,
        // blockDecoder.skip will always skip the requested amount
        // or throw an exception.
        long skipAmount = seekPos - curPos;
        if (blockDecoder.skip(skipAmount) != skipAmount)
            throw new CorruptedInputException();

        curPos = seekPos;
    }
}
 
开发者ID:dbrant,项目名称:zimdroid,代码行数:70,代码来源:SeekableXZInputStream.java


示例5: BlockOutputStream

import org.tukaani.xz.check.Check; //导入依赖的package包/类
public BlockOutputStream(OutputStream out, FilterEncoder[] filters,
                         Check check) throws IOException {
    this.out = out;
    this.check = check;

    // Initialize the filter chain.
    outCounted = new CountingOutputStream(out);
    filterChain = outCounted;
    for (int i = filters.length - 1; i >= 0; --i)
        filterChain = filters[i].getOutputStream(filterChain);

    // Prepare to encode the Block Header field.
    ByteArrayOutputStream bufStream = new ByteArrayOutputStream();

    // Write a dummy Block Header Size field. The real value is written
    // once everything else except CRC32 has been written.
    bufStream.write(0x00);

    // Write Block Flags. Storing Compressed Size or Uncompressed Size
    // isn't supported for now.
    bufStream.write(filters.length - 1);

    // List of Filter Flags
    for (int i = 0; i < filters.length; ++i) {
        EncoderUtil.encodeVLI(bufStream, filters[i].getFilterID());
        byte[] filterProps = filters[i].getFilterProps();
        EncoderUtil.encodeVLI(bufStream, filterProps.length);
        bufStream.write(filterProps);
    }

    // Header Padding
    while ((bufStream.size() & 3) != 0)
        bufStream.write(0x00);

    byte[] buf = bufStream.toByteArray();

    // Total size of the Block Header: Take the size of the CRC32 field
    // into account.
    headerSize = buf.length + 4;

    // This is just a sanity check.
    if (headerSize > EncoderUtil.BLOCK_HEADER_SIZE_MAX)
        throw new UnsupportedOptionsException();

    // Block Header Size
    buf[0] = (byte)(buf.length / 4);

    // Write the Block Header field to the output stream.
    out.write(buf);
    EncoderUtil.writeCRC32(out, buf);

    // Calculate the maximum allowed size of the Compressed Data field.
    // It is hard to exceed it so this is mostly to be pedantic.
    compressedSizeLimit = (EncoderUtil.VLI_MAX & ~3)
                          - headerSize - check.getSize();
}
 
开发者ID:dbrant,项目名称:zimdroid,代码行数:57,代码来源:BlockOutputStream.java


示例6: seek

import org.tukaani.xz.check.Check; //导入依赖的package包/类
/**
 * Does the actual seeking. This is also called when <code>read</code> needs
 * a new Block to decode.
 */
private void seek() throws IOException {
	// If seek(long) wasn't called, we simply need to get the next Block
	// from the same Stream. If there are no more Blocks in this Stream,
	// then we behave as if seek(long) had been called.
	if (!seekNeeded) {
		if (curBlockInfo.hasNext()) {
			curBlockInfo.setNext();
			initBlockDecoder();
			return;
		}

		seekPos = curPos;
	}

	seekNeeded = false;

	// Check if we are seeking to or past the end of the file.
	if (seekPos >= uncompressedSize) {
		curPos = seekPos;
		blockDecoder = null;
		endReached = true;
		return;
	}

	endReached = false;

	// Locate the Block that contains the uncompressed target position.
	locateBlockByPos(curBlockInfo, seekPos);

	// Seek in the underlying stream and create a new Block decoder
	// only if really needed. We can skip it if the current position
	// is already in the correct Block and the target position hasn't
	// been decompressed yet.
	//
	// NOTE: If curPos points to the beginning of this Block, it's
	// because it was left there after decompressing an earlier Block.
	// In that case, decoding of the current Block hasn't been started
	// yet. (Decoding of a Block won't be started until at least one
	// byte will also be read from it.)
	if (!(curPos > curBlockInfo.uncompressedOffset && curPos <= seekPos)) {
		// Seek to the beginning of the Block.
		in.seek(curBlockInfo.compressedOffset);

		// Since it is possible that this Block is from a different
		// Stream than the previous Block, initialize a new Check.
		check = Check.getInstance(curBlockInfo.getCheckType());

		// Create a new Block decoder.
		initBlockDecoder();
		curPos = curBlockInfo.uncompressedOffset;
	}

	// If the target wasn't at a Block boundary, decompress and throw
	// away data to reach the target position.
	if (seekPos > curPos) {
		// NOTE: The "if" below is there just in case. In this situation,
		// blockDecoder.skip will always skip the requested amount
		// or throw an exception.
		long skipAmount = seekPos - curPos;
		if (blockDecoder.skip(skipAmount) != skipAmount)
			throw new CorruptedInputException();

		curPos = seekPos;
	}
}
 
开发者ID:anadon,项目名称:JLS,代码行数:70,代码来源:SeekableXZInputStream.java


示例7: BlockOutputStream

import org.tukaani.xz.check.Check; //导入依赖的package包/类
public BlockOutputStream(OutputStream out, FilterEncoder[] filters,
		Check check) throws IOException {
	this.out = out;
	this.check = check;

	// Initialize the filter chain.
	outCounted = new CountingOutputStream(out);
	filterChain = outCounted;
	for (int i = filters.length - 1; i >= 0; --i)
		filterChain = filters[i].getOutputStream(filterChain);

	// Prepare to encode the Block Header field.
	ByteArrayOutputStream bufStream = new ByteArrayOutputStream();

	// Write a dummy Block Header Size field. The real value is written
	// once everything else except CRC32 has been written.
	bufStream.write(0x00);

	// Write Block Flags. Storing Compressed Size or Uncompressed Size
	// isn't supported for now.
	bufStream.write(filters.length - 1);

	// List of Filter Flags
	for (int i = 0; i < filters.length; ++i) {
		EncoderUtil.encodeVLI(bufStream, filters[i].getFilterID());
		byte[] filterProps = filters[i].getFilterProps();
		EncoderUtil.encodeVLI(bufStream, filterProps.length);
		bufStream.write(filterProps);
	}

	// Header Padding
	while ((bufStream.size() & 3) != 0)
		bufStream.write(0x00);

	byte[] buf = bufStream.toByteArray();

	// Total size of the Block Header: Take the size of the CRC32 field
	// into account.
	headerSize = buf.length + 4;

	// This is just a sanity check.
	if (headerSize > EncoderUtil.BLOCK_HEADER_SIZE_MAX)
		throw new UnsupportedOptionsException();

	// Block Header Size
	buf[0] = (byte) (buf.length / 4);

	// Write the Block Header field to the output stream.
	out.write(buf);
	EncoderUtil.writeCRC32(out, buf);

	// Calculate the maximum allowed size of the Compressed Data field.
	// It is hard to exceed it so this is mostly to be pedantic.
	compressedSizeLimit = (EncoderUtil.VLI_MAX & ~3) - headerSize
			- check.getSize();
}
 
开发者ID:anadon,项目名称:JLS,代码行数:57,代码来源:BlockOutputStream.java


示例8: XZOutputStream

import org.tukaani.xz.check.Check; //导入依赖的package包/类
/**
 * Creates a new XZ compressor using 1-4 filters and the specified
 * integrity check type.
 *
 * @param       out         output stream to which the compressed data
 *                          will be written
 *
 * @param       filterOptions
 *                          array of filter options to use
 *
 * @param       checkType   type of the integrity check,
 *                          for example XZ.CHECK_CRC32
 *
 * @throws      UnsupportedOptionsException
 *                          invalid filter chain
 *
 * @throws      IOException may be thrown from <code>out</code>
 */
public XZOutputStream(OutputStream out, FilterOptions[] filterOptions,
                      int checkType) throws IOException {
    this.out = out;
    updateFilters(filterOptions);

    streamFlags.checkType = checkType;
    check = Check.getInstance(checkType);

    encodeStreamHeader();
}
 
开发者ID:dbrant,项目名称:zimdroid,代码行数:29,代码来源:XZOutputStream.java


示例9: XZOutputStream

import org.tukaani.xz.check.Check; //导入依赖的package包/类
/**
 * Creates a new XZ compressor using 1-4 filters and the specified integrity
 * check type.
 * 
 * @param out
 *            output stream to which the compressed data will be written
 * 
 * @param filterOptions
 *            array of filter options to use
 * 
 * @param checkType
 *            type of the integrity check, for example XZ.CHECK_CRC32
 * 
 * @throws UnsupportedOptionsException
 *             invalid filter chain
 * 
 * @throws IOException
 *             may be thrown from <code>out</code>
 */
public XZOutputStream(OutputStream out, FilterOptions[] filterOptions,
		int checkType) throws IOException {
	this.out = out;
	updateFilters(filterOptions);

	streamFlags.checkType = checkType;
	check = Check.getInstance(checkType);

	encodeStreamHeader();
}
 
开发者ID:anadon,项目名称:JLS,代码行数:30,代码来源:XZOutputStream.java



注:本文中的org.tukaani.xz.check.Check类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java IUpdateContext类代码示例发布时间:2022-05-22
下一篇:
Java IChatBaseComponent类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap