Assert(strcmp(lastRestartPointFname, xlogfname) <= 0);
}
else
- XLogFileName(lastRestartPointFname, 0, 0L, wal_segment_size);
+ XLogFileName(lastRestartPointFname, 0, 0, wal_segment_size);
/* Build the restore command to execute */
xlogRestoreCmd = BuildRestoreCommand(recoveryRestoreCommand,
* We've written all the data to the manifest file. Rewind the file so
* that we can read it all back.
*/
- if (BufFileSeek(manifest->buffile, 0, 0L, SEEK_SET))
+ if (BufFileSeek(manifest->buffile, 0, 0, SEEK_SET))
ereport(ERROR,
(errcode_for_file_access(),
errmsg("could not rewind temporary file")));
else
{
/* run the plan --- the dest receiver will send tuples */
- ExecutorRun(cstate->queryDesc, ForwardScanDirection, 0L, true);
+ ExecutorRun(cstate->queryDesc, ForwardScanDirection, 0, true);
processed = ((DR_copy *) cstate->queryDesc->dest)->processed;
}
ExecutorStart(queryDesc, GetIntoRelEFlags(into));
/* run the plan to completion */
- ExecutorRun(queryDesc, ForwardScanDirection, 0L, true);
+ ExecutorRun(queryDesc, ForwardScanDirection, 0, true);
/* save the rowcount if we're given a qc to fill */
if (qc)
dir = ForwardScanDirection;
/* run the plan */
- ExecutorRun(queryDesc, dir, 0L, true);
+ ExecutorRun(queryDesc, dir, 0, true);
/* run cleanup too */
ExecutorFinish(queryDesc);
ExecutorStart(queryDesc, 0);
/* run the plan */
- ExecutorRun(queryDesc, ForwardScanDirection, 0L, true);
+ ExecutorRun(queryDesc, ForwardScanDirection, 0, true);
processed = queryDesc->estate->es_processed;
NULL);
/* Fetch the result set into the tuplestore */
- ExecutorRun(queryDesc, direction, 0L, false);
+ ExecutorRun(queryDesc, direction, 0, false);
queryDesc->dest->rDestroy(queryDesc->dest);
queryDesc->dest = NULL;
if (innerFile != NULL)
{
- if (BufFileSeek(innerFile, 0, 0L, SEEK_SET))
+ if (BufFileSeek(innerFile, 0, 0, SEEK_SET))
ereport(ERROR,
(errcode_for_file_access(),
errmsg("could not rewind hash-join temporary file")));
*/
if (hashtable->outerBatchFile[curbatch] != NULL)
{
- if (BufFileSeek(hashtable->outerBatchFile[curbatch], 0, 0L, SEEK_SET))
+ if (BufFileSeek(hashtable->outerBatchFile[curbatch], 0, 0, SEEK_SET))
ereport(ERROR,
(errcode_for_file_access(),
errmsg("could not rewind hash-join temporary file")));
file->dirty = false;
file->resowner = CurrentResourceOwner;
file->curFile = 0;
- file->curOffset = 0L;
+ file->curOffset = 0;
file->pos = 0;
file->nbytes = 0;
file->curFile + 1 < file->numFiles)
{
file->curFile++;
- file->curOffset = 0L;
+ file->curOffset = 0;
}
thisfile = file->files[file->curFile];
while (file->curFile + 1 >= file->numFiles)
extendBufFile(file);
file->curFile++;
- file->curOffset = 0L;
+ file->curOffset = 0;
}
/*
/*
* Run the plan to completion.
*/
- ExecutorRun(queryDesc, ForwardScanDirection, 0L, true);
+ ExecutorRun(queryDesc, ForwardScanDirection, 0, true);
/*
* Build command completion status data, if caller wants one.
case TSS_WRITEFILE:
readptr->eof_reached = false;
readptr->file = 0;
- readptr->offset = 0L;
+ readptr->offset = 0;
break;
case TSS_READFILE:
readptr->eof_reached = false;
- if (BufFileSeek(state->myfile, 0, 0L, SEEK_SET) != 0)
+ if (BufFileSeek(state->myfile, 0, 0, SEEK_SET) != 0)
ereport(ERROR,
(errcode_for_file_access(),
errmsg("could not seek in tuplestore temporary file")));