external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Rename DeleteFile -> CitusDeleteFile

pull/1794/head
Brian Cloutier 2017-10-24 15:12:40 -07:00 committed by Brian Cloutier
parent 4f3f30f939
commit 06f756b0a1
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/backend/distributed/worker/worker_data_fetch_protocol.c
View File

@ -65,7 +65,7 @@ static bool ReceiveRegularFile(const char *nodeName, uint32 nodePort,
StringInfo filePath); StringInfo filePath);
static void ReceiveResourceCleanup(int32 connectionId, const char *filename, static void ReceiveResourceCleanup(int32 connectionId, const char *filename,
int32 fileDescriptor); int32 fileDescriptor);
static void DeleteFile(const char *filename); static void CitusDeleteFile(const char *filename);
static void FetchTableCommon(text *tableName, uint64 remoteTableSize, static void FetchTableCommon(text *tableName, uint64 remoteTableSize,
ArrayType *nodeNameObject, ArrayType *nodePortObject, ArrayType *nodeNameObject, ArrayType *nodePortObject,
bool (*FetchTableFunction)(const char *, uint32, bool (*FetchTableFunction)(const char *, uint32,
@ -370,7 +370,7 @@ ReceiveRegularFile(const char *nodeName, uint32 nodePort, const char *nodeUser,
errmsg("could not close file \"%s\": %m", filename))); errmsg("could not close file \"%s\": %m", filename)));
/* if we failed to close file, try to delete it before erroring out */ /* if we failed to close file, try to delete it before erroring out */
DeleteFile(filename); CitusDeleteFile(filename);
return false; return false;
} }
@ -418,7 +418,7 @@ ReceiveResourceCleanup(int32 connectionId, const char *filename, int32 fileDescr
/* Deletes file with the given filename. */ /* Deletes file with the given filename. */
static void static void
DeleteFile(const char *filename) CitusDeleteFile(const char *filename)
{ {
int deleted = unlink(filename); int deleted = unlink(filename);
if (deleted != 0) if (deleted != 0)
@ -894,7 +894,7 @@ FetchRegularTable(const char *nodeName, uint32 nodePort, const char *tableName)
PROCESS_UTILITY_TOPLEVEL, NULL, None_Receiver, NULL); PROCESS_UTILITY_TOPLEVEL, NULL, None_Receiver, NULL);
/* finally delete the temporary file we created */ /* finally delete the temporary file we created */
DeleteFile(localFilePath->data); CitusDeleteFile(localFilePath->data);
SetUserIdAndSecContext(savedUserId, savedSecurityContext); SetUserIdAndSecContext(savedUserId, savedSecurityContext);
@ -1289,7 +1289,7 @@ worker_append_table_to_shard(PG_FUNCTION_ARGS)
PROCESS_UTILITY_TOPLEVEL, NULL, None_Receiver, NULL); PROCESS_UTILITY_TOPLEVEL, NULL, None_Receiver, NULL);
/* finally delete the temporary file we created */ /* finally delete the temporary file we created */
DeleteFile(localFilePath->data); CitusDeleteFile(localFilePath->data);
PG_RETURN_VOID(); PG_RETURN_VOID();
} }