test.java

这是一个基于java编写的torrent的P2P源码

		{
			
		}
	  
	    public DiskManager initializeDiskManager()
		{
			return( null );
			
		}
	  
	    public boolean canForceRecheck()
		{
			return( false );
			
		}

	    public void forceRecheck()
		{
			
		}

	    public void
	    resetFile(
	    	DiskManagerFileInfo		file )
	    {
	    }
	    
	    public void
	    recheckFile(
	    	DiskManagerFileInfo		file )
	    {	
	    }
	    
		public int getHealthStatus()
		{
			return( 0 );
			
		}
		public int
		getNATStatus()
		{
			return( 0 );
		}
		
		public Category getCategory()
		{
			return( null );
			
		}
		
		public void setCategory(Category cat)
		{
			
		}
		
		public void deleteDataFiles()
		{
			
		}
		

		
		public void
		mergeTorrentDetails(
		  	DownloadManager	other_manager )
		{	
		}
		  
		
		public void
		saveResumeData()		
		{
			
		}

		public void
		saveDownload()
		{
		}
		 
		public void
		moveDataFiles(
			File	new_parent_dir )
		{
		}
		
		public void renameDownload(String name){}
		
		 
		public void
		moveTorrentFile(
			File	new_parent_dir )
		{
		}
		
		public File[] calculateDefaultPaths(boolean for_moving) {
			  return null;
		}
		
		public boolean isInDefaultSaveDir() {return false;}
		
	  public Object getData (String key)
	  {
		  return( null );	
	  }
	 
	  public void setData (String key, Object value)
		{
		
	}
	  
	  
	
	  public boolean isDataAlreadyAllocated()
		{
		return( false );
		
	}
	  
	
	  public void setDataAlreadyAllocated( boolean already_allocated )
		{
		
	}
	  
	
	  public long
	  getCreationTime()
		{
		return( 0 );
		
	}

	  public void
	  setCreationTime(
	  	long		t )
		{
		
	}

		public void setSeedingRank(int rank) {
		
			
		}

		public int getSeedingRank() {
			
			return 0;
		}

		public void addPeerListener(DownloadManagerPeerListener listener, boolean bDispatchForExisting) {
			
			
		}

		public PEPiece[] getCurrentPieces() {
		
			return null;
		}

		public PEPeer[] getCurrentPeers() {
		
			return null;
		}

		public int getEffectiveMaxUploads() {
			// TODO Auto-generated method stub
			return 0;
		}
		
		public int getMaxUploads() {
			// TODO Auto-generated method stub
			return 0;
		}
		
		public void setMaxUploads(int max_slots) {
			// TODO Auto-generated method stub
			
		}
		
		public int getEffectiveUploadRateLimitBytesPerSecond() {
		
			return 0;
		}

		public boolean requestAssumedCompleteMode() {
			// TODO Auto-generated method stub
			return false;
		}
	}
	
	protected class
	PEPeerManagerDummy
		implements PEPeerManager
	{
		protected DiskManager	dm;
		
		protected void
		setDiskManager(
			DiskManager	_dm )
		{
			dm	= _dm;
		}
		
		
	 	public DiskManager
		getDiskManager()
	 	{
	 		return( null );
	 	}
		public void
		generateEvidence(
			IndentWriter		writer )
		{
		}
		
	 	public PiecePicker getPiecePicker()
	 	{
	 		return null;
	 	}
	 	
	 	public String
	 	getDisplayName()
	 	{
	 		return( null );
	 	}
	    public LimitedRateGroup getUploadLimitedRateGroup() {  return null;  }
	    public LimitedRateGroup getDownloadLimitedRateGroup() {  return null;  }
    
		public void
		start()
		{
			
		}
			
	    public PeerExchangerItem createPeerExchangeConnection( PEPeerTransport base_peer ) {  return null;  }
	    
	    public void peerVerifiedAsSelf( PEPeerTransport self ){}
	    
		public void
		stopAll()
		{
			
		}
    
		public boolean
		seedPieceRecheck()
		{
			return( false );
		}
		  
	    public void peerConnectionClosed( PEPeerTransport peer, boolean connect_failed ) {
	      
	    }
	    
	    public boolean isInEndGameMode() {  return false;  }
	    
				
	    public int getAverageCompletionInThousandNotation(){  return 0;  }
	    
		public byte[]
		getHash()
		{
			return( null );
		}
		
		public PeerIdentityDataID
		getPeerIdentityDataID()
		{
			return( null );
		}

		public byte[]
		getPeerId()
		{
			return( null );
		}
		
		public void 
		blockWritten(
			int pieceNumber, 
			int offset,
			PEPeer peer)
		{
			if ( !RANDOM_TEST ){
				
				if ( CHECK_WRITES ){
					
					if ( offset == 0 ){
						
						dm.enqueueCheckRequest( dm.createCheckRequest( pieceNumber, null ), null );
					}
				}
			}
	
		}
		
		public void 
		asyncPieceChecked(
			int pieceNumber, 
			boolean result )
		{
			dm.getPiece(pieceNumber).setDone( false );
		}

		public int[] getAvailability()
		{
			return( null );
		}

		public int calcAvailability(int pieceNumber)
		{
			return( 0 );
		}
		
		public int getAvailability(int pieceNumber)
		{
			return( 0 );
		}
		
	    public float getMinAvailability()
		{
	    	return( 0 );
		}


        public boolean isPieceActive(int pieceNumber)
        {
            return false;
        }

		public PEPiece getPiece(int pieceNumber)
		{
			return null;
		}

		public boolean
		hasDownloadablePiece()
		{
			return( false );
		}
		public PEPiece[] getPieces()
		{
			return( null );
		}


		public PEPeerManagerStats
		getStats()
		{
			return( null );
		}


		public void
		processTrackerResponse(
			TRTrackerAnnouncerResponse	response )
		{
		}

			
		public int getNbPeers()
		{
			return( 0 );
		}


		public int getNbSeeds()
		{
			return( 0 );
		}

		public int getNbHashFails()
		{
			return( 0 );
		}

	  
		public void setNbHashFails(int fails)
		{
		}


		public int getPiecesNumber()
		{
			return( 0 );
		}

		public int getPieceLength(int pieceNumber)
		{
			return( 0 );
		}

			
		public long getRemaining()
		{
			return( 0 );
		}

		public int getDownloadPriority()
		{
			return( 0 );
		}


		public long getETA()
		{
			return( 0 );
		}


		public String getElapsedTime()
		{
			return( null );
		}

		
		// Time Started in ms
		public long getTimeStarted()
		{
			return( 0 );
		}


		public long getTimeStartedSeeding()
		{
			return( 0 );
		}

		
		public void
		addListener(
			PEPeerManagerListener	l )
		{		
		}

			
		public void
		removeListener(
			PEPeerManagerListener	l )
		{	
		}

	  
		public boolean needsMD5CheckOnCompletion(int pieceNumber)
		{
			return( false );
		}

		public boolean
		isSeeding()
		{
			return( false );
		}

		public boolean
		isSuperSeedMode()
		{
			return( false );
		}

	  
		public int getNbRemoteConnections()
		{
			return( 0 );
		}

		public long getLastRemoteConnectionTime()
		{
			return(0);
		}

		public int getMaxNewConnectionsAllowed()
		{
			return( 0 );
		}
		
		public void
		dataBytesReceived(
			PEPeer 	peer,
			int		l )
		{	
		}

		
		public void
		dataBytesSent(
			PEPeer 	peer,
			int		l )
		{			
		}

		public void protocolBytesSent( PEPeer peer, int length ) {}

		public void protocolBytesReceived( PEPeer peer, int length ) {}

		public void
		discarded(
			PEPeer peer, int		l )
		{
		}

		
		public PEPeerStats
		createPeerStats( PEPeer owner )
		{
			return( null );
		}

		
		
		public List
		getPeers()
		{
			return( null );
		}

		public List
		getPeers(
			String	address )
		{
			return( null );
		}
		
		public PeerDescriptor[]
		getPendingPeers(
			String	address )
		{
			return( null );
		}
		
		public void
		addPeer(
			PEPeer	peer )
		{			
		}

		public void 
		addPeer( 
			String ip_address, 
			int port, 
			int udp_port, 
			boolean use_crypto ) 
		{
		}
		
		public void
		removePeer(
			PEPeer	peer )
		{	
		}
		
		public void
		removePeer(
			PEPeer	peer,
			String	reason )
		{	
		}
		
		public void 
		peerAdded(PEPeer pc)
		{	
		}

		public void 
		peerRemoved(PEPeer pc)
		{
			
		}

		
		public DiskManagerReadRequest
		createDiskManagerRequest(
		   int pieceNumber,
		   int offset,
		   int length )
		{
			return( null );	
		}

		
		public void
		requestCanceled(
			DiskManagerReadRequest	item )
		{
			
		}

			
		public boolean 
		validatePieceReply(
			int 		pieceNumber, 
			int 		offset, 
			DirectByteBuffer 	data )
		{
			return( false );
		}

		
		public void 
		writeBlock(
			int 		pieceNumber, 
			int 		offset, 
			DirectByteBuffer 	data,
			PEPeer 		sender,
            boolean     cancel)
		{
			
		}

	  
//	  public void writeBlockAndCancelOutstanding(int pieceNumber, int offset, DirectByteBuffer data,PEPeer sender)
//		{
//		
//	}

	  
	  public boolean isWritten( int piece_number, int offset )
		{
		return( false );
		}
		 public Object getData (String key){return( null );}
		  /** To store arbitrary objects against this object. */
		  public void setData (String key, Object value){}

	public void addPiece(PEPiece piece, int pieceNumber)
	{
	}


	public float getAvgAvail()
	{
		return 0;
	}

	  
	public PEPeerTransport getTransportFromIdentity( byte[] peer_id ) { return null;  }
	  
	public PEPeerTransport getTransportFromAddress(String peer) { return null;  }
	}
	/*
	protected class
	DiskManagerDummy
		implements DiskManagerHelper
	{
		public void
		start()
		{
		}
		
		public boolean
		filesExist()
		{
			
		}

		public void 
		setPeerManager(
			PEPeerManager manager )
		{
			
		}


		public void 
		writeBlock(
			int 		pieceNumber, 
			int 		offset, 
			DirectByteBuffer 	data,
			PEPeer sender)
		{
			
		}


		public boolean 
		checkBlock(
			int 		pieceNumber, 
			int 		offset, 
			DirectByteBuffer 	data )
		{
			
		}


		public boolean 
		checkBlock(
			int pieceNumber, 
			int offset, 
			int length )
		{
			
		}

			
		public DiskManagerRequest
		createRequest(
			int pieceNumber,
			int offset,
			int length );
		

		public void enqueueReadRequest( DiskManagerRequest request, ReadRequestListener listener );

		public void
		stopIt();

		public void
	    dumpResumeDataToDisk(
	    	boolean savePartialPieces, 
			boolean force_recheck )
			
			throws Exception;

		public void
		computePriorityIndicator();
		
		public PEPiece[] 
		getRecoveredPieces();

		public void
		aSyncCheckPiece(
			int	pieceNumber );
	  
		public int 
		getPieceNumberToDownload(BitFlags candidatePieces);
		
		public boolean[] 
		getPiecesDone();

		public int 
		getNumberOfPieces();

		public DiskManagerFileInfo[]
		getFiles();

		public int
		getState();
		
		public long
		getTotalLength();
		
		public int
		getPieceLength();
		
		public int 
		getLastPieceLength();

		public long
		getRemaining();
		
		public int
		getPercentDone();
		
		public String
		getErrorMessage();
	  
		public String
		moveCompletedFiles();

		public boolean isChecking();
	  
	   
		public void
		addListener(
			DiskManagerListener	l );
		
		public void
		removeListener(
			DiskManagerListener	l );
	  
	  
	  public void storeFilePriorities();
	  
	  public DownloadManager getDownloadManager();
	  
	  public PEPeerManager getPeerManager();
		
		
		public PieceList
		getPieceList(
			int	piece_number )
		{
			return(null);
		}
		
		public byte[]
		getPieceHash(
			int	piece_number )
		{
			return(null);
		}
		
		public void
		setState(
			int	state )
		{
		}
		
		public void
		setErrorMessage(
			String	str )
		{
		}
		
		public long
		getAllocated()
		{
			return(0);
			
		}
		
		public void
		setAllocated(
			long		num )
		{
		}

		
		public void
		setRemaining(
			long		num )
		{
		}

		
		public void
		setPercentDone(
			int			num )
		{
		}

		
		public void 
		computeFilesDone(
			int pieceNumber )
		{
		}

		
		public TOTorrent
		getTorrent()
		{
			return(null);
		}

	}
*/
}