farrokhi/pg_repack
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Whitespace cleanup.

Browse Source
This commit is contained in:
Josh Kupershmidt 2016-05-07 09:24:05 -04:00
parent de060af137
commit eb2e9c39fb
1 changed files with 15 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
bin/pg_repack.c
View File

@ -943,7 +943,7 @@ rebuild_indexes(const repack_table *table)
} }
CLEARPGRES(res); CLEARPGRES(res);
} }
/* We are only going to re-queue one worker, even /* We are only going to re-queue one worker, even
* though more than one index build might be finished. * though more than one index build might be finished.
* Any other jobs which may be finished will * Any other jobs which may be finished will
@ -1051,7 +1051,7 @@ repack_one_table(repack_table *table, const char *orderby)
if (dryrun) if (dryrun)
return; return;
/* push repack_cleanup_callback() on stack to clean temporary objects */ /* push repack_cleanup_callback() on stack to clean temporary objects */
pgut_atexit_push(repack_cleanup_callback, &table->target_oid); pgut_atexit_push(repack_cleanup_callback, &table->target_oid);
@ -1328,7 +1328,7 @@ repack_one_table(repack_table *table, const char *orderby)
* of APPLY_COUNT, until applying a batch of tuples * of APPLY_COUNT, until applying a batch of tuples
* (via LIMIT) results in our having applied * (via LIMIT) results in our having applied
* MIN_TUPLES_BEFORE_SWITCH or fewer tuples. We don't want to * MIN_TUPLES_BEFORE_SWITCH or fewer tuples. We don't want to
* get stuck repetitively applying some small number of tuples * get stuck repetitively applying some small number of tuples
* from the log table as inserts/updates/deletes may be * from the log table as inserts/updates/deletes may be
* constantly coming into the original table. * constantly coming into the original table.
*/ */
@ -1392,14 +1392,14 @@ repack_one_table(repack_table *table, const char *orderby)
elog(DEBUG2, "---- drop ----"); elog(DEBUG2, "---- drop ----");
command("BEGIN ISOLATION LEVEL READ COMMITTED", 0, NULL); command("BEGIN ISOLATION LEVEL READ COMMITTED", 0, NULL);
if (!(lock_exclusive(connection, utoa(table->target_oid, buffer), if (!(lock_exclusive(connection, utoa(table->target_oid, buffer),
table->lock_table, FALSE))) table->lock_table, FALSE)))
{ {
elog(WARNING, "lock_exclusive() failed in connection for %s", elog(WARNING, "lock_exclusive() failed in connection for %s",
table->target_name); table->target_name);
goto cleanup; goto cleanup;
} }
params[1] = utoa(temp_obj_num, indexbuffer); params[1] = utoa(temp_obj_num, indexbuffer);
command("SELECT repack.repack_drop($1, $2)", 2, params); command("SELECT repack.repack_drop($1, $2)", 2, params);
command("COMMIT", 0, NULL); command("COMMIT", 0, NULL);
@ -1711,7 +1711,7 @@ repack_cleanup_callback(bool fatal, void *userdata)
Oid target_table = *(Oid *) userdata; Oid target_table = *(Oid *) userdata;
const char *params[2]; const char *params[2];
char buffer[12]; char buffer[12];
char num_buff[12]; char num_buff[12];
if(fatal) if(fatal)
{ {
@ -1900,7 +1900,7 @@ repack_table_indexes(PGresult *index_details)
table_name); table_name);
if (!(lock_exclusive(connection, params[1], sql.data, TRUE))) if (!(lock_exclusive(connection, params[1], sql.data, TRUE)))
{ {
elog(WARNING, "lock_exclusive() failed in connection for %s", elog(WARNING, "lock_exclusive() failed in connection for %s",
table_name); table_name);
goto drop_idx; goto drop_idx;
} }
@ -1974,7 +1974,7 @@ repack_all_indexes(char *errbuf, size_t errsize)
if (r_index.head) if (r_index.head)
{ {
appendStringInfoString(&sql, appendStringInfoString(&sql,
"SELECT i.relname, idx.indexrelid, idx.indisvalid, idx.indrelid, idx.indrelid::regclass, n.nspname" "SELECT i.relname, idx.indexrelid, idx.indisvalid, idx.indrelid, idx.indrelid::regclass, n.nspname"
" FROM pg_index idx JOIN pg_class i ON i.oid = idx.indexrelid" " FROM pg_index idx JOIN pg_class i ON i.oid = idx.indexrelid"
" JOIN pg_namespace n ON n.oid = i.relnamespace" " JOIN pg_namespace n ON n.oid = i.relnamespace"
@ -2019,7 +2019,7 @@ repack_all_indexes(char *errbuf, size_t errsize)
if(table_list.head) if(table_list.head)
elog(INFO, "repacking indexes of \"%s\"", cell->val); elog(INFO, "repacking indexes of \"%s\"", cell->val);
if (!repack_table_indexes(res)) if (!repack_table_indexes(res))
elog(WARNING, "repack failed for \"%s\"", cell->val); elog(WARNING, "repack failed for \"%s\"", cell->val);
CLEARPGRES(res); CLEARPGRES(res);