Java Doc for RemoteSlave.java in  » Net » DrFTPD » org » drftpd » master » Java Source Code / Java DocumentationJava Source Code and Java Documentation

Java Source Code / Java Documentation
1. 6.0 JDK Core
2. 6.0 JDK Modules
3. 6.0 JDK Modules com.sun
4. 6.0 JDK Modules com.sun.java
5. 6.0 JDK Modules sun
6. 6.0 JDK Platform
7. Ajax
8. Apache Harmony Java SE
9. Aspect oriented
10. Authentication Authorization
11. Blogger System
12. Build
13. Byte Code
14. Cache
15. Chart
16. Chat
17. Code Analyzer
18. Collaboration
19. Content Management System
20. Database Client
21. Database DBMS
22. Database JDBC Connection Pool
23. Database ORM
24. Development
25. EJB Server geronimo
26. EJB Server GlassFish
27. EJB Server JBoss 4.2.1
28. EJB Server resin 3.1.5
29. ERP CRM Financial
30. ESB
31. Forum
32. GIS
33. Graphic Library
34. Groupware
35. HTML Parser
36. IDE
37. IDE Eclipse
38. IDE Netbeans
39. Installer
40. Internationalization Localization
41. Inversion of Control
42. Issue Tracking
43. J2EE
44. JBoss
45. JMS
46. JMX
47. Library
48. Mail Clients
49. Net
50. Parser
51. PDF
52. Portal
53. Profiler
54. Project Management
55. Report
56. RSS RDF
57. Rule Engine
58. Science
59. Scripting
60. Search Engine
61. Security
62. Sevlet Container
63. Source Control
64. Swing Library
65. Template Engine
66. Test Coverage
67. Testing
68. UML
69. Web Crawler
70. Web Framework
71. Web Mail
72. Web Server
73. Web Services
74. Web Services apache cxf 2.0.1
75. Web Services AXIS2
76. Wiki Engine
77. Workflow Engines
78. XML
79. XML UI
Java
Java Tutorial
Java Open Source
Jar File Download
Java Articles
Java Products
Java by API
Photoshop Tutorials
Maya Tutorials
Flash Tutorials
3ds-Max Tutorials
Illustrator Tutorials
GIMP Tutorials
C# / C Sharp
C# / CSharp Tutorial
C# / CSharp Open Source
ASP.Net
ASP.NET Tutorial
JavaScript DHTML
JavaScript Tutorial
JavaScript Reference
HTML / CSS
HTML CSS Reference
C / ANSI-C
C Tutorial
C++
C++ Tutorial
Ruby
PHP
Python
Python Tutorial
Python Open Source
SQL Server / T-SQL
SQL Server / T-SQL Tutorial
Oracle PL / SQL
Oracle PL/SQL Tutorial
PostgreSQL
SQL / MySQL
MySQL Tutorial
VB.Net
VB.Net Tutorial
Flash / Flex / ActionScript
VBA / Excel / Access / Word
XML
XML Tutorial
Microsoft Office PowerPoint 2007 Tutorial
Microsoft Office Excel 2007 Tutorial
Microsoft Office Word 2007 Tutorial
Java Source Code / Java Documentation » Net » DrFTPD » org.drftpd.master 
Source Cross Reference  Class Diagram Java Document (Java Doc) 


java.lang.Object
   org.drftpd.master.RemoteSlave

All known Subclasses:   org.drftpd.tests.DummyRemoteSlave,
RemoteSlave
public class RemoteSlave implements Runnable,Comparable<RemoteSlave>,Serializable,Entity(Code)

author:
   mog
author:
   zubov
version:
   $Id: RemoteSlave.java 1538 2006-12-14 20:55:37Z zubov $


Field Summary
protected transient  int_errors
    
protected transient  long_lastNetworkError
    

Constructor Summary
public  RemoteSlave(String name)
    
public  RemoteSlave(String name, GlobalContext gctx)
    

Method Summary
public  voidaddMask(String mask)
    
final public  voidaddNetworkError(SocketException e)
    
protected  voidaddQueueDelete(String fileName)
    
protected  voidaddQueueRename(String fileName, String destName)
    
public synchronized  voidaddTransfer(TransferIndex transferIndex, RemoteTransfer transfer)
    
public  booleancheckConnect(Socket socket)
    
public  voidcommit()
    
final public  intcompareTo(RemoteSlave o)
    
public synchronized  voidconnect(Socket socket, ObjectInputStream in, ObjectOutputStream out)
    
final public  booleanequals(Object obj)
    
public  longfetchChecksumFromIndex(String index)
    
public  StringfetchDIZFileFromIndex(String index)
    
public  ID3TagfetchID3TagFromIndex(String index)
    
public  intfetchMaxPathFromIndex(String maxPathIndex)
    
public  voidfetchRemergeResponseFromIndex(String index)
    
public  AsyncResponsefetchResponse(String index)
    
public synchronized  AsyncResponsefetchResponse(String index, int wait)
    
public  LightSFVFilefetchSFVFileFromIndex(String index)
    
public  ConnectInfofetchTransferResponseFromIndex(String index)
    
public  GlobalContextgetGlobalContext()
    
final public  longgetLastDownloadSending()
    
public  longgetLastTimeOnline()
    
final public  longgetLastTransfer()
    
public  longgetLastTransferForDirection(char dir)
    
final public  longgetLastUploadReceiving()
    
public  HostMaskCollectiongetMasks()
    
public  StringgetName()
     Returns the name.
public synchronized  StringgetPASVIP()
    
public  intgetPort()
    
public  PropertiesgetProperties()
    
public  StringgetProperty(String name, String def)
    
public  StringgetProperty(String key)
    
public  longgetReceivedBytes()
    
public  LinkedList<QueuedOperation>getRenameQueue()
    
public  longgetSentBytes()
    
public static  StringgetSlaveNameFromObjectInput(ObjectInputStream in)
    
public synchronized  SlaveStatusgetSlaveStatus()
    
public synchronized  SlaveStatusgetSlaveStatusAvailable()
    
public synchronized  RemoteTransfergetTransfer(TransferIndex transferIndex)
    
public synchronized  Collection<RemoteTransfer>getTransfers()
    
final public  inthashCode()
    
public  voidinit(GlobalContext globalContext)
    
public synchronized  booleanisAvailable()
    
public  booleanisAvailablePing()
    
public  booleanisMemberOf(String string)
    
public synchronized  booleanisOnline()
    
public  voidissueAbortToSlave(TransferIndex transferIndex, String reason)
    
public  StringissueChecksumToSlave(String string)
    
public  StringissueConnectToSlave(String ip, int port, boolean encryptedDataChannel, boolean useSSLClientHandshake)
    
public  StringissueDIZFileToSlave(LinkedRemoteFileInterface file)
    
public  StringissueDeleteToSlave(String sourceFile)
    
public  StringissueID3TagToSlave(String path)
    
public  StringissueListenToSlave(boolean isSecureTransfer, boolean useSSLClientMode)
    
public  StringissueMaxPathToSlave()
    
public  StringissueReceiveToSlave(String name, char c, long position, TransferIndex tindex)
    
public  StringissueRemergeToSlave(String path)
    
public  StringissueRenameToSlave(String from, String toDirPath, String toName)
    
public  StringissueSFVFileToSlave(String path)
    
public  StringissueSendToSlave(String name, char c, long position, TransferIndex tindex)
    
public  StringissueStatusToSlave()
    
public  StringmoreInfo()
    
public  voidprocessQueue()
    
final public  booleanremoveMask(String mask)
    
public  StringremoveProperty(String key)
    
final public static  HashtablerslavesToHashtable(Collection rslaves)
    
public  voidrun()
    
public synchronized  voidsetAvailable(boolean available)
    
final public  voidsetLastDirection(char direction, long l)
    
final public  voidsetLastDownloadSending(long lastDownloadSending)
    
final public  voidsetLastUploadReceiving(long lastUploadReceiving)
    
public  voidsetMasks(HostMaskCollection masks)
    
public  voidsetOffline(String reason)
    
public  voidsetOffline(Throwable t)
    
public  voidsetProperties(Properties keysAndValues)
    
public  voidsetProperty(String name, String value)
    
public  voidsetRenameQueue(LinkedList<QueuedOperation> renameQueue)
    
public  voidshutdown()
    
public  voidsimpleDelete(String path)
    
public  voidsimpleRename(String from, String toDirPath, String toName)
    
public  StringtoString()
    

Field Detail
_errors
protected transient int _errors(Code)



_lastNetworkError
protected transient long _lastNetworkError(Code)




Constructor Detail
RemoteSlave
public RemoteSlave(String name)(Code)



RemoteSlave
public RemoteSlave(String name, GlobalContext gctx)(Code)
Used by everything including tests




Method Detail
addMask
public void addMask(String mask) throws DuplicateElementException(Code)



addNetworkError
final public void addNetworkError(SocketException e)(Code)
If X # of errors occur in Y amount of time, kick slave offline



addQueueDelete
protected void addQueueDelete(String fileName)(Code)



addQueueRename
protected void addQueueRename(String fileName, String destName)(Code)



addTransfer
public synchronized void addTransfer(TransferIndex transferIndex, RemoteTransfer transfer)(Code)



checkConnect
public boolean checkConnect(Socket socket) throws MalformedPatternException(Code)



commit
public void commit()(Code)



compareTo
final public int compareTo(RemoteSlave o)(Code)



connect
public synchronized void connect(Socket socket, ObjectInputStream in, ObjectOutputStream out) throws IOException(Code)



equals
final public boolean equals(Object obj)(Code)



fetchChecksumFromIndex
public long fetchChecksumFromIndex(String index) throws RemoteIOException, SlaveUnavailableException(Code)



fetchDIZFileFromIndex
public String fetchDIZFileFromIndex(String index) throws RemoteIOException, SlaveUnavailableException(Code)



fetchID3TagFromIndex
public ID3Tag fetchID3TagFromIndex(String index) throws RemoteIOException, SlaveUnavailableException(Code)



fetchMaxPathFromIndex
public int fetchMaxPathFromIndex(String maxPathIndex) throws SlaveUnavailableException(Code)



fetchRemergeResponseFromIndex
public void fetchRemergeResponseFromIndex(String index) throws IOException, SlaveUnavailableException(Code)



fetchResponse
public AsyncResponse fetchResponse(String index) throws SlaveUnavailableException, RemoteIOException(Code)

See Also:    fetchResponse(String index, int wait)



fetchResponse
public synchronized AsyncResponse fetchResponse(String index, int wait) throws SlaveUnavailableException, RemoteIOException(Code)
returns an AsyncResponse for that index and throws any exceptions thrown on the Slave side



fetchSFVFileFromIndex
public LightSFVFile fetchSFVFileFromIndex(String index) throws RemoteIOException, SlaveUnavailableException(Code)



fetchTransferResponseFromIndex
public ConnectInfo fetchTransferResponseFromIndex(String index) throws RemoteIOException, SlaveUnavailableException(Code)



getGlobalContext
public GlobalContext getGlobalContext()(Code)



getLastDownloadSending
final public long getLastDownloadSending()(Code)



getLastTimeOnline
public long getLastTimeOnline()(Code)



getLastTransfer
final public long getLastTransfer()(Code)



getLastTransferForDirection
public long getLastTransferForDirection(char dir)(Code)



getLastUploadReceiving
final public long getLastUploadReceiving()(Code)



getMasks
public HostMaskCollection getMasks()(Code)



getName
public String getName()(Code)
Returns the name.



getPASVIP
public synchronized String getPASVIP() throws SlaveUnavailableException(Code)



getPort
public int getPort()(Code)



getProperties
public Properties getProperties()(Code)



getProperty
public String getProperty(String name, String def)(Code)



getProperty
public String getProperty(String key)(Code)



getReceivedBytes
public long getReceivedBytes()(Code)



getRenameQueue
public LinkedList<QueuedOperation> getRenameQueue()(Code)



getSentBytes
public long getSentBytes()(Code)



getSlaveNameFromObjectInput
public static String getSlaveNameFromObjectInput(ObjectInputStream in) throws IOException(Code)



getSlaveStatus
public synchronized SlaveStatus getSlaveStatus() throws SlaveUnavailableException(Code)
Returns the RemoteSlave's saved SlaveStatus, can return a status before remerge() is completed



getSlaveStatusAvailable
public synchronized SlaveStatus getSlaveStatusAvailable() throws SlaveUnavailableException(Code)
Returns the RemoteSlave's stored SlaveStatus, will not return a status before remerge() is completed



getTransfer
public synchronized RemoteTransfer getTransfer(TransferIndex transferIndex) throws SlaveUnavailableException(Code)



getTransfers
public synchronized Collection<RemoteTransfer> getTransfers() throws SlaveUnavailableException(Code)



hashCode
final public int hashCode()(Code)



init
public void init(GlobalContext globalContext)(Code)



isAvailable
public synchronized boolean isAvailable()(Code)
true if the slave has synchronized its filelist since lastconnect



isAvailablePing
public boolean isAvailablePing()(Code)



isMemberOf
public boolean isMemberOf(String string)(Code)



isOnline
public synchronized boolean isOnline()(Code)



issueAbortToSlave
public void issueAbortToSlave(TransferIndex transferIndex, String reason) throws SlaveUnavailableException(Code)



issueChecksumToSlave
public String issueChecksumToSlave(String string) throws SlaveUnavailableException(Code)

Parameters:
  string -
throws:
  SlaveUnavailableException -



issueConnectToSlave
public String issueConnectToSlave(String ip, int port, boolean encryptedDataChannel, boolean useSSLClientHandshake) throws SlaveUnavailableException(Code)



issueDIZFileToSlave
public String issueDIZFileToSlave(LinkedRemoteFileInterface file) throws SlaveUnavailableException(Code)



issueDeleteToSlave
public String issueDeleteToSlave(String sourceFile) throws SlaveUnavailableException(Code)
String index, needs to be used to fetch the response



issueID3TagToSlave
public String issueID3TagToSlave(String path) throws SlaveUnavailableException(Code)



issueListenToSlave
public String issueListenToSlave(boolean isSecureTransfer, boolean useSSLClientMode) throws SlaveUnavailableException(Code)



issueMaxPathToSlave
public String issueMaxPathToSlave() throws SlaveUnavailableException(Code)



issueReceiveToSlave
public String issueReceiveToSlave(String name, char c, long position, TransferIndex tindex) throws SlaveUnavailableException(Code)



issueRemergeToSlave
public String issueRemergeToSlave(String path) throws SlaveUnavailableException(Code)



issueRenameToSlave
public String issueRenameToSlave(String from, String toDirPath, String toName) throws SlaveUnavailableException(Code)



issueSFVFileToSlave
public String issueSFVFileToSlave(String path) throws SlaveUnavailableException(Code)



issueSendToSlave
public String issueSendToSlave(String name, char c, long position, TransferIndex tindex) throws SlaveUnavailableException(Code)



issueStatusToSlave
public String issueStatusToSlave() throws SlaveUnavailableException(Code)



moreInfo
public String moreInfo()(Code)



processQueue
public void processQueue() throws IOException, SlaveUnavailableException(Code)



removeMask
final public boolean removeMask(String mask)(Code)
true if the mask was removed successfully



removeProperty
public String removeProperty(String key) throws KeyNotFoundException(Code)



rslavesToHashtable
final public static Hashtable rslavesToHashtable(Collection rslaves)(Code)



run
public void run()(Code)



setAvailable
public synchronized void setAvailable(boolean available)(Code)



setLastDirection
final public void setLastDirection(char direction, long l)(Code)



setLastDownloadSending
final public void setLastDownloadSending(long lastDownloadSending)(Code)



setLastUploadReceiving
final public void setLastUploadReceiving(long lastUploadReceiving)(Code)



setMasks
public void setMasks(HostMaskCollection masks)(Code)



setOffline
public void setOffline(String reason)(Code)



setOffline
public void setOffline(Throwable t)(Code)



setProperties
public void setProperties(Properties keysAndValues)(Code)
Needed in order for this class to be a Bean



setProperty
public void setProperty(String name, String value)(Code)



setRenameQueue
public void setRenameQueue(LinkedList<QueuedOperation> renameQueue)(Code)



shutdown
public void shutdown()(Code)



simpleDelete
public void simpleDelete(String path)(Code)
Deletes files/directories and waits for the response Meant to be used if you don't want to utilize asynchronization



simpleRename
public void simpleRename(String from, String toDirPath, String toName)(Code)
Renames files/directories and waits for the response



toString
public String toString()(Code)



Methods inherited from java.lang.Object
native protected Object clone() throws CloneNotSupportedException(Code)(Java Doc)
public boolean equals(Object obj)(Code)(Java Doc)
protected void finalize() throws Throwable(Code)(Java Doc)
final native public Class getClass()(Code)(Java Doc)
native public int hashCode()(Code)(Java Doc)
final native public void notify()(Code)(Java Doc)
final native public void notifyAll()(Code)(Java Doc)
public String toString()(Code)(Java Doc)
final native public void wait(long timeout) throws InterruptedException(Code)(Java Doc)
final public void wait(long timeout, int nanos) throws InterruptedException(Code)(Java Doc)
final public void wait() throws InterruptedException(Code)(Java Doc)

www.java2java.com | Contact Us
Copyright 2009 - 12 Demo Source and Support. All rights reserved.
All other trademarks are property of their respective owners.