Package org.vast.process

Interface IDataConnection

All Known Implementing Classes:
DataConnection, DataQueue
public interface IDataConnection

  • Method Details

    • setSource

      void setSource(IProcessExec process, DataComponent component)

    • getSourceProcess

      IProcessExec getSourceProcess()

    • getSourcePort

      DataComponent getSourcePort()

    • getSourceComponent

      DataComponent getSourceComponent()

    • setDestination

      void setDestination(IProcessExec process, DataComponent component)

    • getDestinationProcess

      IProcessExec getDestinationProcess()

    • getDestinationPort

      DataComponent getDestinationPort()

    • getDestinationComponent

      DataComponent getDestinationComponent()

    • transferData

      boolean transferData(boolean block) throws InterruptedException
      Transfer data to destination component
      Parameters:
      block - Set to true if processing should wait until data is available on this connection, false if processing should continue without it
      Returns:
      True if data was actually transferred, false otherwise
      Throws:
      InterruptedException - if interrupted while waiting

    • publishData

      void publishData() throws InterruptedException
      Publish data from source component on this connection
      Throws:
      InterruptedException - if interrupted while waiting

    • isDataAvailable

      boolean isDataAvailable()
      Returns:
      true if data is available (i.e. ready to be transfered) on this connection

    • clear

      void clear()
      Clear all remaining data on this connection