com.ibm.net.rdma.jverbs.endpoints

Class RdmaActiveEndpointGroup<C extends RdmaActiveEndpoint>

java.lang.Object

com.ibm.net.rdma.jverbs.endpoints.RdmaEndpointGroup<C>

com.ibm.net.rdma.jverbs.endpoints.RdmaActiveEndpointGroup<C>

public class RdmaActiveEndpointGroup<C extends RdmaActiveEndpoint>
extends RdmaEndpointGroup<C>

Extends the RdmaEndpointGroup by assigning active CompletionQueue processing units to endpoints. All endpoints within the same group will share one completion queue. The group takes care of processing the completion queue and delivering CompletionQueue events to the appropriate endpoints.

Constructor Summary

Constructors

Constructor and Description
RdmaActiveEndpointGroup(RdmaEndpointFactory<C> factory) Creates an instance of RdmaActiveEndpointGroup for a given custom RdmaEndpointFactory.
RdmaActiveEndpointGroup(RdmaEndpointFactory<C> factory, int timeout) Creates an instance of RdmaActiveEndpointGroup for a given custom RdmaEndpointFactory with timeout.

Method Summary

Modifier and Type	Method and Description
void	close() Close the active endpoint group and associated CQ processor thread

Methods inherited from class com.ibm.net.rdma.jverbs.endpoints.RdmaEndpointGroup

createEndpoint, createServerEndpoint, isClosed

Methods inherited from class java.lang.Object

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

Constructor Detail

RdmaActiveEndpointGroup

public RdmaActiveEndpointGroup(RdmaEndpointFactory<C> factory)
                        throws java.io.IOException

Creates an instance of RdmaActiveEndpointGroup for a given custom RdmaEndpointFactory. Timeout for blocking event processing calls getConnectionEvent() and getCompletionEvent() will be assumed 2 secs.

Parameters:

factory -

Throws:

java.io.IOException - If an I/O error occurs

RdmaActiveEndpointGroup

public RdmaActiveEndpointGroup(RdmaEndpointFactory<C> factory,
                               int timeout)
                        throws java.io.IOException

Creates an instance of RdmaActiveEndpointGroup for a given custom RdmaEndpointFactory with timeout. Timeout in milliseconds specifies time period the event processing blocking calls getConnectionEvent() and getCompletionEvent() wait for event, timeout less than 2 secs will default to 2 secs.

Parameters:

factory -

timeout -

Throws:

java.io.IOException - If an I/O error occurs

Method Detail

close

public void close()
           throws java.io.IOException

Close the active endpoint group and associated CQ processor thread

Overrides:

close in class RdmaEndpointGroup<C extends RdmaActiveEndpoint>

Throws:

java.io.IOException - If an I/O error occurs