Package ibis.ipl.impl.multi

Class MultiReceivePort

java.lang.Object

ibis.ipl.impl.multi.MultiReceivePort

All Implemented Interfaces:

ibis.ipl.Manageable, ibis.ipl.ReceivePort

public class MultiReceivePort
extends java.lang.Object
implements ibis.ipl.ReceivePort

Constructor Summary

Constructors

Constructor	Description
MultiReceivePort(ibis.ipl.PortType type, MultiIbis ibis, java.lang.String name, ibis.ipl.MessageUpcall upcall, ibis.ipl.ReceivePortConnectUpcall connectUpcall, java.util.Properties properties)

Method Summary

Modifier and Type	Method	Description
void	close()
void	close(long timeoutMillis)
ibis.ipl.SendPortIdentifier[]	connectedTo()
void	disableConnections()
void	disableMessageUpcalls()
void	enableConnections()
void	enableMessageUpcalls()
java.lang.String	getManagementProperty(java.lang.String key)
ibis.ipl.PortType	getPortType()
ibis.ipl.ReceivePortIdentifier	identifier()
ibis.ipl.SendPortIdentifier[]	lostConnections()
java.util.Map<java.lang.String,java.lang.String>	managementProperties()
java.lang.String	name()
ibis.ipl.SendPortIdentifier[]	newConnections()
ibis.ipl.ReadMessage	poll()
void	printManagementProperties(java.io.PrintStream stream)
ibis.ipl.ReadMessage	receive()
ibis.ipl.ReadMessage	receive(long timeoutMillis)
void	setManagementProperties(java.util.Map<java.lang.String,java.lang.String> properties)
void	setManagementProperty(java.lang.String key, java.lang.String value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MultiReceivePort

public MultiReceivePort(ibis.ipl.PortType type,
                        MultiIbis ibis,
                        java.lang.String name,
                        ibis.ipl.MessageUpcall upcall,
                        ibis.ipl.ReceivePortConnectUpcall connectUpcall,
                        java.util.Properties properties)
                 throws java.io.IOException

Throws:

java.io.IOException

Method Detail

close

public void close()
           throws java.io.IOException

Specified by:

close in interface ibis.ipl.ReceivePort

Throws:

java.io.IOException

close

public void close(long timeoutMillis)
           throws java.io.IOException

Specified by:

close in interface ibis.ipl.ReceivePort

Throws:

java.io.IOException

connectedTo

public ibis.ipl.SendPortIdentifier[] connectedTo()

Specified by:

connectedTo in interface ibis.ipl.ReceivePort

disableConnections

public void disableConnections()

Specified by:

disableConnections in interface ibis.ipl.ReceivePort

disableMessageUpcalls

public void disableMessageUpcalls()

Specified by:

disableMessageUpcalls in interface ibis.ipl.ReceivePort

enableConnections

public void enableConnections()

Specified by:

enableConnections in interface ibis.ipl.ReceivePort

enableMessageUpcalls

public void enableMessageUpcalls()

Specified by:

enableMessageUpcalls in interface ibis.ipl.ReceivePort

getPortType

public ibis.ipl.PortType getPortType()

Specified by:

getPortType in interface ibis.ipl.ReceivePort

identifier

public ibis.ipl.ReceivePortIdentifier identifier()

Specified by:

identifier in interface ibis.ipl.ReceivePort

lostConnections

public ibis.ipl.SendPortIdentifier[] lostConnections()

Specified by:

lostConnections in interface ibis.ipl.ReceivePort

name

public java.lang.String name()

Specified by:

name in interface ibis.ipl.ReceivePort

newConnections

public ibis.ipl.SendPortIdentifier[] newConnections()

Specified by:

newConnections in interface ibis.ipl.ReceivePort

poll

public ibis.ipl.ReadMessage poll()
                          throws java.io.IOException

Specified by:

poll in interface ibis.ipl.ReceivePort

Throws:

java.io.IOException

receive

public ibis.ipl.ReadMessage receive()
                             throws java.io.IOException

Specified by:

receive in interface ibis.ipl.ReceivePort

Throws:

java.io.IOException

receive

public ibis.ipl.ReadMessage receive(long timeoutMillis)
                             throws java.io.IOException

Specified by:

receive in interface ibis.ipl.ReceivePort

Throws:

java.io.IOException

getManagementProperty

public java.lang.String getManagementProperty(java.lang.String key)
                                       throws ibis.ipl.NoSuchPropertyException

Specified by:

getManagementProperty in interface ibis.ipl.Manageable

Throws:

ibis.ipl.NoSuchPropertyException

managementProperties

public java.util.Map<java.lang.String,java.lang.String> managementProperties()

Specified by:

managementProperties in interface ibis.ipl.Manageable

printManagementProperties

public void printManagementProperties(java.io.PrintStream stream)

Specified by:

printManagementProperties in interface ibis.ipl.Manageable

setManagementProperties

public void setManagementProperties(java.util.Map<java.lang.String,java.lang.String> properties)
                             throws ibis.ipl.NoSuchPropertyException

Specified by:

setManagementProperties in interface ibis.ipl.Manageable

Throws:

ibis.ipl.NoSuchPropertyException

setManagementProperty

public void setManagementProperty(java.lang.String key,
                                  java.lang.String value)
                           throws ibis.ipl.NoSuchPropertyException

Specified by:

setManagementProperty in interface ibis.ipl.Manageable

Throws:

ibis.ipl.NoSuchPropertyException