/*
 * echo_server      : demo DCE RPC application
 *
 * Jim Doyle, jrd@bu.edu  09-05-1998
 *
 *
 */
#if HAVE_CONFIG_H
#include <config.h>
#endif

#ifndef _POSIX_PTHREAD_SEMANTICS
#define _POSIX_PTHREAD_SEMANTICS 1
#endif

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <signal.h>
#include <ctype.h>
#include <dce/rpc.h>
#define DCETHREAD_CHECKED
#define DCETHREAD_USE_THROW
#include <dce/dcethread.h>
#include "echou.h"
#include "misc.h"

static void wait_for_signals(void);

/*
 *
 * A template DCE RPC server
 *
 * main() contains the basic calls needed to register an interface,
 * get communications endpoints, and register the endpoints
 * with the endpoint mapper.
 *
 * ReverseIt() implements the interface specified in echo.idl
 *
 */


int main(int ac ATTRIBUTE_UNUSED, char *av[] ATTRIBUTE_UNUSED)
{
  unsigned32 status;
  rpc_binding_vector_p_t     server_binding;
  char * string_binding;
  unsigned32 i;

  /*
   * Register the Interface with the local endpoint mapper (rpcd)
   */

  printf ("Registering server.... \n");
  rpc_server_register_if(echou_v1_0_s_ifspec,
			 NULL,
			 NULL,
			 &status);
      chk_dce_err(status, "rpc_server_register_if()", "", 1);

      printf("registered.\nPreparing binding handle...\n");

      rpc_server_use_protseq((unsigned_char_p_t)"ncacn_ip_tcp",
	      rpc_c_protseq_max_calls_default, &status);

      chk_dce_err(status, "rpc_server_use_all_protseqs()", "", 1);
      rpc_server_inq_bindings(&server_binding, &status);
      chk_dce_err(status, "rpc_server_inq_bindings()", "", 1);

      /*
       * Register bindings with the endpoint mapper
       */

	printf("registering bindings with endpoint mapper\n");

  rpc_ep_register(echou_v1_0_s_ifspec,
		  server_binding,
		  NULL,
		  (unsigned char *)"QDA application server",
		  &status);
      chk_dce_err(status, "rpc_ep_register()", "", 1);

	printf("registered.\n");

      /*
       * Print out the servers endpoints (TCP and UDP port numbers)
       */

  printf ("Server's communications endpoints are:\n");

  for (i=0; i<server_binding->count; i++)
    {
      rpc_binding_to_string_binding(server_binding->binding_h[i],
				    (unsigned char **)&string_binding,
				    &status
				    );
      if (string_binding)
		printf("\t%s\n",string_binding);
    }


  /*
   * Start the signal waiting thread in background. This thread will
   * Catch SIGINT and gracefully shutdown the server.
   */

  wait_for_signals();

  /*
   * Begin listening for calls
   */

  printf ("listening for calls.... \n");

  DCETHREAD_TRY
    {
      rpc_server_listen(rpc_c_listen_max_calls_default, &status);
    }
  DCETHREAD_CATCH_ALL(THIS_CATCH)
    {
      printf ("Server stoppped listening\n");
    }
  DCETHREAD_ENDTRY

    /*
     * If we reached this point, then the server was stopped, most likely
     * by the signal handler thread called rpc_mgmt_stop_server().
     * gracefully cleanup and unregister the bindings from the
     * endpoint mapper.
     */

    /*
     * Kill the signal handling thread
     */

  printf ("Unregistering server from the endpoint mapper.... \n");
  rpc_ep_unregister(echou_v1_0_s_ifspec,
		    server_binding,
		    NULL,
		    &status);
  chk_dce_err(status, "rpc_ep_unregister()", "", 0);

  /*
   * retire the binding information
   */

  printf("Cleaning up communications endpoints... \n");
  rpc_server_unregister_if(echou_v1_0_s_ifspec,
			   NULL,
			   &status);
  chk_dce_err(status, "rpc_server_unregister_if()", "", 0);

  exit(0);

}


/*=========================================================================
 *
 * Server implementation of ReverseIt()
 *
 *=========================================================================*/

idl_boolean
ReplyBack(h, in_type, in_value, out_value, status)
     rpc_binding_handle_t h;
     idl_long_int in_type;
     EchoUnion *in_value;
     EchoUnion **out_value;
     error_status_t * status;
{

  char * binding_info;
  error_status_t e;
  *out_value = (EchoUnion*) rpc_ss_allocate(sizeof(EchoUnion));

  /*
   * Get some info about the client binding
   */

  rpc_binding_to_string_binding(h, (unsigned char **)&binding_info, &e);
  if (e == rpc_s_ok)
    {
      printf ("ReplyBack() called by client: %s\n", binding_info);
    }

  printf("\n\nFunction ReplyBack() -- input argments\n");

  if (in_value == NULL)
  {
      printf("in_value = [null]\n");
      *out_value = NULL;
  }
  else if (in_type == 1)
  {
      printf("in_value = [int] %li\n", (long int) in_value->integer);
      (*out_value)->integer = -in_value->integer;
  }
  else if (in_type == 2)
  {
      printf("in_value = [float] %f\n", (double) in_value->fp);
      (*out_value)->fp = -in_value->fp;
  }
  else if (in_type == 3)
  {
      int i, len;
      printf("in_value = [string] %s\n", (char*) in_value->str);
      len = strlen((const char *)in_value->str);
      (*out_value)->str = rpc_ss_allocate(sizeof(*in_value->str) * (len+1));

      for (i = 0; i < len; i++)
      {
          (*out_value)->str[i] = in_value->str[len-1-i];
      }

      (*out_value)->str[len] = 0;
  }

  printf ("\n=========================================\n");

  //*out_value = NULL;
  *status = error_status_ok;

  return 1;
}


/*=========================================================================
 *
 * wait_for_signals()
 *
 *
 * Set up the process environment to properly deal with signals.
 * By default, we isolate all threads from receiving asynchronous
 * signals. We create a thread that handles all async signals.
 * The signal handling actions are handled in the handler thread.
 *
 * For AIX, we cant use a thread that sigwaits() on a specific signal,
 * we use a plain old, lame old Unix signal handler.
 *
 *=========================================================================*/


void
wait_for_signals(void)
{
    sigset_t signals;

    sigemptyset(&signals);
    sigaddset(&signals, SIGINT);

    dcethread_signal_to_interrupt(&signals, dcethread_self());
}