// ============================================================================
//
// = PACKAGE
//    tests.Connection
// 
// = FILENAME
//    ServerHandler.java
//
// = AUTHOR
//    Prashant Jain
// 
// ============================================================================
package tests.Connection;

import java.io.*;
import java.net.*;
import JACE.OS.*;
import JACE.Connection.*;

public class ServerHandler extends SvcHandler
{
  public ServerHandler ()
    {
    }
  
  public int open (Object obj)
  {
    new Thread (this).start ();
    return 0;
  }

  public void run ()
    {
      int msg_len;
      System.out.println ("Waiting for messages...");
      try
	{
	  while (true)
	    {
	      StringBuffer msg = new StringBuffer ();
	      msg_len = this.peer ().recv (msg);
	      if (msg_len == 0)
		break;
	      System.out.println ("Received: " + msg);
	      this.peer ().send (new StringBuffer ("Got it!"));
	    }
	}
      catch (NullPointerException e)
	{
	  ACE.ERROR ("connection reset by peer");
	}
      catch (IOException e)
	{
	  ACE.ERROR (e);
	}
      finally
	{
	  try 
	    {
	      this.peer ().close ();
	    }
	  catch (IOException e)
	    {
	    }
	}
      
    }
}