2.11BSD/ingres/source/equel/runtime/IIsync.c
# include "../../ingres.h"
# include "../../symbol.h"
# include "../../pipes.h"
# include "IIglobals.h"
/*
** IIsync is called to syncronize the running
** of a query with the running of the equel process.
**
** The query is flushed and an EOP is written
** to the quel parser.
**
** The quel parser will write an end-of-pipe when
** an operation is complete.
*/
IIsync(file_name, line_no)
char *file_name;
int line_no;
{
if (IIproc_name = file_name)
IIline_no = line_no;
# ifdef xETR1
if (IIdebug)
printf("IIsync\n");
# endif
IIwrpipe(P_END, &IIoutpipe, IIw_down);
IIwrpipe(P_PRIME, &IIoutpipe, IIw_down);
IIerrflag = 0; /* reset error flag. If an error occures,
** IIerrflag will get set in IIerror
*/
IIrdpipe(P_SYNC, &IIinpipe, IIr_down);
IIrdpipe(P_PRIME, &IIinpipe);
}