RFProcessManager Class Reference

Collaboration diagram for RFProcessManager:

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]
int	m_fdout
std::vector< pid_t >	m_pidlist

Detailed Description

Definition at line 22 of file RFProcessManager.h.

Member Function Documentation

Execute()

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;
}

---

The documentation for this class was generated from the following files:

• daq/rfarm/manager/include/RFProcessManager.h
• daq/rfarm/manager/src/RFProcessManager.cc