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

Rename RemoveDirectory -> CitusRemoveDirectory

pull/1793/head
Brian Cloutier 2017-10-24 15:11:43 -07:00 committed by Brian Cloutier
parent 06f756b0a1
commit aa2ab023a2
5 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/distributed/executor/multi_server_executor.c
View File

@ -145,7 +145,7 @@ void
RemoveJobDirectory(uint64 jobId)
{
StringInfo jobDirectoryName = MasterJobDirectoryName(jobId);
RemoveDirectory(jobDirectoryName);
CitusRemoveDirectory(jobDirectoryName);
ResourceOwnerForgetJobDirectory(CurrentResourceOwner, jobId);
}

2
src/backend/distributed/worker/task_tracker.c
View File

@ -340,7 +340,7 @@ TrackerCleanupJobDirectories(void)
StringInfo jobCacheDirectory = makeStringInfo();
appendStringInfo(jobCacheDirectory, "base/%s", PG_JOB_CACHE_DIR);
RemoveDirectory(jobCacheDirectory);
CitusRemoveDirectory(jobCacheDirectory);
CreateDirectory(jobCacheDirectory);
FreeStringInfo(jobCacheDirectory);

2
src/backend/distributed/worker/task_tracker_protocol.c
View File

@ -211,7 +211,7 @@ task_tracker_cleanup_job(PG_FUNCTION_ARGS)
* writing to a table within the schema.
*/
jobDirectoryName = JobDirectoryName(jobId);
RemoveDirectory(jobDirectoryName);
CitusRemoveDirectory(jobDirectoryName);
LockJobResource(jobId, AccessExclusiveLock);
jobSchemaName = JobSchemaName(jobId);

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

@ -152,7 +152,7 @@ worker_range_partition_table(PG_FUNCTION_ARGS)
/* close partition files and atomically rename (commit) them */
ClosePartitionFiles(partitionFileArray, fileCount);
RemoveDirectory(taskDirectory);
CitusRemoveDirectory(taskDirectory);
RenameDirectory(taskAttemptDirectory, taskDirectory);
PG_RETURN_VOID();
@ -213,7 +213,7 @@ worker_hash_partition_table(PG_FUNCTION_ARGS)
/* close partition files and atomically rename (commit) them */
ClosePartitionFiles(partitionFileArray, fileCount);
RemoveDirectory(taskDirectory);
CitusRemoveDirectory(taskDirectory);
RenameDirectory(taskAttemptDirectory, taskDirectory);
PG_RETURN_VOID();
@ -615,13 +615,13 @@ CreateDirectory(StringInfo directoryName)
/*
* RemoveDirectory first checks if the given directory exists. If it does, the
* CitusRemoveDirectory first checks if the given directory exists. If it does, the
* function recursively deletes the contents of the given directory, and then
* deletes the directory itself. This function is modeled on the Boost file
* system library's remove_all() method.
*/
void
RemoveDirectory(StringInfo filename)
CitusRemoveDirectory(StringInfo filename)
{
struct stat fileStat;
int removed = 0;
@ -674,7 +674,7 @@ RemoveDirectory(StringInfo filename)
fullFilename = makeStringInfo();
appendStringInfo(fullFilename, "%s/%s", directoryName, baseFilename);
RemoveDirectory(fullFilename);
CitusRemoveDirectory(fullFilename);
FreeStringInfo(fullFilename);
}

2
src/include/distributed/worker_protocol.h
View File

@ -115,7 +115,7 @@ extern bool CacheDirectoryElement(const char *filename);
extern bool JobDirectoryElement(const char *filename);
extern bool DirectoryExists(StringInfo directoryName);
extern void CreateDirectory(StringInfo directoryName);
extern void RemoveDirectory(StringInfo filename);
extern void CitusRemoveDirectory(StringInfo filename);
extern StringInfo InitTaskDirectory(uint64 jobId, uint32 taskId);
extern void RemoveJobSchema(StringInfo schemaName);
extern Datum * DeconstructArrayObject(ArrayType *arrayObject);