guc.c 104.4 KB
Newer Older
1 2 3 4 5
/*--------------------------------------------------------------------
 * guc.c
 *
 * Support for grand unified configuration scheme, including SET
 * command, configuration file, and command line options.
6
 * See src/backend/utils/misc/README for more information.
7 8
 *
 *
9
 * Copyright 2000-2003 by PostgreSQL Global Development Group
10
 * Written by Peter Eisentraut <peter_e@gmx.net>.
11 12
 *
 * IDENTIFICATION
13
 *	  $Header: /cvsroot/pgsql/src/backend/utils/misc/guc.c,v 1.140 2003/07/27 04:35:53 momjian Exp $
14
 *
15 16 17 18 19 20 21 22 23 24
 *--------------------------------------------------------------------
 */
#include "postgres.h"

#include <errno.h>
#include <float.h>
#include <limits.h>
#include <unistd.h>

#include "utils/guc.h"
25
#include "utils/guc_tables.h"
26

27
#include "access/xlog.h"
28
#include "catalog/namespace.h"
29
#include "catalog/pg_type.h"
30
#include "commands/async.h"
31
#include "commands/variable.h"
32
#include "commands/vacuum.h"
33
#include "executor/executor.h"
34
#include "fmgr.h"
35
#include "funcapi.h"
36
#include "libpq/auth.h"
37
#include "libpq/pqcomm.h"
38
#include "libpq/pqformat.h"
39
#include "mb/pg_wchar.h"
40 41 42 43
#include "miscadmin.h"
#include "optimizer/cost.h"
#include "optimizer/geqo.h"
#include "optimizer/paths.h"
44
#include "optimizer/prep.h"
45
#include "parser/parse_expr.h"
46
#include "parser/parse_relation.h"
47
#include "storage/fd.h"
48 49
#include "storage/freespace.h"
#include "storage/lock.h"
50 51
#include "storage/proc.h"
#include "tcop/tcopprot.h"
52 53
#include "utils/array.h"
#include "utils/builtins.h"
54
#include "utils/datetime.h"
55
#include "utils/pg_locale.h"
56
#include "pgstat.h"
57 58


59 60 61 62
#ifndef PG_KRB_SRVTAB
#define PG_KRB_SRVTAB ""
#endif

B
Bruce Momjian 已提交
63 64 65
#ifdef EXEC_BACKEND
#define CONFIG_EXEC_PARAMS "global/config_exec_params"
#endif
66 67

/* XXX these should appear in other modules' header files */
68
extern bool Log_connections;
69 70
extern int	PreAuthDelay;
extern int	AuthenticationTimeout;
B
Bruce Momjian 已提交
71 72 73
extern int	CheckPointTimeout;
extern int	CommitDelay;
extern int	CommitSiblings;
74
extern char *preload_libraries_string;
75

T
Tatsuo Ishii 已提交
76
#ifdef HAVE_SYSLOG
77
extern char *Syslog_facility;
78
extern char *Syslog_ident;
79

80
static const char *assign_facility(const char *facility,
B
Bruce Momjian 已提交
81
				bool doit, bool interactive);
82
#endif
83

84 85 86
static const char *assign_defaultxactisolevel(const char *newval,
						   bool doit, bool interactive);
static const char *assign_log_min_messages(const char *newval,
87
						bool doit, bool interactive);
88 89 90 91
static const char *assign_client_min_messages(const char *newval,
						   bool doit, bool interactive);
static const char *assign_min_error_statement(const char *newval, bool doit,
						   bool interactive);
92
static const char *assign_msglvl(int *var, const char *newval,
B
Bruce Momjian 已提交
93
			  bool doit, bool interactive);
94
static const char *assign_log_error_verbosity(const char *newval, bool doit,
95
						   bool interactive);
96
static bool assign_phony_autocommit(bool newval, bool doit, bool interactive);
97

98

99 100 101
/*
 * Debugging options
 */
102
#ifdef USE_ASSERT_CHECKING
B
Bruce Momjian 已提交
103
bool		assert_enabled = true;
104
#endif
B
Rename:  
Bruce Momjian 已提交
105 106
bool		log_statement = false;
bool		log_duration = false;
B
Bruce Momjian 已提交
107 108 109 110
bool		Debug_print_plan = false;
bool		Debug_print_parse = false;
bool		Debug_print_rewritten = false;
bool		Debug_pretty_print = false;
111
bool		Explain_pretty_print = true;
112

B
Rename:  
Bruce Momjian 已提交
113 114 115 116
bool		log_parser_stats = false;
bool		log_planner_stats = false;
bool		log_executor_stats = false;
bool		log_statement_stats = false;		/* this is sort of all
B
Bruce Momjian 已提交
117
												 * three above together */
118
bool		log_btree_build_stats = false;
119

B
Bruce Momjian 已提交
120
bool		SQL_inheritance = true;
121

122 123
bool		Australian_timezones = false;

124
bool		Password_encryption = true;
125

126
int			log_min_error_statement = PANIC;
127
int			log_min_messages = NOTICE;
128
int			client_min_messages = NOTICE;
129

130 131
int			log_min_duration_statement = 0;

132

133 134 135 136 137
/*
 * These variables are all dummies that don't do anything, except in some
 * cases provide the value for SHOW to display.  The real state is elsewhere
 * and is kept in sync by assign_hooks.
 */
138
static char *client_min_messages_str;
139 140 141
static char *log_min_messages_str;
static char *log_error_verbosity_str;
static char *log_min_error_statement_str;
142
static bool phony_autocommit;
143
static bool session_auth_is_superuser;
144 145 146 147
static double phony_random_seed;
static char *client_encoding_string;
static char *datestyle_string;
static char *default_iso_level_string;
148 149
static char *locale_collate;
static char *locale_ctype;
150
static char *regex_flavor_string;
151
static char *server_encoding_string;
152
static char *server_version_string;
153 154 155 156
static char *session_authorization_string;
static char *timezone_string;
static char *XactIsoLevel_string;

157

158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198
/*
 * Used for pg_settings. Keep in sync with config_type enum above
 */
static char *config_type_name[] = 
{
	"bool",
	"integer",
	"real",
	"string"
};

/*
 * Used for pg_settings. Keep in sync with GucContext enum in guc.h
 */
static char *GucContextName[] = 
{
	"internal",
	"postmaster",
	"sighup",
	"backend",
	"super-user",
	"user"
};

/*
 * Used for pg_settings. Keep in sync with GucSource enum in guc.h
 */
static char *GucSourceName[] = 
{
	"default",
	"environment variable",
	"configuration file",
	"command line",
	"database",
	"user",
	"client",
	"override",
	"session"
};


199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238
/* Macros for freeing malloc'd pointers only if appropriate to do so */
/* Some of these tests are probably redundant, but be safe ... */
#define SET_STRING_VARIABLE(rec, newval) \
	do { \
		if (*(rec)->variable && \
			*(rec)->variable != (rec)->reset_val && \
			*(rec)->variable != (rec)->session_val && \
			*(rec)->variable != (rec)->tentative_val) \
			free(*(rec)->variable); \
		*(rec)->variable = (newval); \
	} while (0)
#define SET_STRING_RESET_VAL(rec, newval) \
	do { \
		if ((rec)->reset_val && \
			(rec)->reset_val != *(rec)->variable && \
			(rec)->reset_val != (rec)->session_val && \
			(rec)->reset_val != (rec)->tentative_val) \
			free((rec)->reset_val); \
		(rec)->reset_val = (newval); \
	} while (0)
#define SET_STRING_SESSION_VAL(rec, newval) \
	do { \
		if ((rec)->session_val && \
			(rec)->session_val != *(rec)->variable && \
			(rec)->session_val != (rec)->reset_val && \
			(rec)->session_val != (rec)->tentative_val) \
			free((rec)->session_val); \
		(rec)->session_val = (newval); \
	} while (0)
#define SET_STRING_TENTATIVE_VAL(rec, newval) \
	do { \
		if ((rec)->tentative_val && \
			(rec)->tentative_val != *(rec)->variable && \
			(rec)->tentative_val != (rec)->reset_val && \
			(rec)->tentative_val != (rec)->session_val) \
			free((rec)->tentative_val); \
		(rec)->tentative_val = (newval); \
	} while (0)


239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279
/*
 * The display name for each of the groupings defined in enum config_group
 * This array needs to be kept in sync with enum config_group.
 * This array however needs to be NULL terminated.
 */
const char *const config_group_names[] = {
	gettext_noop("Ungrouped"),
	gettext_noop("Connections & Authentication"),
	gettext_noop("Connections & Authentication / Connection Settings"),
	gettext_noop("Connections & Authentication / Security & Authentication"),
	gettext_noop("Resource Usage"),
	gettext_noop("Resource Usage / Memory"),
	gettext_noop("Resource Usage / Free Space Map"),
	gettext_noop("Resource Usage / Kernel Resources"),
	gettext_noop("Write Ahead Log"),
	gettext_noop("Write Ahead Log / Settings"),
	gettext_noop("Write Ahead Log / Checkpoints"),
	gettext_noop("Query Tuning"),
	gettext_noop("Query Tuning / Planner Method Enabling"),
	gettext_noop("Query Tuning / Planner Cost Constants"),
	gettext_noop("Query Tuning / Genetic Query Optimizer"),
	gettext_noop("Query Tuning / Other Planner Options"),
	gettext_noop("Reporting & Logging"),
	gettext_noop("Reporting & Logging / Syslog"),
	gettext_noop("Reporting & Logging / When To Log"),
	gettext_noop("Reporting & Logging / What To Log"),
	gettext_noop("Statistics"),
	gettext_noop("Statistics / Monitoring"),
	gettext_noop("Statistics / Query & Index Statistics Collector"),
	gettext_noop("Client Connection Defaults"),
	gettext_noop("Client Connection Defaults / Statement Behavior"),
	gettext_noop("Client Connection Defaults / Locale and Formatting"),
	gettext_noop("Client Connection Defaults / Other Defaults"),
	gettext_noop("Lock Management"),
	gettext_noop("Version & Platform Compatibility"),
	gettext_noop("Version & Platform Compatibility / Previous Postgres Versions"),
	gettext_noop("Version & Platform Compatibility / Other Platforms & Clients"),
	gettext_noop("Developer Options"),
	NULL
};

280

281
/*
282 283 284 285
 * Contents of GUC tables
 *
 * See src/backend/utils/misc/README for design notes.
 *
286 287 288 289 290 291 292 293 294 295 296 297 298
 * TO ADD AN OPTION:
 *
 * 1. Declare a global variable of type bool, int, double, or char*
 * and make use of it.
 *
 * 2. Decide at what times it's safe to set the option. See guc.h for
 * details.
 *
 * 3. Decide on a name, a default value, upper and lower bounds (if
 * applicable), etc.
 *
 * 4. Add a record below.
 *
299
 * 5. Add it to src/backend/utils/misc/postgresql.conf.sample.
300
 *
301
 * 6. Add it to src/bin/psql/tab-complete.c, if it's a USERSET option.
302
 *
303
 * 7. Don't forget to document the option.
304 305
 */

306

307
/******** option records follow ********/
308

309
static struct config_bool ConfigureNamesBool[] =
310
{
311
	{
312 313 314 315 316
		{"enable_seqscan", PGC_USERSET, QUERY_TUNING_METHOD,
			gettext_noop("Enable planner's use of sequential-scan plans"),
			NULL
		},
		&enable_seqscan,
317
		true, NULL, NULL
318
	},
319
	{
320 321 322 323 324
		{"enable_indexscan", PGC_USERSET, QUERY_TUNING_METHOD,
			gettext_noop("Enable planner's use of index-scan plans"),
			NULL
		},
		&enable_indexscan,
325
		true, NULL, NULL
326 327
	},
	{
328 329 330 331 332
		{"enable_tidscan", PGC_USERSET, QUERY_TUNING_METHOD,
			gettext_noop("Enable planner's use of TID scan plans"),
			NULL
		},
		&enable_tidscan,
333
		true, NULL, NULL
334 335
	},
	{
336 337 338 339 340
		{"enable_sort", PGC_USERSET, QUERY_TUNING_METHOD,
			gettext_noop("Enable planner's use of explicit sort steps"),
			NULL
		},
		&enable_sort,
341
		true, NULL, NULL
342
	},
343
	{
344 345 346 347 348
		{"enable_hashagg", PGC_USERSET, QUERY_TUNING_METHOD,
			gettext_noop("Enable planner's use of hashed aggregation plans"),
			NULL
		},
		&enable_hashagg,
349 350
		true, NULL, NULL
	},
351
	{
352 353 354 355 356
		{"enable_nestloop", PGC_USERSET, QUERY_TUNING_METHOD,
			gettext_noop("Enable planner's use of nested-loop join plans"),
			NULL
		},
		&enable_nestloop,
357
		true, NULL, NULL
358 359
	},
	{
360 361 362 363 364
		{"enable_mergejoin", PGC_USERSET, QUERY_TUNING_METHOD,
			gettext_noop("Enable planner's use of merge join plans"),
			NULL
		},
		&enable_mergejoin,
365
		true, NULL, NULL
366 367
	},
	{
368 369 370 371 372
		{"enable_hashjoin", PGC_USERSET, QUERY_TUNING_METHOD,
			gettext_noop("Enable planner's use of hash join plans"),
			NULL
		},
		&enable_hashjoin,
373
		true, NULL, NULL
374 375
	},
	{
376 377 378 379 380 381
		{"geqo", PGC_USERSET, QUERY_TUNING_GEQO,
			gettext_noop("Enable genetic query optimization"),
			gettext_noop("This algorithm attempts to do planning without "
						 "exhaustive searching")
		},
		&enable_geqo,
382
		true, NULL, NULL
383
	},
384
	{
385 386 387 388 389 390
		/* Not for general use --- used by SET SESSION AUTHORIZATION */
		{"is_superuser", PGC_INTERNAL, UNGROUPED,
			gettext_noop("Set to indicate current user's privilege status"),
			NULL,
			GUC_REPORT | GUC_NO_SHOW_ALL | GUC_NO_RESET_ALL | GUC_NOT_IN_SAMPLE | GUC_DISALLOW_IN_FILE
		},
391 392 393
		&session_auth_is_superuser,
		false, NULL, NULL
	},
394
	{
395 396 397 398 399
		{"tcpip_socket", PGC_POSTMASTER, CONN_AUTH_SETTINGS,
			gettext_noop("Accept TCP/IP connections"),
			NULL
		},
		&NetServer,
400
		false, NULL, NULL
401 402
	},
	{
403 404 405 406 407
		{"ssl", PGC_POSTMASTER, CONN_AUTH_SECURITY,
			gettext_noop("Enables SSL connections"),
			NULL
		},
		&EnableSSL,
408
		false, NULL, NULL
409 410
	},
	{
411 412 413 414 415 416 417 418
		{"fsync", PGC_SIGHUP, WAL_SETTINGS,
			gettext_noop("If on, server physically writes updates to disk"),
			gettext_noop("It will use the fsync() system call in several places to make "
						 "sure that updates are physically written to disk. This insures "
						 "that a database cluster will recover to a consistent state after "
						 "an operating system or hardware crash")
		},
		&enableFsync,
419
		true, NULL, NULL
420
	},
421
	{
422 423 424 425 426 427 428 429 430 431
		{"zero_damaged_pages", PGC_SUSET, DEVELOPER_OPTIONS,
			gettext_noop("Continues processing past damaged page headers"),
			gettext_noop("Detection of a damaged page header normally causes PostgreSQL to "
			"report an error, aborting the current transaction. Setting "
						 "zero_damaged_pages to true causes the system to instead report a "
						 "warning, zero out the damaged page, and continue processing. This "
						 "behavior will destroy data, namely all the rows on the damaged page"),
			GUC_NOT_IN_SAMPLE | GUC_DISALLOW_IN_FILE
		},
		&zero_damaged_pages,
432 433
		false, NULL, NULL
	},
434
	{
435 436 437 438 439 440
		{"silent_mode", PGC_POSTMASTER, LOGGING_WHEN,
			gettext_noop("Runs the server silently"),
			gettext_noop("If this option is set, the server will automatically run in the"
			"background and any controlling terminals are disassociated")
		},
		&SilentMode,
441
		false, NULL, NULL
442 443
	},
	{
444 445 446 447 448
		{"log_connections", PGC_BACKEND, LOGGING_WHAT,
			gettext_noop("Logs each successful connection"),
			NULL
		},
		&Log_connections,
449
		false, NULL, NULL
450 451
	},
	{
452 453 454 455 456
		{"log_timestamp", PGC_SIGHUP, LOGGING_WHAT,
			gettext_noop("Prefixes server log messages with a time stamp"),
			NULL
		},
		&Log_timestamp,
457
		false, NULL, NULL
458 459
	},
	{
460 461 462 463 464
		{"log_pid", PGC_SIGHUP, LOGGING_WHAT,
			gettext_noop("Prefixes server log messages with the server PID"),
			NULL
		},
		&Log_pid,
465
		false, NULL, NULL
466
	},
467

468
#ifdef USE_ASSERT_CHECKING
469
	{
470 471 472 473 474 475 476
		{"debug_assertions", PGC_USERSET, DEVELOPER_OPTIONS,
			gettext_noop("Turns on various assertion checks"),
			gettext_noop("This is a debugging aid. To use this option, "
						 "PostgreSQL must be built with the configure option --enable-cassert"),
			GUC_NOT_IN_SAMPLE
		},
		&assert_enabled,
477
		true, NULL, NULL
478
	},
479 480
#endif

481 482
	{
		/* currently undocumented, so don't show in SHOW ALL */
483 484 485 486 487 488
		{"exit_on_error", PGC_USERSET, UNGROUPED,
			gettext_noop("No Description Available"),
			NULL,
			GUC_NO_SHOW_ALL | GUC_NOT_IN_SAMPLE
		},
		&ExitOnAnyError,
489 490
		false, NULL, NULL
	},
491
	{
492
		{"log_statement", PGC_USERLIMIT, LOGGING_WHAT,
493 494 495 496
			gettext_noop("Causes each SQL statement to be logged"),
			NULL
		},
		&log_statement,
497 498 499
		false, NULL, NULL
	},
	{
500
		{"log_duration", PGC_USERLIMIT, LOGGING_WHAT,
501 502 503 504
			gettext_noop("Duration of every completed statement is logged"),
			NULL
		},
		&log_duration,
505
		false, NULL, NULL
506 507
	},
	{
508 509 510 511 512
		{"debug_print_parse", PGC_USERSET, LOGGING_WHAT,
			gettext_noop("Parse tree printed to server logs"),
			gettext_noop("Parsed for each executed query")
		},
		&Debug_print_parse,
513
		false, NULL, NULL
514 515
	},
	{
516 517 518 519 520
		{"debug_print_rewritten", PGC_USERSET, LOGGING_WHAT,
			gettext_noop("Prints query rewriter output to server log"),
			NULL
		},
		&Debug_print_rewritten,
521
		false, NULL, NULL
522 523
	},
	{
524 525 526 527 528
		{"debug_print_plan", PGC_USERSET, LOGGING_WHAT,
			gettext_noop("Prints execution plan to the server log"),
			NULL
		},
		&Debug_print_plan,
529
		false, NULL, NULL
530 531
	},
	{
532 533 534 535 536
		{"debug_pretty_print", PGC_USERSET, LOGGING_WHAT,
			gettext_noop("Indents displays from parse, rewritten and plan"),
			NULL
		},
		&Debug_pretty_print,
537
		false, NULL, NULL
538 539
	},
	{
540
		{"log_parser_stats", PGC_USERLIMIT, STATS_MONITORING,
541 542 543 544
			gettext_noop("Write parser performance stats to server log"),
			NULL
		},
		&log_parser_stats,
545
		false, NULL, NULL
546 547
	},
	{
548
		{"log_planner_stats", PGC_USERLIMIT, STATS_MONITORING,
549 550 551 552
			gettext_noop("Write planner performance stats to server log"),
			NULL
		},
		&log_planner_stats,
553
		false, NULL, NULL
554 555
	},
	{
556
		{"log_executor_stats", PGC_USERLIMIT, STATS_MONITORING,
557 558 559 560
			gettext_noop("Write executor performance stats to server log"),
			NULL
		},
		&log_executor_stats,
561
		false, NULL, NULL
562 563
	},
	{
564
		{"log_statement_stats", PGC_USERLIMIT, STATS_MONITORING,
565 566 567 568
			gettext_noop("Write statement performance stats to server log"),
			NULL
		},
		&log_statement_stats,
569
		false, NULL, NULL
570
	},
571
#ifdef BTREE_BUILD_STATS
572
	{
573 574 575 576 577 578
		{"log_btree_build_stats", PGC_SUSET, DEVELOPER_OPTIONS,
			gettext_noop("No Description Available"),
			NULL,
			GUC_NOT_IN_SAMPLE
		},
		&log_btree_build_stats,
579
		false, NULL, NULL
580
	},
581 582
#endif

583
	{
584 585 586 587 588
		{"explain_pretty_print", PGC_USERSET, CLIENT_CONN_OTHER,
			gettext_noop("Use indented output format for EXPLAIN VERBOSE"),
			NULL
		},
		&Explain_pretty_print,
589
		true, NULL, NULL
590
	},
591
	{
592 593 594 595 596
		{"stats_start_collector", PGC_POSTMASTER, STATS_COLLECTOR,
			gettext_noop("Start server statistics-collection subprocess"),
			NULL
		},
		&pgstat_collect_startcollector,
597
		true, NULL, NULL
598 599
	},
	{
600 601 602 603 604
		{"stats_reset_on_server_start", PGC_POSTMASTER, STATS_COLLECTOR,
			gettext_noop("Collected statistics zeroed out on server restart"),
			NULL
		},
		&pgstat_collect_resetonpmstart,
605
		true, NULL, NULL
606 607
	},
	{
608 609 610 611 612 613 614
		{"stats_command_string", PGC_SUSET, STATS_COLLECTOR,
			gettext_noop("Enable stat collection of executing commands"),
			gettext_noop("Enables the collection of statistics on the currently "
				"executing command of each session, along with the time "
						 "at which that command began execution.")
		},
		&pgstat_collect_querystring,
615
		false, NULL, NULL
616 617
	},
	{
618 619 620 621 622
		{"stats_row_level", PGC_SUSET, STATS_COLLECTOR,
			gettext_noop("Enable collection of row-level stats on db activity"),
			NULL
		},
		&pgstat_collect_tuplelevel,
623
		false, NULL, NULL
624 625
	},
	{
626 627 628 629 630
		{"stats_block_level", PGC_SUSET, STATS_COLLECTOR,
			gettext_noop("Enables collection of block-level stats on db activity"),
			NULL
		},
		&pgstat_collect_blocklevel,
631
		false, NULL, NULL
632
	},
633

634
	{
635 636 637 638 639 640
		{"trace_notify", PGC_USERSET, DEVELOPER_OPTIONS,
			gettext_noop("Generates debugging output for LISTEN and NOTIFY"),
			NULL,
			GUC_NOT_IN_SAMPLE
		},
		&Trace_notify,
641
		false, NULL, NULL
642
	},
643 644

#ifdef LOCK_DEBUG
645
	{
646 647 648 649 650 651
		{"trace_locks", PGC_SUSET, DEVELOPER_OPTIONS,
			gettext_noop("No Description Available"),
			NULL,
			GUC_NOT_IN_SAMPLE
		},
		&Trace_locks,
652
		false, NULL, NULL
653 654
	},
	{
655 656 657 658 659 660
		{"trace_userlocks", PGC_SUSET, DEVELOPER_OPTIONS,
			gettext_noop("No Description Available"),
			NULL,
			GUC_NOT_IN_SAMPLE
		},
		&Trace_userlocks,
661
		false, NULL, NULL
662 663
	},
	{
664 665 666 667 668 669
		{"trace_lwlocks", PGC_SUSET, DEVELOPER_OPTIONS,
			gettext_noop("No Description Available"),
			NULL,
			GUC_NOT_IN_SAMPLE
		},
		&Trace_lwlocks,
670
		false, NULL, NULL
671 672
	},
	{
673 674 675 676 677 678
		{"debug_deadlocks", PGC_SUSET, DEVELOPER_OPTIONS,
			gettext_noop("No Description Available"),
			NULL,
			GUC_NOT_IN_SAMPLE
		},
		&Debug_deadlocks,
679
		false, NULL, NULL
680
	},
681 682
#endif

683
	{
684 685 686 687 688 689 690 691
		{"log_hostname", PGC_SIGHUP, LOGGING_WHAT,
			gettext_noop("Log hostname to connection logs"),
			gettext_noop("By default, connection logs only show the IP address "
						 "of the connecting host. If you want them to show the host name you "
						 "can turn this on, but depending on your host name resolution "
			"setup it might impose a non-negligible performance penalty")
		},
		&log_hostname,
692
		false, NULL, NULL
693 694
	},
	{
695 696 697 698 699
		{"log_source_port", PGC_SIGHUP, LOGGING_WHAT,
			gettext_noop("Log outgoing port number of the connecting host"),
			NULL
		},
		&LogSourcePort,
700
		false, NULL, NULL
701
	},
702

703
	{
704 705 706 707 708 709
		{"sql_inheritance", PGC_USERSET, COMPAT_OPTIONS_PREVIOUS,
			gettext_noop("This controls the inheritance semantics"),
			gettext_noop("In particular, whether subtables are included by "
						 "various commands by default")
		},
		&SQL_inheritance,
710
		true, NULL, NULL
711 712
	},
	{
713 714 715 716 717 718 719
		{"australian_timezones", PGC_USERSET, CLIENT_CONN_LOCALE,
			gettext_noop("If true, ACST, CST, EST, and SAT are interpreted "
						 "as Australian time zones"),
			gettext_noop("Otherwise they are interpreted as North/South American "
						 "time zones and Saturday")
		},
		&Australian_timezones,
720
		false, ClearDateCache, NULL
721 722
	},
	{
723 724 725 726 727 728 729
		{"password_encryption", PGC_USERSET, CONN_AUTH_SECURITY,
			gettext_noop("If unspecified the password is encrypted"),
			gettext_noop("When a password is specified in CREATE USER or "
			"ALTER USER without writing either ENCRYPTED or UNENCRYPTED, "
						 "this option determines whether the password is to be encrypted")
		},
		&Password_encryption,
730
		true, NULL, NULL
731 732
	},
	{
733 734 735 736 737 738 739 740 741
		{"transform_null_equals", PGC_USERSET, COMPAT_OPTIONS_CLIENT,
			gettext_noop("expr=NULL treated as expr IS NULL"),
			gettext_noop("When turned on, expressions of the form expr = NULL "
			"(or NULL = expr) are treated as expr IS NULL, that is, they "
			"return true if expr evaluates to the null value, and false "
			"otherwise. The correct behavior of expr = NULL is to always "
						 "return null (unknown)")
		},
		&Transform_null_equals,
742
		false, NULL, NULL
743
	},
744
	{
745 746 747 748 749
		{"db_user_namespace", PGC_SIGHUP, CONN_AUTH_SECURITY,
			gettext_noop("This allows per-database user names"),
			NULL
		},
		&Db_user_namespace,
750 751
		false, NULL, NULL
	},
752
	{
753 754 755 756 757 758 759 760
		/* only here for backwards compatibility */
		{"autocommit", PGC_USERSET, CLIENT_CONN_STATEMENT,
			gettext_noop("This var doesn't do anything"),
			gettext_noop("It's just here so that we won't choke on SET AUTOCOMMIT "
						 "TO ON from 7.3-vintage clients."),
			GUC_NO_SHOW_ALL | GUC_NOT_IN_SAMPLE
		},
		&phony_autocommit,
761
		true, assign_phony_autocommit, NULL
762
	},
763
	{
764 765 766 767 768
		{"default_transaction_read_only", PGC_USERSET, CLIENT_CONN_STATEMENT,
			gettext_noop("Controls default read-only status of new transactions"),
			NULL
		},
		&DefaultXactReadOnly,
769 770 771
		false, NULL, NULL
	},
	{
772 773 774 775 776 777
		{"transaction_read_only", PGC_USERSET, CLIENT_CONN_STATEMENT,
			gettext_noop("Current transaction's read-only status"),
			NULL,
			GUC_NO_RESET_ALL | GUC_NOT_IN_SAMPLE | GUC_DISALLOW_IN_FILE
		},
		&XactReadOnly,
778 779
		false, NULL, NULL
	},
780
	{
781 782 783 784 785
		{"add_missing_from", PGC_USERSET, COMPAT_OPTIONS_PREVIOUS,
			gettext_noop("Add missing table references to from clauses"),
			NULL
		},
		&add_missing_from,
786 787
		true, NULL, NULL
	},
788

789
	/* End-of-list marker */
790
	{
791 792
		{NULL, 0, 0, NULL, NULL}, NULL, false, NULL, NULL
	}
793 794 795
};


796
static struct config_int ConfigureNamesInt[] =
797
{
798
	{
799 800 801 802 803 804
		{"default_statistics_target", PGC_USERSET, QUERY_TUNING_OTHER,
			gettext_noop("Sets the default statistics target"),
			gettext_noop("This applies to table columns that have not had a "
			 "column-specific target set via ALTER TABLE SET STATISTICS")
		},
		&default_statistics_target,
805 806
		10, 1, 1000, NULL, NULL
	},
807
	{
808 809 810 811 812 813 814 815
		{"from_collapse_limit", PGC_USERSET, QUERY_TUNING_OTHER,
			gettext_noop("From list size beyond which sub-queries are not "
						 "collapsed"),
			gettext_noop("The planner will merge sub-queries into upper "
			"queries if the resulting FROM list would have no more than "
						 "this many items")
		},
		&from_collapse_limit,
816 817 818
		8, 1, INT_MAX, NULL, NULL
	},
	{
819 820 821 822 823 824 825 826
		{"join_collapse_limit", PGC_USERSET, QUERY_TUNING_OTHER,
			gettext_noop("From list size beyond which JOIN constructs not "
						 "flattened"),
			gettext_noop("The planner will flatten explicit inner JOIN "
						 "constructs into lists of FROM items whenever a list of no more "
						 "than this many items would result")
		},
		&join_collapse_limit,
827 828 829
		8, 1, INT_MAX, NULL, NULL
	},
	{
830 831 832 833 834
		{"geqo_threshold", PGC_USERSET, QUERY_TUNING_GEQO,
			gettext_noop("Threshold of FROM items beyond which geqo is used"),
			NULL
		},
		&geqo_threshold,
835
		11, 2, INT_MAX, NULL, NULL
836
	},
837
	{
838 839 840 841 842
		{"geqo_pool_size", PGC_USERSET, QUERY_TUNING_GEQO,
			gettext_noop("The number of individuals in one population"),
			NULL
		},
		&Geqo_pool_size,
843
		DEFAULT_GEQO_POOL_SIZE, 0, MAX_GEQO_POOL_SIZE, NULL, NULL
844 845
	},
	{
846 847 848 849 850
		{"geqo_effort", PGC_USERSET, QUERY_TUNING_GEQO,
			gettext_noop("Effort is used to calculate a default for generations"),
			NULL
		},
		&Geqo_effort,
851
		1, 1, INT_MAX, NULL, NULL
852 853
	},
	{
854 855 856 857 858 859
		{"geqo_generations", PGC_USERSET, QUERY_TUNING_GEQO,
			gettext_noop("Specifies the number of iterations in the algorithm"),
			gettext_noop("The number must be a positive integer. If 0 is "
						 "specified then Effort * Log2(PoolSize) is used")
		},
		&Geqo_generations,
860
		0, 0, INT_MAX, NULL, NULL
861 862
	},
	{
863 864 865 866 867 868
		{"geqo_random_seed", PGC_USERSET, QUERY_TUNING_GEQO,
			gettext_noop("Can be set to get reproducible results from the algorithm"),
			gettext_noop("If it is set to -1 then the algorithm behaves "
						 "non-deterministically")
		},
		&Geqo_random_seed,
869
		-1, INT_MIN, INT_MAX, NULL, NULL
870 871 872
	},

	{
873 874 875 876 877
		{"deadlock_timeout", PGC_SIGHUP, LOCK_MANAGEMENT,
			gettext_noop("Time to wait on lock (msec) before checking for deadlock"),
			NULL
		},
		&DeadlockTimeout,
878
		1000, 0, INT_MAX, NULL, NULL
879
	},
880

T
Tatsuo Ishii 已提交
881
#ifdef HAVE_SYSLOG
882
	{
883 884 885 886 887 888 889 890
		{"syslog", PGC_SIGHUP, LOGGING_SYSLOG,
			gettext_noop("Allows the use of syslog for logging"),
			gettext_noop("If this option is 1, messages go both to syslog "
						 "and the standard output. A value of 2 sends output only to syslog. "
						 "(Some messages will still go to the standard output/error.) The "
						 "default is 0, which means syslog is off")
		},
		&Use_syslog,
891
		0, 0, 2, NULL, NULL
892
	},
893 894 895
#endif

	/*
B
Bruce Momjian 已提交
896 897
	 * Note: There is some postprocessing done in PostmasterMain() to make
	 * sure the buffers are at least twice the number of backends, so the
898 899 900
	 * constraints here are partially unused. Similarly, the superuser
	 * reserved number is checked to ensure it is less than the max
	 * backends number.
901
	 */
902
	{
903 904 905 906 907
		{"max_connections", PGC_POSTMASTER, CONN_AUTH_SETTINGS,
			gettext_noop("Max number of concurrent connections"),
			NULL
		},
		&MaxBackends,
908
		DEF_MAXBACKENDS, 1, INT_MAX, NULL, NULL
909
	},
910

911
	{
912 913 914 915 916
		{"superuser_reserved_connections", PGC_POSTMASTER, CONN_AUTH_SETTINGS,
			gettext_noop("Number of 'connection slots' reserved for superusers"),
			NULL
		},
		&ReservedBackends,
917 918 919
		2, 0, INT_MAX, NULL, NULL
	},

920
	{
921 922 923 924 925
		{"shared_buffers", PGC_POSTMASTER, RESOURCES_MEM,
			gettext_noop("The number of shared memory buffers used by the server"),
			NULL
		},
		&NBuffers,
926
		DEF_NBUFFERS, 16, INT_MAX, NULL, NULL
927
	},
928

929
	{
930 931 932 933 934
		{"port", PGC_POSTMASTER, CONN_AUTH_SETTINGS,
			gettext_noop("The TCP port the server listens on"),
			NULL
		},
		&PostPortNumber,
935
		DEF_PGPORT, 1, 65535, NULL, NULL
936
	},
937

938
	{
939 940 941 942 943 944 945 946 947
		{"unix_socket_permissions", PGC_POSTMASTER, CONN_AUTH_SETTINGS,
			gettext_noop("Sets the access permissions of the Unix domain socket"),
			gettext_noop("Unix domain sockets use the usual Unix file system "
						 "permission set. The option value is expected to be an numeric mode "
						 "specification in the form accepted by the chmod and umask  system "
						 "calls. (To use the customary octal format the number must start with "
						 "a 0 (zero).)")
		},
		&Unix_socket_permissions,
948
		0777, 0000, 0777, NULL, NULL
949
	},
950

951
	{
952 953 954 955 956 957 958
		{"sort_mem", PGC_USERSET, RESOURCES_MEM,
			gettext_noop("Max memory to be used for sorts and hash tables"),
			gettext_noop("Specifies the amount of memory to be used by internal "
						 "sort operations and hash tables before switching to temporary disk "
						 "files")
		},
		&SortMem,
959
		1024, 8 * BLCKSZ / 1024, INT_MAX, NULL, NULL
960
	},
961

962
	{
963 964 965 966 967
		{"vacuum_mem", PGC_USERSET, RESOURCES_MEM,
			gettext_noop("Max mem used to keep track of to-be-reclaimed tuples"),
			NULL
		},
		&VacuumMem,
968
		8192, 1024, INT_MAX, NULL, NULL
969
	},
970

971
	{
972 973 974 975 976
		{"max_files_per_process", PGC_BACKEND, RESOURCES_KERNEL,
			gettext_noop("Max num of simultaneously open files for each subprocess"),
			NULL
		},
		&max_files_per_process,
977
		1000, 25, INT_MAX, NULL, NULL
978
	},
979

980
#ifdef LOCK_DEBUG
981
	{
982 983 984 985 986 987
		{"trace_lock_oidmin", PGC_SUSET, DEVELOPER_OPTIONS,
			gettext_noop("No Description Available"),
			NULL,
			GUC_NOT_IN_SAMPLE
		},
		&Trace_lock_oidmin,
988
		BootstrapObjectIdData, 1, INT_MAX, NULL, NULL
989 990
	},
	{
991 992 993 994 995 996
		{"trace_lock_table", PGC_SUSET, DEVELOPER_OPTIONS,
			gettext_noop("No Description Available"),
			NULL,
			GUC_NOT_IN_SAMPLE
		},
		&Trace_lock_table,
997
		0, 0, INT_MAX, NULL, NULL
998
	},
999
#endif
1000
	{
1001 1002 1003 1004 1005
		{"max_expr_depth", PGC_USERSET, CLIENT_CONN_OTHER,
			gettext_noop("Max expression nesting depth"),
			NULL
		},
		&max_expr_depth,
1006
		DEFAULT_MAX_EXPR_DEPTH, 10, INT_MAX, NULL, NULL
1007
	},
1008

1009
	{
1010 1011 1012 1013 1014
		{"statement_timeout", PGC_USERSET, CLIENT_CONN_STATEMENT,
			gettext_noop("Max allowed duration (msec) of any statement"),
			gettext_noop("A value of 0 turns off the timeout")
		},
		&StatementTimeout,
1015 1016 1017
		0, 0, INT_MAX, NULL, NULL
	},

1018
	{
1019 1020 1021 1022 1023 1024
		{"max_fsm_relations", PGC_POSTMASTER, RESOURCES_FSM,
			gettext_noop("Max num. of tables+indexes for which free space is "
						 "tracked"),
			NULL
		},
		&MaxFSMRelations,
1025
		1000, 100, INT_MAX, NULL, NULL
1026 1027
	},
	{
1028 1029 1030 1031 1032 1033
		{"max_fsm_pages", PGC_POSTMASTER, RESOURCES_FSM,
			gettext_noop("Max num. of disk pages for which free space is "
						 "tracked"),
			NULL
		},
		&MaxFSMPages,
1034
		20000, 1000, INT_MAX, NULL, NULL
1035
	},
1036

1037
	{
1038 1039 1040 1041 1042 1043 1044
		{"max_locks_per_transaction", PGC_POSTMASTER, LOCK_MANAGEMENT,
			gettext_noop("Max locks per transaction"),
			gettext_noop("The shared lock table is sized on the assumption that "
						 "at most max_locks_per_transaction * max_connections distinct "
					   "objects will need to be locked at any one time.")
		},
		&max_locks_per_xact,
1045
		64, 10, INT_MAX, NULL, NULL
1046
	},
1047

1048
	{
1049 1050 1051 1052 1053
		{"authentication_timeout", PGC_SIGHUP, CONN_AUTH_SECURITY,
			gettext_noop("Max time (sec) to complete client authentication"),
			NULL
		},
		&AuthenticationTimeout,
1054
		60, 1, 600, NULL, NULL
1055
	},
1056

1057
	{
1058 1059 1060 1061 1062 1063 1064
		/* Not for general use */
		{"pre_auth_delay", PGC_SIGHUP, DEVELOPER_OPTIONS,
			gettext_noop("No Description Available"),
			NULL,
			GUC_NOT_IN_SAMPLE
		},
		&PreAuthDelay,
1065
		0, 0, 60, NULL, NULL
1066
	},
1067

1068
	{
1069 1070 1071 1072 1073
		{"checkpoint_segments", PGC_SIGHUP, WAL_CHECKPOINTS,
			gettext_noop("Max distance between automatic WAL checkpoints"),
			NULL
		},
		&CheckPointSegments,
1074
		3, 1, INT_MAX, NULL, NULL
1075
	},
T
Tom Lane 已提交
1076

1077
	{
1078 1079 1080 1081 1082
		{"checkpoint_timeout", PGC_SIGHUP, WAL_CHECKPOINTS,
			gettext_noop("Max time (sec) between automatic WAL checkpoints"),
			NULL
		},
		&CheckPointTimeout,
1083
		300, 30, 3600, NULL, NULL
1084
	},
V
Vadim B. Mikheev 已提交
1085

1086
	{
1087 1088 1089 1090 1091 1092 1093 1094
		{"checkpoint_warning", PGC_SIGHUP, WAL_CHECKPOINTS,
			gettext_noop("Log if filling of checkpoint segments happens more"
						 "frequently than this (sec)"),
			gettext_noop("Send a message to the server logs if checkpoints "
						 "caused by the filling of checkpoint segment files happens more "
						 "frequently than this number of seconds. Zero turns off the warning.")
		},
		&CheckPointWarning,
1095 1096 1097
		30, 0, INT_MAX, NULL, NULL
	},

1098
	{
1099 1100 1101 1102 1103
		{"wal_buffers", PGC_POSTMASTER, WAL_SETTINGS,
			gettext_noop("Disk-page buffers in shared memory for WAL logging"),
			NULL
		},
		&XLOGbuffers,
1104
		8, 4, INT_MAX, NULL, NULL
1105
	},
V
Vadim B. Mikheev 已提交
1106

1107
	{
1108 1109 1110 1111 1112 1113
		{"wal_debug", PGC_SUSET, DEVELOPER_OPTIONS,
			gettext_noop("If nonzero, log WAL-related debugging output"),
			NULL,
			GUC_NOT_IN_SAMPLE
		},
		&XLOG_DEBUG,
1114
		0, 0, 16, NULL, NULL
1115
	},
V
Vadim B. Mikheev 已提交
1116

1117
	{
1118 1119 1120 1121 1122 1123
		{"commit_delay", PGC_USERSET, WAL_CHECKPOINTS,
			gettext_noop("Delay (usec) between transaction commit and "
						 "flushing WAL to disk"),
			NULL
		},
		&CommitDelay,
1124
		0, 0, 100000, NULL, NULL
1125
	},
V
Vadim B. Mikheev 已提交
1126

1127
	{
1128 1129 1130 1131 1132 1133
		{"commit_siblings", PGC_USERSET, WAL_CHECKPOINTS,
			gettext_noop("Min concurrent open trans. before performing "
						 "COMMIT_DELAY"),
			NULL
		},
		&CommitSiblings,
1134
		5, 1, 1000, NULL, NULL
1135
	},
1136

1137
	{
1138 1139 1140 1141 1142 1143 1144 1145
		{"extra_float_digits", PGC_USERSET, CLIENT_CONN_LOCALE,
			gettext_noop("Adjusts number of digits displayed for "
						 "floating-point values"),
			gettext_noop("This affects float4, float8, and geometric data types. "
						 "The parameter value is added to the standard number of digits "
						 "(FLT_DIG or DBL_DIG as appropriate)")
		},
		&extra_float_digits,
1146 1147 1148
		0, -15, 2, NULL, NULL
	},

B
Bruce Momjian 已提交
1149
	{
1150
		{"log_min_duration_statement", PGC_USERLIMIT, LOGGING_WHEN,
1151 1152 1153 1154 1155
			gettext_noop("Min execution time (msec) above which statements will "
						 "be logged"),
			gettext_noop("The default is 0 (turning this feature off).")
		},
		&log_min_duration_statement,
B
Bruce Momjian 已提交
1156 1157 1158
		0, 0, INT_MAX / 1000, NULL, NULL
	},

1159
	/* End-of-list marker */
1160
	{
1161
		{NULL, 0, 0, NULL, NULL}, NULL, 0, 0, 0, NULL, NULL
1162
	}
1163 1164 1165
};


1166
static struct config_real ConfigureNamesReal[] =
1167
{
1168
	{
1169 1170 1171 1172 1173 1174 1175
		{"effective_cache_size", PGC_USERSET, QUERY_TUNING_COST,
			gettext_noop("Planner's assumption about size of the disk cache"),
			gettext_noop("That is, the portion of the kernel's disk cache that "
						 "will be used for PostgreSQL data files. This is measured in disk "
						 "pages, which are normally 8 kB each.")
		},
		&effective_cache_size,
1176
		DEFAULT_EFFECTIVE_CACHE_SIZE, 0, DBL_MAX, NULL, NULL
1177
	},
1178
	{
1179 1180 1181 1182 1183 1184 1185 1186 1187
		{"random_page_cost", PGC_USERSET, QUERY_TUNING_COST,
			gettext_noop("Planner's estimate of the cost of a nonsequentially "
						 "fetched disk page"),
			gettext_noop("This is measured as a multiple of the cost of a "
						 "sequential page fetch. A higher value makes it more likely a "
						 "sequential scan will be used, a lower value makes it more likely an "
						 "index scan will be used.")
		},
		&random_page_cost,
1188
		DEFAULT_RANDOM_PAGE_COST, 0, DBL_MAX, NULL, NULL
1189 1190
	},
	{
1191 1192 1193 1194 1195 1196
		{"cpu_tuple_cost", PGC_USERSET, QUERY_TUNING_COST,
			gettext_noop("Planner's estimate of the cost of processing each tuple"),
			gettext_noop("This is measured as a fraction of the cost of a "
						 "sequential page fetch.")
		},
		&cpu_tuple_cost,
1197
		DEFAULT_CPU_TUPLE_COST, 0, DBL_MAX, NULL, NULL
1198 1199
	},
	{
1200 1201 1202 1203 1204 1205 1206
		{"cpu_index_tuple_cost", PGC_USERSET, QUERY_TUNING_COST,
			gettext_noop("Planner's estimate of processing cost for each "
						 "index tuple during index scan"),
			gettext_noop("This is measured as a fraction of the cost of a "
						 "sequential page fetch.")
		},
		&cpu_index_tuple_cost,
1207
		DEFAULT_CPU_INDEX_TUPLE_COST, 0, DBL_MAX, NULL, NULL
1208 1209
	},
	{
1210 1211 1212 1213 1214 1215
		{"cpu_operator_cost", PGC_USERSET, QUERY_TUNING_COST,
			gettext_noop("Planner's estimate of processing cost of each op. in WHERE"),
			gettext_noop("This is measured as a fraction of the cost of a sequential "
						 "page fetch.")
		},
		&cpu_operator_cost,
1216
		DEFAULT_CPU_OPERATOR_COST, 0, DBL_MAX, NULL, NULL
1217 1218 1219
	},

	{
1220 1221 1222 1223 1224
		{"geqo_selection_bias", PGC_USERSET, QUERY_TUNING_GEQO,
			gettext_noop("The selective pressure within the population"),
			NULL
		},
		&Geqo_selection_bias,
1225 1226
		DEFAULT_GEQO_SELECTION_BIAS, MIN_GEQO_SELECTION_BIAS,
		MAX_GEQO_SELECTION_BIAS, NULL, NULL
1227 1228 1229
	},

	{
1230 1231 1232 1233 1234
		{"seed", PGC_USERSET, UNGROUPED,
			gettext_noop("Seed for random-number generation"),
			NULL,
			GUC_NO_SHOW_ALL | GUC_NO_RESET_ALL | GUC_NOT_IN_SAMPLE | GUC_DISALLOW_IN_FILE
		},
1235 1236 1237 1238
		&phony_random_seed,
		0.5, 0.0, 1.0, assign_random_seed, show_random_seed
	},

1239
	/* End-of-list marker */
1240
	{
1241
		{NULL, 0, 0, NULL, NULL}, NULL, 0.0, 0.0, 0.0, NULL, NULL
1242
	}
1243 1244 1245
};


1246
static struct config_string ConfigureNamesString[] =
1247
{
1248
	{
1249 1250 1251 1252 1253
		{"client_encoding", PGC_USERSET, CLIENT_CONN_LOCALE,
			gettext_noop("Client's character set encoding"),
			NULL,
			GUC_REPORT
		},
1254
		&client_encoding_string,
1255
		"SQL_ASCII", assign_client_encoding, NULL
1256 1257
	},

1258
	{
1259 1260 1261 1262 1263 1264 1265 1266
		{"client_min_messages", PGC_USERSET, LOGGING_WHEN,
			gettext_noop("Controls which message levels are sent to the client"),
			gettext_noop("Valid values are DEBUG5, DEBUG4, DEBUG3, DEBUG2, "
						 "DEBUG1, LOG, NOTICE, WARNING, and ERROR. Each level includes all the "
						 "levels that follow it. The later the level, the fewer messages are "
						 "sent.")
		},
		&client_min_messages_str,
1267
		"notice", assign_client_min_messages, NULL
1268
	},
1269

1270
	{
1271
		{"log_min_messages", PGC_USERLIMIT, LOGGING_WHEN,
1272 1273 1274 1275 1276 1277
			gettext_noop("Controls which message levels logged"),
			gettext_noop("Valid values are DEBUG5, DEBUG4, DEBUG3, DEBUG2, DEBUG1, "
						 "INFO, NOTICE, WARNING, ERROR, LOG, FATAL, and PANIC. Each level "
						 "includes all the levels that follow it")
		},
		&log_min_messages_str,
1278 1279 1280 1281
		"notice", assign_log_min_messages, NULL
	},

	{
1282 1283 1284 1285 1286
		{"log_error_verbosity", PGC_SUSET, LOGGING_WHEN,
			gettext_noop("Controls verbosity of logged messages"),
			gettext_noop("Valid values are TERSE, DEFAULT, and VERBOSE")
		},
		&log_error_verbosity_str,
1287 1288 1289
		"default", assign_log_error_verbosity, NULL
	},

1290
	{
1291
		{"log_min_error_statement", PGC_USERLIMIT, LOGGING_WHEN,
1292 1293 1294 1295 1296
			gettext_noop("Controls whether the erroneous statement is logged"),
			gettext_noop("All SQL statements that cause an error of the "
						 "specified level, or a higher level, are logged")
		},
		&log_min_error_statement_str,
1297
		"panic", assign_min_error_statement, NULL
1298 1299
	},

1300
	{
1301 1302 1303 1304 1305 1306
		{"DateStyle", PGC_USERSET, CLIENT_CONN_LOCALE,
			gettext_noop("The display format for date and time values"),
			gettext_noop("As well as the rules for interpreting ambiguous date "
						 "input values"),
			GUC_LIST_INPUT | GUC_REPORT
		},
1307
		&datestyle_string,
1308
		"ISO, US", assign_datestyle, NULL
1309
	},
1310

1311
	{
1312 1313 1314 1315 1316 1317
		{"default_transaction_isolation", PGC_USERSET, CLIENT_CONN_STATEMENT,
			gettext_noop("The default isolation level of each new transaction"),
			gettext_noop("Each SQL transaction has an isolation level, which "
					 "can be either 'read committed' or 'serializable'.")
		},
		&default_iso_level_string,
1318
		"read committed", assign_defaultxactisolevel, NULL
1319 1320
	},

1321
	{
1322 1323 1324 1325 1326 1327 1328 1329
		{"dynamic_library_path", PGC_SUSET, CLIENT_CONN_OTHER,
			gettext_noop("Path for dynamically loadable modules"),
			gettext_noop("If a dynamically loadable module needs to be opened and "
						 "the specified name does not have a directory component (i.e. the "
						 "name does not contain a slash), the system will search this path for "
						 "the specified file.")
		},
		&Dynamic_library_path,
1330 1331 1332 1333
		"$libdir", NULL, NULL
	},

	{
1334 1335 1336 1337 1338
		{"krb_server_keyfile", PGC_POSTMASTER, CONN_AUTH_SECURITY,
			gettext_noop("The location of the Kerberos server key file"),
			NULL
		},
		&pg_krb_server_keyfile,
1339
		PG_KRB_SRVTAB, NULL, NULL
1340
	},
1341

1342 1343 1344 1345 1346 1347 1348 1349 1350
	{
		{"rendezvous_name", PGC_POSTMASTER, CONN_AUTH_SETTINGS,
			gettext_noop("The Rendezvous broadcast service name"),
			NULL
		},
		&rendezvous_name,
		"", NULL, NULL
	},

1351 1352
	/* See main.c about why defaults for LC_foo are not all alike */

1353
	{
1354 1355 1356 1357 1358 1359
		{"lc_collate", PGC_INTERNAL, CLIENT_CONN_LOCALE,
			gettext_noop("Locale collation order"),
			NULL,
			GUC_NOT_IN_SAMPLE | GUC_DISALLOW_IN_FILE
		},
		&locale_collate,
1360 1361 1362 1363
		"C", NULL, NULL
	},

	{
1364 1365 1366 1367 1368 1369
		{"lc_ctype", PGC_INTERNAL, CLIENT_CONN_LOCALE,
			gettext_noop("Locale character classification and case conversion"),
			NULL,
			GUC_NOT_IN_SAMPLE | GUC_DISALLOW_IN_FILE
		},
		&locale_ctype,
1370 1371 1372
		"C", NULL, NULL
	},

1373
	{
1374 1375 1376 1377 1378
		{"lc_messages", PGC_SUSET, CLIENT_CONN_LOCALE,
			gettext_noop("Language in which messages are displayed"),
			NULL
		},
		&locale_messages,
1379 1380 1381 1382
		"", locale_messages_assign, NULL
	},

	{
1383 1384 1385 1386 1387
		{"lc_monetary", PGC_USERSET, CLIENT_CONN_LOCALE,
			gettext_noop("Locale for formatting monetary amounts"),
			NULL
		},
		&locale_monetary,
1388
		"C", locale_monetary_assign, NULL
1389 1390 1391
	},

	{
1392 1393 1394 1395 1396
		{"lc_numeric", PGC_USERSET, CLIENT_CONN_LOCALE,
			gettext_noop("Locale for formatting numbers"),
			NULL
		},
		&locale_numeric,
1397
		"C", locale_numeric_assign, NULL
1398 1399 1400
	},

	{
1401 1402 1403 1404 1405
		{"lc_time", PGC_USERSET, CLIENT_CONN_LOCALE,
			gettext_noop("Locale for formatting date and time values"),
			NULL
		},
		&locale_time,
1406
		"C", locale_time_assign, NULL
1407 1408
	},

1409
	{
1410 1411 1412 1413 1414
		{"preload_libraries", PGC_POSTMASTER, RESOURCES_KERNEL,
			gettext_noop("Shared libraries to preload into postmaster"),
			NULL,
			GUC_LIST_INPUT | GUC_LIST_QUOTE
		},
1415 1416 1417 1418
		&preload_libraries_string,
		"", NULL, NULL
	},

1419
	{
1420 1421 1422 1423 1424
		{"regex_flavor", PGC_USERSET, COMPAT_OPTIONS_PREVIOUS,
			gettext_noop("Regular expression 'flavor'"),
			gettext_noop("This can be set to advanced, extended, or basic")
		},
		&regex_flavor_string,
1425 1426 1427
		"advanced", assign_regex_flavor, NULL
	},

1428
	{
1429 1430 1431 1432 1433
		{"search_path", PGC_USERSET, CLIENT_CONN_STATEMENT,
			gettext_noop("Schema search order for names not schema-qualified"),
			NULL,
			GUC_LIST_INPUT | GUC_LIST_QUOTE
		},
1434 1435
		&namespace_search_path,
		"$user,public", assign_search_path, NULL
1436 1437 1438
	},

	{
1439 1440 1441 1442 1443 1444
		/* Can't be set in postgresql.conf */
		{"server_encoding", PGC_INTERNAL, CLIENT_CONN_LOCALE,
			gettext_noop("Server (database) character set encoding"),
			NULL,
			GUC_REPORT | GUC_NOT_IN_SAMPLE | GUC_DISALLOW_IN_FILE
		},
1445 1446 1447 1448 1449
		&server_encoding_string,
		"SQL_ASCII", NULL, NULL
	},

	{
1450 1451 1452 1453 1454 1455
		/* Can't be set in postgresql.conf */
		{"server_version", PGC_INTERNAL, UNGROUPED,
			gettext_noop("Server version"),
			NULL,
			GUC_REPORT | GUC_NOT_IN_SAMPLE | GUC_DISALLOW_IN_FILE
		},
1456 1457
		&server_version_string,
		PG_VERSION, NULL, NULL
1458 1459
	},

1460
	{
1461 1462 1463 1464 1465 1466
		/* Not for general use --- used by SET SESSION AUTHORIZATION */
		{"session_authorization", PGC_USERSET, UNGROUPED,
			gettext_noop("Current session userid"),
			NULL,
			GUC_NO_SHOW_ALL | GUC_NO_RESET_ALL | GUC_NOT_IN_SAMPLE | GUC_DISALLOW_IN_FILE
		},
1467 1468
		&session_authorization_string,
		NULL, assign_session_authorization, show_session_authorization
1469 1470
	},

T
Tatsuo Ishii 已提交
1471
#ifdef HAVE_SYSLOG
1472
	{
1473 1474 1475 1476 1477 1478
		{"syslog_facility", PGC_POSTMASTER, LOGGING_SYSLOG,
			gettext_noop("Which syslog 'facility' to be used when syslog enabled"),
			gettext_noop("You may choose from LOCAL0, LOCAL1, LOCAL2, LOCAL3, "
						 "LOCAL4, LOCAL5, LOCAL6, LOCAL7")
		},
		&Syslog_facility,
1479
		"LOCAL0", assign_facility, NULL
1480 1481
	},
	{
1482 1483 1484 1485 1486 1487
		{"syslog_ident", PGC_POSTMASTER, LOGGING_SYSLOG,
			gettext_noop("Program name used to identify PostgreSQL messages "
						 "in syslog"),
			NULL
		},
		&Syslog_ident,
1488
		"postgres", NULL, NULL
1489
	},
1490
#endif
1491

1492
	{
1493 1494 1495 1496 1497
		{"TimeZone", PGC_USERSET, CLIENT_CONN_LOCALE,
			gettext_noop("Time zone for displaying and interpreting time stamps"),
			NULL
		},
		&timezone_string,
1498 1499 1500 1501
		"UNKNOWN", assign_timezone, show_timezone
	},

	{
1502 1503 1504 1505 1506
		{"transaction_isolation", PGC_USERSET, CLIENT_CONN_STATEMENT,
			gettext_noop("Current transaction's isolation level"),
			NULL,
			GUC_NO_RESET_ALL | GUC_NOT_IN_SAMPLE | GUC_DISALLOW_IN_FILE
		},
1507 1508 1509 1510 1511
		&XactIsoLevel_string,
		NULL, assign_XactIsoLevel, show_XactIsoLevel
	},

	{
1512 1513 1514 1515 1516 1517
		{"unix_socket_group", PGC_POSTMASTER, CONN_AUTH_SETTINGS,
			gettext_noop("The group owner of the Unix domain socket"),
			gettext_noop("(The owning user of the socket is always the user "
						 "that starts the server.)")
		},
		&Unix_socket_group,
1518
		"", NULL, NULL
1519
	},
1520

1521
	{
1522 1523 1524 1525 1526
		{"unix_socket_directory", PGC_POSTMASTER, CONN_AUTH_SETTINGS,
			gettext_noop("The Unix-domain socket directory to listen to"),
			NULL
		},
		&UnixSocketDir,
1527
		"", NULL, NULL
1528
	},
1529

1530
	{
1531 1532 1533 1534 1535
		{"virtual_host", PGC_POSTMASTER, CONN_AUTH_SETTINGS,
			gettext_noop("The host name or IP address to listen to"),
			NULL
		},
		&VirtualHost,
1536
		"", NULL, NULL
1537
	},
1538

1539
	{
1540 1541 1542 1543 1544
		{"wal_sync_method", PGC_SIGHUP, WAL_SETTINGS,
			gettext_noop("Method used for forcing WAL updates out to disk"),
			NULL
		},
		&XLOG_sync_method,
1545
		XLOG_sync_method_default, assign_xlog_sync_method, NULL
1546
	},
1547

1548
	/* End-of-list marker */
1549
	{
1550
		{NULL, 0, 0, NULL, NULL}, NULL, NULL, NULL, NULL
1551
	}
1552 1553 1554 1555 1556 1557
};

/******** end of options list ********/


/*
1558
 * Actual lookup of variables is done through this single, sorted array.
1559
 */
1560 1561
struct config_generic **guc_variables;
int			num_guc_variables;
1562

1563
static bool guc_dirty;			/* TRUE if need to do commit/abort work */
1564

1565 1566
static bool reporting_enabled;	/* TRUE to enable GUC_REPORT */

B
Bruce Momjian 已提交
1567
static char *guc_string_workspace;		/* for avoiding memory leaks */
1568

1569

B
Bruce Momjian 已提交
1570
static int	guc_var_compare(const void *a, const void *b);
1571
static void ReportGUCOption(struct config_generic * record);
B
Bruce Momjian 已提交
1572
static char *_ShowOption(struct config_generic * record);
1573 1574 1575


/*
B
Bruce Momjian 已提交
1576
 * Build the sorted array.	This is split out so that it could be
1577 1578
 * re-executed after startup (eg, we could allow loadable modules to
 * add vars, and then we'd need to re-sort).
1579
 */
1580
void
1581
build_guc_variables(void)
1582
{
1583 1584
	int			num_vars = 0;
	struct config_generic **guc_vars;
B
Bruce Momjian 已提交
1585
	int			i;
1586

1587
	for (i = 0; ConfigureNamesBool[i].gen.name; i++)
1588 1589 1590
	{
		struct config_bool *conf = &ConfigureNamesBool[i];

1591 1592 1593
		/* Rather than requiring vartype to be filled in by hand, do this: */
		conf->gen.vartype = PGC_BOOL;
		num_vars++;
1594
	}
1595

1596
	for (i = 0; ConfigureNamesInt[i].gen.name; i++)
1597 1598 1599
	{
		struct config_int *conf = &ConfigureNamesInt[i];

1600 1601
		conf->gen.vartype = PGC_INT;
		num_vars++;
1602
	}
1603

1604
	for (i = 0; ConfigureNamesReal[i].gen.name; i++)
1605 1606 1607
	{
		struct config_real *conf = &ConfigureNamesReal[i];

1608 1609
		conf->gen.vartype = PGC_REAL;
		num_vars++;
1610
	}
1611

1612
	for (i = 0; ConfigureNamesString[i].gen.name; i++)
1613
	{
1614
		struct config_string *conf = &ConfigureNamesString[i];
1615

1616 1617
		conf->gen.vartype = PGC_STRING;
		num_vars++;
1618 1619
	}

1620 1621 1622
	guc_vars = (struct config_generic **)
		malloc(num_vars * sizeof(struct config_generic *));
	if (!guc_vars)
1623 1624 1625
		ereport(FATAL,
				(errcode(ERRCODE_OUT_OF_MEMORY),
				 errmsg("out of memory")));
1626

1627
	num_vars = 0;
1628

1629
	for (i = 0; ConfigureNamesBool[i].gen.name; i++)
B
Bruce Momjian 已提交
1630
		guc_vars[num_vars++] = &ConfigureNamesBool[i].gen;
1631

1632
	for (i = 0; ConfigureNamesInt[i].gen.name; i++)
B
Bruce Momjian 已提交
1633
		guc_vars[num_vars++] = &ConfigureNamesInt[i].gen;
1634

1635
	for (i = 0; ConfigureNamesReal[i].gen.name; i++)
B
Bruce Momjian 已提交
1636
		guc_vars[num_vars++] = &ConfigureNamesReal[i].gen;
1637

1638
	for (i = 0; ConfigureNamesString[i].gen.name; i++)
B
Bruce Momjian 已提交
1639
		guc_vars[num_vars++] = &ConfigureNamesString[i].gen;
1640

1641 1642
	qsort((void *) guc_vars, num_vars, sizeof(struct config_generic *),
		  guc_var_compare);
1643

1644 1645 1646 1647
	if (guc_variables)
		free(guc_variables);
	guc_variables = guc_vars;
	num_guc_variables = num_vars;
1648 1649 1650 1651
}


/*
1652 1653
 * Look up option NAME. If it exists, return a pointer to its record,
 * else return NULL.
1654
 */
1655 1656
static struct config_generic *
find_option(const char *name)
1657
{
1658 1659
	const char **key = &name;
	struct config_generic **res;
1660

1661
	Assert(name);
1662

1663 1664 1665 1666
	/*
	 * by equating const char ** with struct config_generic *, we are
	 * assuming the name field is first in config_generic.
	 */
B
Bruce Momjian 已提交
1667 1668 1669 1670 1671
	res = (struct config_generic **) bsearch((void *) &key,
											 (void *) guc_variables,
											 num_guc_variables,
										 sizeof(struct config_generic *),
											 guc_var_compare);
1672 1673 1674 1675
	if (res)
		return *res;
	return NULL;
}
1676 1677 1678


/*
1679
 * comparator for qsorting and bsearching guc_variables array
1680
 */
1681 1682
static int
guc_var_compare(const void *a, const void *b)
1683
{
1684 1685
	struct config_generic *confa = *(struct config_generic **) a;
	struct config_generic *confb = *(struct config_generic **) b;
1686 1687
	const char *namea;
	const char *nameb;
1688

1689 1690 1691
	/*
	 * The temptation to use strcasecmp() here must be resisted, because
	 * the array ordering has to remain stable across setlocale() calls.
1692
	 * So, build our own with a simple ASCII-only downcasing.
1693
	 */
1694 1695 1696 1697 1698 1699 1700 1701 1702 1703 1704 1705 1706
	namea = confa->name;
	nameb = confb->name;
	while (*namea && *nameb)
	{
		char		cha = *namea++;
		char		chb = *nameb++;

		if (cha >= 'A' && cha <= 'Z')
			cha += 'a' - 'A';
		if (chb >= 'A' && chb <= 'Z')
			chb += 'a' - 'A';
		if (cha != chb)
			return cha - chb;
1707
	}
1708 1709 1710 1711 1712
	if (*namea)
		return 1;				/* a is longer */
	if (*nameb)
		return -1;				/* b is longer */
	return 0;
1713
}
1714 1715 1716


/*
1717
 * Initialize GUC options during program startup.
1718
 */
1719 1720
void
InitializeGUCOptions(void)
1721
{
1722 1723
	int			i;
	char	   *env;
1724

1725 1726 1727 1728
	/*
	 * Build sorted array of all GUC variables.
	 */
	build_guc_variables();
1729

1730
	/*
1731 1732
	 * Load all variables with their compiled-in defaults, and initialize
	 * status fields as needed.
1733
	 */
1734
	for (i = 0; i < num_guc_variables; i++)
1735
	{
1736
		struct config_generic *gconf = guc_variables[i];
1737

1738 1739 1740 1741 1742 1743 1744 1745 1746
		gconf->status = 0;
		gconf->reset_source = PGC_S_DEFAULT;
		gconf->session_source = PGC_S_DEFAULT;
		gconf->tentative_source = PGC_S_DEFAULT;
		gconf->source = PGC_S_DEFAULT;

		switch (gconf->vartype)
		{
			case PGC_BOOL:
B
Bruce Momjian 已提交
1747 1748
				{
					struct config_bool *conf = (struct config_bool *) gconf;
1749

B
Bruce Momjian 已提交
1750 1751
					if (conf->assign_hook)
						if (!(*conf->assign_hook) (conf->reset_val, true, false))
1752 1753
							elog(FATAL, "failed to initialize %s to %d",
								 conf->gen.name, (int) conf->reset_val);
B
Bruce Momjian 已提交
1754 1755 1756 1757
					*conf->variable = conf->reset_val;
					conf->session_val = conf->reset_val;
					break;
				}
1758
			case PGC_INT:
B
Bruce Momjian 已提交
1759 1760
				{
					struct config_int *conf = (struct config_int *) gconf;
1761

B
Bruce Momjian 已提交
1762 1763
					Assert(conf->reset_val >= conf->min);
					Assert(conf->reset_val <= conf->max);
1764 1765 1766
					/* Check to make sure we only have valid PGC_USERLIMITs */
					Assert(conf->gen.context != PGC_USERLIMIT ||
						   strcmp(conf->gen.name, "log_min_duration_statement") == 0);
B
Bruce Momjian 已提交
1767 1768
					if (conf->assign_hook)
						if (!(*conf->assign_hook) (conf->reset_val, true, false))
1769 1770
							elog(FATAL, "failed to initialize %s to %d",
								 conf->gen.name, conf->reset_val);
B
Bruce Momjian 已提交
1771 1772 1773 1774
					*conf->variable = conf->reset_val;
					conf->session_val = conf->reset_val;
					break;
				}
1775 1776
			case PGC_REAL:
				{
B
Bruce Momjian 已提交
1777 1778 1779 1780
					struct config_real *conf = (struct config_real *) gconf;

					Assert(conf->reset_val >= conf->min);
					Assert(conf->reset_val <= conf->max);
1781
					Assert(conf->gen.context != PGC_USERLIMIT);
B
Bruce Momjian 已提交
1782 1783
					if (conf->assign_hook)
						if (!(*conf->assign_hook) (conf->reset_val, true, false))
1784 1785
							elog(FATAL, "failed to initialize %s to %g",
								 conf->gen.name, conf->reset_val);
B
Bruce Momjian 已提交
1786 1787
					*conf->variable = conf->reset_val;
					conf->session_val = conf->reset_val;
1788 1789
					break;
				}
B
Bruce Momjian 已提交
1790
			case PGC_STRING:
1791
				{
B
Bruce Momjian 已提交
1792 1793 1794
					struct config_string *conf = (struct config_string *) gconf;
					char	   *str;

1795 1796 1797 1798 1799
					/* Check to make sure we only have valid PGC_USERLIMITs */
					Assert(conf->gen.context != PGC_USERLIMIT ||
						   conf->assign_hook == assign_log_min_messages ||
						   conf->assign_hook == assign_client_min_messages ||
						   conf->assign_hook == assign_min_error_statement);
B
Bruce Momjian 已提交
1800 1801 1802 1803
					*conf->variable = NULL;
					conf->reset_val = NULL;
					conf->session_val = NULL;
					conf->tentative_val = NULL;
1804

B
Bruce Momjian 已提交
1805
					if (conf->boot_val == NULL)
1806
					{
B
Bruce Momjian 已提交
1807 1808
						/* Cannot set value yet */
						break;
1809
					}
B
Bruce Momjian 已提交
1810 1811 1812

					str = strdup(conf->boot_val);
					if (str == NULL)
1813 1814 1815
						ereport(FATAL,
								(errcode(ERRCODE_OUT_OF_MEMORY),
								 errmsg("out of memory")));
B
Bruce Momjian 已提交
1816 1817 1818
					conf->reset_val = str;

					if (conf->assign_hook)
1819
					{
B
Bruce Momjian 已提交
1820 1821 1822 1823 1824
						const char *newstr;

						newstr = (*conf->assign_hook) (str, true, false);
						if (newstr == NULL)
						{
1825 1826
							elog(FATAL, "failed to initialize %s to \"%s\"",
								 conf->gen.name, str);
B
Bruce Momjian 已提交
1827 1828 1829 1830 1831 1832 1833 1834 1835 1836 1837 1838
						}
						else if (newstr != str)
						{
							free(str);

							/*
							 * See notes in set_config_option about
							 * casting
							 */
							str = (char *) newstr;
							conf->reset_val = str;
						}
1839
					}
B
Bruce Momjian 已提交
1840 1841 1842
					*conf->variable = str;
					conf->session_val = str;
					break;
1843 1844 1845 1846 1847 1848
				}
		}
	}

	guc_dirty = false;

1849 1850
	reporting_enabled = false;

1851 1852 1853
	guc_string_workspace = NULL;

	/*
1854
	 * Prevent any attempt to override the transaction modes from
1855 1856
	 * non-interactive sources.
	 */
1857 1858 1859
	SetConfigOption("transaction_isolation", "default",
					PGC_POSTMASTER, PGC_S_OVERRIDE);
	SetConfigOption("transaction_read_only", "no",
1860 1861 1862 1863
					PGC_POSTMASTER, PGC_S_OVERRIDE);

	/*
	 * For historical reasons, some GUC parameters can receive defaults
B
Bruce Momjian 已提交
1864
	 * from environment variables.	Process those settings.
1865 1866 1867 1868 1869 1870 1871 1872 1873 1874 1875 1876 1877 1878 1879 1880 1881 1882 1883 1884 1885 1886 1887 1888 1889 1890 1891 1892 1893 1894 1895 1896 1897
	 */

	env = getenv("PGPORT");
	if (env != NULL)
		SetConfigOption("port", env, PGC_POSTMASTER, PGC_S_ENV_VAR);

	env = getenv("PGDATESTYLE");
	if (env != NULL)
		SetConfigOption("datestyle", env, PGC_POSTMASTER, PGC_S_ENV_VAR);

	env = getenv("TZ");
	if (env != NULL)
		SetConfigOption("timezone", env, PGC_POSTMASTER, PGC_S_ENV_VAR);

	env = getenv("PGCLIENTENCODING");
	if (env != NULL)
		SetConfigOption("client_encoding", env, PGC_POSTMASTER, PGC_S_ENV_VAR);
}


/*
 * Reset all options to their saved default values (implements RESET ALL)
 */
void
ResetAllOptions(void)
{
	int			i;

	for (i = 0; i < num_guc_variables; i++)
	{
		struct config_generic *gconf = guc_variables[i];

		/* Don't reset non-SET-able values */
1898 1899 1900
		if (gconf->context != PGC_SUSET &&
			gconf->context != PGC_USERLIMIT &&
			gconf->context != PGC_USERSET)
1901 1902 1903 1904 1905 1906 1907 1908 1909 1910 1911
			continue;
		/* Don't reset if special exclusion from RESET ALL */
		if (gconf->flags & GUC_NO_RESET_ALL)
			continue;
		/* No need to reset if wasn't SET */
		if (gconf->source <= PGC_S_OVERRIDE)
			continue;

		switch (gconf->vartype)
		{
			case PGC_BOOL:
B
Bruce Momjian 已提交
1912 1913
				{
					struct config_bool *conf = (struct config_bool *) gconf;
1914

B
Bruce Momjian 已提交
1915 1916
					if (conf->assign_hook)
						if (!(*conf->assign_hook) (conf->reset_val, true, true))
1917
							elog(ERROR, "failed to reset %s", conf->gen.name);
B
Bruce Momjian 已提交
1918 1919 1920 1921 1922 1923 1924 1925
					*conf->variable = conf->reset_val;
					conf->tentative_val = conf->reset_val;
					conf->gen.source = conf->gen.reset_source;
					conf->gen.tentative_source = conf->gen.reset_source;
					conf->gen.status |= GUC_HAVE_TENTATIVE;
					guc_dirty = true;
					break;
				}
1926
			case PGC_INT:
B
Bruce Momjian 已提交
1927 1928
				{
					struct config_int *conf = (struct config_int *) gconf;
1929

B
Bruce Momjian 已提交
1930 1931
					if (conf->assign_hook)
						if (!(*conf->assign_hook) (conf->reset_val, true, true))
1932
							elog(ERROR, "failed to reset %s", conf->gen.name);
B
Bruce Momjian 已提交
1933 1934 1935 1936 1937 1938 1939 1940
					*conf->variable = conf->reset_val;
					conf->tentative_val = conf->reset_val;
					conf->gen.source = conf->gen.reset_source;
					conf->gen.tentative_source = conf->gen.reset_source;
					conf->gen.status |= GUC_HAVE_TENTATIVE;
					guc_dirty = true;
					break;
				}
1941 1942
			case PGC_REAL:
				{
B
Bruce Momjian 已提交
1943 1944 1945 1946
					struct config_real *conf = (struct config_real *) gconf;

					if (conf->assign_hook)
						if (!(*conf->assign_hook) (conf->reset_val, true, true))
1947
							elog(ERROR, "failed to reset %s", conf->gen.name);
B
Bruce Momjian 已提交
1948 1949 1950 1951 1952 1953
					*conf->variable = conf->reset_val;
					conf->tentative_val = conf->reset_val;
					conf->gen.source = conf->gen.reset_source;
					conf->gen.tentative_source = conf->gen.reset_source;
					conf->gen.status |= GUC_HAVE_TENTATIVE;
					guc_dirty = true;
1954 1955
					break;
				}
B
Bruce Momjian 已提交
1956 1957 1958 1959
			case PGC_STRING:
				{
					struct config_string *conf = (struct config_string *) gconf;
					char	   *str;
1960

B
Bruce Momjian 已提交
1961 1962 1963 1964 1965
					if (conf->reset_val == NULL)
					{
						/* Nothing to reset to, as yet; so do nothing */
						break;
					}
1966

B
Bruce Momjian 已提交
1967 1968
					/* We need not strdup here */
					str = conf->reset_val;
1969

B
Bruce Momjian 已提交
1970
					if (conf->assign_hook)
1971
					{
B
Bruce Momjian 已提交
1972 1973 1974 1975
						const char *newstr;

						newstr = (*conf->assign_hook) (str, true, true);
						if (newstr == NULL)
1976
							elog(ERROR, "failed to reset %s", conf->gen.name);
B
Bruce Momjian 已提交
1977 1978 1979 1980 1981 1982 1983 1984
						else if (newstr != str)
						{
							/*
							 * See notes in set_config_option about
							 * casting
							 */
							str = (char *) newstr;
						}
1985 1986
					}

B
Bruce Momjian 已提交
1987 1988 1989 1990 1991 1992 1993 1994
					SET_STRING_VARIABLE(conf, str);
					SET_STRING_TENTATIVE_VAL(conf, str);
					conf->gen.source = conf->gen.reset_source;
					conf->gen.tentative_source = conf->gen.reset_source;
					conf->gen.status |= GUC_HAVE_TENTATIVE;
					guc_dirty = true;
					break;
				}
1995
		}
1996 1997 1998

		if (gconf->flags & GUC_REPORT)
			ReportGUCOption(gconf);
1999 2000 2001 2002 2003 2004 2005 2006 2007 2008 2009 2010 2011 2012 2013 2014
	}
}


/*
 * Do GUC processing at transaction commit or abort.
 */
void
AtEOXact_GUC(bool isCommit)
{
	int			i;

	/* Quick exit if nothing's changed in this transaction */
	if (!guc_dirty)
		return;

2015
	/* Prevent memory leak if ereport during an assign_hook */
2016 2017 2018 2019 2020 2021 2022 2023 2024
	if (guc_string_workspace)
	{
		free(guc_string_workspace);
		guc_string_workspace = NULL;
	}

	for (i = 0; i < num_guc_variables; i++)
	{
		struct config_generic *gconf = guc_variables[i];
2025
		bool		changed;
2026 2027 2028 2029 2030

		/* Skip if nothing's happened to this var in this transaction */
		if (gconf->status == 0)
			continue;

2031 2032
		changed = false;

2033 2034 2035 2036
		switch (gconf->vartype)
		{
			case PGC_BOOL:
				{
B
Bruce Momjian 已提交
2037
					struct config_bool *conf = (struct config_bool *) gconf;
2038

B
Bruce Momjian 已提交
2039 2040 2041 2042 2043 2044 2045 2046 2047 2048 2049
					if (isCommit && (conf->gen.status & GUC_HAVE_TENTATIVE))
					{
						conf->session_val = conf->tentative_val;
						conf->gen.session_source = conf->gen.tentative_source;
					}

					if (*conf->variable != conf->session_val)
					{
						if (conf->assign_hook)
							if (!(*conf->assign_hook) (conf->session_val,
													   true, false))
2050 2051
								elog(LOG, "failed to commit %s",
									 conf->gen.name);
B
Bruce Momjian 已提交
2052
						*conf->variable = conf->session_val;
2053
						changed = true;
B
Bruce Momjian 已提交
2054 2055 2056 2057
					}
					conf->gen.source = conf->gen.session_source;
					conf->gen.status = 0;
					break;
2058 2059 2060
				}
			case PGC_INT:
				{
B
Bruce Momjian 已提交
2061
					struct config_int *conf = (struct config_int *) gconf;
2062

B
Bruce Momjian 已提交
2063 2064 2065 2066 2067 2068 2069 2070 2071 2072 2073
					if (isCommit && (conf->gen.status & GUC_HAVE_TENTATIVE))
					{
						conf->session_val = conf->tentative_val;
						conf->gen.session_source = conf->gen.tentative_source;
					}

					if (*conf->variable != conf->session_val)
					{
						if (conf->assign_hook)
							if (!(*conf->assign_hook) (conf->session_val,
													   true, false))
2074 2075
								elog(LOG, "failed to commit %s",
									 conf->gen.name);
B
Bruce Momjian 已提交
2076
						*conf->variable = conf->session_val;
2077
						changed = true;
B
Bruce Momjian 已提交
2078 2079 2080 2081
					}
					conf->gen.source = conf->gen.session_source;
					conf->gen.status = 0;
					break;
2082 2083 2084
				}
			case PGC_REAL:
				{
B
Bruce Momjian 已提交
2085
					struct config_real *conf = (struct config_real *) gconf;
2086

B
Bruce Momjian 已提交
2087 2088 2089 2090 2091
					if (isCommit && (conf->gen.status & GUC_HAVE_TENTATIVE))
					{
						conf->session_val = conf->tentative_val;
						conf->gen.session_source = conf->gen.tentative_source;
					}
2092

B
Bruce Momjian 已提交
2093 2094 2095 2096 2097
					if (*conf->variable != conf->session_val)
					{
						if (conf->assign_hook)
							if (!(*conf->assign_hook) (conf->session_val,
													   true, false))
2098 2099
								elog(LOG, "failed to commit %s",
									 conf->gen.name);
B
Bruce Momjian 已提交
2100
						*conf->variable = conf->session_val;
2101
						changed = true;
B
Bruce Momjian 已提交
2102 2103 2104 2105
					}
					conf->gen.source = conf->gen.session_source;
					conf->gen.status = 0;
					break;
2106
				}
B
Bruce Momjian 已提交
2107
			case PGC_STRING:
2108
				{
B
Bruce Momjian 已提交
2109
					struct config_string *conf = (struct config_string *) gconf;
2110

B
Bruce Momjian 已提交
2111 2112 2113 2114 2115 2116 2117 2118
					if (isCommit && (conf->gen.status & GUC_HAVE_TENTATIVE))
					{
						SET_STRING_SESSION_VAL(conf, conf->tentative_val);
						conf->gen.session_source = conf->gen.tentative_source;
						conf->tentative_val = NULL;		/* transfer ownership */
					}
					else
						SET_STRING_TENTATIVE_VAL(conf, NULL);
2119

B
Bruce Momjian 已提交
2120
					if (*conf->variable != conf->session_val)
2121
					{
B
Bruce Momjian 已提交
2122
						char	   *str = conf->session_val;
2123

B
Bruce Momjian 已提交
2124
						if (conf->assign_hook)
2125
						{
B
Bruce Momjian 已提交
2126 2127 2128 2129
							const char *newstr;

							newstr = (*conf->assign_hook) (str, true, false);
							if (newstr == NULL)
2130 2131
								elog(LOG, "failed to commit %s",
									 conf->gen.name);
B
Bruce Momjian 已提交
2132 2133 2134 2135 2136 2137 2138 2139 2140
							else if (newstr != str)
							{
								/*
								 * See notes in set_config_option about
								 * casting
								 */
								str = (char *) newstr;
								SET_STRING_SESSION_VAL(conf, str);
							}
2141 2142
						}

B
Bruce Momjian 已提交
2143
						SET_STRING_VARIABLE(conf, str);
2144
						changed = true;
B
Bruce Momjian 已提交
2145 2146 2147 2148
					}
					conf->gen.source = conf->gen.session_source;
					conf->gen.status = 0;
					break;
2149 2150
				}
		}
2151 2152 2153

		if (changed && (gconf->flags & GUC_REPORT))
			ReportGUCOption(gconf);
2154 2155 2156 2157 2158 2159
	}

	guc_dirty = false;
}


2160 2161 2162 2163 2164 2165 2166 2167 2168 2169 2170 2171 2172 2173 2174 2175 2176 2177 2178 2179 2180 2181 2182 2183 2184 2185 2186 2187 2188 2189 2190 2191 2192
/*
 * Start up automatic reporting of changes to variables marked GUC_REPORT.
 * This is executed at completion of backend startup.
 */
void
BeginReportingGUCOptions(void)
{
	int			i;

	/*
	 * Don't do anything unless talking to an interactive frontend of
	 * protocol 3.0 or later.
	 */
	if (whereToSendOutput != Remote ||
		PG_PROTOCOL_MAJOR(FrontendProtocol) < 3)
		return;

	reporting_enabled = true;

	/* Transmit initial values of interesting variables */
	for (i = 0; i < num_guc_variables; i++)
	{
		struct config_generic *conf = guc_variables[i];

		if (conf->flags & GUC_REPORT)
			ReportGUCOption(conf);
	}
}

/*
 * ReportGUCOption: if appropriate, transmit option value to frontend
 */
static void
2193
ReportGUCOption(struct config_generic * record)
2194 2195 2196
{
	if (reporting_enabled && (record->flags & GUC_REPORT))
	{
2197
		char	   *val = _ShowOption(record);
2198 2199 2200 2201 2202 2203 2204 2205 2206 2207 2208 2209
		StringInfoData msgbuf;

		pq_beginmessage(&msgbuf, 'S');
		pq_sendstring(&msgbuf, record->name);
		pq_sendstring(&msgbuf, val);
		pq_endmessage(&msgbuf);

		pfree(val);
	}
}


2210 2211 2212 2213 2214 2215 2216 2217 2218 2219 2220 2221 2222 2223 2224 2225 2226 2227 2228 2229 2230 2231 2232 2233 2234 2235 2236 2237 2238 2239 2240 2241 2242 2243 2244 2245 2246 2247 2248 2249 2250 2251 2252 2253 2254 2255 2256 2257 2258 2259 2260 2261 2262 2263 2264 2265 2266 2267 2268 2269 2270 2271 2272 2273 2274 2275 2276 2277 2278 2279 2280 2281 2282 2283 2284 2285 2286 2287 2288 2289 2290 2291 2292 2293 2294 2295 2296 2297 2298 2299 2300 2301 2302 2303 2304 2305 2306 2307 2308 2309 2310 2311 2312 2313 2314 2315 2316 2317 2318 2319 2320 2321 2322 2323 2324 2325 2326 2327 2328 2329 2330 2331 2332 2333
/*
 * Try to interpret value as boolean value.  Valid values are: true,
 * false, yes, no, on, off, 1, 0.  If the string parses okay, return
 * true, else false.  If result is not NULL, return the parsing result
 * there.
 */
static bool
parse_bool(const char *value, bool *result)
{
	size_t		len = strlen(value);

	if (strncasecmp(value, "true", len) == 0)
	{
		if (result)
			*result = true;
	}
	else if (strncasecmp(value, "false", len) == 0)
	{
		if (result)
			*result = false;
	}

	else if (strncasecmp(value, "yes", len) == 0)
	{
		if (result)
			*result = true;
	}
	else if (strncasecmp(value, "no", len) == 0)
	{
		if (result)
			*result = false;
	}

	else if (strcasecmp(value, "on") == 0)
	{
		if (result)
			*result = true;
	}
	else if (strcasecmp(value, "off") == 0)
	{
		if (result)
			*result = false;
	}

	else if (strcasecmp(value, "1") == 0)
	{
		if (result)
			*result = true;
	}
	else if (strcasecmp(value, "0") == 0)
	{
		if (result)
			*result = false;
	}

	else
		return false;
	return true;
}



/*
 * Try to parse value as an integer.  The accepted formats are the
 * usual decimal, octal, or hexadecimal formats.  If the string parses
 * okay, return true, else false.  If result is not NULL, return the
 * value there.
 */
static bool
parse_int(const char *value, int *result)
{
	long		val;
	char	   *endptr;

	errno = 0;
	val = strtol(value, &endptr, 0);
	if (endptr == value || *endptr != '\0' || errno == ERANGE
#ifdef HAVE_LONG_INT_64
	/* if long > 32 bits, check for overflow of int4 */
		|| val != (long) ((int32) val)
#endif
		)
		return false;
	if (result)
		*result = (int) val;
	return true;
}



/*
 * Try to parse value as a floating point constant in the usual
 * format.	If the value parsed okay return true, else false.  If
 * result is not NULL, return the semantic value there.
 */
static bool
parse_real(const char *value, double *result)
{
	double		val;
	char	   *endptr;

	errno = 0;
	val = strtod(value, &endptr);
	if (endptr == value || *endptr != '\0' || errno == ERANGE)
		return false;
	if (result)
		*result = val;
	return true;
}



/*
 * Sets option `name' to given value. The value should be a string
 * which is going to be parsed and converted to the appropriate data
 * type.  The context and source parameters indicate in which context this
 * function is being called so it can apply the access restrictions
 * properly.
 *
 * If value is NULL, set the option to its default value. If the
 * parameter DoIt is false then don't really set the option but do all
 * the checks to see if it would work.
 *
 * If there is an error (non-existing option, invalid value) then an
2334 2335 2336 2337
 * ereport(ERROR) is thrown *unless* this is called in a context where we
 * don't want to ereport (currently, startup or SIGHUP config file reread).
 * In that case we write a suitable error message via ereport(DEBUG) and
 * return false. This is working around the deficiencies in the ereport
2338 2339 2340 2341 2342 2343 2344 2345 2346 2347 2348 2349 2350 2351 2352
 * mechanism, so don't blame me.  In all other cases, the function
 * returns true, including cases where the input is valid but we chose
 * not to apply it because of context or source-priority considerations.
 *
 * See also SetConfigOption for an external interface.
 */
bool
set_config_option(const char *name, const char *value,
				  GucContext context, GucSource source,
				  bool isLocal, bool DoIt)
{
	struct config_generic *record;
	int			elevel;
	bool		interactive;
	bool		makeDefault;
2353
	bool		DoIt_orig;
2354 2355

	if (context == PGC_SIGHUP || source == PGC_S_DEFAULT)
2356
		elevel = DEBUG2;
2357 2358 2359 2360 2361 2362 2363 2364
	else if (source == PGC_S_DATABASE || source == PGC_S_USER)
		elevel = INFO;
	else
		elevel = ERROR;

	record = find_option(name);
	if (record == NULL)
	{
2365 2366 2367
		ereport(elevel,
				(errcode(ERRCODE_UNDEFINED_OBJECT),
				 errmsg("\"%s\" is not a recognized option", name)));
2368 2369 2370 2371 2372 2373 2374 2375 2376 2377 2378
		return false;
	}

	/*
	 * Check if the option can be set at this time. See guc.h for the
	 * precise rules. Note that we don't want to throw errors if we're in
	 * the SIGHUP context. In that case we just ignore the attempt and
	 * return true.
	 */
	switch (record->context)
	{
2379 2380 2381 2382 2383
		case PGC_INTERNAL:
			if (context == PGC_SIGHUP)
				return true;
			if (context != PGC_INTERNAL)
			{
2384 2385 2386 2387
				ereport(elevel,
						(errcode(ERRCODE_CANT_CHANGE_RUNTIME_PARAM),
						 errmsg("\"%s\" cannot be changed",
								name)));
2388 2389 2390
				return false;
			}
			break;
2391 2392 2393 2394 2395
		case PGC_POSTMASTER:
			if (context == PGC_SIGHUP)
				return true;
			if (context != PGC_POSTMASTER)
			{
2396 2397 2398 2399
				ereport(elevel,
						(errcode(ERRCODE_CANT_CHANGE_RUNTIME_PARAM),
						 errmsg("\"%s\" cannot be changed after server start",
								name)));
2400 2401 2402 2403 2404 2405
				return false;
			}
			break;
		case PGC_SIGHUP:
			if (context != PGC_SIGHUP && context != PGC_POSTMASTER)
			{
2406 2407 2408 2409
				ereport(elevel,
						(errcode(ERRCODE_CANT_CHANGE_RUNTIME_PARAM),
						 errmsg("\"%s\" cannot be changed now",
								name)));
2410 2411 2412 2413 2414 2415 2416 2417 2418 2419 2420 2421 2422 2423 2424 2425 2426 2427 2428 2429 2430 2431 2432 2433 2434 2435
				return false;
			}

			/*
			 * Hmm, the idea of the SIGHUP context is "ought to be global,
			 * but can be changed after postmaster start". But there's
			 * nothing that prevents a crafty administrator from sending
			 * SIGHUP signals to individual backends only.
			 */
			break;
		case PGC_BACKEND:
			if (context == PGC_SIGHUP)
			{
				/*
				 * If a PGC_BACKEND parameter is changed in the config
				 * file, we want to accept the new value in the postmaster
				 * (whence it will propagate to subsequently-started
				 * backends), but ignore it in existing backends.  This is
				 * a tad klugy, but necessary because we don't re-read the
				 * config file during backend start.
				 */
				if (IsUnderPostmaster)
					return true;
			}
			else if (context != PGC_BACKEND && context != PGC_POSTMASTER)
			{
2436 2437 2438 2439
				ereport(elevel,
						(errcode(ERRCODE_CANT_CHANGE_RUNTIME_PARAM),
						 errmsg("\"%s\" cannot be set after connection start",
								name)));
2440 2441 2442 2443 2444 2445
				return false;
			}
			break;
		case PGC_SUSET:
			if (context == PGC_USERSET || context == PGC_BACKEND)
			{
2446 2447 2448 2449
				ereport(elevel,
						(errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
						 errmsg("\"%s\": permission denied",
								name)));
2450
				return false;
2451 2452
			}
			break;
2453 2454 2455
		case PGC_USERLIMIT:
			/* USERLIMIT permissions checked below */
			break;
2456 2457 2458
		case PGC_USERSET:
			/* always okay */
			break;
2459
	}
2460

2461
	/* Should we report errors interactively? */
2462
	interactive = (source >= PGC_S_SESSION);
B
Bruce Momjian 已提交
2463

2464
	/*
B
Bruce Momjian 已提交
2465
	 * Should we set reset/session values?	(If so, the behavior is not
2466 2467 2468
	 * transactional.)
	 */
	makeDefault = DoIt && (source <= PGC_S_OVERRIDE) && (value != NULL);
2469 2470 2471

	/*
	 * Ignore attempted set if overridden by previously processed setting.
B
Bruce Momjian 已提交
2472 2473 2474 2475 2476
	 * However, if DoIt is false then plow ahead anyway since we are
	 * trying to find out if the value is potentially good, not actually
	 * use it. Also keep going if makeDefault is true, since we may want
	 * to set the reset/session values even if we can't set the variable
	 * itself.
2477
	 */
2478
	DoIt_orig = DoIt;	/* we might have to reverse this later */
2479 2480 2481 2482
	if (record->source > source)
	{
		if (DoIt && !makeDefault)
		{
2483
			elog(DEBUG3, "\"%s\": setting ignored because previous source is higher priority",
2484 2485 2486 2487 2488 2489
				 name);
			return true;
		}
		DoIt = false;			/* we won't change the variable itself */
	}

2490 2491 2492
	/*
	 * Evaluate value and set variable
	 */
2493
	switch (record->vartype)
2494 2495 2496
	{
		case PGC_BOOL:
			{
B
Bruce Momjian 已提交
2497
				struct config_bool *conf = (struct config_bool *) record;
2498
				bool		newval;
B
Bruce Momjian 已提交
2499 2500

				if (value)
2501
				{
2502 2503
					if (!parse_bool(value, &newval))
					{
2504 2505 2506 2507
						ereport(elevel,
								(errcode(ERRCODE_INVALID_PARAMETER_VALUE),
								 errmsg("\"%s\" requires a boolean value",
										name)));
2508 2509
						return false;
					}
2510 2511 2512 2513 2514 2515
					/* Limit non-super user changes */
					if (record->context == PGC_USERLIMIT &&
						source > PGC_S_USERSTART &&
						newval < conf->session_val &&
						!superuser())
					{
2516 2517 2518 2519 2520
						ereport(elevel,
								(errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
								 errmsg("\"%s\": permission denied",
										name),
								 errhint("Must be superuser to change this value to false.")));
2521 2522 2523 2524 2525 2526 2527 2528 2529
						return false;
					}
					/* Allow admin to override non-super user setting */
					if (record->context == PGC_USERLIMIT &&
						source < PGC_S_USERSTART &&
						record->session_source > PGC_S_USERSTART &&
						newval > conf->session_val &&
						!superuser())
							DoIt = DoIt_orig;
2530 2531 2532 2533 2534 2535
				}
				else
				{
					newval = conf->reset_val;
					source = conf->gen.reset_source;
				}
B
Bruce Momjian 已提交
2536

2537 2538
				if (conf->assign_hook)
					if (!(*conf->assign_hook) (newval, DoIt, interactive))
B
Bruce Momjian 已提交
2539
					{
2540 2541 2542 2543
						ereport(elevel,
								(errcode(ERRCODE_INVALID_PARAMETER_VALUE),
								 errmsg("invalid value for \"%s\": %d",
										name, (int) newval)));
B
Bruce Momjian 已提交
2544 2545
						return false;
					}
2546 2547 2548

				if (DoIt || makeDefault)
				{
B
Bruce Momjian 已提交
2549
					if (DoIt)
2550
					{
2551 2552 2553 2554 2555 2556 2557 2558 2559 2560 2561 2562 2563 2564 2565 2566 2567 2568 2569 2570 2571 2572 2573 2574 2575 2576 2577
						*conf->variable = newval;
						conf->gen.source = source;
					}
					if (makeDefault)
					{
						if (conf->gen.reset_source <= source)
						{
							conf->reset_val = newval;
							conf->gen.reset_source = source;
						}
						if (conf->gen.session_source <= source)
						{
							conf->session_val = newval;
							conf->gen.session_source = source;
						}
					}
					else if (isLocal)
					{
						conf->gen.status |= GUC_HAVE_LOCAL;
						guc_dirty = true;
					}
					else
					{
						conf->tentative_val = newval;
						conf->gen.tentative_source = source;
						conf->gen.status |= GUC_HAVE_TENTATIVE;
						guc_dirty = true;
2578
					}
2579
				}
B
Bruce Momjian 已提交
2580
				break;
2581
			}
2582 2583

		case PGC_INT:
2584
			{
B
Bruce Momjian 已提交
2585
				struct config_int *conf = (struct config_int *) record;
2586
				int			newval;
2587

B
Bruce Momjian 已提交
2588
				if (value)
2589
				{
2590
					if (!parse_int(value, &newval))
B
Bruce Momjian 已提交
2591
					{
2592 2593 2594 2595
						ereport(elevel,
								(errcode(ERRCODE_INVALID_PARAMETER_VALUE),
								 errmsg("\"%s\" requires an integer value",
										name)));
B
Bruce Momjian 已提交
2596 2597
						return false;
					}
2598
					if (newval < conf->min || newval > conf->max)
B
Bruce Momjian 已提交
2599
					{
2600 2601 2602 2603
						ereport(elevel,
								(errcode(ERRCODE_INVALID_PARAMETER_VALUE),
								 errmsg("%d is outside the valid range for \"%s\" (%d .. %d)",
										newval, name, conf->min, conf->max)));
B
Bruce Momjian 已提交
2604 2605
						return false;
					}
2606 2607 2608 2609
					/* Limit non-super user changes */
					if (record->context == PGC_USERLIMIT &&
						source > PGC_S_USERSTART &&
						conf->session_val != 0 &&
2610
						(newval > conf->session_val || newval == 0) &&
2611 2612
						!superuser())
					{
2613 2614 2615 2616 2617
						ereport(elevel,
								(errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
								 errmsg("\"%s\": permission denied",
										name),
								 errhint("Must be superuser to increase this value or set it to zero.")));
2618 2619 2620 2621 2622 2623 2624 2625 2626
						return false;
					}
					/* Allow admin to override non-super user setting */
					if (record->context == PGC_USERLIMIT &&
						source < PGC_S_USERSTART &&
						record->session_source > PGC_S_USERSTART &&
						newval < conf->session_val &&
						!superuser())
							DoIt = DoIt_orig;
2627 2628 2629 2630 2631 2632 2633 2634 2635
				}
				else
				{
					newval = conf->reset_val;
					source = conf->gen.reset_source;
				}

				if (conf->assign_hook)
					if (!(*conf->assign_hook) (newval, DoIt, interactive))
2636
					{
2637 2638 2639 2640
						ereport(elevel,
								(errcode(ERRCODE_INVALID_PARAMETER_VALUE),
								 errmsg("invalid value for \"%s\": %d",
										name, newval)));
2641 2642
						return false;
					}
2643 2644 2645

				if (DoIt || makeDefault)
				{
B
Bruce Momjian 已提交
2646
					if (DoIt)
2647
					{
2648 2649 2650 2651 2652 2653 2654 2655 2656 2657 2658 2659 2660 2661 2662 2663 2664 2665 2666 2667 2668 2669 2670 2671 2672 2673 2674
						*conf->variable = newval;
						conf->gen.source = source;
					}
					if (makeDefault)
					{
						if (conf->gen.reset_source <= source)
						{
							conf->reset_val = newval;
							conf->gen.reset_source = source;
						}
						if (conf->gen.session_source <= source)
						{
							conf->session_val = newval;
							conf->gen.session_source = source;
						}
					}
					else if (isLocal)
					{
						conf->gen.status |= GUC_HAVE_LOCAL;
						guc_dirty = true;
					}
					else
					{
						conf->tentative_val = newval;
						conf->gen.tentative_source = source;
						conf->gen.status |= GUC_HAVE_TENTATIVE;
						guc_dirty = true;
2675
					}
2676
				}
B
Bruce Momjian 已提交
2677
				break;
2678
			}
2679 2680

		case PGC_REAL:
2681
			{
B
Bruce Momjian 已提交
2682
				struct config_real *conf = (struct config_real *) record;
2683
				double		newval;
2684

B
Bruce Momjian 已提交
2685
				if (value)
2686
				{
2687
					if (!parse_real(value, &newval))
B
Bruce Momjian 已提交
2688
					{
2689 2690 2691 2692
						ereport(elevel,
								(errcode(ERRCODE_INVALID_PARAMETER_VALUE),
								 errmsg("\"%s\" requires a numeric value",
										name)));
B
Bruce Momjian 已提交
2693 2694
						return false;
					}
2695
					if (newval < conf->min || newval > conf->max)
B
Bruce Momjian 已提交
2696
					{
2697 2698 2699 2700
						ereport(elevel,
								(errcode(ERRCODE_INVALID_PARAMETER_VALUE),
								 errmsg("%g is outside the valid range for \"%s\" (%g .. %g)",
										newval, name, conf->min, conf->max)));
B
Bruce Momjian 已提交
2701 2702
						return false;
					}
2703 2704 2705 2706 2707 2708
					/* Limit non-super user changes */
					if (record->context == PGC_USERLIMIT &&
						source > PGC_S_USERSTART &&
						newval > conf->session_val &&
						!superuser())
					{
2709 2710 2711 2712 2713
						ereport(elevel,
								(errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
								 errmsg("\"%s\": permission denied",
										name),
								 errhint("Must be superuser to increase this value.")));
2714 2715 2716 2717 2718 2719 2720 2721 2722
						return false;
					}
					/* Allow admin to override non-super user setting */
					if (record->context == PGC_USERLIMIT &&
						source < PGC_S_USERSTART &&
						record->session_source > PGC_S_USERSTART &&
						newval < conf->session_val &&
						!superuser())
							DoIt = DoIt_orig;
2723 2724 2725 2726 2727 2728 2729 2730 2731
				}
				else
				{
					newval = conf->reset_val;
					source = conf->gen.reset_source;
				}

				if (conf->assign_hook)
					if (!(*conf->assign_hook) (newval, DoIt, interactive))
2732
					{
2733 2734 2735 2736
						ereport(elevel,
								(errcode(ERRCODE_INVALID_PARAMETER_VALUE),
								 errmsg("invalid value for \"%s\": %g",
										name, newval)));
2737 2738
						return false;
					}
2739 2740 2741

				if (DoIt || makeDefault)
				{
B
Bruce Momjian 已提交
2742
					if (DoIt)
2743
					{
2744 2745 2746 2747 2748 2749 2750 2751 2752 2753 2754 2755 2756 2757 2758 2759 2760 2761 2762 2763 2764 2765 2766 2767 2768 2769 2770
						*conf->variable = newval;
						conf->gen.source = source;
					}
					if (makeDefault)
					{
						if (conf->gen.reset_source <= source)
						{
							conf->reset_val = newval;
							conf->gen.reset_source = source;
						}
						if (conf->gen.session_source <= source)
						{
							conf->session_val = newval;
							conf->gen.session_source = source;
						}
					}
					else if (isLocal)
					{
						conf->gen.status |= GUC_HAVE_LOCAL;
						guc_dirty = true;
					}
					else
					{
						conf->tentative_val = newval;
						conf->gen.tentative_source = source;
						conf->gen.status |= GUC_HAVE_TENTATIVE;
						guc_dirty = true;
2771
					}
2772
				}
B
Bruce Momjian 已提交
2773
				break;
2774
			}
2775 2776 2777

		case PGC_STRING:
			{
B
Bruce Momjian 已提交
2778
				struct config_string *conf = (struct config_string *) record;
2779
				char	   *newval;
B
Bruce Momjian 已提交
2780 2781

				if (value)
2782
				{
2783 2784 2785
					newval = strdup(value);
					if (newval == NULL)
					{
2786 2787 2788
						ereport(elevel,
								(errcode(ERRCODE_OUT_OF_MEMORY),
								 errmsg("out of memory")));
2789 2790
						return false;
					}
2791 2792 2793 2794 2795 2796 2797 2798 2799 2800 2801 2802 2803

					if (*conf->variable)
					{
						int old_int_value, new_int_value;

						/* Limit non-super user changes */
						assign_msglvl(&old_int_value, conf->reset_val, true, interactive);
						assign_msglvl(&new_int_value, newval, true, interactive);
						if (record->context == PGC_USERLIMIT &&
							source > PGC_S_USERSTART &&
							new_int_value > old_int_value &&
							!superuser())
						{
2804 2805 2806 2807 2808
							ereport(elevel,
									(errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
									 errmsg("\"%s\": permission denied",
											name),
									 errhint("Must be superuser to increase this value.")));
2809 2810 2811 2812 2813 2814 2815 2816 2817 2818
							return false;
						}
						/* Allow admin to override non-super user setting */
						if (record->context == PGC_USERLIMIT &&
							source < PGC_S_USERSTART &&
							record->session_source > PGC_S_USERSTART &&
							newval < conf->session_val &&
							!superuser())
								DoIt = DoIt_orig;
						}
2819 2820 2821
				}
				else if (conf->reset_val)
				{
2822 2823
					/*
					 * We could possibly avoid strdup here, but easier to
B
Bruce Momjian 已提交
2824 2825
					 * make this case work the same as the normal
					 * assignment case.
2826
					 */
2827 2828 2829
					newval = strdup(conf->reset_val);
					if (newval == NULL)
					{
2830 2831 2832
						ereport(elevel,
								(errcode(ERRCODE_OUT_OF_MEMORY),
								 errmsg("out of memory")));
2833 2834 2835 2836 2837 2838 2839 2840 2841 2842 2843 2844
						return false;
					}
					source = conf->gen.reset_source;
				}
				else
				{
					/* Nothing to reset to, as yet; so do nothing */
					break;
				}

				/*
				 * Remember string in workspace, so that we can free it
2845
				 * and avoid a permanent memory leak if hook ereports.
2846 2847 2848 2849 2850 2851 2852
				 */
				if (guc_string_workspace)
					free(guc_string_workspace);
				guc_string_workspace = newval;

				if (conf->assign_hook)
				{
B
Bruce Momjian 已提交
2853
					const char *hookresult;
2854 2855 2856 2857 2858

					hookresult = (*conf->assign_hook) (newval,
													   DoIt, interactive);
					guc_string_workspace = NULL;
					if (hookresult == NULL)
B
Bruce Momjian 已提交
2859
					{
2860
						free(newval);
2861 2862 2863 2864
						ereport(elevel,
								(errcode(ERRCODE_INVALID_PARAMETER_VALUE),
								 errmsg("invalid value for \"%s\": \"%s\"",
										name, value ? value : "")));
B
Bruce Momjian 已提交
2865 2866
						return false;
					}
2867
					else if (hookresult != newval)
B
Bruce Momjian 已提交
2868
					{
2869
						free(newval);
B
Bruce Momjian 已提交
2870

2871
						/*
B
Bruce Momjian 已提交
2872 2873 2874 2875 2876 2877 2878
						 * Having to cast away const here is annoying, but
						 * the alternative is to declare assign_hooks as
						 * returning char*, which would mean they'd have
						 * to cast away const, or as both taking and
						 * returning char*, which doesn't seem attractive
						 * either --- we don't want them to scribble on
						 * the passed str.
2879 2880 2881 2882 2883 2884
						 */
						newval = (char *) hookresult;
					}
				}

				guc_string_workspace = NULL;
B
Bruce Momjian 已提交
2885

2886 2887 2888 2889 2890 2891 2892 2893 2894 2895
				if (DoIt || makeDefault)
				{
					if (DoIt)
					{
						SET_STRING_VARIABLE(conf, newval);
						conf->gen.source = source;
					}
					if (makeDefault)
					{
						if (conf->gen.reset_source <= source)
B
Bruce Momjian 已提交
2896
						{
2897 2898
							SET_STRING_RESET_VAL(conf, newval);
							conf->gen.reset_source = source;
B
Bruce Momjian 已提交
2899
						}
2900
						if (conf->gen.session_source <= source)
2901
						{
2902 2903
							SET_STRING_SESSION_VAL(conf, newval);
							conf->gen.session_source = source;
2904
						}
2905 2906 2907 2908 2909
						/* Perhaps we didn't install newval anywhere */
						if (newval != *conf->variable &&
							newval != conf->session_val &&
							newval != conf->reset_val)
							free(newval);
B
Bruce Momjian 已提交
2910
					}
2911
					else if (isLocal)
2912
					{
2913 2914
						conf->gen.status |= GUC_HAVE_LOCAL;
						guc_dirty = true;
2915
					}
2916
					else
2917
					{
2918 2919 2920 2921
						SET_STRING_TENTATIVE_VAL(conf, newval);
						conf->gen.tentative_source = source;
						conf->gen.status |= GUC_HAVE_TENTATIVE;
						guc_dirty = true;
2922
					}
2923 2924 2925
				}
				else
					free(newval);
B
Bruce Momjian 已提交
2926
				break;
2927
			}
2928
	}
2929

2930
	if (DoIt && (record->flags & GUC_REPORT))
2931
		ReportGUCOption(record);
2932

2933 2934 2935 2936 2937 2938 2939
	return true;
}



/*
 * Set a config option to the given value. See also set_config_option,
B
Bruce Momjian 已提交
2940
 * this is just the wrapper to be called from outside GUC.	NB: this
2941
 * is used only for non-transactional operations.
2942 2943
 */
void
2944
SetConfigOption(const char *name, const char *value,
2945
				GucContext context, GucSource source)
2946
{
2947
	(void) set_config_option(name, value, context, source, false, true);
2948 2949 2950 2951 2952
}



/*
2953
 * Fetch the current value of the option `name'. If the option doesn't exist,
2954
 * throw an ereport and don't return.
2955 2956 2957 2958 2959
 *
 * The string is *not* allocated for modification and is really only
 * valid until the next call to configuration related functions.
 */
const char *
B
Bruce Momjian 已提交
2960
GetConfigOption(const char *name)
2961
{
B
Bruce Momjian 已提交
2962
	struct config_generic *record;
2963 2964
	static char buffer[256];

2965 2966
	record = find_option(name);
	if (record == NULL)
2967 2968 2969
		ereport(ERROR,
				(errcode(ERRCODE_UNDEFINED_OBJECT),
				 errmsg("\"%s\" is not a recognized option", name)));
2970

2971
	switch (record->vartype)
2972 2973
	{
		case PGC_BOOL:
B
Bruce Momjian 已提交
2974
			return *((struct config_bool *) record)->variable ? "on" : "off";
2975

2976
		case PGC_INT:
2977 2978
			snprintf(buffer, sizeof(buffer), "%d",
					 *((struct config_int *) record)->variable);
2979 2980
			return buffer;

2981
		case PGC_REAL:
2982 2983
			snprintf(buffer, sizeof(buffer), "%g",
					 *((struct config_real *) record)->variable);
2984 2985 2986
			return buffer;

		case PGC_STRING:
B
Bruce Momjian 已提交
2987
			return *((struct config_string *) record)->variable;
2988 2989 2990
	}
	return NULL;
}
2991

2992 2993 2994 2995 2996
/*
 * Get the RESET value associated with the given option.
 */
const char *
GetConfigOptionResetString(const char *name)
2997
{
2998 2999
	struct config_generic *record;
	static char buffer[256];
3000

3001 3002
	record = find_option(name);
	if (record == NULL)
3003 3004 3005
		ereport(ERROR,
				(errcode(ERRCODE_UNDEFINED_OBJECT),
				 errmsg("\"%s\" is not a recognized option", name)));
3006 3007

	switch (record->vartype)
3008 3009
	{
		case PGC_BOOL:
3010
			return ((struct config_bool *) record)->reset_val ? "on" : "off";
3011

3012
		case PGC_INT:
3013
			snprintf(buffer, sizeof(buffer), "%d",
3014 3015
					 ((struct config_int *) record)->reset_val);
			return buffer;
3016 3017

		case PGC_REAL:
3018
			snprintf(buffer, sizeof(buffer), "%g",
3019 3020
					 ((struct config_real *) record)->reset_val);
			return buffer;
3021 3022

		case PGC_STRING:
3023 3024 3025 3026
			return ((struct config_string *) record)->reset_val;
	}
	return NULL;
}
3027

3028 3029 3030 3031 3032 3033 3034 3035 3036 3037 3038 3039 3040 3041 3042 3043 3044 3045 3046


/*
 * flatten_set_variable_args
 *		Given a parsenode List as emitted by the grammar for SET,
 *		convert to the flat string representation used by GUC.
 *
 * We need to be told the name of the variable the args are for, because
 * the flattening rules vary (ugh).
 *
 * The result is NULL if input is NIL (ie, SET ... TO DEFAULT), otherwise
 * a palloc'd string.
 */
char *
flatten_set_variable_args(const char *name, List *args)
{
	struct config_generic *record;
	int			flags;
	StringInfoData buf;
B
Bruce Momjian 已提交
3047
	List	   *l;
3048

3049 3050 3051 3052
	/*
	 * Fast path if just DEFAULT.  We do not check the variable name in
	 * this case --- necessary for RESET ALL to work correctly.
	 */
3053 3054 3055
	if (args == NIL)
		return NULL;

3056
	/* Else get flags for the variable */
3057 3058
	record = find_option(name);
	if (record == NULL)
3059 3060 3061
		ereport(ERROR,
				(errcode(ERRCODE_UNDEFINED_OBJECT),
				 errmsg("\"%s\" is not a recognized option", name)));
3062 3063

	flags = record->flags;
3064 3065 3066 3067

	/* Complain if list input and non-list variable */
	if ((flags & GUC_LIST_INPUT) == 0 &&
		lnext(args) != NIL)
3068 3069 3070
		ereport(ERROR,
				(errcode(ERRCODE_INVALID_PARAMETER_VALUE),
				 errmsg("SET %s takes only one argument", name)));
3071 3072 3073 3074 3075 3076 3077 3078 3079 3080 3081 3082

	initStringInfo(&buf);

	foreach(l, args)
	{
		A_Const    *arg = (A_Const *) lfirst(l);
		char	   *val;

		if (l != args)
			appendStringInfo(&buf, ", ");

		if (!IsA(arg, A_Const))
3083
			elog(ERROR, "unrecognized node type: %d", (int) nodeTag(arg));
3084 3085 3086 3087 3088 3089 3090 3091 3092 3093 3094 3095 3096 3097 3098 3099 3100 3101 3102

		switch (nodeTag(&arg->val))
		{
			case T_Integer:
				appendStringInfo(&buf, "%ld", intVal(&arg->val));
				break;
			case T_Float:
				/* represented as a string, so just copy it */
				appendStringInfo(&buf, "%s", strVal(&arg->val));
				break;
			case T_String:
				val = strVal(&arg->val);
				if (arg->typename != NULL)
				{
					/*
					 * Must be a ConstInterval argument for TIME ZONE.
					 * Coerce to interval and back to normalize the value
					 * and account for any typmod.
					 */
B
Bruce Momjian 已提交
3103 3104
					Datum		interval;
					char	   *intervalout;
3105 3106 3107 3108 3109

					interval =
						DirectFunctionCall3(interval_in,
											CStringGetDatum(val),
											ObjectIdGetDatum(InvalidOid),
B
Bruce Momjian 已提交
3110
								   Int32GetDatum(arg->typename->typmod));
3111 3112 3113 3114

					intervalout =
						DatumGetCString(DirectFunctionCall3(interval_out,
															interval,
B
Bruce Momjian 已提交
3115 3116
											ObjectIdGetDatum(InvalidOid),
													 Int32GetDatum(-1)));
3117 3118 3119 3120 3121
					appendStringInfo(&buf, "INTERVAL '%s'", intervalout);
				}
				else
				{
					/*
B
Bruce Momjian 已提交
3122 3123
					 * Plain string literal or identifier.	For quote
					 * mode, quote it if it's not a vanilla identifier.
3124 3125 3126 3127 3128 3129 3130 3131
					 */
					if (flags & GUC_LIST_QUOTE)
						appendStringInfo(&buf, "%s", quote_identifier(val));
					else
						appendStringInfo(&buf, "%s", val);
				}
				break;
			default:
3132 3133
				elog(ERROR, "unrecognized node type: %d",
					 (int) nodeTag(&arg->val));
3134 3135
				break;
		}
3136
	}
3137 3138 3139 3140 3141 3142 3143 3144 3145 3146 3147 3148 3149 3150 3151 3152 3153 3154 3155 3156 3157 3158

	return buf.data;
}


/*
 * SET command
 */
void
SetPGVariable(const char *name, List *args, bool is_local)
{
	char	   *argstring = flatten_set_variable_args(name, args);

	/* Note SET DEFAULT (argstring == NULL) is equivalent to RESET */
	set_config_option(name,
					  argstring,
					  (superuser() ? PGC_SUSET : PGC_USERSET),
					  PGC_S_SESSION,
					  is_local,
					  true);
}

3159 3160 3161 3162 3163 3164
/*
 * SET command wrapped as a SQL callable function.
 */
Datum
set_config_by_name(PG_FUNCTION_ARGS)
{
B
Bruce Momjian 已提交
3165 3166 3167 3168 3169
	char	   *name;
	char	   *value;
	char	   *new_value;
	bool		is_local;
	text	   *result_text;
3170 3171

	if (PG_ARGISNULL(0))
3172 3173 3174
		ereport(ERROR,
				(errcode(ERRCODE_NULL_VALUE_NOT_ALLOWED),
				 errmsg("SET variable name is required")));
3175 3176

	/* Get the GUC variable name */
3177
	name = DatumGetCString(DirectFunctionCall1(textout, PG_GETARG_DATUM(0)));
3178 3179 3180 3181 3182

	/* Get the desired value or set to NULL for a reset request */
	if (PG_ARGISNULL(1))
		value = NULL;
	else
3183
		value = DatumGetCString(DirectFunctionCall1(textout, PG_GETARG_DATUM(1)));
3184 3185

	/*
B
Bruce Momjian 已提交
3186 3187
	 * Get the desired state of is_local. Default to false if provided
	 * value is NULL
3188 3189 3190 3191 3192 3193 3194 3195 3196 3197 3198 3199 3200 3201 3202
	 */
	if (PG_ARGISNULL(2))
		is_local = false;
	else
		is_local = PG_GETARG_BOOL(2);

	/* Note SET DEFAULT (argstring == NULL) is equivalent to RESET */
	set_config_option(name,
					  value,
					  (superuser() ? PGC_SUSET : PGC_USERSET),
					  PGC_S_SESSION,
					  is_local,
					  true);

	/* get the new current value */
3203
	new_value = GetConfigOptionByName(name, NULL);
3204 3205 3206 3207 3208 3209 3210 3211

	/* Convert return string to text */
	result_text = DatumGetTextP(DirectFunctionCall1(textin, CStringGetDatum(new_value)));

	/* return it */
	PG_RETURN_TEXT_P(result_text);
}

3212 3213 3214 3215
/*
 * SHOW command
 */
void
3216
GetPGVariable(const char *name, DestReceiver *dest)
3217 3218
{
	if (strcasecmp(name, "all") == 0)
3219
		ShowAllGUCConfig(dest);
3220
	else
3221 3222 3223 3224 3225 3226 3227 3228 3229 3230 3231 3232 3233 3234 3235 3236 3237 3238 3239 3240 3241 3242 3243 3244 3245 3246 3247 3248 3249 3250
		ShowGUCConfigOption(name, dest);
}

TupleDesc
GetPGVariableResultDesc(const char *name)
{
	TupleDesc	tupdesc;

	if (strcasecmp(name, "all") == 0)
	{
		/* need a tuple descriptor representing two TEXT columns */
		tupdesc = CreateTemplateTupleDesc(2, false);
		TupleDescInitEntry(tupdesc, (AttrNumber) 1, "name",
						   TEXTOID, -1, 0, false);
		TupleDescInitEntry(tupdesc, (AttrNumber) 2, "setting",
						   TEXTOID, -1, 0, false);
	}
	else
	{
		const char *varname;

		/* Get the canonical spelling of name */
		(void) GetConfigOptionByName(name, &varname);

		/* need a tuple descriptor representing a single TEXT column */
		tupdesc = CreateTemplateTupleDesc(1, false);
		TupleDescInitEntry(tupdesc, (AttrNumber) 1, (char *) varname,
						   TEXTOID, -1, 0, false);
	}
	return tupdesc;
3251 3252 3253 3254 3255 3256 3257 3258 3259 3260 3261 3262 3263 3264 3265 3266 3267 3268 3269 3270 3271 3272 3273 3274
}

/*
 * RESET command
 */
void
ResetPGVariable(const char *name)
{
	if (strcasecmp(name, "all") == 0)
		ResetAllOptions();
	else
		set_config_option(name,
						  NULL,
						  (superuser() ? PGC_SUSET : PGC_USERSET),
						  PGC_S_SESSION,
						  false,
						  true);
}


/*
 * SHOW command
 */
void
3275
ShowGUCConfigOption(const char *name, DestReceiver *dest)
3276
{
3277
	TupOutputState *tstate;
B
Bruce Momjian 已提交
3278 3279 3280
	TupleDesc	tupdesc;
	const char *varname;
	char	   *value;
3281

3282 3283 3284
	/* Get the value and canonical spelling of name */
	value = GetConfigOptionByName(name, &varname);

3285
	/* need a tuple descriptor representing a single TEXT column */
3286
	tupdesc = CreateTemplateTupleDesc(1, false);
3287
	TupleDescInitEntry(tupdesc, (AttrNumber) 1, (char *) varname,
3288
					   TEXTOID, -1, 0, false);
3289

3290 3291 3292 3293
	/* prepare for projection of tuples */
	tstate = begin_tup_output_tupdesc(dest, tupdesc);

	/* Send it */
3294
	do_text_output_oneline(tstate, value);
3295 3296

	end_tup_output(tstate);
3297 3298
}

3299 3300 3301
/*
 * SHOW ALL command
 */
3302
void
3303
ShowAllGUCConfig(DestReceiver *dest)
3304 3305
{
	int			i;
3306
	TupOutputState *tstate;
B
Bruce Momjian 已提交
3307 3308
	TupleDesc	tupdesc;
	char	   *values[2];
3309 3310

	/* need a tuple descriptor representing two TEXT columns */
3311
	tupdesc = CreateTemplateTupleDesc(2, false);
3312 3313 3314 3315 3316 3317 3318
	TupleDescInitEntry(tupdesc, (AttrNumber) 1, "name",
					   TEXTOID, -1, 0, false);
	TupleDescInitEntry(tupdesc, (AttrNumber) 2, "setting",
					   TEXTOID, -1, 0, false);

	/* prepare for projection of tuples */
	tstate = begin_tup_output_tupdesc(dest, tupdesc);
3319

3320 3321
	for (i = 0; i < num_guc_variables; i++)
	{
3322 3323 3324 3325
		struct config_generic *conf = guc_variables[i];

		if (conf->flags & GUC_NO_SHOW_ALL)
			continue;
3326 3327

		/* assign to the values array */
3328 3329
		values[0] = (char *) conf->name;
		values[1] = _ShowOption(conf);
3330 3331 3332

		/* send it to dest */
		do_tup_output(tstate, values);
3333

3334 3335 3336
		/* clean up */
		if (values[1] != NULL)
			pfree(values[1]);
3337
	}
3338 3339

	end_tup_output(tstate);
3340
}
3341

3342
/*
3343 3344
 * Return GUC variable value by name; optionally return canonical
 * form of name.  Return value is palloc'd.
3345 3346
 */
char *
3347
GetConfigOptionByName(const char *name, const char **varname)
3348 3349 3350 3351 3352
{
	struct config_generic *record;

	record = find_option(name);
	if (record == NULL)
3353 3354 3355
		ereport(ERROR,
				(errcode(ERRCODE_UNDEFINED_OBJECT),
				 errmsg("\"%s\" is not a recognized option", name)));
3356

3357 3358 3359
	if (varname)
		*varname = record->name;

3360 3361 3362 3363
	return _ShowOption(record);
}

/*
3364 3365
 * Return GUC variable value by variable number; optionally return canonical
 * form of name.  Return value is palloc'd.
3366
 */
3367 3368
void
GetConfigOptionByNum(int varnum, const char **values, bool *noshow)
3369
{
3370 3371
	char					buffer[256];
	struct config_generic  *conf;
3372 3373 3374 3375 3376

	/* check requested variable number valid */
	Assert((varnum >= 0) && (varnum < num_guc_variables));

	conf = guc_variables[varnum];
3377

3378 3379 3380
	if (noshow)
		*noshow = (conf->flags & GUC_NO_SHOW_ALL) ? true : false;

3381 3382 3383 3384 3385 3386 3387 3388 3389 3390 3391 3392 3393 3394 3395 3396 3397 3398 3399 3400 3401 3402 3403 3404 3405 3406 3407 3408 3409 3410 3411 3412 3413 3414 3415 3416 3417 3418 3419 3420 3421 3422 3423 3424 3425 3426 3427 3428 3429 3430 3431 3432 3433 3434 3435 3436 3437 3438 3439 3440 3441 3442 3443 3444 3445 3446 3447 3448 3449 3450 3451 3452 3453 3454 3455 3456 3457 3458 3459 3460 3461 3462
	/* first get the generic attributes */

	/* name */
	values[0] = conf->name;

	/* setting : use _ShowOption in order to avoid duplicating the logic */
	values[1] = _ShowOption(conf);

	/* context */
	values[2] = GucContextName[conf->context];

	/* vartype */
	values[3] = config_type_name[conf->vartype];

	/* source */
	values[4] = GucSourceName[conf->source];

	/* now get the type specifc attributes */
	switch (conf->vartype)
	{
		case PGC_BOOL:
			{
				/* min_val */
				values[5] = NULL;

				/* max_val */
				values[6] = NULL;
			}
			break;

		case PGC_INT:
			{
				struct config_int *lconf = (struct config_int *) conf;

				/* min_val */
				snprintf(buffer, sizeof(buffer), "%d", lconf->min);
				values[5] = pstrdup(buffer);

				/* max_val */
				snprintf(buffer, sizeof(buffer), "%d", lconf->max);
				values[6] = pstrdup(buffer);
			}
			break;

		case PGC_REAL:
			{
				struct config_real *lconf = (struct config_real *) conf;

				/* min_val */
				snprintf(buffer, sizeof(buffer), "%g", lconf->min);
				values[5] = pstrdup(buffer);

				/* max_val */
				snprintf(buffer, sizeof(buffer), "%g", lconf->max);
				values[6] = pstrdup(buffer);
			}
			break;

		case PGC_STRING:
			{
				/* min_val */
				values[5] = NULL;

				/* max_val */
				values[6] = NULL;
			}
			break;

		default:
			{
				/*
				 * should never get here, but in case we do, set 'em to NULL
				 */

				/* min_val */
				values[5] = NULL;

				/* max_val */
				values[6] = NULL;
			}
			break;
	}
3463 3464 3465 3466 3467 3468 3469 3470 3471 3472 3473 3474 3475 3476 3477 3478 3479 3480
}

/*
 * Return the total number of GUC variables
 */
int
GetNumConfigOptions(void)
{
	return num_guc_variables;
}

/*
 * show_config_by_name - equiv to SHOW X command but implemented as
 * a function.
 */
Datum
show_config_by_name(PG_FUNCTION_ARGS)
{
B
Bruce Momjian 已提交
3481 3482 3483
	char	   *varname;
	char	   *varval;
	text	   *result_text;
3484 3485

	/* Get the GUC variable name */
3486
	varname = DatumGetCString(DirectFunctionCall1(textout, PG_GETARG_DATUM(0)));
3487 3488

	/* Get the value */
3489
	varval = GetConfigOptionByName(varname, NULL);
3490 3491 3492 3493 3494 3495 3496 3497

	/* Convert to text */
	result_text = DatumGetTextP(DirectFunctionCall1(textin, CStringGetDatum(varval)));

	/* return it */
	PG_RETURN_TEXT_P(result_text);
}

3498 3499 3500 3501
/*
 * show_all_settings - equiv to SHOW ALL command but implemented as
 * a Table Function.
 */
3502 3503
#define NUM_PG_SETTINGS_ATTS	7

3504 3505 3506
Datum
show_all_settings(PG_FUNCTION_ARGS)
{
B
Bruce Momjian 已提交
3507 3508 3509 3510 3511 3512 3513
	FuncCallContext *funcctx;
	TupleDesc	tupdesc;
	int			call_cntr;
	int			max_calls;
	TupleTableSlot *slot;
	AttInMetadata *attinmeta;
	MemoryContext oldcontext;
3514 3515

	/* stuff done only on the first call of the function */
B
Bruce Momjian 已提交
3516 3517
	if (SRF_IS_FIRSTCALL())
	{
3518
		/* create a function context for cross-call persistence */
B
Bruce Momjian 已提交
3519
		funcctx = SRF_FIRSTCALL_INIT();
3520

B
Bruce Momjian 已提交
3521 3522 3523 3524
		/*
		 * switch to memory context appropriate for multiple function
		 * calls
		 */
3525 3526
		oldcontext = MemoryContextSwitchTo(funcctx->multi_call_memory_ctx);

3527 3528 3529 3530 3531
		/*
		 * need a tuple descriptor representing NUM_PG_SETTINGS_ATTS columns
		 * of the appropriate types
		 */
		tupdesc = CreateTemplateTupleDesc(NUM_PG_SETTINGS_ATTS, false);
3532 3533 3534 3535
		TupleDescInitEntry(tupdesc, (AttrNumber) 1, "name",
						   TEXTOID, -1, 0, false);
		TupleDescInitEntry(tupdesc, (AttrNumber) 2, "setting",
						   TEXTOID, -1, 0, false);
3536 3537 3538 3539 3540 3541 3542 3543 3544 3545
		TupleDescInitEntry(tupdesc, (AttrNumber) 3, "context",
						   TEXTOID, -1, 0, false);
		TupleDescInitEntry(tupdesc, (AttrNumber) 4, "vartype",
						   TEXTOID, -1, 0, false);
		TupleDescInitEntry(tupdesc, (AttrNumber) 5, "source",
						   TEXTOID, -1, 0, false);
		TupleDescInitEntry(tupdesc, (AttrNumber) 6, "min_val",
						   TEXTOID, -1, 0, false);
		TupleDescInitEntry(tupdesc, (AttrNumber) 7, "max_val",
						   TEXTOID, -1, 0, false);
3546 3547 3548 3549 3550 3551 3552 3553

		/* allocate a slot for a tuple with this tupdesc */
		slot = TupleDescGetSlot(tupdesc);

		/* assign slot to function context */
		funcctx->slot = slot;

		/*
B
Bruce Momjian 已提交
3554 3555
		 * Generate attribute metadata needed later to produce tuples from
		 * raw C strings
3556 3557 3558 3559 3560 3561
		 */
		attinmeta = TupleDescGetAttInMetadata(tupdesc);
		funcctx->attinmeta = attinmeta;

		/* total number of tuples to be returned */
		funcctx->max_calls = GetNumConfigOptions();
3562 3563

		MemoryContextSwitchTo(oldcontext);
B
Bruce Momjian 已提交
3564
	}
3565 3566

	/* stuff done on every call of the function */
B
Bruce Momjian 已提交
3567
	funcctx = SRF_PERCALL_SETUP();
3568 3569 3570 3571 3572 3573

	call_cntr = funcctx->call_cntr;
	max_calls = funcctx->max_calls;
	slot = funcctx->slot;
	attinmeta = funcctx->attinmeta;

B
Bruce Momjian 已提交
3574 3575
	if (call_cntr < max_calls)	/* do when there is more left to send */
	{
3576
		char	   *values[NUM_PG_SETTINGS_ATTS];
3577 3578 3579 3580 3581 3582 3583 3584 3585
		bool		noshow;
		HeapTuple	tuple;
		Datum		result;

		/*
		 * Get the next visible GUC variable name and value
		 */
		do
		{
3586
			GetConfigOptionByNum(call_cntr, (const char **) values, &noshow);
3587 3588 3589 3590 3591 3592 3593
			if (noshow)
			{
				/* bump the counter and get the next config setting */
				call_cntr = ++funcctx->call_cntr;

				/* make sure we haven't gone too far now */
				if (call_cntr >= max_calls)
B
Bruce Momjian 已提交
3594
					SRF_RETURN_DONE(funcctx);
3595 3596 3597 3598 3599 3600 3601 3602 3603
			}
		} while (noshow);

		/* build a tuple */
		tuple = BuildTupleFromCStrings(attinmeta, values);

		/* make the tuple into a datum */
		result = TupleGetDatum(slot, tuple);

B
Bruce Momjian 已提交
3604 3605 3606
		SRF_RETURN_NEXT(funcctx, result);
	}
	else
3607 3608
	{
		/* do when there is no more left */
B
Bruce Momjian 已提交
3609
		SRF_RETURN_DONE(funcctx);
3610
	}
3611 3612
}

3613
static char *
B
Bruce Momjian 已提交
3614
_ShowOption(struct config_generic * record)
3615 3616 3617
{
	char		buffer[256];
	const char *val;
3618

3619 3620 3621 3622 3623
	switch (record->vartype)
	{
		case PGC_BOOL:
			{
				struct config_bool *conf = (struct config_bool *) record;
3624

3625 3626 3627 3628 3629 3630 3631 3632 3633 3634 3635 3636 3637 3638 3639 3640 3641 3642 3643 3644 3645 3646 3647 3648 3649 3650 3651 3652 3653 3654 3655 3656 3657 3658 3659 3660 3661 3662 3663 3664
				if (conf->show_hook)
					val = (*conf->show_hook) ();
				else
					val = *conf->variable ? "on" : "off";
			}
			break;

		case PGC_INT:
			{
				struct config_int *conf = (struct config_int *) record;

				if (conf->show_hook)
					val = (*conf->show_hook) ();
				else
				{
					snprintf(buffer, sizeof(buffer), "%d",
							 *conf->variable);
					val = buffer;
				}
			}
			break;

		case PGC_REAL:
			{
				struct config_real *conf = (struct config_real *) record;

				if (conf->show_hook)
					val = (*conf->show_hook) ();
				else
				{
					snprintf(buffer, sizeof(buffer), "%g",
							 *conf->variable);
					val = buffer;
				}
			}
			break;

		case PGC_STRING:
			{
				struct config_string *conf = (struct config_string *) record;
3665

3666 3667 3668 3669 3670 3671 3672 3673
				if (conf->show_hook)
					val = (*conf->show_hook) ();
				else if (*conf->variable && **conf->variable)
					val = *conf->variable;
				else
					val = "unset";
			}
			break;
3674

3675 3676 3677 3678 3679
		default:
			/* just to keep compiler quiet */
			val = "???";
			break;
	}
3680

3681
	return pstrdup(val);
3682
}
3683 3684


B
Bruce Momjian 已提交
3685 3686 3687 3688 3689 3690 3691 3692 3693 3694 3695 3696
#ifdef EXEC_BACKEND
/*
 *	This routine dumps out all non-default GUC options into a binary
 *	file that is read by all exec'ed backends.  The format is:
 *
 *		variable name, string, null terminated
 *		variable value, string, null terminated
 *		variable source, integer
 */
void
write_nondefault_variables(GucContext context)
{
3697 3698 3699 3700 3701
	int			i;
	char	   *new_filename,
			   *filename;
	int			elevel;
	FILE	   *fp;
B
Bruce Momjian 已提交
3702 3703 3704

	Assert(context == PGC_POSTMASTER || context == PGC_SIGHUP);
	Assert(DataDir);
3705
	elevel = (context == PGC_SIGHUP) ? DEBUG4 : ERROR;
B
Bruce Momjian 已提交
3706 3707 3708 3709 3710

	/*
	 * Open file
	 */
	new_filename = malloc(strlen(DataDir) + strlen(CONFIG_EXEC_PARAMS) +
3711
						  strlen(".new") + 2);
B
Bruce Momjian 已提交
3712 3713 3714
	filename = malloc(strlen(DataDir) + strlen(CONFIG_EXEC_PARAMS) + 2);
	if (new_filename == NULL || filename == NULL)
	{
3715 3716 3717
		ereport(elevel,
				(errcode(ERRCODE_OUT_OF_MEMORY),
				 errmsg("out of memory")));
B
Bruce Momjian 已提交
3718 3719 3720 3721 3722
		return;
	}
	sprintf(new_filename, "%s/" CONFIG_EXEC_PARAMS ".new", DataDir);
	sprintf(filename, "%s/" CONFIG_EXEC_PARAMS, DataDir);

3723 3724 3725 3726
	fp = AllocateFile(new_filename, "w");
	if (!fp)
	{
		free(new_filename);
B
Bruce Momjian 已提交
3727
		free(filename);
3728 3729 3730 3731
		ereport(elevel,
				(errcode_for_file_access(),
				 errmsg("could not write exec config params file \""
						CONFIG_EXEC_PARAMS "\": %m")));
B
Bruce Momjian 已提交
3732 3733 3734 3735 3736 3737 3738 3739 3740 3741 3742 3743 3744 3745 3746 3747 3748 3749 3750 3751 3752 3753 3754 3755 3756 3757 3758 3759 3760 3761 3762 3763 3764 3765 3766 3767 3768 3769 3770 3771 3772 3773 3774 3775 3776 3777 3778 3779 3780 3781 3782 3783 3784 3785 3786 3787 3788 3789 3790 3791 3792 3793 3794 3795 3796 3797 3798 3799 3800 3801 3802 3803 3804
		return;
	}

	for (i = 0; i < num_guc_variables; i++)
	{
		struct config_generic *gconf = guc_variables[i];

		if (gconf->source != PGC_S_DEFAULT)
		{
			fprintf(fp, "%s", gconf->name);
			fputc(0, fp);

			switch (gconf->vartype)
			{
				case PGC_BOOL:
					{
						struct config_bool *conf = (struct config_bool *) gconf;

						if (*conf->variable == 0)
							fprintf(fp, "false");
						else
							fprintf(fp, "true");
					}
					break;

				case PGC_INT:
					{
						struct config_int *conf = (struct config_int *) gconf;

						fprintf(fp, "%d", *conf->variable);
					}
					break;

				case PGC_REAL:
					{
						struct config_real *conf = (struct config_real *) gconf;

						/* Could lose precision here? */
						fprintf(fp, "%f", *conf->variable);
					}
					break;

				case PGC_STRING:
					{
						struct config_string *conf = (struct config_string *) gconf;

						fprintf(fp, "%s", *conf->variable);
					}
					break;
			}

			fputc(0, fp);

			fwrite(&gconf->source, sizeof(gconf->source), 1, fp);
		}
	}

	FreeFile(fp);
	/* Put new file in place, this could delay on Win32 */
	rename(new_filename, filename);
	free(new_filename);
	free(filename);
}


/*
 *	Read string, including null byte from file
 *
 *	Return NULL on EOF and nothing read
 */
static char *
read_string_with_null(FILE *fp)
{
3805 3806 3807 3808
	int			i = 0,
				ch,
				maxlen = 256;
	char	   *str = NULL;
B
Bruce Momjian 已提交
3809 3810 3811 3812 3813 3814 3815 3816

	do
	{
		if ((ch = fgetc(fp)) == EOF)
		{
			if (i == 0)
				return NULL;
			else
3817
				elog(FATAL, "invalid format of exec config params file");
B
Bruce Momjian 已提交
3818 3819 3820 3821 3822 3823 3824 3825 3826 3827 3828 3829 3830 3831 3832 3833 3834 3835 3836
		}
		if (i == 0)
			str = malloc(maxlen);
		else if (i == maxlen)
			str = realloc(str, maxlen *= 2);
		str[i++] = ch;
	} while (ch != 0);

	return str;
}


/*
 *	This routine loads a previous postmaster dump of its non-default
 *	settings.
 */
void
read_nondefault_variables(void)
{
3837 3838 3839 3840 3841
	char	   *filename;
	FILE	   *fp;
	char	   *varname,
			   *varvalue;
	int			varsource;
B
Bruce Momjian 已提交
3842 3843 3844 3845 3846 3847 3848 3849 3850

	Assert(DataDir);

	/*
	 * Open file
	 */
	filename = malloc(strlen(DataDir) + strlen(CONFIG_EXEC_PARAMS) + 2);
	if (filename == NULL)
	{
3851 3852 3853
		ereport(ERROR,
				(errcode(ERRCODE_OUT_OF_MEMORY),
				 errmsg("out of memory")));
B
Bruce Momjian 已提交
3854 3855 3856 3857
		return;
	}
	sprintf(filename, "%s/" CONFIG_EXEC_PARAMS, DataDir);

3858 3859 3860
	fp = AllocateFile(filename, "r");
	if (!fp)
	{
B
Bruce Momjian 已提交
3861
		free(filename);
3862 3863
		/* File not found is fine */
		if (errno != ENOENT)
3864 3865 3866 3867
			ereport(FATAL,
					(errcode_for_file_access(),
					 errmsg("could not read exec config params file \""
							CONFIG_EXEC_PARAMS "\": %m")));
B
Bruce Momjian 已提交
3868
		return;
3869
	}
B
Bruce Momjian 已提交
3870

3871
	for (;;)
B
Bruce Momjian 已提交
3872 3873 3874 3875 3876
	{
		if ((varname = read_string_with_null(fp)) == NULL)
			break;

		if ((varvalue = read_string_with_null(fp)) == NULL)
3877
			elog(FATAL, "invalid format of exec config params file");
3878
		if (fread(&varsource, sizeof(varsource), 1, fp) == 0)
3879
			elog(FATAL, "invalid format of exec config params file");
B
Bruce Momjian 已提交
3880 3881

		(void) set_config_option(varname, varvalue, PGC_POSTMASTER,
3882
								 varsource, false, true);
B
Bruce Momjian 已提交
3883 3884 3885 3886 3887 3888 3889 3890 3891 3892 3893
		free(varname);
		free(varvalue);
	}

	FreeFile(fp);
	free(filename);
	return;
}
#endif


3894 3895 3896 3897 3898 3899 3900 3901
/*
 * A little "long argument" simulation, although not quite GNU
 * compliant. Takes a string of the form "some-option=some value" and
 * returns name = "some_option" and value = "some value" in malloc'ed
 * storage. Note that '-' is converted to '_' in the option name. If
 * there is no '=' in the input string then value will be NULL.
 */
void
B
Bruce Momjian 已提交
3902
ParseLongOption(const char *string, char **name, char **value)
3903
{
B
Bruce Momjian 已提交
3904 3905
	size_t		equal_pos;
	char	   *cp;
3906 3907 3908 3909 3910 3911 3912 3913 3914 3915 3916

	AssertArg(string);
	AssertArg(name);
	AssertArg(value);

	equal_pos = strcspn(string, "=");

	if (string[equal_pos] == '=')
	{
		*name = malloc(equal_pos + 1);
		if (!*name)
3917 3918 3919
			ereport(FATAL,
					(errcode(ERRCODE_OUT_OF_MEMORY),
					 errmsg("out of memory")));
3920 3921 3922 3923 3924
		strncpy(*name, string, equal_pos);
		(*name)[equal_pos] = '\0';

		*value = strdup(&string[equal_pos + 1]);
		if (!*value)
3925 3926 3927
			ereport(FATAL,
					(errcode(ERRCODE_OUT_OF_MEMORY),
					 errmsg("out of memory")));
3928
	}
B
Bruce Momjian 已提交
3929
	else
3930
	{
3931
		/* no equal sign in string */
3932 3933
		*name = strdup(string);
		if (!*name)
3934 3935 3936
			ereport(FATAL,
					(errcode(ERRCODE_OUT_OF_MEMORY),
					 errmsg("out of memory")));
3937 3938 3939
		*value = NULL;
	}

B
Bruce Momjian 已提交
3940
	for (cp = *name; *cp; cp++)
3941 3942 3943
		if (*cp == '-')
			*cp = '_';
}
3944 3945


3946 3947
/*
 * Handle options fetched from pg_database.datconfig or pg_shadow.useconfig.
3948
 * The array parameter must be an array of TEXT (it must not be NULL).
3949
 */
3950 3951 3952
void
ProcessGUCArray(ArrayType *array, GucSource source)
{
B
Bruce Momjian 已提交
3953
	int			i;
3954

3955
	Assert(array != NULL);
3956 3957 3958
	Assert(ARR_ELEMTYPE(array) == TEXTOID);
	Assert(ARR_NDIM(array) == 1);
	Assert(ARR_LBOUND(array)[0] == 1);
3959
	Assert(source == PGC_S_DATABASE || source == PGC_S_USER);
3960 3961 3962 3963 3964 3965 3966 3967 3968 3969

	for (i = 1; i <= ARR_DIMS(array)[0]; i++)
	{
		Datum		d;
		bool		isnull;
		char	   *s;
		char	   *name;
		char	   *value;

		d = array_ref(array, 1, &i,
B
Bruce Momjian 已提交
3970 3971 3972 3973
					  -1 /* varlenarray */ ,
					  -1 /* TEXT's typlen */ ,
					  false /* TEXT's typbyval */ ,
					  'i' /* TEXT's typalign */ ,
3974 3975 3976 3977 3978 3979
					  &isnull);

		if (isnull)
			continue;

		s = DatumGetCString(DirectFunctionCall1(textout, d));
3980

3981 3982 3983
		ParseLongOption(s, &name, &value);
		if (!value)
		{
3984 3985 3986
			ereport(WARNING,
					(errcode(ERRCODE_SYNTAX_ERROR),
					 errmsg("cannot parse setting for \"%s\"", name)));
3987
			free(name);
B
Bruce Momjian 已提交
3988
			continue;
3989 3990
		}

3991
		/*
B
Bruce Momjian 已提交
3992 3993
		 * We process all these options at SUSET level.  We assume that
		 * the right to insert an option into pg_database or pg_shadow was
3994 3995
		 * checked when it was inserted.
		 */
3996
		SetConfigOption(name, value, PGC_SUSET, source);
3997 3998 3999 4000

		free(name);
		if (value)
			free(value);
4001 4002 4003 4004
	}
}


4005 4006 4007 4008
/*
 * Add an entry to an option array.  The array parameter may be NULL
 * to indicate the current table entry is NULL.
 */
4009 4010 4011
ArrayType *
GUCArrayAdd(ArrayType *array, const char *name, const char *value)
{
4012
	const char *varname;
4013 4014 4015 4016 4017 4018 4019 4020 4021 4022
	Datum		datum;
	char	   *newval;
	ArrayType  *a;

	Assert(name);
	Assert(value);

	/* test if the option is valid */
	set_config_option(name, value,
					  superuser() ? PGC_SUSET : PGC_USERSET,
4023
					  PGC_S_SESSION, false, false);
4024

4025 4026 4027 4028
	/* convert name to canonical spelling, so we can use plain strcmp */
	(void) GetConfigOptionByName(name, &varname);
	name = varname;

4029 4030 4031
	newval = palloc(strlen(name) + 1 + strlen(value) + 1);
	sprintf(newval, "%s=%s", name, value);
	datum = DirectFunctionCall1(textin, CStringGetDatum(newval));
B
Bruce Momjian 已提交
4032

4033 4034
	if (array)
	{
B
Bruce Momjian 已提交
4035 4036 4037
		int			index;
		bool		isnull;
		int			i;
4038

4039 4040 4041 4042
		Assert(ARR_ELEMTYPE(array) == TEXTOID);
		Assert(ARR_NDIM(array) == 1);
		Assert(ARR_LBOUND(array)[0] == 1);

B
Bruce Momjian 已提交
4043
		index = ARR_DIMS(array)[0] + 1; /* add after end */
4044 4045 4046 4047 4048 4049 4050

		for (i = 1; i <= ARR_DIMS(array)[0]; i++)
		{
			Datum		d;
			char	   *current;

			d = array_ref(array, 1, &i,
B
Bruce Momjian 已提交
4051 4052 4053 4054
						  -1 /* varlenarray */ ,
						  -1 /* TEXT's typlen */ ,
						  false /* TEXT's typbyval */ ,
						  'i' /* TEXT's typalign */ ,
4055
						  &isnull);
4056 4057
			if (isnull)
				continue;
4058
			current = DatumGetCString(DirectFunctionCall1(textout, d));
B
Bruce Momjian 已提交
4059
			if (strncmp(current, newval, strlen(name) + 1) == 0)
4060 4061 4062 4063 4064 4065 4066
			{
				index = i;
				break;
			}
		}

		isnull = false;
4067 4068
		a = array_set(array, 1, &index,
					  datum,
B
Bruce Momjian 已提交
4069 4070 4071 4072
					  -1 /* varlenarray */ ,
					  -1 /* TEXT's typlen */ ,
					  false /* TEXT's typbyval */ ,
					  'i' /* TEXT's typalign */ ,
4073
					  &isnull);
4074 4075
	}
	else
4076 4077 4078
		a = construct_array(&datum, 1,
							TEXTOID,
							-1, false, 'i');
4079 4080 4081 4082 4083

	return a;
}


4084 4085 4086 4087 4088
/*
 * Delete an entry from an option array.  The array parameter may be NULL
 * to indicate the current table entry is NULL.  Also, if the return value
 * is NULL then a null should be stored.
 */
4089 4090 4091
ArrayType *
GUCArrayDelete(ArrayType *array, const char *name)
{
4092
	const char *varname;
B
Bruce Momjian 已提交
4093 4094 4095
	ArrayType  *newarray;
	int			i;
	int			index;
4096 4097 4098 4099 4100 4101

	Assert(name);

	/* test if the option is valid */
	set_config_option(name, NULL,
					  superuser() ? PGC_SUSET : PGC_USERSET,
4102
					  PGC_S_SESSION, false, false);
4103

4104 4105 4106 4107
	/* convert name to canonical spelling, so we can use plain strcmp */
	(void) GetConfigOptionByName(name, &varname);
	name = varname;

4108 4109 4110 4111 4112
	/* if array is currently null, then surely nothing to delete */
	if (!array)
		return NULL;

	newarray = NULL;
4113 4114 4115 4116 4117 4118 4119 4120 4121
	index = 1;

	for (i = 1; i <= ARR_DIMS(array)[0]; i++)
	{
		Datum		d;
		char	   *val;
		bool		isnull;

		d = array_ref(array, 1, &i,
B
Bruce Momjian 已提交
4122 4123 4124 4125
					  -1 /* varlenarray */ ,
					  -1 /* TEXT's typlen */ ,
					  false /* TEXT's typbyval */ ,
					  'i' /* TEXT's typalign */ ,
4126
					  &isnull);
4127 4128
		if (isnull)
			continue;
4129 4130
		val = DatumGetCString(DirectFunctionCall1(textout, d));

4131
		/* ignore entry if it's what we want to delete */
B
Bruce Momjian 已提交
4132
		if (strncmp(val, name, strlen(name)) == 0
4133 4134 4135
			&& val[strlen(name)] == '=')
			continue;

4136 4137 4138 4139 4140 4141 4142 4143 4144 4145 4146 4147 4148 4149 4150 4151 4152
		/* else add it to the output array */
		if (newarray)
		{
			isnull = false;
			newarray = array_set(newarray, 1, &index,
								 d,
								 -1 /* varlenarray */ ,
								 -1 /* TEXT's typlen */ ,
								 false /* TEXT's typbyval */ ,
								 'i' /* TEXT's typalign */ ,
								 &isnull);
		}
		else
			newarray = construct_array(&d, 1,
									   TEXTOID,
									   -1, false, 'i');

4153 4154 4155 4156 4157
		index++;
	}

	return newarray;
}
4158

4159 4160 4161 4162 4163 4164 4165 4166 4167 4168 4169 4170 4171 4172 4173 4174 4175 4176 4177 4178 4179 4180 4181 4182 4183 4184 4185 4186 4187 4188 4189 4190 4191 4192 4193 4194 4195 4196 4197 4198 4199 4200 4201 4202 4203 4204 4205 4206 4207 4208

/*
 * assign_hook subroutines
 */

#ifdef HAVE_SYSLOG

static const char *
assign_facility(const char *facility, bool doit, bool interactive)
{
	if (strcasecmp(facility, "LOCAL0") == 0)
		return facility;
	if (strcasecmp(facility, "LOCAL1") == 0)
		return facility;
	if (strcasecmp(facility, "LOCAL2") == 0)
		return facility;
	if (strcasecmp(facility, "LOCAL3") == 0)
		return facility;
	if (strcasecmp(facility, "LOCAL4") == 0)
		return facility;
	if (strcasecmp(facility, "LOCAL5") == 0)
		return facility;
	if (strcasecmp(facility, "LOCAL6") == 0)
		return facility;
	if (strcasecmp(facility, "LOCAL7") == 0)
		return facility;
	return NULL;
}
#endif


static const char *
assign_defaultxactisolevel(const char *newval, bool doit, bool interactive)
{
	if (strcasecmp(newval, "serializable") == 0)
	{
		if (doit)
			DefaultXactIsoLevel = XACT_SERIALIZABLE;
	}
	else if (strcasecmp(newval, "read committed") == 0)
	{
		if (doit)
			DefaultXactIsoLevel = XACT_READ_COMMITTED;
	}
	else
		return NULL;
	return newval;
}

static const char *
4209
assign_log_min_messages(const char *newval,
4210
						bool doit, bool interactive)
4211
{
4212
	return (assign_msglvl(&log_min_messages, newval, doit, interactive));
4213 4214
}

4215
static const char *
4216 4217 4218
assign_client_min_messages(const char *newval,
						   bool doit, bool interactive)
{
B
Bruce Momjian 已提交
4219
	return (assign_msglvl(&client_min_messages, newval, doit, interactive));
4220 4221
}

4222
static const char *
4223 4224
assign_min_error_statement(const char *newval, bool doit, bool interactive)
{
B
Bruce Momjian 已提交
4225
	return (assign_msglvl(&log_min_error_statement, newval, doit, interactive));
4226 4227 4228 4229 4230 4231
}

static const char *
assign_msglvl(int *var, const char *newval, bool doit, bool interactive)
{
	if (strcasecmp(newval, "debug") == 0)
B
Bruce Momjian 已提交
4232 4233
	{
		if (doit)
4234
			(*var) = DEBUG2;
B
Bruce Momjian 已提交
4235
	}
4236
	else if (strcasecmp(newval, "debug5") == 0)
B
Bruce Momjian 已提交
4237 4238 4239 4240
	{
		if (doit)
			(*var) = DEBUG5;
	}
4241
	else if (strcasecmp(newval, "debug4") == 0)
B
Bruce Momjian 已提交
4242 4243 4244 4245
	{
		if (doit)
			(*var) = DEBUG4;
	}
4246
	else if (strcasecmp(newval, "debug3") == 0)
B
Bruce Momjian 已提交
4247 4248 4249 4250
	{
		if (doit)
			(*var) = DEBUG3;
	}
4251
	else if (strcasecmp(newval, "debug2") == 0)
B
Bruce Momjian 已提交
4252 4253 4254 4255
	{
		if (doit)
			(*var) = DEBUG2;
	}
4256
	else if (strcasecmp(newval, "debug1") == 0)
B
Bruce Momjian 已提交
4257 4258 4259 4260
	{
		if (doit)
			(*var) = DEBUG1;
	}
4261
	else if (strcasecmp(newval, "log") == 0)
B
Bruce Momjian 已提交
4262 4263 4264 4265
	{
		if (doit)
			(*var) = LOG;
	}
4266
	else if (strcasecmp(newval, "info") == 0)
B
Bruce Momjian 已提交
4267 4268 4269 4270
	{
		if (doit)
			(*var) = INFO;
	}
4271
	else if (strcasecmp(newval, "notice") == 0)
B
Bruce Momjian 已提交
4272 4273 4274 4275
	{
		if (doit)
			(*var) = NOTICE;
	}
4276
	else if (strcasecmp(newval, "warning") == 0)
B
Bruce Momjian 已提交
4277 4278 4279 4280
	{
		if (doit)
			(*var) = WARNING;
	}
4281
	else if (strcasecmp(newval, "error") == 0)
B
Bruce Momjian 已提交
4282 4283 4284 4285
	{
		if (doit)
			(*var) = ERROR;
	}
4286 4287 4288 4289 4290 4291 4292 4293 4294 4295 4296
	/* We allow FATAL/PANIC for client-side messages too. */
	else if (strcasecmp(newval, "fatal") == 0)
	{
		if (doit)
			(*var) = FATAL;
	}
	else if (strcasecmp(newval, "panic") == 0)
	{
		if (doit)
			(*var) = PANIC;
	}
4297 4298 4299 4300
	else
		return NULL;			/* fail */
	return newval;				/* OK */
}
4301

4302 4303 4304 4305 4306 4307 4308 4309 4310 4311 4312 4313 4314 4315 4316 4317 4318 4319 4320 4321 4322 4323 4324
static const char *
assign_log_error_verbosity(const char *newval, bool doit, bool interactive)
{
	if (strcasecmp(newval, "terse") == 0)
	{
		if (doit)
			Log_error_verbosity = PGERROR_TERSE;
	}
	else if (strcasecmp(newval, "default") == 0)
	{
		if (doit)
			Log_error_verbosity = PGERROR_DEFAULT;
	}
	else if (strcasecmp(newval, "verbose") == 0)
	{
		if (doit)
			Log_error_verbosity = PGERROR_VERBOSE;
	}
	else
		return NULL;			/* fail */
	return newval;				/* OK */
}

4325 4326 4327 4328 4329 4330
static bool
assign_phony_autocommit(bool newval, bool doit, bool interactive)
{
	if (!newval)
	{
		if (doit && interactive)
4331 4332 4333
			ereport(ERROR,
					(errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
					 errmsg("SET AUTOCOMMIT TO OFF is no longer supported")));
4334 4335 4336 4337 4338
		return false;
	}
	return true;
}

4339

4340
#include "guc-file.c"