Skip to content

Commit 0b06b9e

Browse files
sfc-gh-npukasfc-gh-npuka
committed
Reformat code with pg_lake custom types registered in pgindent typedefs
Signed-off-by: sfc-gh-npuka <naisila.puka@snowflake.com>
1 parent a4113da commit 0b06b9e

177 files changed

Lines changed: 1349 additions & 1349 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎pg_extension_base/include/pg_extension_base/attached_worker.h‎

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -38,19 +38,19 @@ typedef struct AttachedWorker
3838
/* background worker handle */
3939
pid_t workerPid;
4040
BackgroundWorkerHandle *workerHandle;
41-
} AttachedWorker;
41+
} AttachedWorker;
4242

43-
extern PGDLLEXPORT AttachedWorker * StartAttachedWorker(char *command);
44-
extern PGDLLEXPORT AttachedWorker * StartAttachedWorkerInDatabase(char *command,
45-
char *databaseName,
46-
char *userName);
47-
extern PGDLLEXPORT AttachedWorker * StartAttachedWorkerReturning(char *command);
48-
extern PGDLLEXPORT AttachedWorker * StartAttachedWorkerInDatabaseReturning(char *command,
49-
char *databaseName,
50-
char *userName);
51-
extern PGDLLEXPORT char *ReadFromAttachedWorker(AttachedWorker * worker, bool wait);
52-
extern PGDLLEXPORT void ReadResultsFromAttachedWorker(AttachedWorker * worker,
43+
extern PGDLLEXPORT AttachedWorker *StartAttachedWorker(char *command);
44+
extern PGDLLEXPORT AttachedWorker *StartAttachedWorkerInDatabase(char *command,
45+
char *databaseName,
46+
char *userName);
47+
extern PGDLLEXPORT AttachedWorker *StartAttachedWorkerReturning(char *command);
48+
extern PGDLLEXPORT AttachedWorker *StartAttachedWorkerInDatabaseReturning(char *command,
49+
char *databaseName,
50+
char *userName);
51+
extern PGDLLEXPORT char *ReadFromAttachedWorker(AttachedWorker *worker, bool wait);
52+
extern PGDLLEXPORT void ReadResultsFromAttachedWorker(AttachedWorker *worker,
5353
Tuplestorestate *store,
5454
TupleDesc *resultDesc);
55-
extern PGDLLEXPORT bool IsAttachedWorkerRunning(AttachedWorker * worker);
56-
extern PGDLLEXPORT void EndAttachedWorker(AttachedWorker * worker);
55+
extern PGDLLEXPORT bool IsAttachedWorkerRunning(AttachedWorker *worker);
56+
extern PGDLLEXPORT void EndAttachedWorker(AttachedWorker *worker);

‎pg_extension_base/src/attached_worker.c‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -82,8 +82,8 @@ PG_FUNCTION_INFO_V1(pg_extension_base_run_attached_worker_returning);
8282
extern PGDLLEXPORT void AttachedWorkerMain(Datum mainArg);
8383

8484
/* internal functions */
85-
static AttachedWorker * StartAttachedWorkerInternal(char *command, char *databaseName,
86-
char *userName, uint32 flags);
85+
static AttachedWorker *StartAttachedWorkerInternal(char *command, char *databaseName,
86+
char *userName, uint32 flags);
8787
static void RunAttachedWorker(char *command, char *databaseName, char *userName, ReturnSetInfo *rsinfo);
8888
static void RunAttachedWorkerReturning(char *command, char *databaseName,
8989
char *userName, ReturnSetInfo *rsinfo);
@@ -543,7 +543,7 @@ ProcessProtocolMessages(shm_mq_handle *queue, bool nowait,
543543
* worker until reaching query completion or error.
544544
*/
545545
char *
546-
ReadFromAttachedWorker(AttachedWorker * worker, bool wait)
546+
ReadFromAttachedWorker(AttachedWorker *worker, bool wait)
547547
{
548548
return ProcessProtocolMessages(worker->outputQueue, !wait, NULL);
549549
}
@@ -594,7 +594,7 @@ ValidateWorkerTupleDesc(TupleDesc workerDesc, TupleDesc expectedDesc)
594594
* On return, *resultDesc is set to the TupleDesc that was used.
595595
*/
596596
void
597-
ReadResultsFromAttachedWorker(AttachedWorker * worker, Tuplestorestate *store,
597+
ReadResultsFromAttachedWorker(AttachedWorker *worker, Tuplestorestate *store,
598598
TupleDesc *resultDesc)
599599
{
600600
TupleDesc tupleDesc = *resultDesc;
@@ -661,7 +661,7 @@ ReadResultsFromAttachedWorker(AttachedWorker * worker, Tuplestorestate *store,
661661
* still running.
662662
*/
663663
bool
664-
IsAttachedWorkerRunning(AttachedWorker * worker)
664+
IsAttachedWorkerRunning(AttachedWorker *worker)
665665
{
666666
pid_t pid;
667667

@@ -674,7 +674,7 @@ IsAttachedWorkerRunning(AttachedWorker * worker)
674674
* worker to clean up the resources.
675675
*/
676676
void
677-
EndAttachedWorker(AttachedWorker * worker)
677+
EndAttachedWorker(AttachedWorker *worker)
678678
{
679679
if (worker->sharedMemorySegment == NULL)
680680
return;

‎pg_extension_base/src/base_worker_launcher.c‎

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -152,7 +152,7 @@ typedef struct BaseWorkerControlData
152152
/* current PID of the server starter */
153153
pid_t serverStarterPid;
154154
int serverStarterProcno;
155-
} BaseWorkerControlData;
155+
} BaseWorkerControlData;
156156

157157

158158
typedef enum WorkerState
@@ -162,7 +162,7 @@ typedef enum WorkerState
162162
WORKER_RUNNING,
163163
WORKER_STOPPED,
164164
WORKER_RESTARTING
165-
} WorkerState;
165+
} WorkerState;
166166

167167

168168
/*
@@ -184,7 +184,7 @@ typedef struct DatabaseStarterEntry
184184

185185
/* process number for signaling via ProcSendSignal */
186186
int procno;
187-
} DatabaseStarterEntry;
187+
} DatabaseStarterEntry;
188188

189189

190190
/*
@@ -197,7 +197,7 @@ typedef struct BaseWorkerKey
197197

198198
/* worker ID */
199199
int32 workerId;
200-
} BaseWorkerKey;
200+
} BaseWorkerKey;
201201

202202

203203
/*
@@ -225,7 +225,7 @@ typedef struct BaseWorkerEntry
225225

226226
/* when to restart the base worker (delayed after failure) */
227227
TimestampTz restartAfter;
228-
} BaseWorkerEntry;
228+
} BaseWorkerEntry;
229229

230230

231231
/*
@@ -241,7 +241,7 @@ typedef struct DatabaseEntry
241241

242242
/* whether this is a template database */
243243
bool isTemplate;
244-
} DatabaseEntry;
244+
} DatabaseEntry;
245245

246246

247247
/*
@@ -261,7 +261,7 @@ typedef struct BaseWorkerRegistration
261261

262262
/* entry point function */
263263
Oid entryPointFunctionId;
264-
} BaseWorkerRegistration;
264+
} BaseWorkerRegistration;
265265

266266
/*
267267
* StartDatabaseStarterResult indicates whether a database starter was
@@ -273,7 +273,7 @@ typedef enum StartDatabaseStarterResult
273273
DATABASE_STARTER_EXISTS,
274274
DATABASE_STARTER_DONE,
275275
DATABASE_STARTER_FAILED
276-
} StartDatabaseStarterResult;
276+
} StartDatabaseStarterResult;
277277

278278
/*
279279
* StartBaseWorkerResult indicates whether a base worker was
@@ -286,7 +286,7 @@ typedef enum StartBaseWorkerResult
286286
BASE_WORKER_DONE,
287287
BASE_WORKER_START_FAILED,
288288
BASE_WORKER_START_BLOCKED
289-
} StartBaseWorkerResult;
289+
} StartBaseWorkerResult;
290290

291291

292292

@@ -308,10 +308,10 @@ static StartDatabaseStarterResult StartDatabaseStarter(Oid databaseId,
308308
char *databaseName);
309309

310310
/* shared memory bookkeeping */
311-
static DatabaseStarterEntry * GetDatabaseStarterEntry(Oid databaseId, bool *isFound);
312-
static DatabaseStarterEntry * GetOrCreateDatabaseStarterEntry(Oid databaseId, bool *isFound);
313-
static BaseWorkerEntry * GetBaseWorkerEntry(Oid databaseId, int32 workerId, bool *isFound);
314-
static BaseWorkerEntry * GetOrCreateBaseWorkerEntry(int32 workerId, bool *isFound);
311+
static DatabaseStarterEntry *GetDatabaseStarterEntry(Oid databaseId, bool *isFound);
312+
static DatabaseStarterEntry *GetOrCreateDatabaseStarterEntry(Oid databaseId, bool *isFound);
313+
static BaseWorkerEntry *GetBaseWorkerEntry(Oid databaseId, int32 workerId, bool *isFound);
314+
static BaseWorkerEntry *GetOrCreateBaseWorkerEntry(int32 workerId, bool *isFound);
315315
static void RemoveBaseWorkerEntry(Oid databaseId, int32 workerId);
316316
static void RemoveBaseWorkerEntriesForDatabase(Oid databaseId);
317317
static void RemoveBaseWorkerEntriesNotInRegistrationList(List *workerRegistrationList);
@@ -377,7 +377,7 @@ PGDLLEXPORT void PgExtensionBaseDatabaseStarterMain(Datum arg);
377377
PGDLLEXPORT void PgExtensionBaseWorkerMain(Datum arg);
378378

379379
/* shared memory state */
380-
static BaseWorkerControlData * BaseWorkerControl = NULL;
380+
static BaseWorkerControlData *BaseWorkerControl = NULL;
381381
static HTAB *DatabaseStarterHash = NULL;
382382
static HTAB *BaseWorkerHash = NULL;
383383

‎pg_extension_base/src/extension_ids.c‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ typedef enum ExtensionStatus
4545
EXTENSION_STATUS_UNKNOWN,
4646
EXTENSION_STATUS_EXISTS,
4747
EXTENSION_STATUS_NOT_EXISTS
48-
} ExtensionStatus;
48+
} ExtensionStatus;
4949

5050

5151
/*

‎pg_extension_base/src/library_preloader.c‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -45,12 +45,12 @@ typedef struct PreloadLibrary
4545

4646
/* name of the library */
4747
char *libraryName;
48-
} PreloadLibrary;
48+
} PreloadLibrary;
4949

5050
/* internal functions */
5151
static List *FindAllPreloadLibraries(void);
5252
static List *FindExtensionPreloadLibraryNames(char *extensionName);
53-
static List *AddPreloadLibrary(List *libraries, PreloadLibrary * preloadLibrary);
53+
static List *AddPreloadLibrary(List *libraries, PreloadLibrary *preloadLibrary);
5454

5555
/* SQL-callable functions */
5656
PG_FUNCTION_INFO_V1(pg_extension_base_list_preload_libraries);
@@ -309,7 +309,7 @@ FindExtensionPreloadLibraryNames(char *extensionName)
309309
* unless the library already appears.
310310
*/
311311
static List *
312-
AddPreloadLibrary(List *libraries, PreloadLibrary * preloadLibrary)
312+
AddPreloadLibrary(List *libraries, PreloadLibrary *preloadLibrary)
313313
{
314314
ListCell *libraryCell = NULL;
315315

‎pg_extension_updater/src/pg_extension_updater.c‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ typedef struct UpdatableExtension
4545

4646
/* default version (usually the latest installed version) */
4747
char *defaultVersion;
48-
} UpdatableExtension;
48+
} UpdatableExtension;
4949

5050

5151
/* function declarations */

‎pg_lake_benchmark/include/pg_lake/benchmark.h‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,13 +36,13 @@ typedef struct BenchQuery
3636
{
3737
const char *query;
3838
int query_nr;
39-
} BenchQuery;
39+
} BenchQuery;
4040

4141
extern void PgDuckInstallBenchExtension(BenchmarkType benchType);
4242
extern void PgDuckDropBenchTables(const char *tableNames[], int length);
4343
extern void PgDuckGenerateBenchTables(BenchmarkType benchType, float4 scaleFactor, int iterationCount);
4444
extern void PgDuckCopyBenchTablesToRemoteParquet(const char *tableNames[], int length, char *location);
45-
extern void PgDuckGetQueries(BenchmarkType benchType, BenchQuery * queries, int queryCount);
45+
extern void PgDuckGetQueries(BenchmarkType benchType, BenchQuery *queries, int queryCount);
4646
extern void PgLakeDropBenchTables(const char *tableNames[], int length, char *location);
4747
extern void PgLakeCreateBenchTables(const char *tableNames[], char **partitionBys, int length, BenchmarkTableType tableType, char *location);
4848
extern BenchmarkTableType GetBenchTableType(Oid tableTypeId);

‎pg_lake_benchmark/src/benchmark.c‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ PgDuckCopyBenchTablesToRemoteParquet(const char *tableNames[], int length, char
119119
* PgDuckGetQueries returns the benchmark queries via pgduck server.
120120
*/
121121
void
122-
PgDuckGetQueries(BenchmarkType benchType, BenchQuery * queries, int queryCount)
122+
PgDuckGetQueries(BenchmarkType benchType, BenchQuery *queries, int queryCount)
123123
{
124124
char *query;
125125

‎pg_lake_copy/include/pg_lake/copy/copy.h‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@
2828
extern bool EnablePgLakeCopy;
2929
extern bool EnablePgLakeCopyJson;
3030

31-
bool PgLakeCopyHandler(ProcessUtilityParams * params, void *arg);
31+
bool PgLakeCopyHandler(ProcessUtilityParams *params, void *arg);
3232
void ProcessPgLakeCopy(ParseState *pstate, PlannedStmt *plannedStmt,
3333
const char *queryString, uint64 *rowsProcessed);
3434

‎pg_lake_copy/include/pg_lake/copy/create_table.h‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,6 @@
2020

2121
#include "pg_lake/ddl/utility_hook.h"
2222

23-
bool CreateTableFromFileHandler(ProcessUtilityParams * params, void *arg);
23+
bool CreateTableFromFileHandler(ProcessUtilityParams *params, void *arg);
2424

2525
#endif

0 commit comments

Comments
 (0)