Skip to content

Commit

Permalink
src
Browse files Browse the repository at this point in the history
  • Loading branch information
svenklemm committed May 25, 2024
1 parent 43a5165 commit 772d073
Show file tree
Hide file tree
Showing 73 changed files with 204 additions and 206 deletions.
2 changes: 1 addition & 1 deletion src/adts/bit_array.h
Original file line number Diff line number Diff line change
Expand Up @@ -10,8 +10,8 @@
#include <lib/stringinfo.h>
#include <libpq/pqformat.h>

#include <adts/uint64_vec.h>
#include "bit_array_impl.h"
#include <adts/uint64_vec.h>

/*******************
*** Public API ***
Expand Down
2 changes: 1 addition & 1 deletion src/adts/bit_array_impl.h
Original file line number Diff line number Diff line change
Expand Up @@ -10,8 +10,8 @@
#include <lib/stringinfo.h>
#include <libpq/pqformat.h>

#include "adts/uint64_vec.h"
#include "compat/compat.h"
#include "adts/uint64_vec.h"

#define BITS_PER_BUCKET 64

Expand Down
4 changes: 2 additions & 2 deletions src/agg_bookend.c
Original file line number Diff line number Diff line change
Expand Up @@ -4,12 +4,12 @@
* LICENSE-APACHE for a copy of the license.
*/
#include <postgres.h>
#include <fmgr.h>
#include <access/htup_details.h>
#include <catalog/namespace.h>
#include <catalog/pg_type.h>
#include <libpq/pqformat.h>
#include <fmgr.h>
#include <lib/stringinfo.h>
#include <libpq/pqformat.h>
#include <nodes/value.h>
#include <utils/datum.h>
#include <utils/lsyscache.h>
Expand Down
8 changes: 4 additions & 4 deletions src/bgw/job.c
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@
*/
#include <postgres.h>

#include <unistd.h>
#include <access/xact.h>
#include <catalog/pg_authid.h>
#include <executor/execdebug.h>
Expand All @@ -21,7 +22,6 @@
#include <storage/procarray.h>
#include <storage/sinvaladt.h>
#include <tcop/tcopprot.h>
#include <unistd.h>
#include <utils/acl.h>
#include <utils/builtins.h>
#include <utils/elog.h>
Expand All @@ -31,16 +31,16 @@
#include <utils/syscache.h>
#include <utils/timestamp.h>

#include "compat/compat.h"
#include "bgw/scheduler.h"
#include "bgw_policy/chunk_stats.h"
#include "bgw_policy/policy.h"
#include "bgw/scheduler.h"
#include "compat/compat.h"
#include "config.h"
#include "cross_module_fn.h"
#include "debug_assert.h"
#include "extension.h"
#include "job_stat.h"
#include "job.h"
#include "job_stat.h"
#include "jsonb_utils.h"
#include "license_guc.h"
#include "scan_iterator.h"
Expand Down
2 changes: 1 addition & 1 deletion src/bgw/job.h
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,8 @@
#pragma once

#include <postgres.h>
#include <storage/lock.h>
#include <postmaster/bgworker.h>
#include <storage/lock.h>

#include "export.h"
#include "ts_catalog/catalog.h"
Expand Down
2 changes: 1 addition & 1 deletion src/bgw/job_stat.c
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,8 @@
#include <utils/resowner.h>

#include "guc.h"
#include "job_stat_history.h"
#include "job_stat.h"
#include "job_stat_history.h"
#include "jsonb_utils.h"
#include "scanner.h"
#include "time_bucket.h"
Expand Down
2 changes: 1 addition & 1 deletion src/bgw/job_stat.h
Original file line number Diff line number Diff line change
Expand Up @@ -5,8 +5,8 @@
*/
#pragma once

#include "ts_catalog/catalog.h"
#include "job.h"
#include "ts_catalog/catalog.h"

#define JOB_STAT_FLAGS_DEFAULT 0
#define LAST_CRASH_REPORTED 1
Expand Down
2 changes: 1 addition & 1 deletion src/bgw/job_stat_history.h
Original file line number Diff line number Diff line change
Expand Up @@ -5,9 +5,9 @@
*/
#pragma once

#include "ts_catalog/catalog.h"
#include "job.h"
#include "job_stat.h"
#include "ts_catalog/catalog.h"

#define INVALID_BGW_JOB_STAT_HISTORY_ID 0

Expand Down
2 changes: 1 addition & 1 deletion src/bgw/launcher_interface.c
Original file line number Diff line number Diff line change
Expand Up @@ -7,9 +7,9 @@

#include <fmgr.h>

#include "compat/compat.h"
#include "extension.h"
#include "launcher_interface.h"
#include "compat/compat.h"

#define MIN_LOADER_API_VERSION 4

Expand Down
12 changes: 6 additions & 6 deletions src/bgw/scheduler.c
Original file line number Diff line number Diff line change
Expand Up @@ -12,23 +12,23 @@
*/
#include <postgres.h>

#include <access/xact.h>
#include <miscadmin.h>
#include <nodes/pg_list.h>
#include <pgstat.h>
#include <postmaster/bgworker.h>
#include <storage/ipc.h>
#include <storage/latch.h>
#include <storage/lwlock.h>
#include <storage/proc.h>
#include <storage/shmem.h>
#include <tcop/tcopprot.h>
#include <utils/acl.h>
#include <utils/inval.h>
#include <utils/jsonb.h>
#include <utils/timestamp.h>
#include <utils/snapmgr.h>
#include <utils/memutils.h>
#include <access/xact.h>
#include <pgstat.h>
#include <tcop/tcopprot.h>
#include <nodes/pg_list.h>
#include <utils/snapmgr.h>
#include <utils/timestamp.h>

#include "compat/compat.h"
#include "extension.h"
Expand Down
2 changes: 1 addition & 1 deletion src/bgw/scheduler.h
Original file line number Diff line number Diff line change
Expand Up @@ -5,9 +5,9 @@
*/
#pragma once

#include "compat/compat.h"
#include <postgres.h>
#include <fmgr.h>
#include "compat/compat.h"
#include <postmaster/bgworker.h>

#include "timer.h"
Expand Down
10 changes: 5 additions & 5 deletions src/bgw/timer.c
Original file line number Diff line number Diff line change
Expand Up @@ -4,23 +4,23 @@
* LICENSE-APACHE for a copy of the license.
*/
#include <postgres.h>
#include <access/xact.h>
#include <miscadmin.h>
#include <pgstat.h>
#include <postmaster/bgworker.h>
#include <storage/ipc.h>
#include <storage/latch.h>
#include <storage/lwlock.h>
#include <storage/proc.h>
#include <storage/shmem.h>
#include <utils/jsonb.h>
#include <utils/timestamp.h>
#include <utils/snapmgr.h>
#include <utils/memutils.h>
#include <access/xact.h>
#include <pgstat.h>
#include <utils/snapmgr.h>
#include <utils/timestamp.h>

#include "timer.h"
#include "compat/compat.h"
#include "config.h"
#include "timer.h"

#define MAX_TIMEOUT (5 * INT64CONST(1000))
#define MILLISECS_PER_SEC INT64CONST(1000)
Expand Down
4 changes: 2 additions & 2 deletions src/bgw_policy/chunk_stats.c
Original file line number Diff line number Diff line change
Expand Up @@ -8,10 +8,10 @@
#include <executor/tuptable.h>

#include "bgw/job.h"
#include "ts_catalog/catalog.h"
#include "chunk_stats.h"
#include "utils.h"
#include "policy.h"
#include "ts_catalog/catalog.h"
#include "utils.h"

#include "compat/compat.h"

Expand Down
2 changes: 1 addition & 1 deletion src/bgw_policy/chunk_stats.h
Original file line number Diff line number Diff line change
Expand Up @@ -5,8 +5,8 @@
*/
#pragma once

#include "ts_catalog/catalog.h"
#include "export.h"
#include "ts_catalog/catalog.h"

typedef struct BgwPolicyChunkStats
{
Expand Down
4 changes: 2 additions & 2 deletions src/bgw_policy/policy.h
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,10 @@
*/
#pragma once

#include "config.h"
#include "export.h"
#include "scanner.h"
#include "ts_catalog/catalog.h"
#include "export.h"
#include "config.h"

extern ScanTupleResult ts_bgw_policy_delete_row_only_tuple_found(TupleInfo *ti, void *const data);

Expand Down
2 changes: 1 addition & 1 deletion src/cache.c
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,8 @@
#include <access/xact.h>
#include <storage/ipc.h>

#include "cache.h"
#include "compat/compat.h"
#include "cache.h"

/* List of pinned caches. A cache occurs once in this list for every pin
* taken */
Expand Down
2 changes: 1 addition & 1 deletion src/cache.h
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,8 @@
#pragma once

#include <postgres.h>
#include <utils/memutils.h>
#include <utils/hsearch.h>
#include <utils/memutils.h>

#include "export.h"

Expand Down
12 changes: 6 additions & 6 deletions src/cache_invalidate.c
Original file line number Diff line number Diff line change
Expand Up @@ -5,22 +5,22 @@
*/
#include <postgres.h>
#include <access/xact.h>
#include <utils/lsyscache.h>
#include <utils/inval.h>
#include <catalog/namespace.h>
#include <nodes/nodes.h>
#include <miscadmin.h>
#include <nodes/nodes.h>
#include <utils/inval.h>
#include <utils/lsyscache.h>
#include <utils/syscache.h>

#include "annotations.h"
#include "ts_catalog/catalog.h"
#include "compat/compat.h"
#include "annotations.h"
#include "extension.h"
#include "hypertable_cache.h"
#include "ts_catalog/catalog.h"

#include "bgw/scheduler.h"
#include "cross_module_fn.h"
#include "cache_invalidate.h"
#include "cross_module_fn.h"

/*
* Notes on the way cache invalidation works.
Expand Down
8 changes: 4 additions & 4 deletions src/chunk.c
Original file line number Diff line number Diff line change
Expand Up @@ -5,8 +5,8 @@
*/
#include <postgres.h>

#include <access/htup_details.h>
#include <access/htup.h>
#include <access/htup_details.h>
#include <access/reloptions.h>
#include <access/tupdesc.h>
#include <access/xact.h>
Expand Down Expand Up @@ -41,23 +41,23 @@

#include "chunk.h"

#include "compat/compat.h"
#include "bgw_policy/chunk_stats.h"
#include "cache.h"
#include "chunk_index.h"
#include "chunk_scan.h"
#include "compat/compat.h"
#include "cross_module_fn.h"
#include "debug_assert.h"
#include "debug_point.h"
#include "dimension.h"
#include "dimension_slice.h"
#include "dimension_vector.h"
#include "dimension.h"
#include "errors.h"
#include "export.h"
#include "extension.h"
#include "hypercube.h"
#include "hypertable_cache.h"
#include "hypertable.h"
#include "hypertable_cache.h"
#include "osm_callbacks.h"
#include "partitioning.h"
#include "process_utility.h"
Expand Down
7 changes: 3 additions & 4 deletions src/chunk.h
Original file line number Diff line number Diff line change
Expand Up @@ -8,14 +8,13 @@
#include <postgres.h>
#include <access/htup.h>
#include <access/tupdesc.h>
#include <utils/hsearch.h>
#include <foreign/foreign.h>
#include <utils/hsearch.h>

#include "export.h"
#include "ts_catalog/catalog.h"
#include "chunk_constraint.h"
#include "hypertable.h"
#include "export.h"
#include "hypertable.h"
#include "ts_catalog/catalog.h"

#define INVALID_CHUNK_ID 0
#define IS_OSM_CHUNK(chunk) ((chunk)->fd.osm_chunk == true)
Expand Down
22 changes: 11 additions & 11 deletions src/chunk_adaptive.c
Original file line number Diff line number Diff line change
Expand Up @@ -7,25 +7,25 @@
#include <postgres.h>
#include <catalog/pg_proc.h>
#include <catalog/pg_type.h>
#include <funcapi.h>
#include <math.h>
#include <miscadmin.h>
#include <parser/parse_func.h>
#include <utils/acl.h>
#include <utils/syscache.h>
#include <utils/lsyscache.h>
#include <utils/guc.h>
#include <utils/builtins.h>
#include <utils/array.h>
#include <utils/builtins.h>
#include <utils/guc.h>
#include <utils/lsyscache.h>
#include <utils/snapmgr.h>
#include <utils/syscache.h>
#include <utils/typcache.h>
#include <funcapi.h>
#include <math.h>
#include <parser/parse_func.h>
#include <miscadmin.h>

#include "hypertable_cache.h"
#include "errors.h"
#include "compat/compat.h"
#include "chunk_adaptive.h"
#include "chunk.h"
#include "chunk_adaptive.h"
#include "errors.h"
#include "hypercube.h"
#include "hypertable_cache.h"
#include "utils.h"

#define DEFAULT_CHUNK_SIZING_FN_NAME "calculate_chunk_interval"
Expand Down
Loading

0 comments on commit 772d073

Please sign in to comment.