Class ConcurrentHasher

java.lang.Object

com.biglybt.core.util.ConcurrentHasher

public class ConcurrentHasher
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static boolean	friendly_hashing
protected int	processor_num
protected final AESemaphore	request_sem
protected final List<ConcurrentHasherRequest>	requests
protected final AEMonitor	requests_mon
protected final AESemaphore	scheduler_sem
protected static final ConcurrentHasher	singleton
protected final List<SHA1Hasher>	v1_hashers
protected final List<MessageDigest>	v2_hashers

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ConcurrentHasher()

Method Summary

Modifier and Type	Method	Description
ConcurrentHasherRequest	addRequest(ByteBuffer buffer, int hash_version, int piece_size, long v2_file_size)	add a synchronous request - on return it will have run (or been cancelled)
ConcurrentHasherRequest	addRequest(ByteBuffer buffer, int hash_version, int piece_size, long v2_file_size, ConcurrentHasherRequestListener listener, boolean low_priorty)	Add an asynchronous request if listener supplied, sync otherwise
static boolean	concurrentHashingAvailable()
static ConcurrentHasher	getSingleton()
static void	main(String[] args)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

singleton

protected static final ConcurrentHasher singleton

processor_num

protected int processor_num

requests

protected final List<ConcurrentHasherRequest> requests

v1_hashers

protected final List<SHA1Hasher> v1_hashers

v2_hashers

protected final List<MessageDigest> v2_hashers

request_sem

protected final AESemaphore request_sem

scheduler_sem

protected final AESemaphore scheduler_sem

requests_mon

protected final AEMonitor requests_mon

friendly_hashing

private static boolean friendly_hashing

Constructor Details

ConcurrentHasher

protected ConcurrentHasher()

Method Details

getSingleton

public static ConcurrentHasher getSingleton()

concurrentHashingAvailable

public static boolean concurrentHashingAvailable()

addRequest

public ConcurrentHasherRequest addRequest(ByteBuffer buffer,
 int hash_version,
 int piece_size,
 long v2_file_size)

add a synchronous request - on return it will have run (or been cancelled)

addRequest

public ConcurrentHasherRequest addRequest(ByteBuffer buffer,
 int hash_version,
 int piece_size,
 long v2_file_size,
 ConcurrentHasherRequestListener listener,
 boolean low_priorty)

Add an asynchronous request if listener supplied, sync otherwise

Parameters:

buffer -

listener -

low_priorty - low priority checks will cause the "friendly hashing" setting to be taken into account

priority -

Returns:

main

public static void main(String[] args)