diskmanagerreadrequestimpl.java

java 文件下载器。可自定义

// 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:   DiskManagerReadRequestImpl.java

package org.gudy.azureus2.core3.disk.impl.access.impl;

import org.gudy.azureus2.core3.disk.DiskManagerReadRequest;
import org.gudy.azureus2.core3.util.SystemTime;

// Referenced classes of package org.gudy.azureus2.core3.disk.impl.access.impl:
//			DiskManagerRequestImpl

public class DiskManagerReadRequestImpl extends DiskManagerRequestImpl
	implements DiskManagerReadRequest
{

	private static final int EXPIRATION_TIME = 60000;
	private final int pieceNumber;
	private final int offset;
	private final int length;
	private final int hashcode;
	private long timeCreated;
	private boolean flush;
	private boolean cancelled;
	private boolean use_cache;

	public DiskManagerReadRequestImpl(int _pieceNumber, int _offset, int _length)
	{
		use_cache = true;
		pieceNumber = _pieceNumber;
		offset = _offset;
		length = _length;
		timeCreated = SystemTime.getCurrentTime();
		hashcode = pieceNumber + offset + length;
	}

	protected String getName()
	{
		return (new StringBuilder()).append("Read: ").append(pieceNumber).append(",off=").append(offset).append(",len=").append(length).append(",fl=").append(flush).append(",uc=").append(use_cache).toString();
	}

	public boolean isExpired()
	{
		long now = SystemTime.getCurrentTime();
		if (now >= timeCreated)
		{
			return now - timeCreated > 60000L;
		} else
		{
			timeCreated = now;
			return false;
		}
	}

	public void resetTime(long now)
	{
		timeCreated = now;
	}

	public int getPieceNumber()
	{
		return pieceNumber;
	}

	public int getOffset()
	{
		return offset;
	}

	public int getLength()
	{
		return length;
	}

	public void setFlush(boolean _flush)
	{
		flush = _flush;
	}

	public boolean getFlush()
	{
		return flush;
	}

	public void setUseCache(boolean cache)
	{
		use_cache = cache;
	}

	public boolean getUseCache()
	{
		return use_cache;
	}

	public void cancel()
	{
		cancelled = true;
	}

	public boolean isCancelled()
	{
		return cancelled;
	}

	public boolean equals(Object o)
	{
		if (!(o instanceof DiskManagerReadRequestImpl))
			return false;
		DiskManagerReadRequestImpl otherRequest = (DiskManagerReadRequestImpl)o;
		if (otherRequest.pieceNumber != pieceNumber)
			return false;
		if (otherRequest.offset != offset)
			return false;
		return otherRequest.length == length;
	}

	public int hashCode()
	{
		return hashcode;
	}

	public long getTimeCreated(long now)
	{
		if (timeCreated > now)
			timeCreated = now;
		return timeCreated;
	}
}