6 * Copyright (C) 1987 by the Massachusetts Institute of Technology
10 #include <sys/types.h>
12 #include <sys/socket.h>
13 #include <netinet/in.h>
15 #include <moira_site.h>
20 typedef struct returned_tuples {
21 struct returned_tuples *next;
27 * This should be in the kerberos header file.
37 * This structure holds all per-client information; one of these is
38 * allocated for each active client.
41 typedef struct _client {
42 OPERATION pending_op; /* Primary pending operation */
43 CONNECTION con; /* Connection to the client */
44 int action; /* what action is pending? */
45 mr_params *args, reply;
46 int id; /* Unique id of client */
47 struct sockaddr_in haddr; /* IP address of client */
48 char clname[MAX_K_NAME_SZ];/* Name client authenticated to */
49 struct krbname kname; /* Parsed version of the above */
50 int users_id; /* MR internal ID of authenticated user */
51 int client_id; /* MR internal ID of client for modby field */
52 returned_tuples *first, *last;
53 time_t last_time_used; /* Last time connection used */
54 char entity[9]; /* entity on other end of the connection */
72 extern char *krb_realm;
80 #define LOG_CONNECT 0x0001
81 #define LOG_REQUESTS 0x0002
82 #define LOG_ARGS 0x0004
83 #define LOG_RESP 0x0008
84 #define LOG_RES 0x0010
85 #define LOG_VALID 0x0020
86 #define LOG_SQL 0x0040
87 #define LOG_GDSS 0x0080
90 /* max length of query argument allowed */
92 /* Used to setup static argv, maximum argc */
95 /* statistics on number of queries by version number */
96 extern int newqueries, oldqueries;
98 /* Maximum and minimum values that will ever be chosen for IDs */
99 #define MAX_ID_VALUE 31999
100 #define MIN_ID_VALUE 100
102 /* Sleepy states for the server! */
109 /* state for the incremental update system */
110 extern int inc_running, inc_pid;
111 extern time_t inc_started, now;
112 #define INC_TIMEOUT (3 * 60) /* 3 minutes */
115 #define SQL_NO_MATCH 1403 /* oracle, not ingres (= 100) */
117 /* prototypes from gdb */
119 int gdb_debug(int flag);
120 void start_accepting_client(CONNECTION, OPERATION, CONNECTION *,
121 char *, int*, TUPLE *);
122 int initialize_operation(OPERATION, int (*init_function)(), char *,
123 int (*cancel_function)());
124 int reset_operation(OPERATION);
125 int delete_operation(OPERATION);
126 int start_replying_to_client(OPERATION, CONNECTION, int, char *, char *);
127 int op_select(LIST_OF_OPERATIONS, int, fd_set *, fd_set *, fd_set *,
130 /* prototypes from libmoira */
131 struct save_queue *sq_create(void);
132 int sq_save_data(struct save_queue *sq, void *data);
133 int sq_save_unique_data(struct save_queue *sq, void *data);
134 int sq_save_args(int argc, void *argv[], struct save_queue *sq);
135 int sq_get_data(struct save_queue *sq, void *data);
136 int sq_remove_data(struct save_queue *sq, void *data);
137 int sq_empty(struct save_queue *sq);
138 void sq_destroy(struct save_queue *sq);
140 void send_zgram(char *instance, char *buf);
141 void critical_alert(char *, char *, ...);
142 void mr_destroy_reply(mr_params *reply);
145 /* prototypes from increment.dc */
146 void incremental_init(void);
147 void next_incremental(void);
148 void incremental_update(void);
149 void incremental_flush(void);
151 /* prototypes from qrtn.dc */
153 void dosql(char *buffers[]);
154 int mr_open_database(void);
155 void mr_close_database(void);
156 int mr_process_query(client *cl, char *name, int argc, char *argv_ro[],
157 int (*action)(), char *actarg);
158 int mr_check_access(client *cl, char *name, int argc, char *argv_ro[]);
159 void sanity_check_queries(void);
160 int set_krb_mapping(char *name, char *login, int ok, int *kid, int *uid);
161 int get_client(client *cl, char **client_type, int *client_id);
162 int find_member(char *list_type, int list_id, char *member_type,
164 int do_for_all_rows(char *query, int count, int (*action)(), int actarg);
165 int build_qual(char *fmt, int argc, char *argv[], char *qual);
168 /* prototyoes from qsupport.dc */
169 int set_pop_usage(int id, int cnt);
171 /* prototypes from qvalidate.dc */
172 void sanity_check_database(void);
173 int add_string(char *name);
174 int convert_wildcards(char *arg);
176 /* prototypes from mr_main.c */
177 void clist_delete(client *cp);
179 /* prototypes from mr_sauth.c */
180 void do_auth(client *cl);
182 /* prototypes from mr_scall.c */
183 void do_client(client *cp);
184 int trigger_dcm(int dummy0, int dummy1, client *cl);
186 /* prototypes from mr_shutdown.c */
188 void do_shutdown(client *cl);
190 /* prototypes from mr_util.c */
191 char *requote(char *buf, char *cp, int len);
192 void log_args(char *tag, int version, int argc, char **argv);
193 void mr_com_err(char *whoami, int code, char *fmt, caddr_t pvar);
194 int mr_trim_args(int argc, char **argv);
195 char **mr_copy_args(char **argv, int argc);