#include stdio
#include stdlib
#include descrip

#include port
#include server_rpc
#include thread
#include "rpc_app.h"

#define MAX_ERRORS	100

static void sum (
  void *app_data,
  int *a,
  int *b,
  int *sum
) {

  *sum = *a + *b;

}

static void diff (
  void *app_data,
  int *a,
  int *b,
  int *diff
) {

  *diff = *a - *b;

}

static void mult (
  void *app_data,
  int *a,
  int *b,
  int *mult
) {

  *mult = *a * *b;

}

static int rpc_thread (
  THREAD_HANDLE thread_h
) {

RPC_PORT data_port;
RPC_BUF buf;
float sec = 2.0;
int ret_stat, stat;

  ret_stat = 1;

  data_port = (RPC_PORT) thread_get_app_data( thread_h );
  if ( !data_port ) {
    ret_stat = RPC_BADPARAM;
    goto err_return;
  }

  stat = server_rpc_create_buffer( MAX_FUNCS, data_port, NULL, &buf );
  if ( ! ( stat & 1 ) ) {
    ret_stat = stat;
    goto err_return;
  }

  stat = server_rpc_register_function( buf, sum, SUM );
  if ( ! ( stat & 1 ) ) {
    ret_stat = stat;
    goto err_return;
  }

  stat = server_rpc_register_function( buf, diff, DIFF );
  if ( ! ( stat & 1 ) ) {
    ret_stat = stat;
    goto err_return;
  }

  stat = server_rpc_register_function( buf, mult, MULT );
  if ( ! ( stat & 1 ) ) {
    ret_stat = stat;
    goto err_return;
  }

  stat = server_rpc_dispatch_requests( buf );
  if ( ! ( stat & 1 ) ) {
    ret_stat = stat;
  }

  sys_wait_seconds( &sec );

  stat = server_rpc_destroy_buffer( buf );
  if ( ! ( stat & 1 ) ) {
    ret_stat = stat;
  }

  stat = nsv_disconnect( data_port );
  if ( ! ( stat & 1 ) ) {
    ret_stat = stat;
  }

  stat = nsv_delete_port( &data_port );
  if ( ! ( stat & 1 ) ) {
    ret_stat = stat;
  }

  stat = thread_destroy_handle( thread_h );
  if ( ! ( stat & 1 ) ) {
    ret_stat = stat;
  }

  if ( ! ( ret_stat & 1 ) ) goto err_return;

norm_ret:
  THREAD_SUCCESS( 1 )

err_return:
  THREAD_ERROR( ret_stat )

}

main (
  int argc,
  int **argv
) {

RPC_PORT connect_port, data_port;
THREAD_HANDLE thread_h;
int stat, num_errors;
char optional_data[16+1];

  stat = nsv_create_named_port( "TEST", 1, 128, "my connect port",
   &connect_port );
  if ( ! ( stat & 1 ) ) {
    exit( stat );
  }

  num_errors = 0;

  do {

    stat = nsv_create_port( 10, 512, "my data port", &data_port );
    if ( ! ( stat & 1 ) ) {
      goto err_label;
    }

    stat = nsv_accept_connection( connect_port, data_port, optional_data );
    if ( ! ( stat & 1 ) ) {
      goto err_label;
    }

    if ( optional_data[0] )
      printf( "connect data = [%s]\n", optional_data );
    else
      printf( "no connect data\n" );

    stat = thread_create_handle( &thread_h, (void *) data_port );
    if ( ! ( stat & 1 ) ) {
      goto err_label;
    }

    thread_create_proc( thread_h, rpc_thread );
    if ( ! ( stat & 1 ) ) {
      goto err_label;
    }

/*
    rpc_thread( thread_h );
    stat = 1;
*/


err_label:
    if ( ! ( stat & 1 ) ) {
      /* log error message */
      printf( "stat = %d\n", stat );
      num_errors++;
    }

  } while ( num_errors < MAX_ERRORS );

  stat = nsv_delete_port( &connect_port );
  if ( ! ( stat & 1 ) ) {
    printf( "stat = %d\n", stat );
  }

}