process.c

/*************************************************************************\
* Copyright (c) 2002 The University of Chicago, as Operator of Argonne
* National Laboratory.
* Copyright (c) 2002 Deutches Elektronen-Synchrotron in der Helmholtz-
* Gemelnschaft (DESY).
* Copyright (c) 2002 Berliner Speicherring-Gesellschaft fuer Synchrotron-
* Strahlung mbH (BESSY).
* Copyright (c) 2002 Southeastern Universities Research Association, as
* Operator of Thomas Jefferson National Accelerator Facility.
* Copyright (c) 2002 The Regents of the University of California, as
* Operator of Los Alamos National Laboratory.
* This file is distributed subject to a Software License Agreement found
* in the file LICENSE that is included with this distribution. 
\*************************************************************************/
/* process.c */

/************************DESCRIPTION***********************************
  This file contains routines for spawning a related process
**********************************************************************/

#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#ifdef WIN32
#include <process.h>     /* For spawn */
#endif
#include <Xm/Xm.h>
#include <Xm/RowColumn.h>
#include <Xm/PushB.h>

#include "alLib.h"
#include "ax.h"

#define masterCommand "MASTER_ONLY"
extern int DEBUG;

extern int _lock_flag; 
extern int masterFlag;
extern int notsave;

static char *g_popupCmdString;
static Widget g_pum = NULL;
#ifdef WIN32
#define strtok_r strtok_s
#endif

/******************************************************
  spawn a new related prcess if command is not null
******************************************************/
void processSpawn_callback(Widget w,char *command,void * call_data)
{
	char buff[MAX_STRING_LENGTH +2];
	size_t l;
	int status;
#ifdef WIN32
	static int first=1;
	static char *ComSpec;
#endif    

if(notsave) { fprintf(stderr,"NOT SAVE mode - no related process started"); return;}

	if (command) {
		/* Strip any LF from the end */
		l = strlen(command);
		if (*(command+l-1) == '\n') *(command+l-1) = ' ';
		
/* If more then 1 alh process work with the same config files
of cource, usually all this process can span all callback,
BUT in some special case (in our situation it's mail to 
mobil-phone) it's expensive (in money :) or processor-time) 
or not so important. In this case ONLY master alh_process 
span this task.  For distinguish with common case we add
additional last parameters in command MASTER_ONLY:
WAS: $SEVRCOMMAND UP_ERROR             mailx mobil@server.com "ALARM HAPPEN"
NOW: $SEVRCOMMAND UP_ERROR MASTER_ONLY mailx mobil@server.com "ALARM HAPPEN" 

Coding:
------

If don't locking system    -- cut MASTER_ONLY from string and spawn it
Else if you're  master-alh-process  -- the same
      else do nothing
*/
		/* ________MASTER_ONLY code ________________________ */
		if(strncmp(command,masterCommand,strlen(masterCommand))==0)
		  {
		    command += strlen(masterCommand);
		    if (_lock_flag && !masterFlag) return; 
		  }
		/* _______End MASTER_ONLY code ______________________ */

#ifdef WIN32
		sprintf(buff,"%s",command);
		/* Get ComSpec for the command shell (should be defined) */
		if (first) {
			first=0;
			ComSpec = getenv("ComSpec");
		}
		if (!ComSpec) {
			errMsg("processSpawn_callback: Cannot find command processor\n");
			return;
		}
		status = _spawnl(_P_DETACH, ComSpec, ComSpec, "/C", buff, NULL);
#else
		sprintf(buff,"%s &",command);
		status=system(buff);
#endif	
		if(status == -1) {
			/* System call failed */
			char *errstring=strerror(errno);

			errMsg("processSpawn_callback: Cannot process command:\n"
			    "%s\n  %s",
			    buff,errstring);
		} else if (status > 0) {
			/* Assume program returned an error */
			errMsg("processSpawn_callback: Command returned %d:\n"
			    "%s\n",
			    status,buff);
		}
	}
}

/***************************************************
  menu callback
****************************************************/
static void relprocmenu_cb (
  Widget w,
  XtPointer index,
  void * call_data
) {

char buf[1023+1], *tk, *ctx;
int i;
int indexi = (long) index;

  strncpy( buf, g_popupCmdString, 1023 );
  buf[1023] = 0;

  i = 0;
  ctx = NULL;
  tk = strtok_r( buf, "!\n", &ctx );
  while ( tk ) {
    tk = strtok_r( NULL, "!\n", &ctx );
    if ( tk ) {
      if ( i == indexi ) {
        processSpawn_callback( w, tk, call_data );
        return;
      }
      i++;
    }
    tk = strtok_r( NULL, "!\n", &ctx );
  };

}

/***************************************************
  relatedProcess_callback
****************************************************/
void relatedProcess_callback(void *widget,GCLINK *link,void *cbs)
{
	void *area;
	char buf[1023+1], *tk, *ctx;
	int i, n;
	Widget pdm, pb;
        Arg args[10];
	XmString str;
        Window root, child;
        int rootX, rootY, winX, winY;
        unsigned int mask;
        XButtonEvent be;

	XtVaGetValues(widget, XmNuserData, &area, NULL);

	if (link && alProcessExists(link)){

	  strncpy( buf, link->pgcData->command, 1023 );
	  buf[1023] = 0;

	  i = 0;
	  ctx = NULL;
          tk = strtok_r( buf, "!\n", &ctx );
	  while ( tk ) {
            if ( tk ) {
	      i++;
	    }
            tk = strtok_r( NULL, "!\n", &ctx );
	  };

	  if ( i > 1 ) {

	    if ( i % 2 ) { /* if i > one then i must be even */
              fprintf( stderr, "Command syntax error\n" );
              return;
	    }

            g_popupCmdString = link->pgcData->command;

            if ( g_pum ) {
              XtDestroyWidget( g_pum );
              g_pum = NULL;
	    }

            n = 0;
            XtSetArg( args[n], XmNpopupEnabled, (XtArgVal) False ); n++;
            g_pum = XmCreatePopupMenu( topLevelShell, "relprocmenu", args, n );

            pdm = XmCreatePulldownMenu( g_pum, "relprocpd", NULL, 0 );

	    strncpy( buf, link->pgcData->command, 1023 );
	    buf[1023] = 0;

	    i = 0;
	    ctx = NULL;
            tk = strtok_r( buf, "!\n", &ctx );

	    while ( tk ) {

              if ( tk ) {

                long ilong = i;
                str = XmStringCreateLocalized( tk );
                pb = XtVaCreateManagedWidget( "pb", xmPushButtonWidgetClass,
                 g_pum, XmNlabelString, str, NULL );
                XmStringFree( str );
                XtAddCallback( pb, XmNactivateCallback, relprocmenu_cb,
                 (XtPointer)ilong );

	        i++;

	      }

              tk = strtok_r( NULL, "!\n", &ctx );
              tk = strtok_r( NULL, "!\n", &ctx );

	    };

            XQueryPointer( display, XtWindow(XtParent(widget)), &root, &child,
             &rootX, &rootY, &winX, &winY, &mask );

            be.x_root = rootX;
	    be.y_root = rootY;

	    XmMenuPosition( g_pum, &be );
            XtManageChild( g_pum );

	  }
	  else {

	    strncpy( buf, link->pgcData->command, 1023 );
	    buf[1023] = 0;

	    ctx = NULL;
            tk = strtok_r( buf, "!\n", &ctx );
            processSpawn_callback( widget, tk, cbs );

	  }

	}

}