Examples of net.jini.jeri.ServerEndpoint.enumerateListenEndpoints()

net.jini.jeri.ServerEndpoint.enumerateListenEndpoints()
Enumerates the communication endpoints represented by this ServerEndpoint by passing the ListenEndpoint for each of them to listenContext, which will ensure an active listen operation on each endpoint, and returns an Endpoint instance corresponding to the listen operations chosen by listenContext.
This method uses listenContext to cooperate with the caller to ensure the appropriate listen operations. In this cooperation,
- the ServerEndpoint is responsible for declaring to the caller the discrete communication endpoints represented by this ServerEndpoint as ListenEndpoint instances passed to listenContext's {@link ListenContext#addListenEndpoint addListenEndpoint} method, and
- the caller is responsible for declaring the active listen operations to be used for this ServerEndpoint.enumerateListenEndpoints invocation corresponding to each discrete communication endpoint as {@link ListenCookie ListenCookie} instances returned fromlistenContext's addListenEndpoint method.
For each ListenEndpoint, the caller (through listenContext) may choose to start a new listen operation, or it may choose to reuse a previously started listen operation that it has a ListenCookie for.
This method sequentially invokes addListenEndpoint on listenContext once for each discrete communication endpoint represented by this ServerEndpoint, passing the ListenEndpoint representing that communication endpoint. If any of the invocations of ListenContext.addListenEndpoint throws an exception, this method throws that exception. Otherwise, this method returns an Endpoint instance that sends requests to be received by the listen operations chosen by listenContext. @param listenContext the ListenContext to passthis ServerEndpoint's ListenEndpoint instances to @return the Endpoint instance for sending requeststo this ServerEndpoint's communication endpoints being listened on @throws IOException if an I/O exception occurs while attemptingto listen for requests on the communication endpoints represented by this ServerEndpoint. This could occur, for example, if an I/O resource associated with one of the communication endpoints is already in exclusive use, or if there are insufficient I/O resources for the operation. @throws SecurityException if the current security context doesnot have the permissions necessary to listen for requests on one of the communication endpoints represented by this ServerEndpoint @throws IllegalArgumentException if an invocation of theaddListenEndpoint method on the supplied ListenContext returns a ListenCookie that does not correspond to the ListenEndpoint that was passed to it @throws NullPointerException if listenContext isnull

   */
  public Object run() throws IOException {
      ServerEndpoint serverEndpoint =
    createServerEndpoint(serverSubject, null, "localhost", 0,
             null, getServerSocketFactory());
      endpoint = serverEndpoint.enumerateListenEndpoints(
    new ListenContext() {
        public ListenCookie addListenEndpoint(
      ListenEndpoint listenEndpoint)
      throws IOException
        {

View Full Code Here

      throw new IOException();
        }
    }
    LC lc = new LC();
    try {
        serverEndpoint.enumerateListenEndpoints(lc);
    } catch (IOException e) {
    }
    return lc.listenEndpoint;
      }

View Full Code Here

  }
    }


    public static void main(String[] args) throws Exception {
  ServerEndpoint sep = TcpServerEndpoint.getInstance(0);
  Endpoint ep = sep.enumerateListenEndpoints(new ListenContext() {
      public ListenCookie addListenEndpoint(ListenEndpoint lep)
    throws IOException
      {
    return lep.listen(new Dispatcher()).getCookie();
      }

View Full Code Here

      getServerEndpoint(new PrearrangedServerSocketFactory(socket));
  ServerConnManagerImpl mgr = new ServerConnManagerImpl();
  endpointInternals.setServerConnManager(ep, mgr);


  ListenContextImpl lc = new ListenContextImpl();
  ep.enumerateListenEndpoints(lc);
  ServerConnection conn = mgr.getServerConnection();
  try {
      InputStream in = new BufferedInputStream(conn.getInputStream());
      OutputStream out = new BufferedOutputStream(conn.getOutputStream());
      InboundRequestHandle handle = conn.processRequestData(in, out);

View Full Code Here

    return le.listen(new RequestDispatcher() {
        public void dispatch(InboundRequest r) { }
    }).getCookie();
      }
  };
  se.enumerateListenEndpoints(lc);


  synchronized (ssf) {
      long now, deadline = 0;
      while (!ssf.serverSocketClosed) {
    now = System.currentTimeMillis();

View Full Code Here

        method);
      }
  }


  Endpoint endpoint =
      serverEndpoint.enumerateListenEndpoints(new ListenContext() {
    public ListenCookie addListenEndpoint(ListenEndpoint le)
        throws IOException
    {
        return le.listen(new RD()).getCookie();
    }

View Full Code Here

   * UnknownHostException that does contain the local host name
   * in its detail message.
   */
  System.err.println("Trying with permission:");
  try {
      se.enumerateListenEndpoints(lc);
      throw new RuntimeException("TEST FAILED");
  } catch (UnknownHostException e) {
      e.printStackTrace();
      String message = e.getMessage();
      if (message == null || message.indexOf(localName) == -1) {

View Full Code Here

  AccessControlContext acc = new AccessControlContext(
      new ProtectionDomain[] { new ProtectionDomain(null, null) });
  try {
      AccessController.doPrivileged(new PrivilegedExceptionAction() {
    public Object run() throws IOException {
        se.enumerateListenEndpoints(lc);
        throw new RuntimeException("TEST FAILED");
    }
      }, acc);
  } catch (PrivilegedActionException pae) {
      IOException e = (IOException) pae.getCause();

View Full Code Here

    public void run() throws Exception {
        //Obtain a serverEndpoint instance
        ServerEndpoint se = getServerEndpoint();
        IllegalArgumentContext context = new IllegalArgumentContext(null);
        //Call enumerateListenEndpoints and extract cookies
        se.enumerateListenEndpoints(context);
        ArrayList cookies = context.getCookies();
        //Obtain a different server endpoint
        se = (ServerEndpoint) getConfigObject(ServerEndpoint.class,
            "diffEndpoint");
        boolean exceptionThrown = false;

View Full Code Here

        //Obtain a different server endpoint
        se = (ServerEndpoint) getConfigObject(ServerEndpoint.class,
            "diffEndpoint");
        boolean exceptionThrown = false;
        try {
            se.enumerateListenEndpoints(
                new IllegalArgumentContext(cookies));
        } catch (IllegalArgumentException e) {
            exceptionThrown = true;
        }
        if (!exceptionThrown) {

View Full Code Here

0 1 2

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.