1: # include "../../ingres.h" 2: # include "../../symbol.h" 3: # include "../../pipes.h" 4: # include "IIglobals.h" 5: 6: /* 7: ** IIsync is called to syncronize the running 8: ** of a query with the running of the equel process. 9: ** 10: ** The query is flushed and an EOP is written 11: ** to the quel parser. 12: ** 13: ** The quel parser will write an end-of-pipe when 14: ** an operation is complete. 15: */ 16: 17: IIsync(file_name, line_no) 18: char *file_name; 19: int line_no; 20: { 21: if (IIproc_name = file_name) 22: IIline_no = line_no; 23: 24: # ifdef xETR1 25: if (IIdebug) 26: printf("IIsync\n"); 27: # endif 28: 29: IIwrpipe(P_END, &IIoutpipe, IIw_down); 30: IIwrpipe(P_PRIME, &IIoutpipe, IIw_down); 31: 32: IIerrflag = 0; /* reset error flag. If an error occures, 33: ** IIerrflag will get set in IIerror 34: */ 35: IIrdpipe(P_SYNC, &IIinpipe, IIr_down); 36: IIrdpipe(P_PRIME, &IIinpipe); 37: }