/*	Created by:	Robert French
 *
 *	$Source: /afs/rel-eng.athena.mit.edu/project/release/current/source/athena/athena.bin/attach/RCS/zephyr.c,v $
 *	$Author: probe $
 *
 *	Copyright (c) 1988 by the Massachusetts Institute of Technology.
 */

#ifndef lint
static char rcsid_zephyr_c[] = "$Header: /afs/rel-eng.athena.mit.edu/project/release/current/source/athena/athena.bin/attach/RCS/zephyr.c,v 1.9 92/07/31 13:24:57 probe Exp $";
#endif

#include "attach.h"
#ifdef ZEPHYR
#include <zephyr/zephyr.h>
#include <setjmp.h>
#include <signal.h>

#ifdef __HIGHC__
#define	min(x,y)	_min(x,y)
#else
#define	min(x,y)	((x)<(y)?(x):(y))
#endif

#define ZEPHYR_MAXONEPACKET 5
Code_t ZSubscribeTo(), ZUnsubscribeTo();

static ZSubscription_t subs[ZEPHYR_MAXSUBS];
static int num_subs = 0;

static jmp_buf	timeout;

static sig_catch zephyr_timeout()
{
	longjmp(timeout, 1);
}

static int zephyr_op(func)
    Code_t (*func)();
{
    static int inited = 0;
    static int wgport = 0;
    int count, count2;
    ZSubscription_t shortsubs[ZEPHYR_MAXONEPACKET];
    Code_t retval;
#ifdef POSIX
    struct sigaction newsig, oldsig;
#else
    sig_catch	(*oldsig)();
#endif

    if (setjmp(timeout))
	    return 1;		/* We timed out, punt */

#ifdef POSIX
    newsig.sa_handler = zephyr_timeout;
    sigemptyset(&newsig.sa_mask);
    sigaddset(&newsig.sa_mask, SIGALRM);
    newsig.sa_flags = 0;
    sigaction(SIGALRM, &newsig, &oldsig);
#else
    oldsig = signal(SIGALRM, zephyr_timeout);
#endif
    alarm(ZEPHYR_TIMEOUT);
    
    if (inited < 0)
	return 1;

    if (!num_subs)
	return 0;	/* Can't lose if doing nothing */

    if (!inited) {
	if ((retval = ZInitialize()) != ZERR_NONE) {
	    com_err(progname, retval, "while intializing Zephyr library");
	    inited = -1;
	    return 1;
	}
	if ((wgport = ZGetWGPort()) == -1) {
	    /*
	     * Be quiet about windowgram lossage
	     */
	    inited = -1;
	    return 1;
	}
	inited = 1;
    }

    for (count=0; count<num_subs; count += ZEPHYR_MAXONEPACKET) {
	for (count2=0; count2<min(ZEPHYR_MAXONEPACKET,num_subs-count); count2++)
	    shortsubs[count2] = subs[count+count2];
	if ((retval = (func)(shortsubs,
			     min(ZEPHYR_MAXONEPACKET,num_subs-count),
			     wgport)) != ZERR_NONE) {
	    fprintf(stderr, "Error while subscribing: %s\n",
		    error_message(retval));
	    inited = -1;
	    return 1;
	}
    }
    alarm(0);
#ifdef POSIX
    sigaction(SIGALRM, &oldsig, (struct sigaction *)0);
#else
    (void) signal(SIGALRM, oldsig);
#endif
    return 0;
}

void zephyr_addsub(class)
    const char *class;
{
    if (num_subs == ZEPHYR_MAXSUBS)
	return;
    
    if (debug_flag)
	    printf("Subscribing to zephyr instance %s.\n", class);
    subs[num_subs].zsub_recipient = "*";
    subs[num_subs].zsub_classinst = strdup(class);
    subs[num_subs].zsub_class = ZEPHYR_CLASS;
    num_subs++;
}

int zephyr_sub(iszinit)
int iszinit;
{
    if(zephyr_op(ZSubscribeTo) && iszinit)
      {
	error_status = ERR_ZINITZLOSING;
	return FAILURE;
      }
    return SUCCESS;
}

int zephyr_unsub(iszinit)
int iszinit;
{
    if(zephyr_op(ZUnsubscribeTo) && iszinit)
      {
	error_status = ERR_ZINITZLOSING;
	return FAILURE;
      }
    return SUCCESS;
}
#endif