Public Member Functions | |
| QueueInputPipeInterface | inputPipe (Queue queue, AgentAddress address, Integer maxNbrConnections) throws IOException |
| create an input pipe with the following arguments | |
| QueueInputPipeInterface | inputPipe (Queue queue, AgentAddress address) throws IOException |
| create an input pipe with the following arguments | |
| QueueOutputPipeInterface | outputPipe (AgentAddress address) throws UnknownHostException, IOException |
| QueueOutputPipeInterface | outputPipe (AgentAddress address, AgentAddress rawDataAddress) throws UnknownHostException, IOException |
| create an output pipe with the following arguments | |
| AgentAddress | getSelfAddress (int idx) |
Detailed Description
Member Function Documentation
◆ getSelfAddress()
| AgentAddress frodo2.communication.PipeFactory.getSelfAddress | ( | int | idx | ) |
- Parameters
-
idx can be port (tcp), rank (mpi), ...
- Returns
- an address to yourself depending on an int parameter
Implemented in frodo2.communication.tcp.TCPPipeFactory.
Referenced by frodo2.daemon.TestLocalWhitePages.SimpleAgent.agentReportGlobal(), frodo2.algorithms.test.AllTests.createQueueNetwork(), frodo2.controller.TestController.DaemonExtension.DaemonExtension(), frodo2.daemon.Daemon.init(), frodo2.controller.TestWhitePages.setUp(), frodo2.algorithms.SingleQueueAgent< Val extends Addable< Val > >.setup(), frodo2.daemon.TestLocalWhitePages.testAgentAddress(), frodo2.controller.TestWhitePages.testAgentReporting(), frodo2.controller.TestWhitePages.testDaemonReporting(), frodo2.controller.TestWhitePages.testKillAllAgents(), and frodo2.daemon.TestLocalWhitePages.testLocalAgentAddressRequestUnknown().
◆ inputPipe() [1/2]
| QueueInputPipeInterface frodo2.communication.PipeFactory.inputPipe | ( | Queue | queue, |
| AgentAddress | address ) throws IOException |
create an input pipe with the following arguments
- Parameters
-
queue (self-explanatory) address (self-explanatory)
- Returns
- a pipe
- Exceptions
-
IOException (self-explanatory)
Implemented in frodo2.communication.tcp.TCPPipeFactory.
◆ inputPipe() [2/2]
| QueueInputPipeInterface frodo2.communication.PipeFactory.inputPipe | ( | Queue | queue, |
| AgentAddress | address, | ||
| Integer | maxNbrConnections ) throws IOException |
create an input pipe with the following arguments
- Parameters
-
queue (self-explanatory) address (self-explanatory) maxNbrConnections (self-explanatory)
- Returns
- a pipe
- Exceptions
-
IOException (self-explanatory)
Implemented in frodo2.communication.tcp.TCPPipeFactory.
Referenced by frodo2.algorithms.test.AllTests.createQueueNetwork(), frodo2.daemon.Daemon.init(), frodo2.controller.TestConfigurationManager.setUp(), frodo2.controller.TestWhitePages.setUp(), frodo2.algorithms.SingleQueueAgent< Val extends Addable< Val > >.setup(), frodo2.daemon.TestLocalWhitePages.testAgentAddress(), frodo2.controller.TestWhitePages.testDaemonReporting(), and frodo2.daemon.TestLocalWhitePages.testLocalAgentAddressRequestUnknown().
◆ outputPipe() [1/2]
| QueueOutputPipeInterface frodo2.communication.PipeFactory.outputPipe | ( | AgentAddress | address | ) | throws UnknownHostException, IOException |
- Parameters
-
address (self-explanatory)
- Returns
- a pipe
- Exceptions
-
UnknownHostException (self-explanatory) IOException (self-explanatory)
Implemented in frodo2.communication.tcp.TCPPipeFactory.
Referenced by frodo2.algorithms.test.AllTests.createQueueNetwork(), and frodo2.daemon.userIO.UserIO.registerController().
◆ outputPipe() [2/2]
| QueueOutputPipeInterface frodo2.communication.PipeFactory.outputPipe | ( | AgentAddress | address, |
| AgentAddress | rawDataAddress ) throws UnknownHostException, IOException |
create an output pipe with the following arguments
- Parameters
-
address (self-explanatory) rawDataAddress (self-explanatory)
- Returns
- a pipe
- Exceptions
-
UnknownHostException (self-explanatory) IOException (self-explanatory)
Implemented in frodo2.communication.tcp.TCPPipeFactory.
The documentation for this interface was generated from the following file:
- src/frodo2/communication/PipeFactory.java
