diff options
Diffstat (limited to 'pkg/vocl/builtin_vo.c')
| -rw-r--r-- | pkg/vocl/builtin_vo.c | 194 |
1 files changed, 194 insertions, 0 deletions
diff --git a/pkg/vocl/builtin_vo.c b/pkg/vocl/builtin_vo.c new file mode 100644 index 00000000..4cb4dd29 --- /dev/null +++ b/pkg/vocl/builtin_vo.c @@ -0,0 +1,194 @@ +/* Copyright(c) 1986 Association of Universities for Research in Astronomy Inc. + */ + +#define import_spp +#define import_libc +#define import_fset +#define import_error +#define import_ctype +#define import_stdio +#define import_alloc +#define import_ttset +#define import_prstat +#define import_xwhen +#include <iraf.h> + +/* +*/ +#include "config.h" +#include "clmodes.h" +#include "mem.h" +#include "operand.h" +#include "opcodes.h" +#include "param.h" +#include "task.h" +#include "errs.h" + + +/* + * BUILTIN_VO -- This file contains the functions that perform the built-in + * VO-related commands of the cl, such as coneCaller(), getRegistry(), etc. + * + * SetVOBuiltins() contains a table of functions and their user names; add + * to this table when adding new builtin functions. + * + * See builtins.c for addition notes and details. + */ + +extern int cldebug, cltrace; /* debug/trace flags */ +extern int lastjobno; /* last background job spawned */ +extern int gologout; /* flag to execute() to cause logout */ +extern int logout_status; /* optional arg to logout() */ +extern int errorline; /* error recover line */ +extern int currentline; /* line currently being executed */ +extern char *findexe(); + +extern int do_error; /* for error recovery/trapping */ + + +extern int VOClient_initialized; + +typedef int (*PFI)(); + +static PFI old_onipc; /* X_IPC handler */ +int voc_onipc(); + + +/* CL_VOCINIT -- Initialize the VO Client interface. + */ +void +cl_vocinit (void) +{ + register struct pfile *pfp; + struct operand o; + int n, status; + + if (VOClient_initialized == 0) { + + c_xwhen (X_IPC, voc_onipc, &old_onipc); + + pfp = newtask->t_pfp; + if ((n = nargs (pfp)) > 1) { + cl_error (E_UERR, e_posargs, "vocinit"); + return; + + } else if (n < 1) { + status = voc_initVOClient (envget("vo_runid")); + + } else { + pushbparams (pfp->pf_pp); + popop(); /* discard fake name. */ + opcast (OT_STRING); + o = popop(); /* get ltask */ + + status = voc_initVOClient (o.o_val.v_s); + } + + if (status) { + cl_error (E_UERR, "Can't init VOClient", "vocinit"); + } else + VOClient_initialized = 1; + } +} + + +/* CL_VOCSTOP -- Stop the VO Client interface. + */ +void +cl_vocstop (void) +{ + register struct pfile *pfp; + struct operand o; + int n, status; + + if (VOClient_initialized == 1) { + c_xwhen (X_IPC, old_onipc, &old_onipc); + + pfp = newtask->t_pfp; + if ((n = nargs (pfp)) > 1) { + cl_error (E_UERR, e_posargs, "vocstop"); + return; + + } else if (n < 1) { + voc_closeVOClient (1); + + } else { + pushbparams (pfp->pf_pp); + popop(); /* discard fake name. */ + opcast (OT_INT); + o = popop(); /* get ltask */ + voc_closeVOClient (o.o_val.v_i); + } + VOClient_initialized = 0; + } +} + + +/* CL_VOCRESET -- Restart the VO Client interface. + */ +void +cl_vocreset () +{ + int status; + + voc_closeVOClient (1); + status = voc_initVOClient (envget("vo_runid")); +} + + +/* ======================================================== + * + * End of builtin functions. + * What follows is their support code. + * + * ========================================================*/ + + +/* VO_SETBUILTINS -- Add the builtin functions to package at pkp (this should + * always just be clpackage). To add more functions, write the support function + * and enter it into the builtin table, btbl. Reverse alpha due to lifo nature + * of list. Aliases can be made easily with multiple b_names using the same + * b_f. Setting LT_INVIS will keep it from being seen in the menu. + */ +void +vo_setbuiltins ( + struct package *pkp +) +{ + static struct builtin { + char *b_name; + void (*b_f)(); + int b_flags; + } btbl[] = { + { "vocinit", cl_vocinit, 0}, /* initialize the VO Client */ + { "vocstop", cl_vocstop, 0}, /* stop the VO Client */ + { "vocreset", cl_vocreset, 0}, /* reset the VO Client */ + NULL + }; + + register struct builtin *bp; + + for (bp = btbl; bp < &btbl[sizeof(btbl)/sizeof(struct builtin)]; bp++) + newbuiltin (pkp, bp->b_name, bp->b_f, bp->b_flags, "", 0); +} + + +/* VOC_ONIPC -- Call this when get a signal that indicates a write to an IPC + * channel with no reader. We are called after the system X_IPC handler + * has been called to cleanup the internal process tables and file system, + * disabling any further output to the process. + */ +/* ARGSUSED */ +int +voc_onipc ( + int *vex, /* virtual exception code */ + PFI *next_handler /* next handler to be called */ +) +{ + VOClient_initialized = 0; + cl_vocreset(); + cl_error (E_UERR, "Abnormal termination of %s, resetting\n", + "VOClientd"); + + return (0); +} |