X-Git-Url: http://git.indexdata.com/?p=yaz-moved-to-github.git;a=blobdiff_plain;f=server%2Fsession.h;h=5217a897bc30b3ea98bcacb90db1fecce431fda8;hp=b36448af8d9ef1ec088ac1650bc24fcb4f9aac24;hb=59526fbbf2e3b54ce94b3e79e6c7fef9e4f456fb;hpb=b200b3ce30a8db1d68b2ddfe9994acff1a5d2789 diff --git a/server/session.h b/server/session.h index b36448a..5217a89 100644 --- a/server/session.h +++ b/server/session.h @@ -1,10 +1,71 @@ /* - * Copyright (C) 1994, Index Data I/S - * All rights reserved. + * Copyright (C) 1995-1999, Index Data + * See the file LICENSE for details. * Sebastian Hammer, Adam Dickmeiss * * $Log: session.h,v $ - * Revision 1.5 1995-04-20 15:13:01 quinn + * Revision 1.24 2000-11-23 10:58:32 adam + * SSL comstack support. Separate POSIX thread support library. + * + * Revision 1.23 2000/04/05 07:39:55 adam + * Added shared library support (libtool). + * + * Revision 1.22 2000/03/20 19:06:25 adam + * Added Segment request for fronend server. Work on admin for client. + * + * Revision 1.21 1999/11/30 13:47:12 adam + * Improved installation. Moved header files to include/yaz. + * + * Revision 1.20 1999/10/11 10:01:24 adam + * Implemented bend_sort_rr handler for frontend server. + * + * Revision 1.19 1999/04/20 09:56:48 adam + * Added 'name' paramter to encoder/decoder routines (typedef Odr_fun). + * Modified all encoders/decoders to reflect this change. + * + * Revision 1.18 1998/08/03 10:23:57 adam + * Fixed bug regarding Options for Sort. + * + * Revision 1.17 1998/07/20 12:38:43 adam + * Implemented delete result set service to server API. + * + * Revision 1.16 1998/03/31 11:07:45 adam + * Furhter work on UNIverse resource report. + * Added Extended Services handling in frontend server. + * + * Revision 1.15 1998/02/11 11:53:36 adam + * Changed code so that it compiles as C++. + * + * Revision 1.14 1998/02/10 11:03:57 adam + * Added support for extended handlers in backend server interface. + * + * Revision 1.13 1998/01/29 13:30:23 adam + * Better event handle system for NT/Unix. + * + * Revision 1.12 1997/09/01 08:53:01 adam + * New windows NT/95 port using MSV5.0. The test server 'ztest' was + * moved a separate directory. MSV5.0 project server.dsp created. + * As an option, the server can now operate as an NT service. + * + * Revision 1.11 1995/11/08 17:41:40 quinn + * Smallish. + * + * Revision 1.10 1995/08/29 11:18:01 quinn + * Added code to receive close + * + * Revision 1.9 1995/06/16 10:31:38 quinn + * Added session timeout. + * + * Revision 1.8 1995/05/17 08:42:28 quinn + * Transfer auth info to backend. Allow backend to reject init gracefully. + * + * Revision 1.7 1995/05/16 08:51:08 quinn + * License, documentation, and memory fixes + * + * Revision 1.6 1995/05/15 11:56:41 quinn + * Asynchronous facilities. Restructuring of seshigh code. + * + * Revision 1.5 1995/04/20 15:13:01 quinn * Cosmetic * * Revision 1.4 1995/04/10 10:23:39 quinn @@ -26,13 +87,55 @@ #ifndef SESSION_H #define SESSION_H -#include -#include -#include +#include +#include +#include +#include +#include +#include "eventl.h" + +typedef enum { + REQUEST_IDLE, /* the request is just sitting in the queue */ + REQUEST_PENDING /* operation pending (b'end processing or network I/O*/ + /* this list will have more elements when acc/res control is added */ +} request_state; + +typedef struct request +{ + int len_refid; /* length of referenceid */ + char *refid; /* referenceid */ + request_state state; + + Z_APDU *request; /* Current request */ + NMEM request_mem; /* memory handle for request */ + + int size_response; /* size of buffer */ + int len_response; /* length of encoded data */ + char *response; /* encoded data waiting for transmission */ + + void *clientData; + struct request *next; + struct request_q *q; +} request; + +typedef struct request_q +{ + request *head; + request *tail; + request *list; + int num; +} request_q; /* * association state. */ +typedef enum +{ + ASSOC_NEW, /* not initialized yet */ + ASSOC_UP, /* normal operation */ + ASSOC_DEAD /* dead. Close if input arrives */ +} association_state; + typedef struct association { IOCHAN client_chan; /* event-loop control */ @@ -40,20 +143,49 @@ typedef struct association ODR decode; /* decoding stream */ ODR encode; /* encoding stream */ ODR print; /* printing stream (for -a) */ - char *encode_buffer; /* temporary holding of encoded data */ + char *encode_buffer; /* temporary buffer for encoded data */ int encoded_len; /* length of encoded data */ char *input_buffer; /* input buffer (allocated by comstack) */ int input_buffer_len; /* length (size) of buffer */ int input_apdu_len; /* length of current incoming APDU */ oid_proto proto; /* protocol (PROTO_Z3950/PROTO_SR) */ void *backend; /* backend handle */ + request_q incoming; /* Q of incoming PDUs */ + request_q outgoing; /* Q of outgoing data buffers (enc. PDUs) */ + association_state state; - int preferredMessageSize; /* session parameters */ + /* session parameters */ + int preferredMessageSize; int maximumRecordSize; + int version; /* highest version-bit set (2 or 3) */ + + unsigned cs_get_mask; + unsigned cs_put_mask; + unsigned cs_accept_mask; + + struct bend_initrequest *init; +#if 0 + int (*bend_sort) (); + int (*bend_search) (); + int (*bend_present) (); + int (*bend_esrequest) (); + int (*bend_delete) (); + int (*bend_scan) (); + int (*bend_segment) (); +#endif } association; association *create_association(IOCHAN channel, COMSTACK link); void destroy_association(association *h); void ir_session(IOCHAN h, int event); +void request_enq(request_q *q, request *r); +request *request_head(request_q *q); +request *request_deq(request_q *q); +request *request_deq_x(request_q *q, request *r); +void request_initq(request_q *q); +void request_delq(request_q *q); +request *request_get(request_q *q); +void request_release(request *r); + #endif