---

CTBsystem.cxx

Go to the documentation of this file.

/*----------------------------------------------------------------------------*/
/* C Tool Box: Designed and implemented by:                                   */
/*    Walter F.J. Mueller   Gesellschaft fuer Schwerionenforschung (GSI)      */
/*                          Planckstrasse 1, D-64291 Darmstadt, Germany       */
/*                  Email:  W.F.J.Mueller@gsi.de                              */
/*                  WWW:    http://www-kp3.gsi.de/www/kp3/people/mueller.html */
/*------------------------------------------+---------------------------------*/

#include    <sys/time.h>
#include    <sys/timeb.h>
#include    <sys/types.h>
#include    <stdlib.h>
#include    <stdio.h>
#include    <time.h>
#include    <pwd.h>
#include    <unistd.h>

#include    "CTB.hxx"
#include    "CTBcstringBase.hxx"
#include    "CTBcstring.hxx"
// #include    "CTBexception.hxx"  // needed only for VMS mode ... //

#include    "CTBsystem.hxx"

// todo: is __GNUC__ here the correct flag. Probably not, __Linux__ ???
#if defined(_AIX) | defined(__GNUC__)
#define true_clk_tck CLOCKS_PER_SEC
#else
#define true_clk_tck CLK_TCK
#endif

#if defined(__VMS) & !defined(CTB__GenericCode)
#pragma message disable DOLLARID
#include    <starlet.h>
#include    <lib$routines.h>
#include    <jpidef.h>
#endif

//------------------------------------------+-----------------------------------

#if defined(__VMS) && !defined(CTB__GenericCode)
double CTBsystem::CpuTime()
{
  int           i_rc;
  CTBint32      i_item_code = JPI$_CPUTIM;
  CTBuint32     i_cputicks;

  i_rc = lib$getjpi(&i_item_code,0,0,&i_cputicks,0,0);
  if (!(i_rc & 0x1)) throw CTBexception();
  return 1.e-2 * (double) i_cputicks;
}

#else
double CTBsystem::CpuTime()
{
  return (double) clock() / (double) true_clk_tck;
}

#endif

//------------------------------------------+-----------------------------------

#if defined(__VMS) && !defined(CTB__GenericCode)
double CTBsystem::ElapsedTime()
{
  int           i_rc;
  CTBuint32     i_vmstime[2];

  i_rc = sys$gettim(&i_vmstime);
  if (!(i_rc & 0x1)) throw CTBexception();
  return 1.e-7 * ((double) i_vmstime[0] + 4294967296. * (double) i_vmstime[1]);
}

#else

double CTBsystem::ElapsedTime()
{
  struct timeb  s_time;

  ftime(&s_time);
  return (double) s_time.time + 1.e-3 * (double) s_time.millitm;
}
#endif


//------------------------------------------+-----------------------------------

int CTBsystem::SelectRead(int i_fd, float f_timeout)
{
  struct timeval   timeout;
  struct timeval*  p_timeout = 0;

  fd_set           fdset;

  if (i_fd < 0) return -1;                  // return error on invalid FD

  if (f_timeout >= 0.) {
    timeout.tv_sec  = (int) f_timeout;
    timeout.tv_usec = (int) (1000000. * (f_timeout - (float) timeout.tv_sec));
    p_timeout = &timeout;
  }

  FD_ZERO(&fdset);
  FD_SET(i_fd,&fdset);

  return select(i_fd+1,&fdset,0,0,p_timeout);
}

//------------------------------------------+-----------------------------------

int CTBsystem::SelectWrite(int i_fd, float f_timeout)
{
  struct timeval   timeout;
  struct timeval*  p_timeout = 0;

  fd_set           fdset;

  if (i_fd < 0) return -1;                  // return error on invalid FD

  if (f_timeout >= 0.) {
    timeout.tv_sec  = (int) f_timeout;
    timeout.tv_usec = (int) (1000000. * (f_timeout - (float) timeout.tv_sec));
    p_timeout = &timeout;
  }

  FD_ZERO(&fdset);
  FD_SET(i_fd,&fdset);

  return select(i_fd+1,0,&fdset,0,p_timeout);
}

//------------------------------------------+-----------------------------------

void CTBsystem::Sleep(float f_time)
{
  float         f_trest = f_time;
  unsigned long i_utime;
  
  if (f_time <= 0.) return;
  while (f_trest > 0.) {
    if (f_trest > 1800.) {
      i_utime  = 1800 * 1000000;
      f_trest -= 1800.;
    } else {
      i_utime  = (unsigned long) (1000000. * f_trest);
      f_trest  = 0.;
    }
    usleep(i_utime);
  }
  return;
}

//------------------------------------------+-----------------------------------

void CTBsystem::ExpandFilename(char* c_dst, int i_size, const char* c_src)
{
  CTBcstring<FILENAME_MAX>  c_field;
  CTBcstring<FILENAME_MAX>  c_output;
  int i_nfield = CTBcstringBase::NField(c_src,-1,"/");

  for (int i = 0; i < i_nfield; i++) {      // loop over fields
    if (i != 0) c_output += "/";            // reinsert delimiter
    c_field.CopyField(c_src,i,"/");         // extract a field

    if (i == 0 && c_field[0] == '~') {      // is first fields starting with ~

#if !defined(__VMS) || (__CRTL_VER >= 70000000)
      struct passwd* p_pwd = 0;
      if (c_field.Length() == 1) {          // is just ~
        char* c_user = getenv("USER");      // get current user name
        if (c_user != 0) p_pwd = getpwnam(c_user);
      } else {
        p_pwd = getpwnam(&c_field[1]);      // get home directory of ~user
      }
      c_output += (p_pwd != 0) ? p_pwd->pw_dir : (char *) c_field;
#else
      c_output += c_field;
#endif
      
    } else if (c_field[0] == '$') {         // field starts with $
      char* c_value = getenv(&c_field[1]);
      c_output += (c_value != 0) ? c_value : (char*) c_field;

    } else {                                // otherwise, just a `normal' field
      c_output += c_field;
    }
  }

  CTBcstringBase::Copy(c_dst,i_size,c_output);

  return;
}
// Notes:
//  this implemention currently only substitues cases like ../$envvar/...
//  while any other case like   ../bla$envvar/.... or .../$foo$bar/ are not
//  handled like a shell would do it. This is mainly done to avoid problems
//  on VMS systems (but also for ease of implementation....).

---