Public Member Functions
	RFProcessManager (char *nodename)

int	Execute (char script, int nargs, char *args)

int	Execute (char scr, char arg0=NULL, char arg1=NULL, char arg2=NULL, char arg3=NULL, char arg4=NULL, char arg5=NULL, char arg6=NULL, char *arg7=NULL)

int	CheckOutput ()

int	GetFd ()

pid_t	CheckProcess ()

Static Public Member Functions
static void	signal_handler (int num)

Private Attributes
int	m_iopipe [2]

std::vector< pid_t >	m_pidlist

Detailed Description

Definition at line 22 of file RFProcessManager.h.

Constructor & Destructor Documentation

◆ RFProcessManager()

RFProcessManager ( char * nodename )

Definition at line 34 of file RFProcessManager.cc.

{
  // Create IO pipe for output logging
  if (pipe2(m_iopipe, O_NONBLOCK) < 0) {
    perror("pipe");
    m_iopipe[0] = -1; m_iopipe[1] = -1;
  }
  FILE* f = fopen("pid.data", "w");
  fprintf(f, "%d", getpid());
  fclose(f);
}

◆ ~RFProcessManager()

~RFProcessManager ( )

virtual

Definition at line 46 of file RFProcessManager.cc.

47{

48}

Member Function Documentation

◆ CheckOutput()

int CheckOutput ( )

Definition at line 147 of file RFProcessManager.cc.

{
  // Setup select parameter
  fd_set fdset;
 
  // Fetch fd
  int nfd;
  for (;;) {
    FD_ZERO(&fdset);
    int highest = 0;
    if (m_iopipe[0] > 0) {
      FD_SET(m_iopipe[0], &fdset);
      highest = m_iopipe[0];
    } else {
      printf("Pipe for log is not availablle\n");
    }
    NSMcontext* nsmc = RFNSM::GetContext();
    if (nsmc) {
      if (nsmc->sock > highest) highest = nsmc->sock;
      FD_SET(nsmc->sock, &fdset);
    } else {
      //printf("No NSM context is available\n");
    }
    // Time out parameter
    struct timeval tv;
    tv.tv_sec = 1;
    tv.tv_usec = 1; // omajinai
 
    if ((nfd = select(highest + 1, &fdset, NULL, NULL, &tv)) < 0) {
      switch (errno) {
        case EINTR: continue; // why? if we get a signal, we can return, too
        case EAGAIN: continue;
        default:
          //close(m_iopipe[0]);
          //m_iopipe[0] = -1;
          return 0;
      }
    } else {
      if (nsmc && FD_ISSET(nsmc->sock, &fdset)) {
        //        NSMCommunicator(nsmc).callContext();
        char buf[NSM_TCPMSGSIZ];
        if (nsmlib_recv(nsmc, (struct NSMtcphead_struct*)buf, 1000) < 0)
          printf("RFProcessManager: Failed to read NSM context\n");
        else
          nsmlib_call(nsmc, (struct NSMtcphead_struct*)buf);
      }
      if (m_iopipe[0] > 0 &&
          FD_ISSET(m_iopipe[0], &fdset)) {
        break;
      }
      if (nfd == 0) break; // was a timeout -> return to do other stuff
    }
  }
  // Return nfd
  //  time_t now = time ( NULL );
  //  printf ( "[%s] CheckOutput : nfd = %d\n", ctime(&now), nfd );
  //  fflush ( stdout );
  return nfd;
}

◆ CheckProcess()

pid_t CheckProcess ( )

Definition at line 212 of file RFProcessManager.cc.

{
  for (vector<pid_t>::iterator it = m_pidlist.begin(); it != m_pidlist.end(); ++it) {
    pid_t pid = *it;
    int status;
    pid_t outpid = waitpid(pid, &status, WNOHANG);
    //    if (outpid == -1) {
    if (outpid != 0 || outpid == pid) {
      m_pidlist.erase(it);
      return pid;
    }
  }
  return 0;
}

◆ Execute() [1/2]

int Execute	(	char *	scr,
		char *	arg0 = `NULL`,
		char *	arg1 = `NULL`,
		char *	arg2 = `NULL`,
		char *	arg3 = `NULL`,
		char *	arg4 = `NULL`,
		char *	arg5 = `NULL`,
		char *	arg6 = `NULL`,
		char *	arg7 = `NULL`
	)

Definition at line 106 of file RFProcessManager.cc.

{
  char* arglist[8];
  int narg = 0;
  if (arg0 != NULL) {
    arglist[0] = arg0;
    narg++;
  }
  if (arg1 != NULL) {
    arglist[1] = arg1;
    narg++;
  }
  if (arg2 != NULL) {
    arglist[2] = arg2;
    narg++;
  }
  if (arg3 != NULL) {
    arglist[3] = arg3;
    narg++;
  }
  if (arg4 != NULL) {
    arglist[4] = arg4;
    narg++;
  }
  if (arg5 != NULL) {
    arglist[5] = arg5;
    narg++;
  }
  if (arg6 != NULL) {
    arglist[6] = arg6;
    narg++;
  }
  if (arg7 != NULL) {
    arglist[7] = arg7;
    narg++;
  }
  return Execute(scr, narg, arglist);
}

◆ Execute() [2/2]

int Execute	(	char *	script,
		int	nargs,
		char **	args
	)

Fill arg0

Definition at line 55 of file RFProcessManager.cc.

{
 
  printf("RFProcessManager : Execute : scr=%s, nargs=%d\n", scr, nargs);
  // Fork processes
  pid_t pid = fork();
  if (pid == (pid_t) 0) {   // In case of forked process
    char argbuf[10][256];
    char* argval[10];
    int nargval = 0;
    strcpy(argbuf[0], scr);
    argval[nargval++] = argbuf[0];
    // Fill argbuf
    for (int i = 0; i < nargs; i++) {
      strcpy(argbuf[nargval], args[i]);
      argval[nargval] = argbuf[nargval];
      nargval++;
      //      printf ( "argval[%d] = %s\n", i+1, argval[i+1] );
    }
    argval[nargval] = NULL;
 
    // Connect stderr/out to write pipe[1], which is read by parent process thru pipe[0]
    close(1);
    dup2(m_iopipe[1], 1);    // redirect stderr to pipe 1
    close(2);
    dup2(m_iopipe[1], 2);    // redirect stdout to pipe 1
    close(m_iopipe[0]);  // Close read pipe in child process
 
    // execute script in forked process by execvp()
    printf("RFProcessManager : invoking %s\n", scr);
    for (int i = 0; i < 10; i++) {
      if (argval[i] == NULL) break;
      printf("argval[%d] = %s\n", i, argval[i]);
    }
    fflush(stdout);
    fflush(stderr);
    execvp(scr, argval); // returns int stexe
    perror("execvp!!");
    fprintf(stderr, "missing file : %s\n", scr);
    fflush(stderr);
    exit(-1);
  }
  // Parent process (pid>0 : success, pid<0 : error )
  printf("RFProcessManager : forked. pid=%d\n", pid);
  //close(m_iopipe[1]);
 
  m_pidlist.push_back(pid);
  return pid;
}

◆ GetFd()

int GetFd ( )

Definition at line 207 of file RFProcessManager.cc.

{
  return m_iopipe[0];
}

◆ signal_handler()

void signal_handler ( int num )

static

Definition at line 50 of file RFProcessManager.cc.

51{

52}

Member Data Documentation

◆ m_iopipe

int m_iopipe[2]

private

Definition at line 44 of file RFProcessManager.h.

◆ m_pidlist

std::vector<pid_t> m_pidlist