⟦ccdb951b3⟧

TextFile

/* rt2ssrespond.c - RTPM: responder */

# ifndef lint
static char Rcsid[] = "@(#)$Header: /cs/research/pp/hubris/pp-beta/Chans/x40088/RCS/rt2ssrespond.c,v 5.0 90/09/20 15:58:18 pp Exp Locker: pp $";
# endif

/*
 * $Header: /cs/research/pp/hubris/pp-beta/Chans/x40088/RCS/rt2ssrespond.c,v 5.0 90/09/20 15:58:18 pp Exp Locker: pp $
 *
 * $Log:	rt2ssrespond.c,v $
 * Revision 5.0  90/09/20  15:58:18  pp
 * rcsforce : 5.0 public release
 * 
 */



/*
 *				  NOTICE
 *
 *    Acquisition, use, and distribution of this module and related
 *    materials are subject to the restrictions of a license agreement.
 *    Consult the Preface in the User's Manual for the full terms of
 *    this agreement.
 *
 */


/* LINTLIBRARY */

#include <stdio.h>
#include <isode/rtpkt.h>
#include <isode/tailor.h>
#if ISODE < 65


/* \f

   DATA */

extern int acsap_conntype;

/* \f

   RT-BEGIN.INDICATION (X.410 OPEN.INDICATION) */

int	RtBInit (vecp, vec, rts, rti)
int	vecp;
char  **vec;
struct RtSAPstart *rts;
struct RtSAPindication *rti;
{
    int     len,
	    result;
    char   *base;
    register struct assocblk   *acb;
    register PE	pe;
    struct SSAPref ref;
    struct SSAPstart    sss;
    register struct SSAPstart  *ss = &sss;
    struct SSAPindication   sis;
    register struct SSAPindication *si = &sis;
    register struct SSAPabort  *sa = &si -> si_abort;
    int sc_reason = SC_CONGESTION;

    isodetailor (NULLCP, 0);

    missingP (vec);
    missingP (rts);
    missingP (rti);

    if ((acb = newacblk ()) == NULL)
	return rtsaplose (rti, RTS_CONGEST, NULLCP, "out of memory");
    acb -> acb_flags |= ACB_RTS;
    SetSS2RtService (acb);

    if (SInit (vecp, vec, ss, si) == NOTOK) {
	(void) ss2rtslose (acb, rti, "SInit", sa);
	goto out1;
    }

    acb -> acb_fd = ss -> ss_sd;
    acb -> acb_uabort = SUAbortRequest;

    base = NULLCP, len = 0;
    acb -> acb_connect = ss -> ss_connect;	/* struct copy */
    if ((ss -> ss_requirements &= RTS_MYREQUIRE) != RTS_MYREQUIRE) {
	(void) rtsaplose (rti, RTS_PROTOCOL, NULLCP,
		    "desired session requirements unavailable");
	goto out2;
    }
    acb -> acb_requirements = ss -> ss_requirements;

#define dotoken(requires,shift,bit,type) \
{ \
    if (acb -> acb_requirements & requires) \
	switch (ss -> ss_settings & (ST_MASK << shift)) { \
	    case ST_INIT_VALUE << shift: \
		acb -> acb_avail |= bit; \
		break; \
 \
	    case ST_RESP_VALUE << shift: \
		acb -> acb_owned |= bit; \
		acb -> acb_avail |= bit; \
		break; \
 \
	    default: \
		(void) rtsaplose (rti, RTS_PROTOCOL, NULLCP, \
			"%s token management botched", type); \
		goto out2; \
	} \
    }
    dotokens ();
#undef	dotoken
    if (acb -> acb_owned != 0 && acb -> acb_owned != acb -> acb_avail) {
	(void) rtsaplose (rti, RTS_PROTOCOL, NULLCP,
		"token management botched");
	goto out2;
    }
    if (acb -> acb_owned)
	acb -> acb_flags |= ACB_TURN;
    acb -> acb_settings = ss -> ss_settings;
    acb -> acb_ssdusize = ss -> ss_ssdusize;

    if ((pe = ssdu2pe (ss -> ss_data, ss -> ss_cc, NULLCP, &result))
	    == NULLPE) {
	(void) rtsaplose (rti, result != PS_ERR_NMEM ? RTS_PROTOCOL
		: RTS_CONGEST, NULLCP, "%s", ps_error (result));
	goto out2;
    }

    SSFREE (ss);

    acsap_ckpoint = PCONN_CK_DFLT, acsap_window = PCONN_WD_DFLT;
    acsap_mode = PCONN_DM_DFLT, acsap_data = NULLPE;
    if (parse_OACS_PConnect (pe, 1, NULLIP, NULLVP, NULLCP) == NOTOK) {
	(void) pylose ();
	pe_free (pe);
	goto out2;
    }

    PLOG (rtsap_log, print_OACS_PConnect, pe, "PConnect", 1);

    if (acsap_conntype == CN_RECOVER) {
	(void) rtsaplose (rti, RTS_CONGEST, NULLCP,
			  "rejecting attempted recovery");
	pe_free (pe);
	if ((pe = pe_alloc (PE_CLASS_UNIV, PE_FORM_CONS, PE_CONS_SET))
	        && set_add (pe, num2prim (RTS_RECOVER, PE_CLASS_CONT,
					  PREF_REASON)) != NOTOK) {
	    PLOG (rtsap_log, print_OACS_PRefuse, pe, "PRefuse", 0);
	    if (pe2ssdu (pe, &base, &len) == NOTOK) {
		if (base)
		    free (base), base = NULL;
		len = 0;
	    }
	}
	if (pe)
	    pe_free (pe);
	sc_reason = SC_REJECTED;
	goto out2;
    }

    acb -> acb_ckpoint = acb -> acb_ssdusize >> 10;
    if ((0 < acsap_ckpoint && acsap_ckpoint < acb -> acb_ckpoint)
	    || acb -> acb_ckpoint <= 0)
	acb -> acb_ckpoint = acsap_ckpoint;
    acb -> acb_window = acsap_window;

    bzero ((char *) rts, sizeof *rts);
    rts -> rts_sd = acb -> acb_fd;
    rts -> rts_initiator.rta_addr = ss -> ss_calling;	/* struct copy */
    if (acsap_mode == PCONN_DM_TWA)
	rts -> rts_mode = RTS_TWA, acb -> acb_flags |= ACB_TWA;
    else
	rts -> rts_mode = RTS_MONOLOGUE;
    rts -> rts_turn = acb -> acb_flags & ACB_TURN ? RTS_RESPONDER
	    : RTS_INITIATOR;
    rts -> rts_port = htons ((u_short) acsap_application);
    rts -> rts_data = pe_expunge (pe, acsap_data);
    
    return OK;

out2: ;
    bzero ((char *) &ref, sizeof ref);


    if(SConnResponse (acb -> acb_fd, &ref, NULLSA, sc_reason, 0, 0,
		      SERIAL_NONE, base, len, si) == NOTOK)
	SLOG (rtsap_log, LLOG_EXCEPTIONS, NULLCP, ("SConnResponse failed"));
    acb -> acb_fd = NOTOK;
    if (base)
	free (base);

out1: ;
    SSFREE (ss);
    freeacblk (acb);

    return NOTOK;
}

/* \f

   RT-BEGIN.RESPONSE (X.410 OPEN.RESPONSE) */

int	RtBeginResponse (sd, status, data, rti)
int	sd;
int	status;
PE	data;
struct RtSAPindication *rti;
{
    int	    len,
	    result;
    char   *base;
    register PE	pe,
		p,
		q,
		r;
    register struct assocblk   *acb;
    struct SSAPref ref;
    struct SSAPindication sis;
    register struct SSAPindication *si = &sis;
    register struct SSAPabort *sa = &si -> si_abort;

    if ((acb = findacblk (sd)) == NULL || (acb -> acb_flags & ACB_CONN))
	return rtsaplose (rti, RTS_PARAMETER, NULLCP,
		"invalid association descriptor");
    if ((acb -> acb_flags & ACB_ACS) || !(acb -> acb_flags & ACB_RTS))
	return rtsaplose (rti, RTS_OPERATION, NULLCP,
		"not an association descriptor for RTS");
    switch (status) {
	case RTS_ACCEPT: 
	    break;

	case RTS_MODE:
	case RTS_VALIDATE: 
	case RTS_BUSY: 
	    if (data)
		return rtsaplose (rti, RTS_PARAMETER, NULLCP,
			"user data not permitted when refusing association");
	    break;

	default: 
	    return rtsaplose (rti, RTS_PARAMETER, NULLCP,
		    "bad value for status parameter");
    }
    missingP (rti);

    base = NULLCP;
    switch (status) {
	case RTS_ACCEPT: 
/* begin PAccept PSDU */
	    if ((pe = pe_alloc (PE_CLASS_UNIV, PE_FORM_CONS, PE_CONS_SET))
		    == NULLPE) {
	no_mem: ;
		(void) rtsaplose (rti, RTS_CONGEST, NULLCP, "out of memory");
		goto out1;
	    }
	    if (set_add (pe, p = pe_alloc (PE_CLASS_CONT, PE_FORM_CONS,
			    PACC_DTS)) == NOTOK
		    || set_add (p, num2prim (SYN_X409, PE_CLASS_CONT,
			    DTS_SYNTAX)) == NOTOK
		    || set_add (pe, p = pe_alloc (PE_CLASS_CONT, PE_FORM_CONS,
			    PACC_DATA)) == NOTOK
		    || set_add (p, num2prim (acb -> acb_ckpoint,
			    PE_CLASS_CONT, PACC_DATA_CK)) == NOTOK
		    || set_add (p, num2prim (acb -> acb_window,
			    PE_CLASS_CONT, PACC_DATA_WD)) == NOTOK
		    || set_add (p, q = pe_alloc (PE_CLASS_CONT, PE_FORM_CONS,
			    PACC_DATA_CN)) == NOTOK
		    || set_add (q, r = pe_alloc (PE_CLASS_CONT, PE_FORM_CONS,
			    CN_OPEN)) == NOTOK
		    || set_add (r, data ? data : pe_alloc (PE_CLASS_UNIV,
						PE_FORM_PRIM, PE_PRIM_NULL))
			    == NOTOK)
		goto no_mem;
/* end PAccept PSDU */
	    status = SC_ACCEPT;
	    break;

	default: 
/* begin PRefuse PSDU */
	    if ((pe = pe_alloc (PE_CLASS_UNIV, PE_FORM_CONS, PE_CONS_SET))
		    == NULLPE
		    || set_add (pe, num2prim (status, PE_CLASS_CONT,
			    PREF_REASON)) == NOTOK)
		goto no_mem;
/* end PRefuse PSDU */
	    status = SC_REJECTED;
	    break;
    }

#ifdef	DEBUG
    if (rtsap_log -> ll_events & LLOG_PDUS)
	if (status == SC_ACCEPT)
	    vpdu (rtsap_log, print_OACS_PAccept, pe, "PAccept", 0)
	else
	    vpdu (rtsap_log, print_OACS_PRefuse, pe, "PRefuse", 0);
#endif

    if (pe2ssdu (pe, &base, &len) == NOTOK)
	goto no_mem;

    if (SConnResponse (acb -> acb_fd, &acb -> acb_connect, NULLSA, status,
		acb -> acb_requirements, acb -> acb_settings, SERIAL_NONE,
		base, len, si) == NOTOK) {
	acb -> acb_fd = NOTOK;
	(void) ss2rtslose (acb, rti, "SConnResponse", sa);
	goto out3;
    }

    if (status == SC_ACCEPT)
	acb -> acb_flags |= ACB_CONN;
    else {
	acb -> acb_fd = NOTOK;
	freeacblk (acb);
    }
    result = OK;

out2: ;
    if (pe) {
	if (data)
	    (void) pe_extract (pe, data);
	pe_free (pe);
    }
    if (base)
	free (base);

    return result;

out1: ;
    bzero ((char *) &ref, sizeof ref);
    (void) SConnResponse (acb -> acb_fd, &ref, NULLSA, SC_CONGEST, 0, 0,
	    SERIAL_NONE, NULLCP, 0, si);
    acb -> acb_fd = NOTOK;
out3: ;
    freeacblk (acb);
    result = NOTOK;
    goto out2;
}
#endif
DataMuseum.dk

DKUUG/EUUG Conference tapes

⟦ccdb951b3⟧ TextFile

Derivation

TextFile
