concurrenthasherrequest.java

来自「java 文件下载器。可自定义」· Java 代码 · 共 101 行

// Decompiled by Jad v1.5.8e2. Copyright 2001 Pavel Kouznetsov.
// Jad home page: http://kpdus.tripod.com/jad.html
// Decompiler options: packimports(3) fieldsfirst ansi space 
// Source File Name:   ConcurrentHasherRequest.java

package org.gudy.azureus2.core3.util;

import java.nio.ByteBuffer;

// Referenced classes of package org.gudy.azureus2.core3.util:
//			AEMonitor, AESemaphore, ConcurrentHasherRequestListener, SHA1Hasher, 
//			ConcurrentHasher

public class ConcurrentHasherRequest
{

	private static AEMonitor class_mon = new AEMonitor("ConcHashRequest:class");
	private ConcurrentHasher concurrent_hasher;
	private ByteBuffer buffer;
	private ConcurrentHasherRequestListener listener;
	private int size;
	private byte result[];
	private boolean cancelled;
	private boolean low_priority;
	private AESemaphore sem;

	protected ConcurrentHasherRequest(ConcurrentHasher _concurrent_hasher, ByteBuffer _buffer, ConcurrentHasherRequestListener _listener, boolean _low_priorty)
	{
		sem = new AESemaphore("ConcHashRequest");
		concurrent_hasher = _concurrent_hasher;
		buffer = _buffer;
		listener = _listener;
		low_priority = _low_priorty;
		size = buffer.limit() - buffer.position();
	}

	public byte[] getResult()
	{
		sem.reserve();
		return result;
	}

	public void cancel()
	{
		if (cancelled)
			break MISSING_BLOCK_LABEL_64;
		cancelled = true;
		sem.releaseForever();
		ConcurrentHasherRequestListener listener_copy;
		class_mon.enter();
		listener_copy = listener;
		listener = null;
		class_mon.exit();
		break MISSING_BLOCK_LABEL_53;
		Exception exception;
		exception;
		class_mon.exit();
		throw exception;
		if (listener_copy != null)
			listener_copy.complete(this);
	}

	public boolean getCancelled()
	{
		return cancelled;
	}

	public int getSize()
	{
		return size;
	}

	public boolean isLowPriority()
	{
		return low_priority;
	}

	protected void run(SHA1Hasher hasher)
	{
		if (cancelled)
			break MISSING_BLOCK_LABEL_78;
		result = hasher.calculateHash(buffer);
		sem.releaseForever();
		if (cancelled)
			break MISSING_BLOCK_LABEL_78;
		ConcurrentHasherRequestListener listener_copy;
		class_mon.enter();
		listener_copy = listener;
		listener = null;
		class_mon.exit();
		break MISSING_BLOCK_LABEL_67;
		Exception exception;
		exception;
		class_mon.exit();
		throw exception;
		if (listener_copy != null)
			listener_copy.complete(this);
	}

}