andersk Git - moira.git/blame_incremental

... / ...

Commit	Line	Data
	1	/*
	2	* $Source$
	3	* $Author$
	4	* $Header$
	5	*
	6	* Copyright (C) 1987 by the Massachusetts Institute of Technology
	7	* For copying and distribution information, please see the file
	8	* <mit-copyright.h>.
	9	*
	10	*/
	11
	12	#ifndef lint
	13	static char *rcsid_sms_query_c = "$Header$";
	14	#endif lint
	15
	16	#include <mit-copyright.h>
	17	#include "mr_private.h"
	18
	19	/*
	20	* This routine is the primary external interface to the mr library.
	21	*
	22	* It builds a new argument vector with the query handle prepended,
	23	* and calls mr_query_internal.
	24	*/
	25	int level = 0;
	26
	27	int mr_query(name, argc, argv, callproc, callarg)
	28	char name; / Query name */
	29	int argc; /* Arg count */
	30	char *argv; / Args */
	31	int (callproc)(); / Callback procedure */
	32	char callarg; / Callback argument */
	33	{
	34	register char nargv = (char )malloc(sizeof(char ) (argc+1));
	35	register int status = 0;
	36	nargv[0] = name;
	37	bcopy((char )argv, (char )(nargv+1), sizeof(char ) argc);
	38	status = mr_query_internal(argc+1, nargv, callproc, callarg);
	39	free(nargv);
	40	return status;
	41	}
	42	/*
	43	* This routine makes an MR query.
	44	*
	45	* argv[0] is the query name.
	46	* argv[1..argc-1] are the query arguments.
	47	*
	48	* callproc is called once for each returned value, with arguments
	49	* argc, argv, and callarg.
	50	* If it returns a non-zero value, further calls to it are not done, and
	51	* all future data from the server is ignored (there should be some
	52	* way to send it a quench..)
	53	*/
	54
	55	int mr_query_internal(argc, argv, callproc, callarg)
	56	int argc; /* Arg count */
	57	char *argv; / Args */
	58	int (callproc)(); / Callback procedure */
	59	char callarg; / Callback argument */
	60	{
	61	int status;
	62	mr_params params_st;
	63	register mr_params *params = NULL;
	64	mr_params *reply = NULL;
	65	int stopcallbacks = 0;
	66
	67	if (level) return MR_QUERY_NOT_REENTRANT;
	68
	69	CHECK_CONNECTED;
	70	level++;
	71
	72	params = &params_st;
	73	params->mr_version_no = sending_version_no;
	74	params->mr_procno = MR_QUERY;
	75	params->mr_argc = argc;
	76	params->mr_argl = NULL;
	77	params->mr_argv = argv;
	78
	79	if ((status = mr_do_call(params, &reply)))
	80	goto punt;
	81
	82	while ((status = reply->mr_status) == MR_MORE_DATA) {
	83	if (!stopcallbacks)
	84	stopcallbacks =
	85	(*callproc)(reply->mr_argc, reply->mr_argv, callarg);
	86	mr_destroy_reply(reply);
	87	reply = NULL;
	88
	89	initialize_operation(_mr_recv_op, mr_start_recv, &reply,
	90	(int (*)())NULL);
	91	queue_operation(_mr_conn, CON_INPUT, _mr_recv_op);
	92
	93	mr_complete_operation(_mr_recv_op);
	94	if (OP_STATUS(_mr_recv_op) != OP_COMPLETE) {
	95	mr_disconnect();
	96	status = MR_ABORTED;
	97	goto punt_1;
	98	}
	99	}
	100	punt:
	101	mr_destroy_reply(reply);
	102	punt_1:
	103	level--;
	104	return status;
	105	}