void org.libcsdbg.jtracer.MainFrame.run

(

)

Server thread implementation.

Definition at line 239 of file MainFrame.java.

References org.libcsdbg.jtracer.Registry.get(), org.libcsdbg.jtracer.MainFrame.listener, org.libcsdbg.jtracer.MainFrame.server, and org.libcsdbg.jtracer.MainFrame.shutdown().

  {
    try {
      Registry conf = Registry.getCurrent();
      Enumeration keys = conf.getSectionKeys("server");
      if (keys == null)
        throw new Exception("No server configuration found");

      /* Create the listener socket unbound */
      listener = new ServerSocket();
      listener.setReuseAddress(true);

      /* Bind to one or more interfaces */
      InetSocketAddress iface = null;
      while (keys.hasMoreElements()) {
        String key = (String) keys.nextElement();

        iface = (InetSocketAddress) conf.get("server", key);
        listener.bind(iface);

        InetAddress addr = iface.getAddress();
        String msg = "Accepting connections @";
        msg += addr.getHostAddress() + ":" + iface.getPort();

        if (addr.isAnyLocalAddress())
          msg += " (all local)";
        
        else if (addr.isMulticastAddress())
          msg += " (multicast)";
        
        else
          msg += " (" + addr.getCanonicalHostName() + ")";

        log.appendln(msg, "status");
      }

      if (iface == null || !listener.isBound())
        throw new Exception("No server configuration found");

      firePropertyChange("isServing", null, true);
      status.startUptimeTimer();

      /* Listen for incoming connections */
      while (server == Thread.currentThread()) {
        status.setMessage("Waiting for connections", true);

        try {
          Socket peer = listener.accept();

          String addr = peer.getInetAddress().getHostAddress();
          int port = peer.getPort();
          log.appendln("Connected peer @" + addr + ":" + port, "status");

          desktop.register(peer);
        }

        catch (Throwable t) {
          log.appendln(t.toString(), "alert");
          if (!(t instanceof IOException))
            Registry.debug(t);
        }
      }
      
      status.stopUptimeTimer();
      status.setMessage("Service complete", true);
      firePropertyChange("isServing", null, false);
    }

    catch (Throwable t) {
      Registry.debug(t);
      getToolkit().beep();
      shutdown();

      log.appendln("Failed to start server (" + t.toString() + ")", "error");
      status.setMessage("Server failed", false);
    }
  }

Here is the call graph for this function: