indent

Author: lfittl

src/backend/executor/execParallel.c

@@ -300,7 +300,7 @@ ExecInstrInitWorker(shm_toc *toc, uint64 key, bool missing_ok)
  * torn down.  Returns NULL if there was no instrumentation.
  */
 SharedWorkerInstrumentation *
-ExecInstrRetrieve(SharedWorkerInstrumentation * shared, Size elemsz)
+ExecInstrRetrieve(SharedWorkerInstrumentation *shared, Size elemsz)
 {
 	Size		size;
 	SharedWorkerInstrumentation *si;

src/backend/executor/nodeBitmapIndexscan.c

@@ -399,11 +399,11 @@ ExecBitmapIndexScanInitializeWorker(BitmapIndexScanState *node,
 
 	/*
 	 * Write statistics straight into this worker's shared slot as the scan
-	 * runs, rather than into worker-local memory copied out at shutdown.
-	 * This has no write-side contention (one writer per slot) and lets the
-	 * leader observe progress mid-query.  The slot is not reset here: when
-	 * workers are relaunched (e.g. a rescanned Gather) the counts accumulate
-	 * across rounds.
+	 * runs, rather than into worker-local memory copied out at shutdown. This
+	 * has no write-side contention (one writer per slot) and lets the leader
+	 * observe progress mid-query.  The slot is not reset here: when workers
+	 * are relaunched (e.g. a rescanned Gather) the counts accumulate across
+	 * rounds.
 	 */
 	Assert(ParallelWorkerNumber < node->biss_SharedInfo->num_workers);
 	pfree(node->biss_Instrument);
@@ -414,8 +414,8 @@ ExecBitmapIndexScanInitializeWorker(BitmapIndexScanState *node,
 	/*
 	 * Unlike a plain index scan, the bitmap index scan descriptor is created
 	 * eagerly in ExecInitBitmapIndexScan, before this runs, and it captured a
-	 * pointer to the now-freed local instrumentation.  Repoint it at the shared
-	 * slot so the AM writes there (and not into freed memory).
+	 * pointer to the now-freed local instrumentation.  Repoint it at the
+	 * shared slot so the AM writes there (and not into freed memory).
 	 */
 	if (node->biss_ScanDesc != NULL)
 		node->biss_ScanDesc->instrument = node->biss_Instrument;

src/backend/executor/nodeIndexonlyscan.c

@@ -872,11 +872,11 @@ ExecIndexOnlyScanInstrumentInitWorker(IndexOnlyScanState *node,
 
 	/*
 	 * Write statistics straight into this worker's shared slot as the scan
-	 * runs, rather than into worker-local memory copied out at shutdown.
-	 * This has no write-side contention (one writer per slot) and lets the
-	 * leader observe progress mid-query.  The slot is not reset here: when
-	 * workers are relaunched (e.g. a rescanned Gather) the counts accumulate
-	 * across rounds.
+	 * runs, rather than into worker-local memory copied out at shutdown. This
+	 * has no write-side contention (one writer per slot) and lets the leader
+	 * observe progress mid-query.  The slot is not reset here: when workers
+	 * are relaunched (e.g. a rescanned Gather) the counts accumulate across
+	 * rounds.
 	 */
 	Assert(ParallelWorkerNumber < node->ioss_SharedInfo->num_workers);
 	pfree(node->ioss_Instrument);

src/backend/executor/nodeIndexscan.c

@@ -1807,11 +1807,11 @@ ExecIndexScanInstrumentInitWorker(IndexScanState *node,
 
 	/*
 	 * Write statistics straight into this worker's shared slot as the scan
-	 * runs, rather than into worker-local memory copied out at shutdown.
-	 * This has no write-side contention (one writer per slot) and lets the
-	 * leader observe progress mid-query.  The slot is not reset here: when
-	 * workers are relaunched (e.g. a rescanned Gather) the counts accumulate
-	 * across rounds.
+	 * runs, rather than into worker-local memory copied out at shutdown. This
+	 * has no write-side contention (one writer per slot) and lets the leader
+	 * observe progress mid-query.  The slot is not reset here: when workers
+	 * are relaunched (e.g. a rescanned Gather) the counts accumulate across
+	 * rounds.
 	 */
 	Assert(ParallelWorkerNumber < node->iss_SharedInfo->num_workers);
 	pfree(node->iss_Instrument);

src/include/executor/execParallel.h

@@ -50,11 +50,11 @@ extern void ParallelQueryMain(dsm_segment *seg, shm_toc *toc);
 
 /* Generic per-worker node instrumentation container helpers */
 extern void ExecInstrEstimate(ParallelContext *pcxt, Size elemsz);
-extern SharedWorkerInstrumentation * ExecInstrInitDSM(ParallelContext *pcxt,
-													  uint64 key, Size elemsz);
-extern SharedWorkerInstrumentation * ExecInstrInitWorker(shm_toc *toc,
-														 uint64 key, bool missing_ok);
-extern SharedWorkerInstrumentation * ExecInstrRetrieve(SharedWorkerInstrumentation * shared,
-													   Size elemsz);
+extern SharedWorkerInstrumentation *ExecInstrInitDSM(ParallelContext *pcxt,
+													 uint64 key, Size elemsz);
+extern SharedWorkerInstrumentation *ExecInstrInitWorker(shm_toc *toc,
+														uint64 key, bool missing_ok);
+extern SharedWorkerInstrumentation *ExecInstrRetrieve(SharedWorkerInstrumentation *shared,
+													  Size elemsz);
 
 #endif							/* EXECPARALLEL_H */

src/include/executor/instrument_node.h

@@ -46,7 +46,7 @@ typedef struct SharedWorkerInstrumentation
 {
 	int			num_workers;
 	/* num_workers cache-line-padded slots follow; see GetWorkerInstr() */
-}			SharedWorkerInstrumentation;
+} SharedWorkerInstrumentation;
 
 /* DSM bytes needed for a container holding nworkers slots of elemsz bytes */
 static inline Size
@@ -58,7 +58,7 @@ SharedWorkerInstrSize(int nworkers, Size elemsz)
 
 /* Address of a given worker's slot (untyped) */
 static inline void *
-GetWorkerInstrSlot(SharedWorkerInstrumentation * si, Size elemsz, int worker)
+GetWorkerInstrSlot(SharedWorkerInstrumentation *si, Size elemsz, int worker)
 {
 	return (char *) si + CACHELINEALIGN(sizeof(SharedWorkerInstrumentation)) +
 		(Size) worker * CACHELINEALIGN(elemsz);