mustard@thor.sdrc.com (Sandy Mustard) (06/01/91)
Hi,
I'm having a problem with X on VMS that I'm hoping someone out there
might be able to help me with.
Basically I have a process that is running as an X client. It spawns
using SYS$CREPRC a subprocess (right now I'm using LOGINOUT.EXE) and
assigns newly created mailboxes to it's stdin, stdout and stderr. I
issue a QIO with a IO$M_WRTATTN mode and have it invoke an AST. This
AST will set an event flag whenever some process writes into that mailbox.
The event flag is given as the source for the XtAddInput call.
The problem is that the call back specified in the XtAddInput call never
gets invoked. I do see during the debugging trace that the event flag
does get set.
Does anyone have any experience with XtAddInput on VMS and could you
enlighten me as to how I might fix this?
The source code follows if this may help.
#include "GlP.h"
#include <X11/X.h>
#include <X11/Intrinsic.h>
#include <iodef.h>
#include <dvidef.h>
#include <descrip.h>
#include <ssdef.h>
extern int crtcld();
void post_mbx_ast();
void child_term_ast();
extern FILE * act_file;
extern FILE * err_file;
static int next_child = 0;
struct itmlst /* standard item list structure */
{
short len;
short code;
char *buff;
unsigned short *blen;
};
/************************************************************************/
/* child output stream callback */
/************************************************************************/
void child_out_cb (gl_child, fdes, id)
GL_CHILD *gl_child;
int *fdes;
int *id;
{
char *ptr;
int stat;
ptr = fgets (gl_child->out_bfr, gl_child->out_max-1,
gl_child->out_file);
if (ptr != NULL)
{
/* strip off the new line */
gl_child->out_bfr[strlen(gl_child->out_bfr)-1] = '\0';
if (gl_child->out_action != NULL)
vcpu (gl_child->out_action);
}
else
{
if (gl_child->dead == FALSE)
{
gl_child->dead = TRUE;
if (gl_child->death_action != NULL)
vcpu (gl_child->death_action);
}
XtRemoveInput (*id);
stat = SYS$DASSGN(gl_child->out_chan);
}
}
/************************************************************************/
/* child error stream callback */
/************************************************************************/
void child_err_cb (gl_child, fdes, id)
GL_CHILD *gl_child;
int *fdes;
int *id;
{
char *ptr;
int stat;
ptr = fgets (gl_child->err_bfr, gl_child->err_max-1,
gl_child->err_file);
if (ptr != NULL)
{
/* strip off the new line */
gl_child->err_bfr[strlen(gl_child->err_bfr)-1] = '\0';
if (gl_child->err_action != NULL)
vcpu (gl_child->err_action);
}
else
{
if (gl_child->dead == FALSE)
{
gl_child->dead = TRUE;
if (gl_child->death_action != NULL)
vcpu (gl_child->death_action);
}
XtRemoveInput (*id);
stat = SYS$DASSGN(gl_child->err_chan);
}
}
int child_create ()
{
int i;
GL_CHILD * gl_child;
int r;
gl_child = child_bfr;
/* for each child definition */
for (i=0; i<=child_idx; i++)
{
child_spawn (gl_child);
/* add output handler - if requested */
if (gl_child->out_action != NULL)
{
r = Xt$Add_Input (&gl_child->out_file_en, 0, /* XtInputReadMask, */
child_out_cb, gl_child);
}
/* add error handler - if requested */
if (gl_child->err_action != NULL)
{
r = Xt$Add_Input (&gl_child->err_file_en, 0, /* XtInputReadMask, */
child_err_cb, gl_child);
}
gl_child++;
}
}
/************************************************************************/
/* attach the child to X */
/************************************************************************/
int child_spawn (child)
GL_CHILD *child;
{
int pid;
int stat;
char mbxnam[32];
struct dsc$descriptor mbxdsc;
static char buffer[32];
static int buflen;
static int termunit;
static struct itmlst dvilst[] = {
{ sizeof buffer, DVI$_DEVNAM, 0-0, 0-0 },
{ sizeof (long), DVI$_UNIT, &termunit, NULL },
{ 0, 0, NULL, NULL } };
next_child++;
sprintf(buffer, "GL_CLD%08.8d", next_child);
/* create a mailbox for messages to the child */
strcpy(mbxnam, buffer);
mbxnam[14] ='I';
mbxdsc.dsc$w_length = strlen(mbxnam);
mbxdsc.dsc$a_pointer = mbxnam;
mbxdsc.dsc$b_class = DSC$K_CLASS_S;
mbxdsc.dsc$b_dtype = DSC$K_DTYPE_T;
stat = SYS$CREMBX(0, &child->in_chan, BUFSIZ, BUFSIZ, 0, 0, &mbxdsc);
dvilst[0].buff = buffer;
dvilst[0].blen = &buflen;
/* create a pipe for output messages from the child */
if (child->out_action != NULL)
{
mbxnam[14] ='O';
stat = SYS$CREMBX(0, &child->out_chan, BUFSIZ, BUFSIZ, 0, 0, &mbxdsc);
stat = SYS$GETDVIW(0, child->out_chan, 0, dvilst, 0, 0, 0, 0);
stat = LIB$GET_EF(&child->out_file_en);
stat = SYS$QIO(0, child->out_chan, (IO$_SETMODE|IO$M_WRTATTN),
&child->out_iosb, 0, 0,
post_mbx_ast, child->out_file_en, 0, 0, 0, 0);
child->out_bfr = (char *) calloc(1, child->out_max+1);
child->out_file = fopen(buffer, "r");
}
/* create a pipe for error messages from the child */
if (child->err_action != NULL)
{
mbxnam[14] ='E';
stat = SYS$CREMBX(0, &child->err_chan, BUFSIZ, BUFSIZ, 0, 0, &mbxdsc);
stat = SYS$GETDVIW(0, child->err_chan, 0, dvilst, 0, 0, 0, 0);
stat = LIB$GET_EF(&child->err_file_en);
stat = SYS$QIO(0, child->err_chan, (IO$_SETMODE|IO$M_WRTATTN),
&child->err_iosb, 0, 0,
post_mbx_ast, child->err_file_en, 0, 0, 0, 0);
child->err_bfr = (char *) calloc(1, child->err_max+1);
child->err_file = fopen(buffer, "r");
}
/* create a termination mailbox for the child */
mbxnam[14] ='T';
stat = SYS$CREMBX(0, &child->term_chan, BUFSIZ, BUFSIZ, 0, 0, &mbxdsc);
stat = SYS$GETDVIW(0, child->term_chan, 0, dvilst, 0, 0, 0, 0);
stat = SYS$QIO(0, child->term_chan, (IO$_SETMODE|IO$M_WRTATTN),
&child->iosb, 0, 0,
child_term_ast, child, 0, 0, 0, 0);
fflush (act_file);
/* create the child process */
if (crtcld (child->name, child->path, termunit,
child->in_chan, child->out_chan, child->err_chan) == 1)
{
perror ("child execl");
assert (FALSE);
}
return(0);
}
void child_term_ast(child)
GL_CHILD * child;
{
int stat;
stat = SYS$QIOW(0, child->out_chan, IO$_WRITEOF,
&child->iosb[0], 0, 0, 0, 0, 0, 0, 0, 0);
stat = SYS$DASSGN(child->term_chan);
}
void post_mbx_ast(efn)
int efn;
{
int stat;
stat = SYS$SETEF(efn);
}JONESD@kcgl1.eng.ohio-state.edu (David Jones) (06/01/91)
In message <166@thor.sdrc.com>, mustard@thor.sdrc.com (Sandy Mustard) writes: >I'm having a problem with X on VMS that I'm hoping someone out there >might be able to help me with. > >Basically I have a process that is running as an X client. It spawns >using SYS$CREPRC a subprocess (right now I'm using LOGINOUT.EXE) and >assigns newly created mailboxes to it's stdin, stdout and stderr. I >issue a QIO with a IO$M_WRTATTN mode and have it invoke an AST. This >AST will set an event flag whenever some process writes into that mailbox. >The event flag is given as the source for the XtAddInput call. > >The problem is that the call back specified in the XtAddInput call never >gets invoked. I do see during the debugging trace that the event flag >does get set. > > The source code follows if this may help. > > [ source deleted ] You are using LIB$GET_EF to allocate an event flag number, which returns flag numbers in cluster 1 (32-63). The XtAddInput function requires that the flag be in cluster 0 (0-31). You'll have to manage the event flag allocation yourself, I believe the toolkit uses flags 24 and 25 and RMS uses something in the upper 20s, so you should stick with low flag numbers if possible. Also be aware that the client_proc is responsible for clearing the event flag. If it returns with the event flag still set, the dispatcher will call it again immediately. Your code will be more robust if you use the second argument to XtAddInput as well. The GL_CHILD structure should have a psuedo-iosb for use as the second argument to XtAddInput. When you clear the event flag, also zero the first word of the iosb. Likewise, when you set the event flag, deposit a 1 in the first word. The ast parameter for the write attention ast would have to be changed to the address of the structure. David L. Jones | Phone: (614) 292-6929 Ohio State Unviversity | Internet: 1971 Neil Ave. Rm. 406 | jonesd@kcgl1.eng.ohio-state.edu Columbus, OH 43210 | jones-d@eng.ohio-state.edu Disclaimer: A repudiation of a claim.
jon@innerdoor.austin.ibm.com (Jon H. Werner) (06/03/91)
In article <166@thor.sdrc.com>, mustard@thor.sdrc.com (Sandy Mustard) writes: |> |> Hi, |> |> I'm having a problem with X on VMS that I'm hoping someone out there |> might be able to help me with. |> |> Basically I have a process that is running as an X client. It spawns |> using SYS$CREPRC a subprocess (right now I'm using LOGINOUT.EXE) and |> assigns newly created mailboxes to it's stdin, stdout and stderr. I |> issue a QIO with a IO$M_WRTATTN mode and have it invoke an AST. This |> AST will set an event flag whenever some process writes into that mailbox. |> The event flag is given as the source for the XtAddInput call. |> |> The problem is that the call back specified in the XtAddInput call never |> gets invoked. I do see during the debugging trace that the event flag |> does get set. |> You need to get a flag from cluster 0 and use that in the first parameter call to XtAddInput. Set this flag in your write-attention AST procedure. While you're in the AST use a dynamically allocated link-list to store your messages with a ptr to the current message. Then in the XtAddInput procedure read in the message and remove it form the list. I do this because the mail handler can handle input faster than the Event handler in X. This should help you get started. Remember though that VMS 5.4 ASTs are not X re-entrant. -- ______________________________________________________________________________ jon@innerdoor.austin.ibm.com * Insert Standard Disclaimer here * IBM Advanced Workstations Division Austin, Texas USA 512-823-5156