/****************************************************************************/
/* Copyright (c) 2000 MBARI                                                 */
/* MBARI Proprietary Information. All rights reserved.                      */
/****************************************************************************/
/* Summary  :                                                               */
/* Filename : SharedObjectClient.cc                                         */
/* Author   : Tom O'Reilly                                                  */
/* Project  :                                                               */
/* Version  : 1.0                                                           */
/* Created  : 02/07/2000                                                    */
/* Modified :                                                               */
/* Archived :                                                               */
/****************************************************************************/
/* Modification History:                                                    */
/****************************************************************************/
#include <stdio.h>
#include <string.h>
#include <malloc.h>
#include <errno.h>
#include <sys/name.h>
#include <sys/time.h>
#include <sys/kernel.h>
#include <sys/proxy.h>
#include "SharedObjectClient.h"
#include "Syslog.h"


SharedObjectClient::SharedObjectClient(const char *name, 
				       const char *serverName,
				       int serverConnectTimeout)
  : SharedObject(name)
{
  _serverName = strdup(serverName);
  _serverPid = NoPid;
  _connected = False;

  if (serverConnectTimeout == DoNotConnect) {
    _serverConnectTimeout = 10;
    return;
  }

  _serverConnectTimeout = serverConnectTimeout;
  bind(serverConnectTimeout);
}


SharedObjectClient::SharedObjectClient(const char *name) 
  : SharedObject(name)
{
  _serverName = 0;
  _serverPid = NoPid;
  _connected = False;
  _serverConnectTimeout = 10;
}


SharedObjectClient::~SharedObjectClient()
{
  free((void *)_serverName);
}


void SharedObjectClient::setConnectTimeout(int timeout)
{
  _serverConnectTimeout = timeout;
}


void SharedObjectClient::bind(int serverConnectTimeout)
{
  findServer(serverConnectTimeout);
}


void SharedObjectClient::bind(const char *serverName, 
			      int serverConnectTimeout)
{
  setServerName(serverName);
  findServer(serverConnectTimeout);
}


void SharedObjectClient::setServerName(const char *name)
{
  free((void *)_serverName);
  _serverName = strdup(name);
}


void SharedObjectClient::findServer(int timeoutSecs)
{
  Boolean debug = False;

  int timeOutMillisecs = timeoutSecs * 1000;
  struct timespec sleepTime;

  const int sleepMillisecs = 1000;

  sleepTime.tv_sec = 0;
  sleepTime.tv_nsec = sleepMillisecs * 1000000;
  int elapsed = 0;

  // Try until timed out
  while (elapsed < timeOutMillisecs) {
    // Try to locate server by name
    dprintf("SharedObjectClient::findServer() - look for %s", _serverName);
    if ((_serverPid = qnx_name_locate(0, _serverName, 0, 0)) != -1) {
      // Found it!
      dprintf("SharedObjectClient::findServer() - found it, pid %d", 
	      _serverPid);

      _connected = True;
      return;
    }

    // Wait a bit, then try again
    nanosleep(&sleepTime, 0);
    elapsed += sleepMillisecs;
  }

  // Couldn't find server
  throw MissingServer(_serverName);
}



void SharedObjectClient::send(Request *request, int nRequestBytes, 
			      Reply *reply, int nReplyBytes)
{
  Boolean debug = False;

  if (!connected()) {
    // Not connected to server; try to find it
    findServer(_serverConnectTimeout);
  }

  dprintf("SharedObjectClient::send()- server=%d, requestBytes=%d, "
	  "replyBytes=%d\n", _serverPid, nRequestBytes, nReplyBytes);

  if (Send(_serverPid, (void *)request, (void *)reply, 
	   nRequestBytes, nReplyBytes) == -1) {

    if (errno == ESRCH) {
      // Server pid no longer there
      _connected = False;
      throw MissingServer(_serverName);
    }
    char errorBuf[256];

    dprintf("SharedObjectClient::send() - errno=%d\n", errno);

    sprintf(errorBuf, "SharedObjectClient::send() failed - %s", 
	    strerror(errno));

    dprintf("%s\n", errorBuf);

    throw Error(errorBuf);
  }
  dprintf("SharedObjectClient::send()- done\n");

}