⟦4c85a178a⟧

TextFile

/* ro2ssinitiat.c - initiator */

#ifndef	lint
static char *rcsid = "$Header: /f/osi/rosap/RCS/ro2ssinitiat.c,v 7.0 89/11/23 22:21:19 mrose Rel $";
#endif

/* 
 * $Header: /f/osi/rosap/RCS/ro2ssinitiat.c,v 7.0 89/11/23 22:21:19 mrose Rel $
 *
 * Based on an TCP-based implementation by George Michaelson of University
 * College London.
 *
 *
 * $Log:	ro2ssinitiat.c,v $
 * Revision 7.0  89/11/23  22:21:19  mrose
 * Release 6.0
 * 
 */

/*
 *				  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 <signal.h>
#include "ropkt.h"
#include "isoservent.h"
#include "tailor.h"

/* \f

   RO-BEGIN.REQUEST */

int	RoBeginRequest (called, data, roc, roi)
struct RoSAPaddr *called;
PE	data;
struct RoSAPconnect *roc;
struct RoSAPindication *roi;
{
    SBV     smask;
    int     result;

    isodetailor (NULLCP, 0);

    missingP (called);
    missingP (roc);
    bzero ((char *) roc, sizeof *roc);
    missingP (roi);

    smask = sigioblock ();

    result = RoBeginRequestAux (called, data, roc, roi);

    (void) sigiomask (smask);

    return result;
}

/* \f

 */

static int  RoBeginRequestAux (called, data, roc, roi)
struct RoSAPaddr *called;
PE	data;
struct RoSAPconnect *roc;
struct RoSAPindication *roi;
{
    int	    len,
	    result,
	    settings;
    char   *base;
#ifdef	notdef
    register struct isoservent *is;
#endif
    register PE	pe,
		p,
		q,
		r;
    register struct assocblk *acb;
    struct SSAPref ref;
    struct SSAPconnect scs;
    register struct SSAPconnect *sc = &scs;
    struct SSAPindication sis;
    register struct SSAPindication *si = &sis;
    register struct SSAPabort *sa = &si -> si_abort;

    if ((acb = newacblk ()) == NULL)
	return rosaplose (roi, ROS_CONGEST, NULLCP, "out of memory");

/* begin PConnect PSDU */
    if ((pe = pe_alloc (PE_CLASS_UNIV, PE_FORM_CONS, PE_CONS_SET)) == NULLPE) {
no_mem: ;
	result = rosaplose (roi, ROS_CONGEST, NULLCP, "out of memory");
	goto out1;
    }
    if (set_add (pe, p = pe_alloc (PE_CLASS_CONT, PE_FORM_CONS, PCONN_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,
		    PCONN_DATA)) == NOTOK
	    || set_add (p, q = pe_alloc (PE_CLASS_CONT, PE_FORM_CONS,
		    PCONN_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
	    || set_add (p, num2prim ((int) ntohs (called -> roa_port),
		    PE_CLASS_CONT, PCONN_DATA_AP)) == NOTOK)
	goto no_mem;
/* end PConnect PSDU */

    PLOG (rosap_log, print_OACS_PConnect, pe, "PConnect", 0);

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

    if (data)
	(void) pe_extract (pe, data), data = NULLPE;
    pe_free (pe);
    pe = NULLPE;

#ifdef	notdef		/* SEK doesn't like this */
    if (called -> roa_addr.sa_selectlen == 0) {
	if ((is = getisoserventbyname ("ros", "ssap")) == NULL) {
	    result = rosaplose (roi, ROS_ADDRESS, NULLCP,
			"ssap/ros: unknown entity");
	    goto out2;
	}
	if (is -> is_selectlen > SSSIZE) {	/* XXX */
	    result = rosaplose (roi, ROS_ADDRESS, NULLCP,
			"ssap/ros: selector too long (%d octets)",
			is -> is_selectlen);
	    goto out2;
	}
	bcopy (is -> is_selector, called -> roa_addr.sa_selector,
	    called -> roa_addr.sa_selectlen = is -> is_selectlen);
    }
#endif

    acb -> acb_requirements = SR_BCSUBSET;
    settings = 0;
#define dotoken(requires,shift,bit,type) \
{ \
    if (acb -> acb_requirements & requires) \
	settings |= ST_INIT_VALUE << shift; \
}
    dotokens ();
#undef	dotoken

    bzero ((char *) &ref, sizeof ref);	/* ECMA says don't encode this yet */
    if (SConnRequest (&ref, NULLSA, &called -> roa_addr,
		acb -> acb_requirements, settings, SERIAL_NONE, base, len,
		NULLQOS, sc, si) == NOTOK) {
	result = ss2roslose (NULLACB, roi, "SConnRequest", sa);
	goto out2;
    }
    free (base);

    bzero ((char *) roc, sizeof *roc);

    if (sc -> sc_result == SC_ACCEPT) {
	acb -> acb_fd = sc -> sc_sd;
	acb -> acb_uabort = SUAbortRequest;
    }
    else
        if (sc -> sc_result == SC_ABORT) {
	    acb -> acb_fd = NOTOK;

	    (void) ss2rosabort (acb, sa, roi);

	    roc -> roc_sd = NOTOK;
	    roc -> roc_result = ROS_ABORTED;

	    return OK;
	}

    if ((pe = ssdu2pe (sc -> sc_data, sc -> sc_cc, NULLCP, &result))
	    == NULLPE) {
	if (sc -> sc_result != SC_ACCEPT) {
	    bzero ((char *) sa, sizeof *sa);
	    sa -> sa_reason = sc -> sc_result;
	    acb -> acb_fd = NOTOK;
	    (void) ss2roslose (acb, roi, "SConnRequest(pseudo)", sa);

	    roc -> roc_sd = NOTOK;
	    roc -> roc_result = roi -> roi_preject.rop_reason;

	    result = OK;
	}
	else
	    result = ropktlose (acb, roi, result != PS_ERR_NMEM ? ROS_PROTOCOL
		    : ROS_CONGEST, NULLCP, "%s", ps_error (result));
	goto out1;
    }

    SCFREE (sc);

    if (sc -> sc_result != SC_ACCEPT) {
	if (parse_OACS_PRefuse (pe, 1, NULLIP, NULLVP, NULLCP) == NOTOK) {
	    result = pylose ();
	    goto out1;
	}

	PLOG (rosap_log, print_OACS_PRefuse, pe, "PRefuse", 1);

	pe_free (pe);
	
	freeacblk (acb);

	roc -> roc_sd = NOTOK;
	switch (acsap_refuse) {
	    case REFUSE_BUSY: 
		roc -> roc_result = ROS_BUSY;
		break;

	    case REFUSE_VALIDATE: 
		roc -> roc_result = ROS_VALIDATE;
		break;

	    default: 
		roc -> roc_result = ROS_PROTOCOL;
		break;
	}

	return OK;
    }

    acb -> acb_flags = ACB_CONN | ACB_ROS | ACB_INIT;
    (void) RoSService (acb, roi);
    if (!((acb -> acb_requirements = sc -> sc_requirements) & SR_DUPLEX)
	    && !(acb -> acb_requirements & SR_HALFDUPLEX)) {
	result = ropktlose (acb, roi, ROS_PROTOCOL, NULLCP,
		    "desired session requirements denied");
	goto out1;
    }
    if (acb -> acb_requirements & SR_HALFDUPLEX)
	acb -> acb_flags |= ACB_TURN;	/* it it is there we must have it */

    acsap_data = NULLPE;
    if (parse_OACS_PAccept (pe, 1, NULLIP, NULLVP, NULLCP) == NOTOK) {
	result = pylose ();
	goto out1;
    }

    PLOG (rosap_log, print_OACS_PAccept, pe, "PAccept", 1);

    roc -> roc_sd = acb -> acb_fd;
    roc -> roc_result = ROS_ACCEPT;
    roc -> roc_data = pe_expunge (pe, acsap_data);

    return OK;

out2: ;
    free (base);

out1: ;
    SCFREE (sc);
    if (pe) {
	if (data)
	    (void) pe_extract (pe, data);
	pe_free (pe);
    }
    freeacblk (acb);

    return result;
}
DataMuseum.dk

DKUUG/EUUG Conference tapes

⟦4c85a178a⟧ TextFile

Derivation

TextFile
