2 @file osrf_app_session.h
3 @brief Header for osrfAppSession.
6 #ifndef OSRF_APP_SESSION_H
7 #define OSRF_APP_SESSION_H
9 #include "opensrf/transport_client.h"
10 #include "opensrf/osrf_message.h"
11 #include "opensrf/osrf_system.h"
12 #include "opensrf/string_array.h"
13 #include "opensrf/osrfConfig.h"
14 #include "opensrf/osrf_hash.h"
15 #include "opensrf/osrf_list.h"
16 #include "opensrf/osrf_json.h"
22 enum OSRF_SESSION_STATE {
23 OSRF_SESSION_CONNECTING,
24 OSRF_SESSION_CONNECTED,
25 OSRF_SESSION_DISCONNECTED
28 enum OSRF_SESSION_TYPE {
33 struct osrf_app_request_struct;
34 typedef struct osrf_app_request_struct osrfAppRequest;
36 #define OSRF_REQUEST_HASH_SIZE 64
39 @brief Representation of a session with another application.
41 An osrfAppSession is a list of lists. It includes a list of osrfAppRequests
42 representing outstanding requests. Each osrfAppRequest includes a list of
45 struct osrf_app_session_struct {
47 /** Our message passing object */
48 transport_client* transport_handle;
50 /** The original remote id of the remote service we're talking to */
52 /** The current remote id of the remote service we're talking to */
55 /** Whom we're talking to if we're a client;
56 what app we're serving if we're a server */
59 /** The current request thread_trace */
64 /** Boolean; true if this session does not require connect messages.
65 Assigned a value depending on the compile-time macro ASSUME_STATELESS. */
68 /** The connect state */
69 enum OSRF_SESSION_STATE state;
71 /** SERVER or CLIENT */
72 enum OSRF_SESSION_TYPE type;
74 /** the current locale for this session. **/
77 /** let the user use the session to store their own session data. */
80 /** Callback function for freeing user's session data. */
81 void (*userDataFree) (void*);
85 /** Hash table of pending requests. */
86 osrfAppRequest* request_hash[ OSRF_REQUEST_HASH_SIZE ];
88 typedef struct osrf_app_session_struct osrfAppSession;
90 // --------------------------------------------------------------------------
92 // --------------------------------------------------------------------------
94 osrfAppSession* osrfAppSessionClientInit( const char* remote_service );
96 osrfAppSession* osrf_app_server_session_init(
97 const char* session_id, const char* our_app, const char* remote_id );
99 char* osrf_app_session_set_locale( osrfAppSession*, const char* );
101 osrfAppSession* osrf_app_session_find_session( const char* session_id );
103 /* DEPRECATED; use osrfAppSessionSendRequest() instead. */
104 int osrfAppSessionMakeRequest(
105 osrfAppSession* session, const jsonObject* params,
106 const char* method_name, int protocol, osrfStringArray* param_strings);
108 int osrfAppSessionSendRequest(
109 osrfAppSession* session, const jsonObject* params,
110 const char* method_name, int protocol );
112 void osrf_app_session_set_complete( osrfAppSession* session, int request_id );
114 int osrf_app_session_request_complete( const osrfAppSession* session, int request_id );
116 osrfMessage* osrfAppSessionRequestRecv(
117 osrfAppSession* session, int request_id, int timeout );
119 void osrf_app_session_request_finish( osrfAppSession* session, int request_id );
121 int osrf_app_session_request_resend( osrfAppSession*, int request_id );
123 void osrf_app_session_reset_remote( osrfAppSession* );
125 void osrf_app_session_set_remote( osrfAppSession* session, const char* remote_id );
127 void osrf_app_session_push_queue( osrfAppSession*, osrfMessage* msg );
129 int osrfAppSessionConnect( osrfAppSession* );
131 int osrf_app_session_disconnect( osrfAppSession* );
133 int osrf_app_session_queue_wait( osrfAppSession*, int timeout, int* recvd );
135 void osrfAppSessionFree( osrfAppSession* );
137 void osrf_app_session_request_reset_timeout( osrfAppSession* session, int req_id );
139 int osrfAppRequestRespond( osrfAppSession* ses, int requestId, const jsonObject* data );
141 int osrfAppRequestRespondComplete(
142 osrfAppSession* ses, int requestId, const jsonObject* data );
144 int osrfAppSessionStatus( osrfAppSession* ses, int type,
145 const char* name, int reqId, const char* message );
147 void osrfAppSessionCleanup( void );