2.11BSD/ingres/source/equel/runtime/IIflushtup.c
# include "../../ingres.h"
# include "../../aux.h"
# include "../../symbol.h"
# include "../../tree.h"
# include "../../pipes.h"
# include "IIglobals.h"
/*
** IIflushtup is called to syncronize the data pipe
** after a retrieve.
*/
IIflushtup(file_name, line_no)
char *file_name;
int line_no;
{
register int i;
struct retcode ret;
if (IIproc_name = file_name)
IIline_no = line_no;
# ifdef xATR1
if (IIdebug)
printf("IIflushtup : IIerrflag %d\n",
IIerrflag);
# endif
if (IIerrflag < 2000)
{
/* flush the data pipe */
IIrdpipe(P_SYNC, &IIeinpipe, IIr_front);
IIrdpipe(P_PRIME, &IIeinpipe);
/* flush the control pipe */
if ((i = IIrdpipe(P_NORM, &IIinpipe, IIr_down, &ret, sizeof (ret))) == sizeof (ret))
{
/* there was a tuple count field */
IItupcnt = ret.rc_tupcount;
}
IIrdpipe(P_SYNC, &IIinpipe, IIr_down);
IIrdpipe(P_PRIME, &IIinpipe);
}
IIin_retrieve = 0;
IIndomains = 0;
IIdomains = 0;
}