2.11BSD#431 - /usr/ingres/source/equel/runtime/IIflushtup.c

   1: # include   "../../ingres.h"
   2: # include   "../../aux.h"
   3: # include   "../../symbol.h"
   4: # include   "../../tree.h"
   5: # include   "../../pipes.h"
   6: # include   "IIglobals.h"
   7: 
   8: /*
   9: **	IIflushtup is called to syncronize the data pipe
  10: **	after a retrieve.
  11: */
  12: 
  13: IIflushtup(file_name, line_no)
  14: char    *file_name;
  15: int line_no;
  16: {
  17:     register int        i;
  18:     struct retcode      ret;
  19: 
  20:     if (IIproc_name = file_name)
  21:         IIline_no = line_no;
  22: 
  23: #	ifdef xATR1
  24:     if (IIdebug)
  25:         printf("IIflushtup : IIerrflag %d\n",
  26:         IIerrflag);
  27: #	endif
  28: 
  29:     if (IIerrflag < 2000)
  30:     {
  31:         /* flush the data pipe */
  32:         IIrdpipe(P_SYNC, &IIeinpipe, IIr_front);
  33:         IIrdpipe(P_PRIME, &IIeinpipe);
  34: 
  35:         /* flush the control pipe */
  36:         if ((i = IIrdpipe(P_NORM, &IIinpipe, IIr_down, &ret, sizeof (ret))) == sizeof (ret))
  37:         {
  38:             /* there was a tuple count field */
  39:             IItupcnt = ret.rc_tupcount;
  40:         }
  41:         IIrdpipe(P_SYNC, &IIinpipe, IIr_down);
  42:         IIrdpipe(P_PRIME, &IIinpipe);
  43:     }
  44:     IIin_retrieve = 0;
  45:     IIndomains = 0;
  46:     IIdomains = 0;
  47: }

Defined functions