⟦4e0d05dba⟧

TextFile

/* connection.h - directory internal structures */

/*
 * $Header: /f/osi/h/quipu/RCS/connection.h,v 7.0 89/11/23 21:56:28 mrose Rel $
 *
 *
 * $Log:	connection.h,v $
 * Revision 7.0  89/11/23  21:56:28  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.
 *
 */


#ifndef QUIPUCON
#define QUIPUCON

#include "psap2.h"
#include "acsap.h"
#include "quipu/common.h"
#include "quipu/dsargument.h"

#define DB_NDATA 1      /* Number of PE's expected for Bind info.  */

#define GETEDB_PRIO		1
#define DSA_PRIO_LOW            2
#define DSA_PRIO_MED            3
#define DSA_PRIO_HIGH           4
#define DSA_MAX_PRIO            4

#define MAX_CONNS		20	/* Maximum concurrent connections */
#define CONNS_RESERVED_DI	2	/* Reserved for Get DSA Info ops */
#define CONNS_RESERVED_X500	10	/* Reserved for normal operations */
/*
*  If the connection definitions are altered bear in mind that 
*  MAX_CONNS - CONNS_RESERVED_FOR_DI - CONNS_RESERVED_FOR_X500
*  must be at least 1 to allow get edb ops to happen, and should
*  probably be at least 2 to allow one get edb operation to block.
*/

#define ACT_TYPE_REQ            1
#define ACT_TYPE_CHN            2
#define ACT_TYPE_RESP           3

#define RESP_TYPE_RET           1
#define RESP_TYPE_REJ           2

#define RET_TYPE_RES            1
#define RET_TYPE_ERR            2

/*
*  The following structures form the basis of the connection mesh
*  which is central to the scheduling of the DSA.
*/

/*
*  The di_block structure is used to generate lists of dsa information
*  blocks even when the information is not yet available.
*  There are 3 states which a di_block can be in:
*	DI_ACCESSPOINT:	di_block contains access point only.
*	DI_COMPLETE:	di_block contains entry for dsa.
*	DI_DEFERRED:	di_block is waiting for a dsa entry.
*
*  The links in this structure need to be handled with care!!
*  di_next is used to link the "di_block"s on
*	1) the global list if that is where this block is kept
*	2) the requesting operation if that is where this block is kept
*	3) the requesting task if that is where this block is kept
*
*  di_wake_next is used to link the "di_block"s for the performing
*  operation, so that it is obvious what needs to be alerted.
*
*  di_task points to the task to be alerted from type DI_TASK
*  di_oper points to the operation to be alerted from type DI_OPERATION
*  di_perform points to the operation performing the get dsa info operation
*/
typedef
    struct di_block
    {
	DN	  di_dn;	/* Name of dsa this block refers to */

	char	  di_type;	/* Global list, operation list or task list */
#define DI_GLOBAL	1	/* deferred_dis lists this block */
#define DI_OPERATION	2	/* di_oper lists this block */
#define DI_TASK		3	/* di_task lists this block */

	struct task_act		* di_task;
	struct oper_act		* di_oper;

/*
*  The following are needed to generate chaining arguments from DSAInformation
*  in the case of chaining (DI_OPERATION); and to generate continuation
*  references in the case of referring (DI_TASK). Not present for DI_GLOBAL
*/
	DN			  di_target;
	int			  di_reftype;
	int			  di_rdn_resolved;
	int			  di_aliasedRDNs;

	char	  di_state;	/* How the dsa information is formed */
#define DI_COMPLETE	1	/* di_entry filled out */
#define DI_ACCESSPOINT	2	/* di_accesspoints filled out */
#define DI_DEFERRED	3	/* di_perform still generating di_entry */

	struct access_point	* di_accesspoints;

	Entry			  di_entry;

	struct oper_act		* di_perform;
	struct di_block		* di_wake_next;	/* List of blocks to wake */

	struct di_block		* di_next;	/* List of blocks */
    } DI_Block;
#define NULL_DI_BLOCK	((struct di_block *) NULL)

typedef
    struct init_activity
    {
	char                            ia_class;
	char                            ia_type;

	struct AcSAPstart               * ia_acs;
	int                             ia_defctxres;

	struct ds_bind_arg              ia_req;
	struct ds_bind_arg		ia_res;
	struct ds_bind_error		ia_err;

	int				ia_vecp;
	char 				*ia_vec[4];
	/* Vector to pass AcInit() when a new association is ready */

    } InitActivity;

typedef
    struct response
    {
	char                    resp_type;
	char                    ret_type;

	struct ds_op_res        resp_res;
	struct DSError          resp_err;
	int                     resp_rej;
	ContinuationRef         resp_ref;
    } OpenResponse;

typedef
    struct task_act
    {
	int                     tk_id;
	int                     tk_prio;
	char                    tk_state;
#define TK_ACTIVE		  1	/* Task ready to have work done */
#define TK_PASSIVE		  2	/* Task waiting for operation */
#define TK_SUSPEND		  3	/* Giving the network a chance */
#define TK_DEFERRED		  4	/* Waiting to generate referral */

	char                    tk_type;

	struct di_block		* tk_dsas;	/* di_blocks for referral */

	struct ds_op_arg        tk_req;
	struct chain_arg	*tk_cha;
	struct common_args      *tk_ca;

	struct response         tk_resp;
	struct ds_op_res        *tk_result;
	struct DSError          *tk_error;

	/* Specific additions to provide multi-subtask search implementation */
	struct ds_search_task	*local_st;
	struct ds_search_task	*refer_st;
	struct ds_search_task	*referred_st;

	char			tk_timed;
	time_t			tk_timeout;
	struct oper_act         *tk_operlist;
	struct task_act         *tk_next;

	struct connection       *tk_conn;
    } * Task;
#define NULLTASK ((struct task_act *) NULL)

typedef
    struct ns_task_act
    {
	PS	ns_ts_ps;
	int	ns_ts_id;
	int	ns_ts_fd;
	AttributeType	ns_ts_attr;
    } * NS_Task;
#define NULLNS_TASK ((struct ns_task_act *) NULL)

typedef
    struct oper_act
    {
	int                       on_id;
	char                      on_state;
#define ON_DEFERRED		  1	/* Waiting for DSA INFO */
#define ON_WAITING		  2	/* Waiting to open connection */
#define ON_CHAINED		  3	/* Waiting for a response */
#define ON_COMPLETE		  4	/* Waiting to be used by task */
#define ON_ABANDONED		  5	/* Waiting for response - no task */

	char                      on_type;
#define ON_TYPE_X500		  1
#define ON_TYPE_BIND_COMPARE	  2
#define ON_TYPE_GET_DSA_INFO	  3
#define ON_TYPE_NAMESERVICE	  4
#define ON_TYPE_GET_EDB		  5
#define ON_TYPE_SUBTASK		  6

/* Specific to ON_TYPE_X500 */
	struct task_act         *on_task;		/* Task to wake */

/* Specific to ON_TYPE_BIND_COMPARE */
	struct connection	*on_bind_compare;	/* Bind to wake */

/* Specific to ON_TYPE_GET_DSA_INFO */
	struct di_block		* on_wake_list;		/* di_blocks to wake */

/* Specific to ON_TYPE_NAMESERVICE */
	struct ns_task_act	* on_nstask;		/* ns task to wake */

/* Specific to ON_TYPE_GET_EDB */
	Entry			  on_getedb_eptr;	/* previous entry */
	char			* on_getedb_ver;	/* previous version */

/* Specific to ON_TYPE_SUBTASK */
	struct ds_search_task	* on_subtask;

	struct di_block		* on_dsas;	/* DSAInfos for chaining */

	struct ds_op_arg        on_req;		/* Argument stuff */
	struct ds_op_arg	*on_arg;
	struct chain_arg	*on_cha;
	struct common_args      *on_ca;

	struct response         on_resp;	/* Response stuff */
	struct ds_op_res        *on_result;
	struct DSError          *on_error;

	struct oper_act         *on_next_conn;
	struct oper_act         *on_next_task;

	struct connection       *on_conn;
    } Oper;
#define NULLOPER ((struct oper_act *) NULL)

/*
* Conn is the structure used to represent external connections
*/
typedef
    struct connection
    {
	char			  cn_state;
/* State of the connection */
#define CN_INDICATED		  1
#define CN_WAITING		  2
#define CN_CONNECTING1		  3
#define CN_CONNECTING2		  4
#define CN_OPEN			  5
#define CN_FAILED		  6
#define CN_CLOSING		  7
#define CN_OPENING		  8

	char			  cn_ctx; 
/* CN_CTX values defined in dsargument.h for use by decoders */

	char			  cn_initiator;
/* Flags whether THIS DSA or THAT (REMOTE) DSA initiated connection */
#define INITIATED_BY_THIS         1
#define INITIATED_BY_THAT         2

	struct init_activity	  cn_init_act;
/* Information used during initialisation of the connection */

	struct oper_act 	* cn_bind_compare;
/* Handle on remote compare operation (if any) during initialisation */

        time_t			  cn_last_used;
/* Time at which this connection was last used */

        time_t			  cn_last_release;
/* Time at which this connection release was last attempted */

	DN                        cn_who;
/* Name of entity requesting the association is producing this operation */

	DN                        cn_what;
/* Name of the entity at the far end of the connection */

	struct PSAPaddr           cn_addr;
/* Address of the entity at the far end of the connection */

	int                       cn_ad;
/* Descriptor identifying the association on which the connection is based */

	int			  cn_context_id;
/* Context identifier of context to be used for user-data. */

	int                       cn_op_id;
/* Used to ensure unique invoke id's are used when invoking operations. */

	struct task_act		* cn_tasklist;
/* List of tasks received over this connection. */

	struct oper_act		* cn_operlist;
/* List of operations sent over this connection. */

	struct connection       * cn_next;
/* Rest of list of connections. */

	int 			cn_authen;
/* Takes a value from bind.h -> level to which the association is authenticated */

    } *Conn;
#define NULLCONN ((Conn) NULL)

/*
*  Global variables are nasty but useful. Here the external definitions
*  for the most crucial are given:
*	a handle on the connections being processed
*	info describing how this DSA wants the lower layers parameterised
*	a handle on current deferred get dsa info operations
*	a handle on current get_edb operations
*/
extern struct connection	* connlist;     /* Connection blocks */
extern int			  conns_used;	/* No. conns in connlist */
extern struct connection	* connwaitlist; /* Connection blocks to be */
extern struct di_block		* deferred_dis;	/* deferred di_blocks */
extern struct oper_act		* get_edb_ops;	/* GET_EDB operations */
extern struct PSAPaddr		* mydsaaddr;	/* PSAP of this DSA */

#endif
DataMuseum.dk

DKUUG/EUUG Conference tapes

⟦4e0d05dba⟧ TextFile

Derivation

TextFile
