#include <ctype.h>
#include <netdb.h>
#include <pwd.h>
#include <netinet/in.h>
#include <arpa/inet.h>

Include dependency graph for port.h:

This graph shows which files directly or indirectly include this file:

Macros
#define	PGINVALID_SOCKET (-1)

#define	IS_DIR_SEP(ch) ((ch) == '/')

#define	is_absolute_path(filename)

#define	PG_BACKEND_VERSIONSTR "postgres (PostgreSQL) " PG_VERSION "\n"

#define	EXE ""

#define	DEVNULL "/dev/null"

#define	USE_REPL_SNPRINTF 1

#define	vsnprintf pg_vsnprintf

#define	snprintf pg_snprintf

#define	vsprintf pg_vsprintf

#define	sprintf pg_sprintf

#define	vfprintf pg_vfprintf

#define	fprintf pg_fprintf

#define	vprintf pg_vprintf

#define	printf(...) pg_printf(__VA_ARGS__)

#define	strerror pg_strerror

#define	strerror_r pg_strerror_r

#define	PG_STRERROR_R_BUFLEN 256 /* Recommended buffer size for strerror_r */

#define	TIMEZONE_GLOBAL timezone

#define	TZNAME_GLOBAL tzname

#define	closesocket close

#define	PG_IOLBF _IOLBF

#define	pgoff_t off_t

#define	fseeko(a, b, c) fseek(a, b, c)

#define	ftello(a) ftell(a)

#define	SSL_get_current_compression(x) 0

#define	RTLD_NOW 1

#define	RTLD_GLOBAL 0

#define	qsort(a, b, c, d) pg_qsort(a,b,c,d)

#define	pg_backend_random pg_strong_random

Typedefs
typedef int	pgsocket

typedef int(*	qsort_arg_comparator) (const void a, const void b, void *arg)

typedef void(*	pqsigfunc) (int signo)

Functions
bool	pg_set_noblock (pgsocket sock)

bool	pg_set_block (pgsocket sock)

bool	has_drive_prefix (const char *filename)

char *	first_dir_separator (const char *filename)

char *	last_dir_separator (const char *filename)

char *	first_path_var_separator (const char *pathlist)

void	join_path_components (char ret_path, const char head, const char *tail)

void	canonicalize_path (char *path)

void	make_native_path (char *path)

void	cleanup_path (char *path)

bool	path_contains_parent_reference (const char *path)

bool	path_is_relative_and_below_cwd (const char *path)

bool	path_is_prefix_of_path (const char path1, const char path2)

char *	make_absolute_path (const char *path)

const char *	get_progname (const char *argv0)

void	get_share_path (const char my_exec_path, char ret_path)

void	get_etc_path (const char my_exec_path, char ret_path)

void	get_include_path (const char my_exec_path, char ret_path)

void	get_pkginclude_path (const char my_exec_path, char ret_path)

void	get_includeserver_path (const char my_exec_path, char ret_path)

void	get_lib_path (const char my_exec_path, char ret_path)

void	get_pkglib_path (const char my_exec_path, char ret_path)

void	get_locale_path (const char my_exec_path, char ret_path)

void	get_doc_path (const char my_exec_path, char ret_path)

void	get_html_path (const char my_exec_path, char ret_path)

void	get_man_path (const char my_exec_path, char ret_path)

bool	get_home_path (char *ret_path)

void	get_parent_directory (char *path)

char **	pgfnames (const char *path)

void	pgfnames_cleanup (char **filenames)

void	set_pglocale_pgservice (const char argv0, const char app)

int	find_my_exec (const char argv0, char retpath)

int	find_other_exec (const char argv0, const char target, const char versionstr, char retpath)

void	pg_usleep (long microsec)

int	pg_strcasecmp (const char s1, const char s2)

int	pg_strncasecmp (const char s1, const char s2, size_t n)

unsigned char	pg_toupper (unsigned char ch)

unsigned char	pg_tolower (unsigned char ch)

unsigned char	pg_ascii_toupper (unsigned char ch)

unsigned char	pg_ascii_tolower (unsigned char ch)

int	pg_vsnprintf (char str, size_t count, const char fmt, va_list args)

int	pg_snprintf (char str, size_t count, const char fmt,...) pg_attribute_printf(3

int int	pg_vsprintf (char str, const char fmt, va_list args)

int	pg_sprintf (char str, const char fmt,...) pg_attribute_printf(2

int int	pg_vfprintf (FILE stream, const char fmt, va_list args)

int	pg_fprintf (FILE stream, const char fmt,...) pg_attribute_printf(2

int int	pg_vprintf (const char *fmt, va_list args)

int	pg_printf (const char *fmt,...) pg_attribute_printf(1

int	pg_strfromd (char *str, size_t count, int precision, double value)

char *	pg_strerror (int errnum)

char *	pg_strerror_r (int errnum, char *buf, size_t buflen)

const char *	pg_strsignal (int signum)

void	simple_prompt (const char prompt, char destination, size_t destlen, bool echo)

int	pclose_check (FILE *stream)

bool	rmtree (const char *path, bool rmtopdir)

char *	crypt (const char key, const char setting)

double	pg_erand48 (unsigned short xseed[3])

long	pg_lrand48 (void)

long	pg_jrand48 (unsigned short xseed[3])

void	pg_srand48 (long seed)

int	fls (int mask)

int	getpeereid (int sock, uid_t uid, gid_t gid)

int	isinf (double x)

float	strtof (const char nptr, char *endptr)

char *	mkdtemp (char *path)

double	rint (double x)

int	inet_aton (const char cp, struct in_addr addr)

ssize_t	pg_pread (int fd, void *buf, size_t nbyte, off_t offset)

ssize_t	pg_pwrite (int fd, const void *buf, size_t nbyte, off_t offset)

size_t	strlcat (char dst, const char src, size_t siz)

size_t	strlcpy (char dst, const char src, size_t siz)

size_t	strnlen (const char *str, size_t maxlen)

long	random (void)

void	unsetenv (const char *name)

void	srandom (unsigned int seed)

void *	dlopen (const char *file, int mode)

void *	dlsym (void handle, const char symbol)

int	dlclose (void *handle)

char *	dlerror (void)

int	pqGetpwuid (uid_t uid, struct passwd resultbuf, char buffer, size_t buflen, struct passwd **result)

int	pqGethostbyname (const char name, struct hostent resultbuf, char buffer, size_t buflen, struct hostent result, int herrno)

void	pg_qsort (void base, size_t nel, size_t elsize, int(cmp)(const void , const void ))

int	pg_qsort_strcmp (const void a, const void b)

void	qsort_arg (void base, size_t nel, size_t elsize, qsort_arg_comparator cmp, void arg)

int	pg_get_encoding_from_locale (const char *ctype, bool write_message)

char *	inet_net_ntop (int af, const void src, int bits, char dst, size_t size)

bool	pg_strong_random (void *buf, size_t len)

int	pg_check_dir (const char *dir)

int	pg_mkdir_p (char *path, int omode)

pqsigfunc	pqsignal (int signo, pqsigfunc func)

pqsigfunc	pqsignal_no_restart (int signo, pqsigfunc func)

char *	escape_single_quotes_ascii (const char *src)

char *	wait_result_to_str (int exit_status)

bool	wait_result_is_signal (int exit_status, int signum)

bool	wait_result_is_any_signal (int exit_status, bool include_command_not_found)

Macro Definition Documentation

◆ closesocket

#define closesocket close

Definition at line 312 of file port.h.

Referenced by archive_close_connection(), ident_inet(), internal_cancel(), ParallelBackupEnd(), ParallelBackupStart(), PerformRadiusTransaction(), pgstat_init(), PostmasterMarkPIDForWorkerNotify(), pqDropConnection(), readMessageFromPipe(), run_ifaddr_callback(), ShutdownWorkersHard(), StreamClose(), and StreamServerPort().

◆ DEVNULL

#define DEVNULL "/dev/null"

Definition at line 123 of file port.h.

Referenced by do_init(), initialize_data_directory(), initializeInput(), regression_main(), start_postmaster(), SysLoggerMain(), and test_config_settings().

◆ EXE

#define EXE ""

Definition at line 117 of file port.h.

Referenced by find_other_exec(), and get_progname().

◆ fprintf

#define fprintf pg_fprintf

Definition at line 196 of file port.h.

Referenced by _connectDB(), _dosmaperr(), _print_horizontal_line(), _ShowOption(), add_socket_to_set(), addScript(), advanceConnectionState(), advice(), appendPsqlMetaConnect(), appendShellString(), apw_dump_now(), BaseBackup(), bootstrap_template1(), change_directory(), check_for_isn_and_int8_passing_mismatch(), check_for_jsonb_9_4_usage(), check_for_reg_data_type_usage(), check_for_tables_with_oids(), check_input(), check_loadable_libraries(), check_locale_encoding(), check_prepare_conn(), check_system_link_file(), CheckConnection(), CheckForExternalTrigger(), checkInitSteps(), close_file(), ClosePager(), coerceToBool(), coerceToDouble(), coerceToInt(), colorcomplement(), commandFailed(), ConditionError(), convert_sourcefiles_in(), create_data_directory(), create_script_for_cluster_analyze(), create_script_for_old_cluster_deletion(), create_xlog_or_symlink(), CreateOptsFile(), CustomizableCleanupPriorWALFiles(), CustomizableInitialize(), CustomizableNextWALFileReady(), defaultNoticeProcessor(), DescribeQuery(), do_field(), do_header(), do_pg_stop_backup(), doConnect(), dolink(), doLog(), dropDBs(), dropRoles(), dropTablespaces(), dsa_dump(), dshash_dump(), dumpDatabases(), dumpGroups(), dumpnfa(), dumpRoleMembership(), dumpRoles(), dumpTablespaces(), dumpTimestamp(), dumpUserConfig(), echo_hidden_command(), ecpg_filter(), ecpg_log(), ecpg_start_test(), ECPGdump_a_simple(), evalStandardFunc(), evaluateExpr(), evaluateSleep(), exec_command_write(), exec_prog(), executeMetaCommand(), ExecuteSqlCommand(), executeStatement(), exportFile(), file_line_count(), file_size(), findBuiltin(), get_id(), get_opts(), get_progname(), get_su_pwd(), get_user_name_or_exit(), getopt(), getopt_long(), gseg_internal_consistent(), gseg_leaf_consistent(), gseg_penalty(), gseg_picksplit(), gseg_same(), gseg_union(), handle_args(), handle_sigint(), hash_stats(), header(), helpSQL(), helpVariables(), identify_system_timezone(), importFile(), infile(), init_htab(), initCreateFKeys(), initCreatePKeys(), initCreateTables(), initDropTables(), initGenerateData(), initialize_environment(), initVacuum(), isolation_init(), isolation_start_test(), isotesterNoticeProcessor(), listAvailableScripts(), load_resultmap(), LocalBufferAlloc(), lookupCreateVariable(), main(), make_absolute_path(), make_directory(), makeVariableValue(), MarkLocalBufferDirty(), memory_exhausted(), MemoryContextStatsDetail(), MemoryContextStatsInternal(), MemoryContextStatsPrint(), my_truncate(), new_9_0_populate_pg_largeobject_metadata(), nfanode(), old_9_3_check_for_line_data_type_usage(), old_9_6_check_for_unknown_data_type_usage(), old_9_6_invalidate_hash_indexes(), open_result_files(), optimize(), output_cursor_statement(), output_deallocate_prepare_statement(), output_declare_statement(), output_get_descr(), output_get_descr_header(), output_line_number(), output_prepare_statement(), output_row(), output_set_descr(), output_set_descr_header(), output_statement(), overwrite(), packArcInfoCmp(), parse_psql_options(), parseCommandLine(), parseQuery(), parseScriptWeight(), passwordFromFile(), perform_spin_delay(), pg_attribute_printf(), pg_char_to_encoding(), pg_log_generic_v(), pg_log_v(), pg_malloc_internal(), pg_realloc(), pg_regcomp(), pg_strdup(), pgwin32_is_service(), pickout(), pipe_read_line(), PostmasterMain(), PQdisplayTuples(), pqGetc(), pqGetInt(), pqGetnchar(), pqGets_internal(), PQprint(), PQprintTuples(), pqPutc(), pqPutInt(), pqPutMsgEnd(), pqPutMsgStart(), pqPutnchar(), pqPuts(), pqSaveParameterStatus(), pqSetenvPoll(), pqSkipnchar(), print(), print2(), print_action(), print_aligned_text(), print_aligned_vertical(), print_aligned_vertical_line(), print_asciidoc_text(), print_asciidoc_vertical(), print_html_text(), print_html_vertical(), print_latex_vertical(), print_troff_ms_vertical(), print_with_linenumbers(), printHistory(), PrintNotifications(), printProgressReport(), PrintQueryStatus(), printTable(), printTableAddCell(), printTableAddHeader(), process_file(), progress_report(), psql_command(), psql_start_test(), PSQLexec(), PSQLexecWatch(), pvsnprintf(), readCommandResponse(), regression_main(), report_error_message(), report_multiple_error_messages(), RestoreWALFileForRecovery(), results_differ(), rstacktoodeep(), rulesub(), run_diff(), run_named_permutations(), run_permutation(), run_schedule(), runInitSteps(), runShellCommand(), s_lock_stuck(), scan_available_timezones(), score_timezone(), selectColorTrigrams(), sendCommand(), SendQuery(), set_dump_section(), set_random_seed(), setalarm(), setup_cancel_handler(), setup_data_file_paths(), setup_locale_encoding(), setup_pgdata(), SetWALFileNameForCleanup(), SetWALSegSize(), slashUsage(), slice_check(), spawn_process(), sql_check(), sql_conn(), sql_exec(), sqlprint(), status_end(), stop_postmaster(), strtodouble(), strtoint64(), syntax_error(), test_pattern(), test_timing(), threadRun(), TParserClose(), TParserCopyClose(), TParserCopyInit(), TParserGet(), TParserInit(), try_complete_step(), tryExecuteStatement(), update_metainfo_datafile(), usage(), vacuumlo(), verror(), wait_for_tests(), warn(), warn_on_mount_point(), warning(), whenever_action(), write_version_file(), writezone(), XidCacheRemoveRunningXids(), and yearistype().

◆ fseeko

#define fseeko	(	a,
		b,
		c
	)	fseek(a, b, c)

Definition at line 356 of file port.h.

◆ ftello

#define ftello ( a ) ftell(a)

Definition at line 357 of file port.h.

◆ is_absolute_path

#define is_absolute_path ( filename )

Value:

( \
    IS_DIR_SEP((filename)[0]) \
)

Definition at line 86 of file port.h.

Referenced by BeginCopyTo(), connectOptions2(), convert_and_check_filename(), create_xlog_or_symlink(), CreateTableSpace(), do_connect(), exec_command_conninfo(), find_in_dynamic_libpath(), find_my_exec(), get_extension_script_directory(), get_prompt(), main(), make_absolute_path(), passwordFromFile(), path_is_relative_and_below_cwd(), perform_base_backup(), process_file(), setup_bin_paths(), tablespace_list_append(), and tokenize_inc_file().

◆ IS_DIR_SEP

#define IS_DIR_SEP ( ch ) ((ch) == '/')

Definition at line 84 of file port.h.

Referenced by dir_strcmp(), do_pg_start_backup(), first_dir_separator(), join_path_components(), last_dir_separator(), make_relative_path(), path_is_prefix_of_path(), path_is_relative_and_below_cwd(), trim_directory(), and trim_trailing_separator().

◆ pg_backend_random

#define pg_backend_random pg_strong_random

Definition at line 516 of file port.h.

◆ PG_BACKEND_VERSIONSTR

#define PG_BACKEND_VERSIONSTR "postgres (PostgreSQL) " PG_VERSION "\n"

Definition at line 111 of file port.h.

Referenced by adjust_data_dir(), do_kill(), do_start(), getInstallationPaths(), main(), and setup_bin_paths().

◆ PG_IOLBF

#define PG_IOLBF _IOLBF

Definition at line 324 of file port.h.

Referenced by logfile_open(), main(), SysLogger_Start(), and update_metainfo_datafile().

◆ PG_STRERROR_R_BUFLEN

#define PG_STRERROR_R_BUFLEN 256 /* Recommended buffer size for strerror_r */

Definition at line 210 of file port.h.

Referenced by connectFailureMessage(), connectNoDelay(), dopr(), initialize_SSL(), internal_cancel(), lo_export(), lo_import_internal(), open_client_SSL(), pg_local_sendauth(), pg_strerror(), pgtls_read(), pgtls_write(), PQconnectPoll(), pqsecure_raw_read(), pqsecure_raw_write(), pqSocketCheck(), setKeepalivesCount(), setKeepalivesIdle(), and setKeepalivesInterval().

◆ PGINVALID_SOCKET

#define PGINVALID_SOCKET (-1)

Definition at line 33 of file port.h.

Referenced by AddWaitEventToSet(), ClosePostmasterPorts(), CloseServerPorts(), ConditionVariablePrepareToSleep(), ConnCreate(), copy_read_data(), CopyStreamPoll(), ident_inet(), initMasks(), internal_cancel(), LogicalRepApplyLoop(), LogStreamerMain(), makeEmptyPGconn(), ModifyWaitEvent(), PerformRadiusTransaction(), pgstat_drop_database(), pgstat_init(), pgstat_initstats(), pgstat_ping(), pgstat_report_analyze(), pgstat_report_autovac(), pgstat_report_checksum_failures_in_db(), pgstat_report_deadlock(), pgstat_report_recovery_conflict(), pgstat_report_tempfile(), pgstat_report_vacuum(), pgstat_reset_counters(), pgstat_reset_shared_counters(), pgstat_reset_single_counter(), pgstat_send(), pgstat_send_tabstat(), pgstat_start(), pgstat_vacuum_stat(), PostmasterMain(), PostmasterMarkPIDForWorkerNotify(), PQconnectPoll(), pqDropConnection(), PQfn(), PQgetCancel(), pqGetline2(), pqGetline3(), pqReadData(), PQrequestCancel(), pqSendSome(), PQsocket(), pqSocketCheck(), readMessageFromPipe(), run_ifaddr_callback(), sendTerminateConn(), ServerLoop(), socket_close(), StreamConnection(), StreamLog(), StreamServerPort(), SysLoggerMain(), WaitEventSetWait(), WaitLatch(), WaitLatchOrSocket(), and WalReceiverMain().

◆ pgoff_t

#define pgoff_t off_t

Definition at line 339 of file port.h.

◆ printf

#define printf ( ... ) pg_printf(__VA_ARGS__)

Definition at line 198 of file port.h.

Referenced by aes_cbc_decrypt(), array_in(), bootstrap_template1(), callback(), cash_in(), check_constant_qual(), check_errno(), check_ok(), check_result_of_insert(), check_return(), CleanupPriorWALFiles(), cluster_all_databases(), connection_warnings(), connectToServer(), create_data_directory(), create_xlog_or_symlink(), date_test_defmt(), date_test_fmt(), date_test_strdate(), debugStartup(), debugtup(), describe_char(), do_connect(), do_help(), do_status(), dosqlprint(), DoubleMetaphone(), dump_assert(), dump_assign(), dump_binary(), dump_block(), dump_call(), dump_case(), dump_close(), dump_commit(), dump_cursor_direction(), dump_dynexecute(), dump_dynfors(), dump_execsql(), dump_exit(), dump_expr(), dump_fetch(), dump_forc(), dump_foreach_a(), dump_fori(), dump_fors(), dump_getdiag(), dump_if(), dump_ind(), dump_loop(), dump_open(), dump_perform(), dump_raise(), dump_return(), dump_return_next(), dump_return_query(), dump_rollback(), dump_set(), dump_sqlda(), dump_stmt(), dump_while(), echo_hidden_command(), ecpg_process_output(), error(), exec_command_conninfo(), exec_command_pset(), exec_command_s(), ExecHashIncreaseNumBatches(), ExecHashIncreaseNumBuckets(), ExecHashTableCreate(), executeCommand(), executeMaintenanceCommand(), executeQuery(), executeQueryOrDie(), fa(), fb(), fc(), fd(), fe(), fmtlong(), generate_partitionwise_join_paths(), get_su_pwd(), handle_args(), handle_help_version_opts(), help(), init_perm(), initialize_data_directory(), initialize_environment(), int2int4_sum(), InteractiveBackend(), len_utf8(), main(), MainLoop(), output(), pg_fatal(), pg_log_v(), plpgsql_dumptree(), PostgresMain(), pprint(), preprocess_expression(), print(), print_addr(), print_double(), print_elapse(), print_expr(), print_pathkeys(), print_rmgr_list(), print_rt(), print_slot(), print_tl(), printatt(), PrintControlValues(), printGSSInfo(), printMixedStruct(), PrintNewControlValues(), printPsetInfo(), printResult(), printResults(), printResultSet(), printSimpleStats(), printSSLInfo(), PrintTiming(), PrintVariables(), PSQLexec(), regression_main(), reindex_all_databases(), run_permutation(), run_schedule(), run_single_test(), run_vacuum_command(), runShellCommand(), SendQuery(), setup_locale_encoding(), setup_text_search(), show_binary_results(), show_item(), sql_check(), sqlnotice(), test(), test_config_settings(), test_file_descriptor_sync(), test_non_sync(), test_null(), test_open_sync(), test_open_syncs(), test_sync(), test_timing(), TopoSort(), try_complete_step(), update_spins_per_delay(), usage(), vacuum_one_database(), XLogDumpDisplayRecord(), XLogDumpDisplayStats(), XLogDumpStatsRow(), and yesno_prompt().

◆ qsort

#define qsort	(	a,
		b,
		c,
		d
	)	pg_qsort(a,b,c,d)

Definition at line 491 of file port.h.

Referenced by _bt_deltasortsplits(), _ltree_picksplit(), aclitemsort(), aclmembers(), acquire_sample_rows(), add_guc_variable(), AddEnumLabel(), AlterSubscription_refresh(), array_to_tsvector(), associate(), BufferSync(), build_guc_variables(), BuildEventTriggerCache(), buildIndexArray(), calc_word_similarity(), carcsort(), check_loadable_libraries(), CheckConstraintFetch(), checkSharedDependencies(), choose_bitmap_and(), compactify_tuples(), compileTheLexeme(), compute_array_stats(), compute_range_stats(), compute_scalar_stats(), compute_tsvector_stats(), create_hash_bounds(), CreateStatistics(), dsynonym_init(), eliminate_duplicate_dependencies(), entry_dealloc(), EnumValuesCreate(), ExecInitInterpreter(), expand_grouping_sets(), filemap_finalize(), fill_in_constant_lengths(), find_inheritance_children(), findDependentObjects(), findObjectByCatalogId(), g_int_picksplit(), g_intbig_picksplit(), generate_trgm(), generate_wildcard_trgm(), get_docrep(), ghstore_picksplit(), ginGetBAEntry(), gist_box_picksplit(), gseg_picksplit(), gtrgm_picksplit(), gtsquery_picksplit(), gtsvector_picksplit(), heap_compute_xid_horizon_for_tuples(), hstoreUniquePairs(), IssuePendingWritebacks(), list_qsort(), load_domaintype_info(), load_enum_cache_data(), lookupVariable(), ltree_picksplit(), ltsGetFreeBlock(), main(), mcelem_array_contained_selec(), mergeins(), mXactCacheGetBySet(), mXactCachePut(), NIImportOOAffixes(), NISortAffixes(), NISortDictionary(), packGraph(), perform_base_backup(), pg_import_system_collations(), ProcArrayApplyRecoveryInfo(), process_target_file(), QTNSort(), range_gist_double_sorting_split(), rankSort(), read_dictionary(), readstoplist(), ready_list_sort(), rebuild_database_list(), ReorderBufferCopySnap(), select_active_windows(), selectColorTrigrams(), SerializeTransactionState(), setExtensionMembership(), setup_pct_info(), SnapBuildBuildSnapshot(), sort_object_addresses(), sort_policies_by_name(), sort_pool(), sort_snapshot(), sortDumpableObjectsByTypeName(), sortins(), sortouts(), spg_box_quad_picksplit(), spg_kd_picksplit(), spg_quad_picksplit(), spg_text_picksplit(), spgPageIndexMultiDelete(), SyncRepGetNthLatestSyncRecPtr(), tbm_begin_iterate(), TidListEval(), tsq_mcontains(), tsvector_delete_by_indices(), uniqueint(), uniqueLongPos(), uniquePos(), uniqueWORD(), UpdateLogicalMappings(), WriteDataChunks(), and writezone().

◆ RTLD_GLOBAL

#define RTLD_GLOBAL 0

Definition at line 472 of file port.h.

Referenced by internal_load_library().

◆ RTLD_NOW

#define RTLD_NOW 1

Definition at line 464 of file port.h.

Referenced by internal_load_library().

◆ snprintf

#define snprintf pg_snprintf

Definition at line 192 of file port.h.

Referenced by _ArchiveEntry(), _discoverArchiveFormat(), _EndBlob(), _LoadBlobs(), _PG_init(), _ShowOption(), _StartBlob(), _tarAddFile(), _tarGetHeader(), _tarPositionTo(), addRangeTableEntryForValues(), AddToDataDirLockFile(), adjust_data_dir(), AllocSetStats(), AlterObjectOwner_internal(), AlterSystemSetConfigFile(), anybit_typmodout(), anychar_typmodout(), ApplyLauncherRegister(), ApplyWorkerMain(), apw_dump_now(), autovac_report_activity(), autovac_report_workitem(), BackendInitialize(), BackendRun(), BackgroundWorkerUnblockSignals(), BasicOpenFilePerm(), begin_remote_xact(), bootstrap_template1(), build_pgstattuple_type(), buildWorkerCommand(), buildWorkerResponse(), cache_locale_time(), calculate_database_size(), calculate_relation_size(), calculate_tablespace_size(), cfopen(), check_file_clone(), check_file_excluded(), check_for_isn_and_int8_passing_mismatch(), check_for_jsonb_9_4_usage(), check_for_reg_data_type_usage(), check_for_tables_with_oids(), check_foreign_key(), check_hard_link(), check_loadable_libraries(), check_log_duration(), check_primary_key(), check_single_dir(), checkControlFile(), CheckPointLogicalRewriteHeap(), CheckPointSnapBuild(), CheckSCRAMAuth(), choose_dsm_implementation(), ChooseConstraintName(), ChooseExtendedStatisticName(), ChooseRelationName(), cidout(), cleanup(), CleanupBackgroundWorker(), CleanupBackupHistory(), CleanupPriorWALFiles(), close_cursor(), compile_pltcl_function(), connectOptions2(), convert_sourcefiles_in(), convertTSFunction(), copy_subdir_files(), copydir(), CopyFromErrorCallback(), crashDumpHandler(), create_new_objects(), create_target_dir(), create_target_symlink(), create_toast_table(), createBackupLabel(), CreateLockFile(), CreateReplicationSlot(), CreateSocketLockFile(), CreateSubscription(), CreateTrigger(), CustomizableCleanupPriorWALFiles(), CustomizableInitialize(), db_dir_size(), DeleteAllExportedSnapshotFiles(), describeDumpableObject(), dir_close(), dir_existsfile(), dir_get_file_size(), dir_open_for_write(), disable_old_cluster(), do_compile(), do_edit(), do_init(), do_kill(), do_lo_list(), do_logrotate(), do_pg_start_backup(), do_promote(), do_setval(), do_start(), do_watch(), DropSubscription(), dsm_cleanup_for_mmap(), dsm_impl_mmap(), dsm_impl_op(), dsm_impl_pin_segment(), dsm_impl_sysv(), dsm_impl_unpin_segment(), dumpSequence(), ean2isn(), ean2string(), ecpg_build_params(), ecpg_log(), ecpg_raise(), ecpg_raise_backend(), ecpg_start_test(), ECPGget_desc(), ECPGset_desc(), ECPGset_var(), exec_prog(), ExecBuildAuxRowMark(), ExecCreateTableAs(), ExecGrant_Largeobject(), ExecParallelHashJoinSetUpBatches(), ExecQueryUsingCursor(), exitArchiveRecovery(), expand_inherited_rtentry(), ExplainPropertyInteger(), ExportSnapshot(), fetch_file_range(), fetch_more_data(), find_other_exec(), FindStreamingStart(), finish_foreign_modify(), finish_heap_swap(), float4_numeric(), float8_numeric(), footers_with_default(), format_operator_internal(), format_procedure_internal(), formatPGVersionNumber(), fsync_pgdata(), generate_old_dump(), GenerationStats(), get_alternative_expectfile(), get_bin_version(), get_config_unit_name(), get_control_data(), get_controlfile(), get_db_infos(), get_dbstat_filename(), get_errno_symbol(), get_extension_aux_control_filename(), get_extension_control_directory(), get_extension_control_filename(), get_extension_script_directory(), get_extension_script_filename(), get_home_path(), get_major_server_version(), get_prompt(), get_rel_infos(), get_sock_dir(), get_str_from_var_sci(), get_tablespace_paths(), get_tsearch_config_filename(), GetConfigOption(), GetConfigOptionByNum(), GetConfigOptionResetString(), getnameinfo(), getVariable(), heap_xlog_logical_rewrite(), ident_inet(), identify_system_timezone(), identify_target_directory(), IdentifySystem(), ImportSnapshot(), incompatible_module_error(), init_params(), init_ps_display(), initCreatePKeys(), initCreateTables(), initGenerateData(), initialize_data_directory(), initialize_environment(), initialize_SSL(), InitTempTableNamespace(), int44out(), int_to_roman(), intervaltypmodout(), isolation_start_test(), join_path_components(), jsonb_agg_transfn(), jsonb_object_agg_transfn(), KeepFileRestoredFromArchive(), KillExistingArchiveStatus(), KillExistingXLOG(), LaunchParallelWorkers(), libpqrcv_readtimelinehistoryfile(), llvm_create_types(), load_module(), load_relcache_init_file(), load_relmap_file(), load_resultmap(), log_line_prefix(), logfile_getname(), logical_rewrite_log_mapping(), logicalrep_worker_launch(), macaddr8_out(), macaddr_out(), main(), make_new_heap(), make_text_key(), mark_file_as_archived(), nameconcatoid(), network_out(), network_show(), new_9_0_populate_pg_largeobject_metadata(), nextval_internal(), nfalsepos_for_missing_strings(), numerictypmodout(), oidout(), old_9_3_check_for_line_data_type_usage(), old_9_6_check_for_unknown_data_type_usage(), open_file_in_directory(), open_result_files(), open_target_file(), open_walfile(), OpenTemporaryFileInTablespace(), page_header(), parseServiceInfo(), ParseTzFile(), perform_base_backup(), PerformPortalFetch(), pg_getnameinfo_all(), pg_GSS_load_servicename(), pg_lock_status(), pg_ls_dir_files(), pg_lsn_mi(), pg_lsn_out(), pg_perm_setlocale(), pg_rusage_show(), pg_signal_thread(), pg_size_pretty(), pg_strerror_r(), pg_tablespace_location(), pg_tzenumerate_next(), pg_tzset_offset(), pgarch_ArchiverCopyLoop(), pgarch_archiveXlog(), pgarch_readyXlog(), pgfdw_subxact_callback(), pgrowlocks(), pgstat_reset_remove_files(), pgtypes_fmt_replace(), PGTYPESdate_fmt_asc(), pgwin32_create_signal_listener(), pid_lock_file_exists(), plperl_spi_prepare(), plpgsql_param_ref(), pltcl_init_interp(), pltcl_SPI_prepare(), PLy_procedure_compile(), PLy_procedure_create(), PLy_procedure_munge_source(), populate_with_dummy_strings(), PortalRun(), postgresAcquireSampleRowsFunc(), postgresReScanForeignScan(), PostmasterMain(), PQconnectPoll(), pqGetHomeDirectory(), PQsslAttribute(), prepare_foreign_modify(), preprocess_targetlist(), pretty_wal_size(), print_wchar_str(), printProgressReport(), PrintQueryStatus(), proc_exit(), process_psqlrc(), process_source_file(), process_target_file(), ProcessQuery(), progress_report(), provider_init(), psql_command(), psql_start_test(), read_client_final_message(), ReadControlFile(), ReceiveAndUnpackTarFile(), ReceiveTarFile(), ReceiveXlogStream(), recurse_dir(), regclassout(), regconfigout(), regdictionaryout(), regnamespaceout(), regoperout(), regprocout(), regression_main(), regroleout(), regtypeout(), RelationCacheInitFilePreInvalidate(), RelationCacheInitFileRemove(), RelationCacheInitFileRemoveInDir(), remove_new_subdir(), remove_target_dir(), remove_target_file(), remove_target_symlink(), RemoveAttributeById(), RemovePgTempFiles(), RemovePgTempFilesInDir(), RemovePgTempRelationFiles(), RemovePgTempRelationFilesInDbspace(), RemoveTempXlogFiles(), RemoveXlogFile(), ReorderBufferCleanupSerializedTXNs(), ReorderBufferSerializedPath(), replace_variables(), report_fork_failure_to_client(), report_unmatched_relation(), ResetUnloggedRelations(), ResetUnloggedRelationsInDbspaceDir(), ResetUnloggedRelationsInTablespaceDir(), RestoreArchive(), RestoreArchivedFile(), results_differ(), rewind_copy_file_range(), RI_Initial_Check(), RI_PartitionRemove_Check(), rmtree(), sanitize_char(), scan_available_timezones(), scan_directory(), select_default_timezone(), send_message_to_frontend(), SendBaseBackup(), sendDir(), sendTablespace(), SendXlogRecPtrResult(), set_info_version(), set_pglocale_pgservice(), setup_background_workers(), setup_config(), SharedFilePath(), SharedFileSetPath(), SharedSegmentName(), show_data_directory_mode(), show_eval_params(), show_log_file_mode(), show_tcp_keepalives_count(), show_tcp_keepalives_idle(), show_tcp_keepalives_interval(), show_tcp_user_timeout(), show_trgm(), show_unix_socket_permissions(), SimpleXLogPageRead(), SlabStats(), SlruDeleteSegment(), SlruInternalDeleteSegment(), slurpFile(), sql_exec_dumpalldbs(), sql_exec_dumpalltables(), sql_exec_dumpalltbspc(), SSLerrmessage(), standard_ProcessUtility(), start_postmaster(), StartChildProcess(), StartLogStreamer(), StartReplication(), StartupReplicationSlots(), StartupXLOG(), stop_postmaster(), StreamServerPort(), sts_filename(), SyncVariables(), SysLogger_Start(), tar_open_for_write(), TempTablespacePath(), test_config_settings(), threadRun(), tidout(), timeofday(), timestamptz_to_str(), transfer_relfile(), transformRowExpr(), transformSetOperationTree(), truncate_target_file(), update_controlfile(), uuid_generate_internal(), uuid_generate_v1mc(), vacuumlo(), validate_exec(), ValidatePgVersion(), ValidateXLOGDirectoryStructure(), VXIDGetDatum(), wait_result_to_str(), walkdir(), WalRcvWaitForStartPosition(), WalReceiverMain(), worker_spi_launch(), write_relcache_init_file(), write_relmap_file(), WriteRecoveryConf(), writeTimeLineHistory(), writeTimeLineHistoryFile(), xidout(), XLogArchiveIsBusy(), XLogFileCopy(), XLogFileInit(), XLogFileRead(), XLogSendPhysical(), XLOGShmemSize(), XLogWalRcvFlush(), and yesno_prompt().

◆ sprintf

#define sprintf pg_sprintf

Definition at line 194 of file port.h.

Referenced by _ArchiveEntry(), _conv(), _PG_init(), _StartBlob(), _StartBlobs(), aclitemout(), AddISO8601IntPart(), AddPostgresIntPart(), AddVerboseIntPart(), AppendSeconds(), ApplyLogicalMappingFile(), array_dims(), array_out(), assign_pgstat_temp_directory(), BackendRun(), bootstrap_template1(), bt_page_print_tuples(), build_subplan(), build_tuplestore_recursively(), CheckPointReplicationSlots(), ChooseIndexColumnNames(), CreateFakeRelcacheEntry(), CreateNewPortal(), CreateSlotOnDisk(), CreateWalTarMethod(), DCH_to_char(), deallocate_one(), do_kill(), do_lo_import(), doabbr(), ecpg_auto_prepare(), ecpg_build_native_sqlda(), ecpg_build_params(), ecpg_is_type_an_array(), ecpg_store_input(), ECPGdump_a_simple(), ECPGdump_a_struct(), EncodeDateOnly(), EncodeDateTime(), EncodeInterval(), encodingid_to_string(), find_in_dynamic_libpath(), fmtfloat(), fmtptr(), generate_normalized_query(), get_comma_elts(), get_str_from_var(), getNextFlagFromString(), gtsvectorout(), hashline_number(), infix(), initialize_environment(), initialize_worker_spi(), InitializeGUCOptionsFromEnvironment(), InternalIpcMemoryCreate(), LaunchParallelWorkers(), lquery_out(), main(), make_absolute_path(), make_colname_unique(), mdunlinkfork(), MergeAffix(), NIAddAffix(), NUM_processor(), num_word(), oidvectorout(), optionListToArray(), parseQuery(), pg_get_userbyid(), pg_regerror(), pg_strfromd(), pg_wcsformat(), PGTYPESnumeric_from_double(), pgwin32_unsetenv(), plperl_create_sub(), PortalRunMulti(), pqInternalNotice(), PQprintTuples(), PQsetClientEncoding(), pqSetenvPoll(), preparedStatementName(), print_double(), prs_process_call(), ReceiveXlogStream(), regoperout(), regression_main(), ReorderBufferCleanupSerializedTXNs(), ReplicationSlotDropPtr(), ReplicationSlotSave(), report_invalid_encoding(), report_untranslatable_char(), restore(), RestoreSlotFromDisk(), ri_Check_Pk_Match(), RI_FKey_cascade_del(), RI_FKey_cascade_upd(), RI_FKey_check(), ri_restrict(), ri_set(), rstacktoodeep(), SaveSlotToPath(), scram_build_verifier(), seg_out(), SelectConfigFiles(), send_int8_string(), set_debug_options(), set_ps_display(), set_rtable_names(), SetOutput(), setup_background_workers(), setup_config(), setup_formatted_log_time(), SnapBuildRestore(), SnapBuildSerialize(), SPI_result_code_string(), sprintf_double_value(), sprintf_float_value(), sql_check(), sql_exec_searchtables(), stringoffset(), stringrule(), SyncRepWaitForLSN(), tarOpen(), transformRelOptions(), ts_process_call(), tsvectorout(), tt_process_call(), ttdummy(), unsetenv(), winsock_strerror(), worker_spi_launch(), WriteToc(), and yearistype().

◆ SSL_get_current_compression

#define SSL_get_current_compression ( x ) 0

Definition at line 449 of file port.h.

Referenced by be_tls_get_compression(), and PQsslAttribute().

◆ strerror

#define strerror pg_strerror

Definition at line 205 of file port.h.

Referenced by _tarReadRaw(), adjust_data_dir(), cfgetc(), cfread(), change_directory(), check_bin_dir(), check_errno(), check_file_clone(), check_for_isn_and_int8_passing_mismatch(), check_for_jsonb_9_4_usage(), check_for_reg_data_type_usage(), check_for_tables_with_oids(), check_hard_link(), check_loadable_libraries(), check_ok(), check_single_dir(), checkControlFile(), CheckForExternalTrigger(), cloneFile(), close_file(), convert_sourcefiles_in(), copyFile(), create_script_for_cluster_analyze(), create_script_for_old_cluster_deletion(), CustomizableCleanupPriorWALFiles(), dir_getlasterror(), do_edit(), do_kill(), do_logrotate(), do_promote(), do_reload(), do_restart(), do_stop(), dolink(), exec_command_cd(), file_line_count(), file_size(), get_bin_version(), get_cfp_error(), get_control_data(), get_pgpid(), get_sock_dir(), get_tablespace_paths(), get_user_name(), gnuish_strerror_r(), ident_inet(), infile(), initialize_environment(), linkFile(), load_resultmap(), main(), make_absolute_path(), make_directory(), memcheck(), mkdirs(), new_9_0_populate_pg_largeobject_metadata(), old_9_3_check_for_line_data_type_usage(), old_9_6_check_for_unknown_data_type_usage(), old_9_6_invalidate_hash_indexes(), open_file_in_directory(), open_result_files(), parallel_exec_prog(), parallel_transfer_all_new_dbs(), pid_lock_file_exists(), PostmasterMain(), PostmasterMarkPIDForWorkerNotify(), process_file(), pvsnprintf(), reap_child(), regression_main(), report_fork_failure_to_client(), results_differ(), rewriteVisibilityMap(), run_schedule(), scan_available_timezones(), search_directory(), SelectConfigFiles(), SetWALSegSize(), spawn_process(), start_postmaster(), stop_postmaster(), tablespace_list_append(), tar_getlasterror(), threadRun(), tokenize_file(), tokenize_inc_file(), transfer_relfile(), trap_sigint_during_startup(), try_complete_step(), validate_exec(), wait_for_tests(), write_syslogger_file(), writezone(), and XLogDumpXLogRead().

◆ strerror_r

#define strerror_r pg_strerror_r

Definition at line 209 of file port.h.

Referenced by dopr(), gnuish_strerror_r(), initialize_SSL(), lo_export(), lo_import_internal(), pg_fe_getauthname(), pg_local_sendauth(), and PQconnectPoll().

◆ TIMEZONE_GLOBAL

#define TIMEZONE_GLOBAL timezone

Definition at line 226 of file port.h.

Referenced by abstime2tm(), get_timezone_offset(), and timestamp2tm().

◆ TZNAME_GLOBAL

#define TZNAME_GLOBAL tzname

Definition at line 227 of file port.h.

Referenced by abstime2tm(), and timestamp2tm().

◆ USE_REPL_SNPRINTF

#define USE_REPL_SNPRINTF 1

Definition at line 142 of file port.h.

◆ vfprintf

#define vfprintf pg_vfprintf

Definition at line 195 of file port.h.

Referenced by ecpg_log(), pg_log_generic_v(), print_lo_result(), status(), verror(), and write_stderr().

◆ vprintf

#define vprintf pg_vprintf

Definition at line 197 of file port.h.

Referenced by appendStringInfo().

◆ vsnprintf

#define vsnprintf pg_vsnprintf

Definition at line 191 of file port.h.

Referenced by appendPQExpBufferVA(), dblink_res_error(), do_serialize(), exec_prog(), executeQueryOrDie(), header(), parallel_exec_prog(), pg_log_generic_v(), pg_log_v(), PLy_exception_set(), PLy_exception_set_plural(), pqInternalNotice(), prep_status(), psql_command(), pvsnprintf(), px_debug(), report_invalid_record(), report_status(), and write_stderr().

◆ vsprintf

#define vsprintf pg_vsprintf

Definition at line 193 of file port.h.

Typedef Documentation

◆ pgsocket

typedef int pgsocket

Definition at line 31 of file port.h.

◆ pqsigfunc

typedef void(* pqsigfunc) (int signo)

Definition at line 525 of file port.h.

◆ qsort_arg_comparator

typedef int(* qsort_arg_comparator) (const void *a, const void *b, void *arg)

Definition at line 493 of file port.h.

Function Documentation

◆ canonicalize_path()

void canonicalize_path ( char * path )

Definition at line 254 of file path.c.

References skip_drive, trim_directory(), and trim_trailing_separator().

Referenced by adjust_data_dir(), check_canonical_path(), check_required_directory(), convert_and_check_filename(), create_script_for_old_cluster_deletion(), create_xlog_or_symlink(), CreateTableSpace(), do_copy(), exec_command_edit(), exec_command_write(), find_in_dynamic_libpath(), find_my_exec(), find_other_exec(), get_tablespace_mapping(), main(), make_absolute_path(), make_relative_path(), parseCommandLine(), process_file(), resolve_symlinks(), set_pglocale_pgservice(), setup(), setup_bin_paths(), setup_pgdata(), SplitDirectoriesString(), tablespace_list_append(), and tokenize_inc_file().

 {
     char       *p,
                *to_p;
     char       *spath;
     bool        was_sep = false;
     int         pending_strips;
 
 #ifdef WIN32
 
     /*
      * The Windows command processor will accept suitably quoted paths with
      * forward slashes, but barfs badly with mixed forward and back slashes.
      */
     for (p = path; *p; p++)
     {
         if (*p == '\\')
             *p = '/';
     }
 
     /*
      * In Win32, if you do: prog.exe "a b" "\c\d\" the system will pass \c\d"
      * as argv[2], so trim off trailing quote.
      */
     if (p > path && *(p - 1) == '"')
         *(p - 1) = '/';
 #endif
 
     /*
      * Removing the trailing slash on a path means we never get ugly double
      * trailing slashes. Also, Win32 can't stat() a directory with a trailing
      * slash. Don't remove a leading slash, though.
      */
     trim_trailing_separator(path);
 
     /*
      * Remove duplicate adjacent separators
      */
     p = path;
 #ifdef WIN32
     /* Don't remove leading double-slash on Win32 */
     if (*p)
         p++;
 #endif
     to_p = p;
     for (; *p; p++, to_p++)
     {
         /* Handle many adjacent slashes, like "/a///b" */
         while (*p == '/' && was_sep)
             p++;
         if (to_p != p)
             *to_p = *p;
         was_sep = (*p == '/');
     }
     *to_p = '\0';
 
     /*
      * Remove any trailing uses of "." and process ".." ourselves
      *
      * Note that "/../.." should reduce to just "/", while "../.." has to be
      * kept as-is.  In the latter case we put back mistakenly trimmed ".."
      * components below.  Also note that we want a Windows drive spec to be
      * visible to trim_directory(), but it's not part of the logic that's
      * looking at the name components; hence distinction between path and
      * spath.
      */
     spath = skip_drive(path);
     pending_strips = 0;
     for (;;)
     {
         int         len = strlen(spath);
 
         if (len >= 2 && strcmp(spath + len - 2, "/.") == 0)
             trim_directory(path);
         else if (strcmp(spath, ".") == 0)
         {
             /* Want to leave "." alone, but "./.." has to become ".." */
             if (pending_strips > 0)
                 *spath = '\0';
             break;
         }
         else if ((len >= 3 && strcmp(spath + len - 3, "/..") == 0) ||
                  strcmp(spath, "..") == 0)
         {
             trim_directory(path);
             pending_strips++;
         }
         else if (pending_strips > 0 && *spath != '\0')
         {
             /* trim a regular directory name canceled by ".." */
             trim_directory(path);
             pending_strips--;
             /* foo/.. should become ".", not empty */
             if (*spath == '\0')
                 strcpy(spath, ".");
         }
         else
             break;
     }
 
     if (pending_strips > 0)
     {
         /*
          * We could only get here if path is now totally empty (other than a
          * possible drive specifier on Windows). We have to put back one or
          * more ".."'s that we took off.
          */
         while (--pending_strips > 0)
             strcat(path, "../");
         strcat(path, "..");
     }
 }

◆ cleanup_path()

void cleanup_path ( char * path )

Definition at line 185 of file path.c.

References MAXPGPATH.

Referenced by get_configdata().

 {
 #ifdef WIN32
     char       *ptr;
 
     /*
      * GetShortPathName() will fail if the path does not exist, or short names
      * are disabled on this file system.  In both cases, we just return the
      * original path.  This is particularly useful for --sysconfdir, which
      * might not exist.
      */
     GetShortPathName(path, path, MAXPGPATH - 1);
 
     /* Replace '\' with '/' */
     for (ptr = path; *ptr; ptr++)
     {
         if (*ptr == '\\')
             *ptr = '/';
     }
 #endif
 }

◆ crypt()

char* crypt	(	const char *	key,
		const char *	setting
	)

Definition at line 488 of file crypt.c.

References __bcrypt(), __md5crypt(), _PASSWORD_EFMT1, a64toi, C_block::b, cryptresult, des_cipher(), des_setkey(), i, and itoa64.

 {
     char       *encp;
     int32_t     i;
     int         t;
     int32_t     salt;
     int         num_iter,
                 salt_size;
     C_block     keyblock,
                 rsltblock;
 
 #if 0
     /* Non-DES encryption schemes hook in here. */
     if (setting[0] == _PASSWORD_NONDES)
     {
         switch (setting[1])
         {
             case '2':
                 return (__bcrypt(key, setting));
             case '1':
             default:
                 return (__md5crypt(key, setting));
         }
     }
 #endif
 
     for (i = 0; i < 8; i++)
     {
         if ((t = 2 * (unsigned char) (*key)) != 0)
             key++;
         keyblock.b[i] = t;
     }
     if (des_setkey((char *) keyblock.b))    /* also initializes "a64toi" */
         return (NULL);
 
     encp = &cryptresult[0];
     switch (*setting)
     {
         case _PASSWORD_EFMT1:
 
             /*
              * Involve the rest of the password 8 characters at a time.
              */
             while (*key)
             {
                 if (des_cipher((char *) (void *) &keyblock,
                                (char *) (void *) &keyblock, 0L, 1))
                     return (NULL);
                 for (i = 0; i < 8; i++)
                 {
                     if ((t = 2 * (unsigned char) (*key)) != 0)
                         key++;
                     keyblock.b[i] ^= t;
                 }
                 if (des_setkey((char *) keyblock.b))
                     return (NULL);
             }
 
             *encp++ = *setting++;
 
             /* get iteration count */
             num_iter = 0;
             for (i = 4; --i >= 0;)
             {
                 if ((t = (unsigned char) setting[i]) == '\0')
                     t = '.';
                 encp[i] = t;
                 num_iter = (num_iter << 6) | a64toi[t];
             }
             setting += 4;
             encp += 4;
             salt_size = 4;
             break;
         default:
             num_iter = 25;
             salt_size = 2;
     }
 
     salt = 0;
     for (i = salt_size; --i >= 0;)
     {
         if ((t = (unsigned char) setting[i]) == '\0')
             t = '.';
         encp[i] = t;
         salt = (salt << 6) | a64toi[t];
     }
     encp += salt_size;
     if (des_cipher((char *) (void *) &constdatablock,
                    (char *) (void *) &rsltblock, salt, num_iter))
         return (NULL);
 
     /*
      * Encode the 64 cipher bits as 11 ascii characters.
      */
     i = ((int32_t) ((rsltblock.b[0] << 8) | rsltblock.b[1]) << 8) |
         rsltblock.b[2];
     encp[3] = itoa64[i & 0x3f];
     i >>= 6;
     encp[2] = itoa64[i & 0x3f];
     i >>= 6;
     encp[1] = itoa64[i & 0x3f];
     i >>= 6;
     encp[0] = itoa64[i];
     encp += 4;
     i = ((int32_t) ((rsltblock.b[3] << 8) | rsltblock.b[4]) << 8) |
         rsltblock.b[5];
     encp[3] = itoa64[i & 0x3f];
     i >>= 6;
     encp[2] = itoa64[i & 0x3f];
     i >>= 6;
     encp[1] = itoa64[i & 0x3f];
     i >>= 6;
     encp[0] = itoa64[i];
     encp += 4;
     i = ((int32_t) ((rsltblock.b[6]) << 8) | rsltblock.b[7]) << 2;
     encp[2] = itoa64[i & 0x3f];
     i >>= 6;
     encp[1] = itoa64[i & 0x3f];
     i >>= 6;
     encp[0] = itoa64[i];
 
     encp[3] = 0;
 
     return (cryptresult);
 }

◆ dlclose()

int dlclose ( void * handle )

Referenced by internal_load_library(), and internal_unload_library().

◆ dlerror()

char* dlerror ( void )

Referenced by internal_load_library().

◆ dlopen()

void* dlopen	(	const char *	file,
		int	mode
	)

Referenced by internal_load_library().

◆ dlsym()

void* dlsym	(	void *	handle,
		const char *	symbol
	)

Referenced by internal_load_library(), internal_unload_library(), load_external_function(), and lookup_external_function().

◆ escape_single_quotes_ascii()

char* escape_single_quotes_ascii ( const char * src )

Definition at line 33 of file quotes.c.

References i, malloc, and SQL_STR_DOUBLE.

Referenced by escape_quotes(), and write_auto_conf_file().

 {
     int         len = strlen(src),
                 i,
                 j;
     char       *result = malloc(len * 2 + 1);
 
     if (!result)
         return NULL;
 
     for (i = 0, j = 0; i < len; i++)
     {
         if (SQL_STR_DOUBLE(src[i], true))
             result[j++] = src[i];
         result[j++] = src[i];
     }
     result[j] = '\0';
     return result;
 }

◆ find_my_exec()

int find_my_exec	(	const char *	argv0,
		char *	retpath
	)

Definition at line 129 of file exec.c.

References _, canonicalize_path(), errcode(), errcode_for_file_access(), first_dir_separator(), first_path_var_separator(), is_absolute_path, join_path_components(), log_error, MAXPGPATH, Min, resolve_symlinks(), StrNCpy, and validate_exec().

Referenced by do_kill(), find_other_exec(), find_other_exec_or_die(), getInstallationPaths(), InitStandaloneProcess(), main(), process_psqlrc(), set_pglocale_pgservice(), setup(), and setup_bin_paths().

 {
     char        cwd[MAXPGPATH],
                 test_path[MAXPGPATH];
     char       *path;
 
     if (!getcwd(cwd, MAXPGPATH))
     {
         log_error(errcode_for_file_access(),
                   _("could not identify current directory: %m"));
         return -1;
     }
 
     /*
      * If argv0 contains a separator, then PATH wasn't used.
      */
     if (first_dir_separator(argv0) != NULL)
     {
         if (is_absolute_path(argv0))
             StrNCpy(retpath, argv0, MAXPGPATH);
         else
             join_path_components(retpath, cwd, argv0);
         canonicalize_path(retpath);
 
         if (validate_exec(retpath) == 0)
             return resolve_symlinks(retpath);
 
         log_error(errcode(ERRCODE_WRONG_OBJECT_TYPE),
                   _("invalid binary \"%s\""), retpath);
         return -1;
     }
 
 #ifdef WIN32
     /* Win32 checks the current directory first for names without slashes */
     join_path_components(retpath, cwd, argv0);
     if (validate_exec(retpath) == 0)
         return resolve_symlinks(retpath);
 #endif
 
     /*
      * Since no explicit path was supplied, the user must have been relying on
      * PATH.  We'll search the same PATH.
      */
     if ((path = getenv("PATH")) && *path)
     {
         char       *startp = NULL,
                    *endp = NULL;
 
         do
         {
             if (!startp)
                 startp = path;
             else
                 startp = endp + 1;
 
             endp = first_path_var_separator(startp);
             if (!endp)
                 endp = startp + strlen(startp); /* point to end */
 
             StrNCpy(test_path, startp, Min(endp - startp + 1, MAXPGPATH));
 
             if (is_absolute_path(test_path))
                 join_path_components(retpath, test_path, argv0);
             else
             {
                 join_path_components(retpath, cwd, test_path);
                 join_path_components(retpath, retpath, argv0);
             }
             canonicalize_path(retpath);
 
             switch (validate_exec(retpath))
             {
                 case 0:         /* found ok */
                     return resolve_symlinks(retpath);
                 case -1:        /* wasn't even a candidate, keep looking */
                     break;
                 case -2:        /* found but disqualified */
                     log_error(errcode(ERRCODE_WRONG_OBJECT_TYPE),
                               _("could not read binary \"%s\""),
                               retpath);
                     break;
             }
         } while (*endp);
     }
 
     log_error(errcode(ERRCODE_UNDEFINED_FILE),
               _("could not find a \"%s\" to execute"), argv0);
     return -1;
 }

◆ find_other_exec()

int find_other_exec	(	const char *	argv0,
		const char *	target,
		const char *	versionstr,
		char *	retpath
	)

Definition at line 324 of file exec.c.

References canonicalize_path(), EXE, find_my_exec(), last_dir_separator(), MAXPGPATH, pipe_read_line(), snprintf, and validate_exec().

Referenced by do_kill(), find_other_exec_or_die(), getInstallationPaths(), isolation_start_test(), main(), and setup_bin_paths().

 {
     char        cmd[MAXPGPATH];
     char        line[MAXPGPATH];
 
     if (find_my_exec(argv0, retpath) < 0)
         return -1;
 
     /* Trim off program name and keep just directory */
     *last_dir_separator(retpath) = '\0';
     canonicalize_path(retpath);
 
     /* Now append the other program's name */
     snprintf(retpath + strlen(retpath), MAXPGPATH - strlen(retpath),
              "/%s%s", target, EXE);
 
     if (validate_exec(retpath) != 0)
         return -1;
 
     snprintf(cmd, sizeof(cmd), "\"%s\" -V", retpath);
 
     if (!pipe_read_line(cmd, line, sizeof(line)))
         return -1;
 
     if (strcmp(line, versionstr) != 0)
         return -2;
 
     return 0;
 }

◆ first_dir_separator()

char* first_dir_separator ( const char * filename )

Definition at line 103 of file path.c.

References IS_DIR_SEP, skip_drive, and unconstify.

Referenced by check_restricted_library_name(), check_valid_extension_name(), check_valid_version_name(), expand_dynamic_library_name(), find_in_dynamic_libpath(), find_my_exec(), load_libraries(), and substitute_libpath_macro().

 {
     const char *p;
 
     for (p = skip_drive(filename); *p; p++)
         if (IS_DIR_SEP(*p))
             return unconstify(char *, p);
     return NULL;
 }

◆ first_path_var_separator()

char* first_path_var_separator ( const char * pathlist )

Definition at line 120 of file path.c.

References IS_PATH_VAR_SEP, and unconstify.

Referenced by find_in_dynamic_libpath(), and find_my_exec().

 {
     const char *p;
 
     /* skip_drive is not needed */
     for (p = pathlist; *p; p++)
         if (IS_PATH_VAR_SEP(*p))
             return unconstify(char *, p);
     return NULL;
 }

◆ fls()

int fls ( int mask )

Definition at line 55 of file fls.c.

References bit().

Referenced by _hash_get_oldblock_from_newbucket(), add_paths_to_append_rel(), and generate_union_paths().

 {
     int         bit;
 
     if (mask == 0)
         return (0);
     for (bit = 1; mask != 1; bit++)
         mask = (unsigned int) mask >> 1;
     return (bit);
 }

◆ get_doc_path()

void get_doc_path	(	const char *	my_exec_path,
		char *	ret_path
	)

Definition at line 776 of file path.c.

References make_relative_path().

Referenced by get_configdata().

 {
     make_relative_path(ret_path, DOCDIR, PGBINDIR, my_exec_path);
 }

◆ get_etc_path()

void get_etc_path	(	const char *	my_exec_path,
		char *	ret_path
	)

Definition at line 713 of file path.c.

References make_relative_path().

Referenced by get_configdata(), process_psqlrc(), and set_pglocale_pgservice().

 {
     make_relative_path(ret_path, SYSCONFDIR, PGBINDIR, my_exec_path);
 }

◆ get_home_path()

bool get_home_path ( char * ret_path )

Definition at line 807 of file path.c.

References MAXPGPATH, pqGetpwuid(), snprintf, and strlcpy().

Referenced by expand_tilde(), initializeInput(), and process_psqlrc().

 {
 #ifndef WIN32
     char        pwdbuf[BUFSIZ];
     struct passwd pwdstr;
     struct passwd *pwd = NULL;
 
     (void) pqGetpwuid(geteuid(), &pwdstr, pwdbuf, sizeof(pwdbuf), &pwd);
     if (pwd == NULL)
         return false;
     strlcpy(ret_path, pwd->pw_dir, MAXPGPATH);
     return true;
 #else
     char       *tmppath;
 
     /*
      * Note: We use getenv() here because the more modern SHGetFolderPath()
      * would force the backend to link with shell32.lib, which eats valuable
      * desktop heap.  XXX This function is used only in psql, which already
      * brings in shell32 via libpq.  Moving this function to its own file
      * would keep it out of the backend, freeing it from this concern.
      */
     tmppath = getenv("APPDATA");
     if (!tmppath)
         return false;
     snprintf(ret_path, MAXPGPATH, "%s/postgresql", tmppath);
     return true;
 #endif
 }

◆ get_html_path()

void get_html_path	(	const char *	my_exec_path,
		char *	ret_path
	)

Definition at line 785 of file path.c.

References make_relative_path().

Referenced by get_configdata().

 {
     make_relative_path(ret_path, HTMLDIR, PGBINDIR, my_exec_path);
 }

◆ get_include_path()

void get_include_path	(	const char *	my_exec_path,
		char *	ret_path
	)

Definition at line 722 of file path.c.

References make_relative_path().

Referenced by get_configdata(), and main().

 {
     make_relative_path(ret_path, INCLUDEDIR, PGBINDIR, my_exec_path);
 }

◆ get_includeserver_path()

void get_includeserver_path	(	const char *	my_exec_path,
		char *	ret_path
	)

Definition at line 740 of file path.c.

References make_relative_path().

Referenced by get_configdata().

 {
     make_relative_path(ret_path, INCLUDEDIRSERVER, PGBINDIR, my_exec_path);
 }

◆ get_lib_path()

void get_lib_path	(	const char *	my_exec_path,
		char *	ret_path
	)

Definition at line 749 of file path.c.

References make_relative_path().

Referenced by get_configdata().

 {
     make_relative_path(ret_path, LIBDIR, PGBINDIR, my_exec_path);
 }

◆ get_locale_path()

void get_locale_path	(	const char *	my_exec_path,
		char *	ret_path
	)

Definition at line 767 of file path.c.

References make_relative_path().

Referenced by get_configdata(), pg_bindtextdomain(), and set_pglocale_pgservice().

 {
     make_relative_path(ret_path, LOCALEDIR, PGBINDIR, my_exec_path);
 }

◆ get_man_path()

void get_man_path	(	const char *	my_exec_path,
		char *	ret_path
	)

Definition at line 794 of file path.c.

References make_relative_path().

Referenced by get_configdata().

 {
     make_relative_path(ret_path, MANDIR, PGBINDIR, my_exec_path);
 }

◆ get_parent_directory()

void get_parent_directory ( char * path )

Definition at line 854 of file path.c.

References trim_directory().

Referenced by destroy_tablespace_directories(), fsync_parent_path(), main(), process_file(), TablespaceCreateDbspace(), and tokenize_inc_file().

 {
     trim_directory(path);
 }

◆ get_pkginclude_path()

void get_pkginclude_path	(	const char *	my_exec_path,
		char *	ret_path
	)

Definition at line 731 of file path.c.

References make_relative_path().

Referenced by get_configdata(), and main().

 {
     make_relative_path(ret_path, PKGINCLUDEDIR, PGBINDIR, my_exec_path);
 }

◆ get_pkglib_path()

void get_pkglib_path	(	const char *	my_exec_path,
		char *	ret_path
	)

Definition at line 758 of file path.c.

References make_relative_path().

Referenced by get_configdata(), getInstallationPaths(), and InitStandaloneProcess().

 {
     make_relative_path(ret_path, PKGLIBDIR, PGBINDIR, my_exec_path);
 }

◆ get_progname()

const char* get_progname ( const char * argv0 )

Definition at line 453 of file path.c.

References EXE, fprintf, last_dir_separator(), pg_strcasecmp(), progname, and skip_drive.

Referenced by get_opts(), handle_help_version_opts(), main(), parseCommandLine(), pg_logging_init(), and regression_main().

 {
     const char *nodir_name;
     char       *progname;
 
     nodir_name = last_dir_separator(argv0);
     if (nodir_name)
         nodir_name++;
     else
         nodir_name = skip_drive(argv0);
 
     /*
      * Make a copy in case argv[0] is modified by ps_status. Leaks memory, but
      * called only once.
      */
     progname = strdup(nodir_name);
     if (progname == NULL)
     {
         fprintf(stderr, "%s: out of memory\n", nodir_name);
         abort();                /* This could exit the postmaster */
     }
 
 #if defined(__CYGWIN__) || defined(WIN32)
     /* strip ".exe" suffix, regardless of case */
     if (strlen(progname) > sizeof(EXE) - 1 &&
         pg_strcasecmp(progname + strlen(progname) - (sizeof(EXE) - 1), EXE) == 0)
         progname[strlen(progname) - (sizeof(EXE) - 1)] = '\0';
 #endif
 
     return progname;
 }

◆ get_share_path()

void get_share_path	(	const char *	my_exec_path,
		char *	ret_path
	)

Definition at line 704 of file path.c.

References make_relative_path().

Referenced by get_configdata(), get_extension_control_directory(), get_extension_control_filename(), get_extension_script_directory(), get_tsearch_config_filename(), ParseTzFile(), pg_TZDIR(), and setup_bin_paths().

 {
     make_relative_path(ret_path, PGSHAREDIR, PGBINDIR, my_exec_path);
 }

◆ getpeereid()

int getpeereid	(	int	sock,
		uid_t *	uid,
		gid_t *	gid
	)

Definition at line 35 of file getpeereid.c.

Referenced by ident_inet(), and PQconnectPoll().

 {
 #if defined(SO_PEERCRED)
     /* Linux: use getsockopt(SO_PEERCRED) */
     struct ucred peercred;
     ACCEPT_TYPE_ARG3 so_len = sizeof(peercred);
 
     if (getsockopt(sock, SOL_SOCKET, SO_PEERCRED, &peercred, &so_len) != 0 ||
         so_len != sizeof(peercred))
         return -1;
     *uid = peercred.uid;
     *gid = peercred.gid;
     return 0;
 #elif defined(LOCAL_PEERCRED)
     /* Debian with FreeBSD kernel: use getsockopt(LOCAL_PEERCRED) */
     struct xucred peercred;
     ACCEPT_TYPE_ARG3 so_len = sizeof(peercred);
 
     if (getsockopt(sock, 0, LOCAL_PEERCRED, &peercred, &so_len) != 0 ||
         so_len != sizeof(peercred) ||
         peercred.cr_version != XUCRED_VERSION)
         return -1;
     *uid = peercred.cr_uid;
     *gid = peercred.cr_gid;
     return 0;
 #elif defined(HAVE_GETPEERUCRED)
     /* Solaris: use getpeerucred() */
     ucred_t    *ucred;
 
     ucred = NULL;               /* must be initialized to NULL */
     if (getpeerucred(sock, &ucred) == -1)
         return -1;
 
     *uid = ucred_geteuid(ucred);
     *gid = ucred_getegid(ucred);
     ucred_free(ucred);
 
     if (*uid == (uid_t) (-1) || *gid == (gid_t) (-1))
         return -1;
     return 0;
 #else
     /* No implementation available on this platform */
     errno = ENOSYS;
     return -1;
 #endif
 }

◆ has_drive_prefix()

bool has_drive_prefix ( const char * filename )

Definition at line 87 of file path.c.

References skip_drive.

Referenced by process_file().

 {
 #ifdef WIN32
     return skip_drive(path) != path;
 #else
     return false;
 #endif
 }

◆ inet_aton()

int inet_aton	(	const char *	cp,
		struct in_addr *	addr
	)

Definition at line 56 of file inet_aton.c.

References pg_hton32, and val.

Referenced by getaddrinfo().

 {
     unsigned int val;
     int         base,
                 n;
     char        c;
     u_int       parts[4];
     u_int      *pp = parts;
 
     for (;;)
     {
         /*
          * Collect number up to ``.''. Values are specified as for C: 0x=hex,
          * 0=octal, other=decimal.
          */
         val = 0;
         base = 10;
         if (*cp == '0')
         {
             if (*++cp == 'x' || *cp == 'X')
                 base = 16, cp++;
             else
                 base = 8;
         }
         while ((c = *cp) != '\0')
         {
             if (isdigit((unsigned char) c))
             {
                 val = (val * base) + (c - '0');
                 cp++;
                 continue;
             }
             if (base == 16 && isxdigit((unsigned char) c))
             {
                 val = (val << 4) +
                     (c + 10 - (islower((unsigned char) c) ? 'a' : 'A'));
                 cp++;
                 continue;
             }
             break;
         }
         if (*cp == '.')
         {
             /*
              * Internet format: a.b.c.d a.b.c   (with c treated as 16-bits)
              * a.b     (with b treated as 24 bits)
              */
             if (pp >= parts + 3 || val > 0xff)
                 return 0;
             *pp++ = val, cp++;
         }
         else
             break;
     }
 
     /*
      * Check for trailing junk.
      */
     while (*cp)
         if (!isspace((unsigned char) *cp++))
             return 0;
 
     /*
      * Concoct the address according to the number of parts specified.
      */
     n = pp - parts + 1;
     switch (n)
     {
 
         case 1:                 /* a -- 32 bits */
             break;
 
         case 2:                 /* a.b -- 8.24 bits */
             if (val > 0xffffff)
                 return 0;
             val |= parts[0] << 24;
             break;
 
         case 3:                 /* a.b.c -- 8.8.16 bits */
             if (val > 0xffff)
                 return 0;
             val |= (parts[0] << 24) | (parts[1] << 16);
             break;
 
         case 4:                 /* a.b.c.d -- 8.8.8.8 bits */
             if (val > 0xff)
                 return 0;
             val |= (parts[0] << 24) | (parts[1] << 16) | (parts[2] << 8);
             break;
     }
     if (addr)
         addr->s_addr = pg_hton32(val);
     return 1;
 }

◆ inet_net_ntop()

char* inet_net_ntop	(	int	af,
		const void *	src,
		int	bits,
		char *	dst,
		size_t	size
	)

Definition at line 77 of file inet_net_ntop.c.

References EAFNOSUPPORT, inet_net_ntop_ipv4(), inet_net_ntop_ipv6(), PGSQL_AF_INET, and PGSQL_AF_INET6.

Referenced by getHostaddr(), getnameinfo(), inet_abbrev(), network_host(), network_out(), and network_show().

 {
     /*
      * We need to cover both the address family constants used by the PG inet
      * type (PGSQL_AF_INET and PGSQL_AF_INET6) and those used by the system
      * libraries (AF_INET and AF_INET6).  We can safely assume PGSQL_AF_INET
      * == AF_INET, but the INET6 constants are very likely to be different. If
      * AF_INET6 isn't defined, silently ignore it.
      */
     switch (af)
     {
         case PGSQL_AF_INET:
             return (inet_net_ntop_ipv4(src, bits, dst, size));
         case PGSQL_AF_INET6:
 #if defined(AF_INET6) && AF_INET6 != PGSQL_AF_INET6
         case AF_INET6:
 #endif
             return (inet_net_ntop_ipv6(src, bits, dst, size));
         default:
             errno = EAFNOSUPPORT;
             return (NULL);
     }
 }

◆ isinf()

int isinf ( double x )

Referenced by calc_length_hist_frac(), check_float4_val(), check_float8_val(), dcbrt(), dcos(), dcosd(), dcot(), dcotd(), dexp(), dlog1(), dlog10(), dpow(), dsin(), dsind(), dsqrt(), dtan(), dtand(), dtof(), executeItemOptUnwrapTarget(), float4_accum(), float4_dist(), float4_div(), float4_mi(), float4_mul(), float4_numeric(), float4_pl(), float4_to_char(), float4in(), float8_accum(), float8_combine(), float8_dist(), float8_div(), float8_mi(), float8_mul(), float8_numeric(), float8_pl(), float8_regr_accum(), float8_regr_combine(), float8_timestamptz(), float8_to_char(), fmtfloat(), gbt_float8_dist(), get_len_position(), in_range_float4_float8(), in_range_float8_float8(), is_infinite(), main(), make_interval(), pg_hypot(), pg_strfromd(), sprintf_double_value(), sprintf_float_value(), strtof(), SV_to_JsonbValue(), and width_bucket_float8().

◆ join_path_components()

void join_path_components	(	char *	ret_path,
		const char *	head,
		const char *	tail
	)

Definition at line 218 of file path.c.

References IS_DIR_SEP, MAXPGPATH, skip_drive, snprintf, and strlcpy().

Referenced by find_my_exec(), main(), make_relative_path(), process_file(), resolve_symlinks(), and tokenize_inc_file().

 {
     if (ret_path != head)
         strlcpy(ret_path, head, MAXPGPATH);
 
     /*
      * Remove any leading "." in the tail component.
      *
      * Note: we used to try to remove ".." as well, but that's tricky to get
      * right; now we just leave it to be done by canonicalize_path() later.
      */
     while (tail[0] == '.' && IS_DIR_SEP(tail[1]))
         tail += 2;
 
     if (*tail)
     {
         /* only separate with slash if head wasn't empty */
         snprintf(ret_path + strlen(ret_path), MAXPGPATH - strlen(ret_path),
                  "%s%s",
                  (*(skip_drive(head)) != '\0') ? "/" : "",
                  tail);
     }
 }

◆ last_dir_separator()

char* last_dir_separator ( const char * filename )

Definition at line 138 of file path.c.

References IS_DIR_SEP, skip_drive, and unconstify.

Referenced by check_file_excluded(), ECPGconnect(), find_other_exec(), get_progname(), main(), resolve_symlinks(), sendDir(), sendFile(), setup(), and setup_bin_paths().

 {
     const char *p,
                *ret = NULL;
 
     for (p = skip_drive(filename); *p; p++)
         if (IS_DIR_SEP(*p))
             ret = p;
     return unconstify(char *, ret);
 }

◆ make_absolute_path()

char* make_absolute_path ( const char * path )

Definition at line 608 of file path.c.

References _, buf, canonicalize_path(), elog, ereport, errcode(), errmsg(), ERROR, fprintf, free, is_absolute_path, malloc, MAXPGPATH, sprintf, and strerror.

Referenced by do_kill(), regression_main(), SelectConfigFiles(), and SetDataDir().

 {
     char       *new;
 
     /* Returning null for null input is convenient for some callers */
     if (path == NULL)
         return NULL;
 
     if (!is_absolute_path(path))
     {
         char       *buf;
         size_t      buflen;
 
         buflen = MAXPGPATH;
         for (;;)
         {
             buf = malloc(buflen);
             if (!buf)
             {
 #ifndef FRONTEND
                 ereport(ERROR,
                         (errcode(ERRCODE_OUT_OF_MEMORY),
                          errmsg("out of memory")));
 #else
                 fprintf(stderr, _("out of memory\n"));
                 return NULL;
 #endif
             }
 
             if (getcwd(buf, buflen))
                 break;
             else if (errno == ERANGE)
             {
                 free(buf);
                 buflen *= 2;
                 continue;
             }
             else
             {
                 int         save_errno = errno;
 
                 free(buf);
                 errno = save_errno;
 #ifndef FRONTEND
                 elog(ERROR, "could not get current working directory: %m");
 #else
                 fprintf(stderr, _("could not get current working directory: %s\n"),
                         strerror(errno));
                 return NULL;
 #endif
             }
         }
 
         new = malloc(strlen(buf) + strlen(path) + 2);
         if (!new)
         {
             free(buf);
 #ifndef FRONTEND
             ereport(ERROR,
                     (errcode(ERRCODE_OUT_OF_MEMORY),
                      errmsg("out of memory")));
 #else
             fprintf(stderr, _("out of memory\n"));
             return NULL;
 #endif
         }
         sprintf(new, "%s/%s", buf, path);
         free(buf);
     }
     else
     {
         new = strdup(path);
         if (!new)
         {
 #ifndef FRONTEND
             ereport(ERROR,
                     (errcode(ERRCODE_OUT_OF_MEMORY),
                      errmsg("out of memory")));
 #else
             fprintf(stderr, _("out of memory\n"));
             return NULL;
 #endif
         }
     }
 
     /* Make sure punctuation is canonical, too */
     canonicalize_path(new);
 
     return new;
 }

◆ make_native_path()

void make_native_path ( char * path )

Definition at line 166 of file path.c.

Referenced by do_kill(), pgarch_archiveXlog(), and RestoreArchivedFile().

 {
 #ifdef WIN32
     char       *p;
 
     for (p = filename; *p; p++)
         if (*p == '/')
             *p = '\\';
 #endif
 }

◆ mkdtemp()

char* mkdtemp ( char * path )

Definition at line 286 of file mkdtemp.c.

References _DIAGASSERT, and GETTEMP().

Referenced by stop_postmaster().

 {
     _DIAGASSERT(path != NULL);
 
     return GETTEMP(path, NULL, 1) ? path : NULL;
 }

◆ path_contains_parent_reference()

bool path_contains_parent_reference ( const char * path )

Definition at line 376 of file path.c.

References skip_drive.

Referenced by convert_and_check_filename(), and path_is_relative_and_below_cwd().

 {
     int         path_len;
 
     path = skip_drive(path);    /* C: shouldn't affect our conclusion */
 
     path_len = strlen(path);
 
     /*
      * ".." could be the whole path; otherwise, if it's present it must be at
      * the beginning, in the middle, or at the end.
      */
     if (strcmp(path, "..") == 0 ||
         strncmp(path, "../", 3) == 0 ||
         strstr(path, "/../") != NULL ||
         (path_len >= 3 && strcmp(path + path_len - 3, "/..") == 0))
         return true;
 
     return false;
 }

◆ path_is_prefix_of_path()

bool path_is_prefix_of_path	(	const char *	path1,
		const char *	path2
	)

Definition at line 438 of file path.c.

References IS_DIR_SEP.

Referenced by convert_and_check_filename(), create_script_for_old_cluster_deletion(), CreateTableSpace(), and parseCommandLine().

 {
     int         path1_len = strlen(path1);
 
     if (strncmp(path1, path2, path1_len) == 0 &&
         (IS_DIR_SEP(path2[path1_len]) || path2[path1_len] == '\0'))
         return true;
     return false;
 }

◆ path_is_relative_and_below_cwd()

bool path_is_relative_and_below_cwd ( const char * path )

Definition at line 405 of file path.c.

References is_absolute_path, IS_DIR_SEP, and path_contains_parent_reference().

Referenced by convert_and_check_filename().

 {
     if (is_absolute_path(path))
         return false;
     /* don't allow anything above the cwd */
     else if (path_contains_parent_reference(path))
         return false;
 #ifdef WIN32
 
     /*
      * On Win32, a drive letter _not_ followed by a slash, e.g. 'E:abc', is
      * relative to the cwd on that drive, or the drive's root directory if
      * that drive has no cwd.  Because the path itself cannot tell us which is
      * the case, we have to assume the worst, i.e. that it is not below the
      * cwd.  We could use GetFullPathName() to find the full path but that
      * could change if the current directory for the drive changes underneath
      * us, so we just disallow it.
      */
     else if (isalpha((unsigned char) path[0]) && path[1] == ':' &&
              !IS_DIR_SEP(path[2]))
         return false;
 #endif
     else
         return true;
 }

◆ pclose_check()

int pclose_check ( FILE * stream )

Definition at line 527 of file exec.c.

References _, errcode(), log_error, pfree(), and wait_result_to_str().

Referenced by pipe_read_line().

 {
     int         exitstatus;
     char       *reason;
 
     exitstatus = pclose(stream);
 
     if (exitstatus == 0)
         return 0;               /* all is well */
 
     if (exitstatus == -1)
     {
         /* pclose() itself failed, and hopefully set errno */
         log_error(errcode(ERRCODE_SYSTEM_ERROR),
                   _("pclose failed: %m"));
     }
     else
     {
         reason = wait_result_to_str(exitstatus);
         log_error(errcode(ERRCODE_SYSTEM_ERROR),
                   "%s", reason);
         pfree(reason);
     }
     return exitstatus;
 }

◆ pg_ascii_tolower()

unsigned char pg_ascii_tolower ( unsigned char ch )

Definition at line 146 of file pgstrcasecmp.c.

Referenced by asc_initcap(), asc_tolower(), pg_wc_tolower(), and SB_lower_char().

 {
     if (ch >= 'A' && ch <= 'Z')
         ch += 'a' - 'A';
     return ch;
 }

◆ pg_ascii_toupper()

unsigned char pg_ascii_toupper ( unsigned char ch )

Definition at line 135 of file pgstrcasecmp.c.

Referenced by asc_initcap(), asc_toupper(), filter_list_to_array(), and pg_wc_toupper().

 {
     if (ch >= 'a' && ch <= 'z')
         ch += 'A' - 'a';
     return ch;
 }

◆ pg_check_dir()

int pg_check_dir ( const char * dir )

Definition at line 31 of file pgcheckdir.c.

References closedir(), dirent::d_name, opendir(), and readdir().

Referenced by create_data_directory(), create_xlog_or_symlink(), main(), and verify_dir_is_empty_or_create().

 {
     int         result = 1;
     DIR        *chkdir;
     struct dirent *file;
     bool        dot_found = false;
     bool        mount_found = false;
     int         readdir_errno;
 
     chkdir = opendir(dir);
     if (chkdir == NULL)
         return (errno == ENOENT) ? 0 : -1;
 
     while (errno = 0, (file = readdir(chkdir)) != NULL)
     {
         if (strcmp(".", file->d_name) == 0 ||
             strcmp("..", file->d_name) == 0)
         {
             /* skip this and parent directory */
             continue;
         }
 #ifndef WIN32
         /* file starts with "." */
         else if (file->d_name[0] == '.')
         {
             dot_found = true;
         }
         /* lost+found directory */
         else if (strcmp("lost+found", file->d_name) == 0)
         {
             mount_found = true;
         }
 #endif
         else
         {
             result = 4;         /* not empty */
             break;
         }
     }
 
     if (errno)
         result = -1;            /* some kind of I/O error? */
 
     /* Close chkdir and avoid overwriting the readdir errno on success */
     readdir_errno = errno;
     if (closedir(chkdir))
         result = -1;            /* error executing closedir */
     else
         errno = readdir_errno;
 
     /* We report on mount point if we find a lost+found directory */
     if (result == 1 && mount_found)
         result = 3;
 
     /* We report on dot-files if we _only_ find dot files */
     if (result == 1 && dot_found)
         result = 2;
 
     return result;
 }

◆ pg_erand48()

double pg_erand48 ( unsigned short xseed[3] )

Definition at line 88 of file erand48.c.

References _dorand48().

Referenced by computeIterativeZipfian(), doLog(), drandom(), geqo_rand(), getExponentialRand(), getGaussianRand(), getPoissonRand(), getrand(), and sampler_random_fract().

 {
     uint64      x = _dorand48(xseed);
 
     return ldexp((double) (x & UINT64CONST(0xFFFFFFFFFFFF)), -48);
 }

◆ pg_fprintf()

int pg_fprintf	(	FILE *	stream,
		const char *	fmt,
			...
	)

◆ pg_get_encoding_from_locale()

int pg_get_encoding_from_locale	(	const char *	ctype,
		bool	write_message
	)

Definition at line 433 of file chklocale.c.

References PG_SQL_ASCII.

Referenced by cache_locale_time(), check_encoding_locale_matches(), check_locale_encoding(), connectOptions2(), pg_import_system_collations(), PGLC_localeconv(), PQsetClientEncoding(), SetMessageEncoding(), and setup_locale_encoding().

 {
     return PG_SQL_ASCII;
 }

◆ pg_jrand48()

long pg_jrand48 ( unsigned short xseed[3] )

Definition at line 112 of file erand48.c.

References _dorand48().

Referenced by initRandomState(), and main().

 {
     uint64      x = _dorand48(xseed);
 
     return (int32) ((x >> 16) & UINT64CONST(0xFFFFFFFF));
 }

◆ pg_lrand48()

long pg_lrand48 ( void )

Definition at line 100 of file erand48.c.

References _dorand48(), and _rand48_seed.

Referenced by random(), test_huge_distances(), and test_pattern().

 {
     uint64      x = _dorand48(_rand48_seed);
 
     return (x >> 17) & UINT64CONST(0x7FFFFFFF);
 }

◆ pg_mkdir_p()

int pg_mkdir_p	(	char *	path,
		int	omode
	)

Definition at line 57 of file pgmkdirp.c.

References mkdir, S_IRWXG, S_IRWXO, S_IRWXU, S_ISDIR, S_IWUSR, S_IXUSR, and stat.

Referenced by create_data_directory(), create_xlog_or_symlink(), StartLogStreamer(), and verify_dir_is_empty_or_create().

 {
     struct stat sb;
     mode_t      numask,
                 oumask;
     int         last,
                 retval;
     char       *p;
 
     retval = 0;
     p = path;
 
 #ifdef WIN32
     /* skip network and drive specifiers for win32 */
     if (strlen(p) >= 2)
     {
         if (p[0] == '/' && p[1] == '/')
         {
             /* network drive */
             p = strstr(p + 2, "/");
             if (p == NULL)
             {
                 errno = EINVAL;
                 return -1;
             }
         }
         else if (p[1] == ':' &&
                  ((p[0] >= 'a' && p[0] <= 'z') ||
                   (p[0] >= 'A' && p[0] <= 'Z')))
         {
             /* local drive */
             p += 2;
         }
     }
 #endif
 
     /*
      * POSIX 1003.2: For each dir operand that does not name an existing
      * directory, effects equivalent to those caused by the following command
      * shall occur:
      *
      * mkdir -p -m $(umask -S),u+wx $(dirname dir) && mkdir [-m mode] dir
      *
      * We change the user's umask and then restore it, instead of doing
      * chmod's.  Note we assume umask() can't change errno.
      */
     oumask = umask(0);
     numask = oumask & ~(S_IWUSR | S_IXUSR);
     (void) umask(numask);
 
     if (p[0] == '/')            /* Skip leading '/'. */
         ++p;
     for (last = 0; !last; ++p)
     {
         if (p[0] == '\0')
             last = 1;
         else if (p[0] != '/')
             continue;
         *p = '\0';
         if (!last && p[1] == '\0')
             last = 1;
 
         if (last)
             (void) umask(oumask);
 
         /* check for pre-existing directory */
         if (stat(path, &sb) == 0)
         {
             if (!S_ISDIR(sb.st_mode))
             {
                 if (last)
                     errno = EEXIST;
                 else
                     errno = ENOTDIR;
                 retval = -1;
                 break;
             }
         }
         else if (mkdir(path, last ? omode : S_IRWXU | S_IRWXG | S_IRWXO) < 0)
         {
             retval = -1;
             break;
         }
         if (!last)
             *p = '/';
     }
 
     /* ensure we restored umask */
     (void) umask(oumask);
 
     return retval;
 }

◆ pg_pread()

ssize_t pg_pread	(	int	fd,
		void *	buf,
		size_t	nbyte,
		off_t	offset
	)

Definition at line 27 of file pread.c.

References _dosmaperr(), and read.

Referenced by FileRead(), and XLogPageRead().

 {
 #ifdef WIN32
     OVERLAPPED  overlapped = {0};
     HANDLE      handle;
     DWORD       result;
 
     handle = (HANDLE) _get_osfhandle(fd);
     if (handle == INVALID_HANDLE_VALUE)
     {
         errno = EBADF;
         return -1;
     }
 
     overlapped.Offset = offset;
     if (!ReadFile(handle, buf, size, &result, &overlapped))
     {
         _dosmaperr(GetLastError());
         return -1;
     }
 
     return result;
 #else
     if (lseek(fd, offset, SEEK_SET) < 0)
         return -1;
 
     return read(fd, buf, size);
 #endif
 }

◆ pg_printf()

int pg_printf	(	const char *	fmt,
			...
	)

◆ pg_pwrite()

ssize_t pg_pwrite	(	int	fd,
		const void *	buf,
		size_t	nbyte,
		off_t	offset
	)

Definition at line 27 of file pwrite.c.

References _dosmaperr(), and write.

Referenced by FileWrite(), XLogFileInit(), and XLogWrite().

 {
 #ifdef WIN32
     OVERLAPPED  overlapped = {0};
     HANDLE      handle;
     DWORD       result;
 
     handle = (HANDLE) _get_osfhandle(fd);
     if (handle == INVALID_HANDLE_VALUE)
     {
         errno = EBADF;
         return -1;
     }
 
     overlapped.Offset = offset;
     if (!WriteFile(handle, buf, size, &result, &overlapped))
     {
         _dosmaperr(GetLastError());
         return -1;
     }
 
     return result;
 #else
     if (lseek(fd, offset, SEEK_SET) < 0)
         return -1;
 
     return write(fd, buf, size);
 #endif
 }

◆ pg_qsort()

void pg_qsort	(	void *	base,
		size_t	nel,
		size_t	elsize,
		int()(const void , const void *)	cmp
	)

Definition at line 113 of file qsort.c.

References cmp(), med3(), Min, swap, SWAPINIT, and vecswap.

Referenced by apw_load_buffers(), build_distinct_groups(), DropRelFileNodesAllBuffers(), and InitCatalogCache().

 {
     char       *pa,
                *pb,
                *pc,
                *pd,
                *pl,
                *pm,
                *pn;
     size_t      d1,
                 d2;
     int         r,
                 swaptype,
                 presorted;
 
 loop:SWAPINIT(a, es);
     if (n < 7)
     {
         for (pm = (char *) a + es; pm < (char *) a + n * es; pm += es)
             for (pl = pm; pl > (char *) a && cmp(pl - es, pl) > 0;
                  pl -= es)
                 swap(pl, pl - es);
         return;
     }
     presorted = 1;
     for (pm = (char *) a + es; pm < (char *) a + n * es; pm += es)
     {
         if (cmp(pm - es, pm) > 0)
         {
             presorted = 0;
             break;
         }
     }
     if (presorted)
         return;
     pm = (char *) a + (n / 2) * es;
     if (n > 7)
     {
         pl = (char *) a;
         pn = (char *) a + (n - 1) * es;
         if (n > 40)
         {
             size_t      d = (n / 8) * es;
 
             pl = med3(pl, pl + d, pl + 2 * d, cmp);
             pm = med3(pm - d, pm, pm + d, cmp);
             pn = med3(pn - 2 * d, pn - d, pn, cmp);
         }
         pm = med3(pl, pm, pn, cmp);
     }
     swap(a, pm);
     pa = pb = (char *) a + es;
     pc = pd = (char *) a + (n - 1) * es;
     for (;;)
     {
         while (pb <= pc && (r = cmp(pb, a)) <= 0)
         {
             if (r == 0)
             {
                 swap(pa, pb);
                 pa += es;
             }
             pb += es;
         }
         while (pb <= pc && (r = cmp(pc, a)) >= 0)
         {
             if (r == 0)
             {
                 swap(pc, pd);
                 pd -= es;
             }
             pc -= es;
         }
         if (pb > pc)
             break;
         swap(pb, pc);
         pb += es;
         pc -= es;
     }
     pn = (char *) a + n * es;
     d1 = Min(pa - (char *) a, pb - pa);
     vecswap(a, pb - d1, d1);
     d1 = Min(pd - pc, pn - pd - es);
     vecswap(pb, pn - d1, d1);
     d1 = pb - pa;
     d2 = pd - pc;
     if (d1 <= d2)
     {
         /* Recurse on left partition, then iterate on right partition */
         if (d1 > es)
             pg_qsort(a, d1 / es, es, cmp);
         if (d2 > es)
         {
             /* Iterate rather than recurse to save stack space */
             /* pg_qsort(pn - d2, d2 / es, es, cmp); */
             a = pn - d2;
             n = d2 / es;
             goto loop;
         }
     }
     else
     {
         /* Recurse on right partition, then iterate on left partition */
         if (d2 > es)
             pg_qsort(pn - d2, d2 / es, es, cmp);
         if (d1 > es)
         {
             /* Iterate rather than recurse to save stack space */
             /* pg_qsort(a, d1 / es, es, cmp); */
             n = d1 / es;
             goto loop;
         }
     }
 }

◆ pg_qsort_strcmp()

int pg_qsort_strcmp	(	const void *	a,
		const void *	b
	)

Definition at line 232 of file qsort.c.

Referenced by BuildEventTriggerCache(), filter_event_trigger(), readstoplist(), and searchstoplist().

 {
     return strcmp(*(const char *const *) a, *(const char *const *) b);
 }

◆ pg_set_block()

bool pg_set_block ( pgsocket sock )

Definition at line 49 of file noblock.c.

 {
 #if !defined(WIN32)
     int         flags;
 
     flags = fcntl(sock, F_GETFL);
     if (flags < 0)
         return false;
     if (fcntl(sock, F_SETFL, (flags & ~O_NONBLOCK)) == -1)
         return false;
     return true;
 #else
     unsigned long ioctlsocket_ret = 0;
 
     /* Returns non-0 on failure, while fcntl() returns -1 on failure */
     return (ioctlsocket(sock, FIONBIO, &ioctlsocket_ret) == 0);
 #endif
 }

◆ pg_set_noblock()

bool pg_set_noblock ( pgsocket sock )

Definition at line 25 of file noblock.c.

Referenced by pgstat_init(), pq_init(), PQconnectPoll(), and report_fork_failure_to_client().

 {
 #if !defined(WIN32)
     int         flags;
 
     flags = fcntl(sock, F_GETFL);
     if (flags < 0)
         return false;
     if (fcntl(sock, F_SETFL, (flags | O_NONBLOCK)) == -1)
         return false;
     return true;
 #else
     unsigned long ioctlsocket_ret = 1;
 
     /* Returns non-0 on failure, while fcntl() returns -1 on failure */
     return (ioctlsocket(sock, FIONBIO, &ioctlsocket_ret) == 0);
 #endif
 }

◆ pg_snprintf()

int pg_snprintf	(	char *	str,
		size_t	count,
		const char *	fmt,
			...
	)

◆ pg_sprintf()

int pg_sprintf	(	char *	str,
		const char *	fmt,
			...
	)

◆ pg_srand48()

void pg_srand48 ( long seed )

Definition at line 131 of file erand48.c.

References _rand48_seed, and RAND48_SEED_0.

Referenced by srandom().

 {
     _rand48_seed[0] = RAND48_SEED_0;
     _rand48_seed[1] = (unsigned short) seed;
     _rand48_seed[2] = (unsigned short) (seed >> 16);
 }

◆ pg_strcasecmp()

int pg_strcasecmp	(	const char *	s1,
		const char *	s2
	)

Definition at line 36 of file pgstrcasecmp.c.

References IS_HIGHBIT_SET.

Referenced by array_out(), ATExecSetStorage(), build_startup_packet(), cache_locale_time(), check_datestyle(), check_ddl_tag(), check_ident_usermap(), check_log_destination(), check_table_rewrite_ddl_tag(), check_usermap(), check_wal_consistency_checking(), CheckSCRAMAuth(), comp_keyword_case_hook(), config_enum_lookup_by_name(), convert_any_priv_string(), convert_priv_string(), defGetBoolean(), defGetTypeLength(), DefineAggregate(), DefineCollation(), DefineType(), do_kill(), do_pset(), echo_hidden_hook(), echo_hook(), equivalent_locale(), evaluateSleep(), exec_command(), find_matching_ts_config(), get_progname(), getMetaCommand(), helpSQL(), histcontrol_hook(), hostname_match(), locate_stem_module(), lookup_prop_name(), main(), makeVariableValue(), on_error_rollback_hook(), parse_hstore(), parse_slash_copy(), parseArchiveFormat(), parseNameAndArgTypes(), ParseVariableBool(), pg_fe_sendauth(), pg_find_encoding(), pg_size_bytes(), pg_stat_get_progress_info(), pgp_get_cipher_code(), pgp_get_digest_code(), PGTYPEStimestamp_defmt_scan(), plperl_trigger_handler(), plpgsql_extra_checks_check_hook(), PLy_exec_trigger(), pq_verify_peer_name_matches_certificate_name(), pqPacketSend(), pqSetenvPoll(), process_backslash_command(), prsd_headline(), px_find_digest(), px_gen_salt(), px_resolve_alias(), ReadArrayStr(), SetMessageEncoding(), show_context_hook(), splitTzLine(), SyncRepGetStandbyPriority(), transformPartitionSpec(), validate_exec(), variable_is_guc_list_quote(), verbosity_hook(), wildcard_certificate_match(), and xmlpi().

 {
     for (;;)
     {
         unsigned char ch1 = (unsigned char) *s1++;
         unsigned char ch2 = (unsigned char) *s2++;
 
         if (ch1 != ch2)
         {
             if (ch1 >= 'A' && ch1 <= 'Z')
                 ch1 += 'a' - 'A';
             else if (IS_HIGHBIT_SET(ch1) && isupper(ch1))
                 ch1 = tolower(ch1);
 
             if (ch2 >= 'A' && ch2 <= 'Z')
                 ch2 += 'a' - 'A';
             else if (IS_HIGHBIT_SET(ch2) && isupper(ch2))
                 ch2 = tolower(ch2);
 
             if (ch1 != ch2)
                 return (int) ch1 - (int) ch2;
         }
         if (ch1 == 0)
             break;
     }
     return 0;
 }

◆ pg_strerror()

char* pg_strerror ( int errnum )

Definition at line 35 of file strerror.c.

References pg_strerror_r(), and PG_STRERROR_R_BUFLEN.

 {
     static char errorstr_buf[PG_STRERROR_R_BUFLEN];
 
     return pg_strerror_r(errnum, errorstr_buf, sizeof(errorstr_buf));
 }

◆ pg_strerror_r()

char* pg_strerror_r	(	int	errnum,
		char *	buf,
		size_t	buflen
	)

Definition at line 46 of file strerror.c.

References _, buf, get_errno_symbol(), gnuish_strerror_r(), snprintf, and generate_unaccent_rules::str.

Referenced by pg_strerror().

 {
     char       *str;
 
     /* If it's a Windows Winsock error, that needs special handling */
 #ifdef WIN32
     /* Winsock error code range, per WinError.h */
     if (errnum >= 10000 && errnum <= 11999)
         return win32_socket_strerror(errnum, buf, buflen);
 #endif
 
     /* Try the platform's strerror_r(), or maybe just strerror() */
     str = gnuish_strerror_r(errnum, buf, buflen);
 
     /*
      * Some strerror()s return an empty string for out-of-range errno.  This
      * is ANSI C spec compliant, but not exactly useful.  Also, we may get
      * back strings of question marks if libc cannot transcode the message to
      * the codeset specified by LC_CTYPE.  If we get nothing useful, first try
      * get_errno_symbol(), and if that fails, print the numeric errno.
      */
     if (str == NULL || *str == '\0' || *str == '?')
         str = get_errno_symbol(errnum);
 
     if (str == NULL)
     {
         snprintf(buf, buflen, _("operating system error %d"), errnum);
         str = buf;
     }
 
     return str;
 }

◆ pg_strfromd()

int pg_strfromd	(	char *	str,
		size_t	count,
		int	precision,
		double	value
	)

Definition at line 1265 of file snprintf.c.

References Assert, PrintfTarget::bufend, PrintfTarget::bufptr, PrintfTarget::bufstart, convert(), dopr_outch(), dostr(), PrintfTarget::failed, isinf(), PrintfTarget::nchars, sprintf, generate_unaccent_rules::str, PrintfTarget::stream, and value.

Referenced by float4out(), and float8out_internal().

 {
     PrintfTarget target;
     int         signvalue = 0;
     int         vallen;
     char        fmt[8];
     char        convert[64];
 
     /* Set up the target like pg_snprintf, but require nonempty buffer */
     Assert(count > 0);
     target.bufstart = target.bufptr = str;
     target.bufend = str + count - 1;
     target.stream = NULL;
     target.nchars = 0;
     target.failed = false;
 
     /*
      * We bound precision to a reasonable range; the combination of this and
      * the knowledge that we're using "g" format without padding allows the
      * convert[] buffer to be reasonably small.
      */
     if (precision < 1)
         precision = 1;
     else if (precision > 32)
         precision = 32;
 
     /*
      * The rest is just an inlined version of the fmtfloat() logic above,
      * simplified using the knowledge that no padding is wanted.
      */
     if (isnan(value))
     {
         strcpy(convert, "NaN");
         vallen = 3;
     }
     else
     {
         static const double dzero = 0.0;
 
         if (value < 0.0 ||
             (value == 0.0 &&
              memcmp(&value, &dzero, sizeof(double)) != 0))
         {
             signvalue = '-';
             value = -value;
         }
 
         if (isinf(value))
         {
             strcpy(convert, "Infinity");
             vallen = 8;
         }
         else
         {
             fmt[0] = '%';
             fmt[1] = '.';
             fmt[2] = '*';
             fmt[3] = 'g';
             fmt[4] = '\0';
             vallen = sprintf(convert, fmt, precision, value);
             if (vallen < 0)
             {
                 target.failed = true;
                 goto fail;
             }
 
 #ifdef WIN32
             if (vallen >= 6 &&
                 convert[vallen - 5] == 'e' &&
                 convert[vallen - 3] == '0')
             {
                 convert[vallen - 3] = convert[vallen - 2];
                 convert[vallen - 2] = convert[vallen - 1];
                 vallen--;
             }
 #endif
         }
     }
 
     if (signvalue)
         dopr_outch(signvalue, &target);
 
     dostr(convert, vallen, &target);
 
 fail:
     *(target.bufptr) = '\0';
     return target.failed ? -1 : (target.bufptr - target.bufstart
                                  + target.nchars);
 }

◆ pg_strncasecmp()

int pg_strncasecmp	(	const char *	s1,
		const char *	s2,
		size_t	n
	)

Definition at line 69 of file pgstrcasecmp.c.

References IS_HIGHBIT_SET.

Referenced by check_datestyle(), check_ddl_tag(), check_special_value(), check_timezone(), command_no_begin(), do_pset(), equivalent_locale(), float4in(), float8in_internal_opt_error(), helpSQL(), is_select_command(), MainLoop(), makeVariableValue(), map_sql_identifier_to_xml_name(), numeric_in(), parse_bool_with_len(), parse_jsonb_index_flags(), parse_or_operator(), ParseTzFile(), ParseVariableBool(), pqPacketSend(), range_parse(), scan_directory_ci(), set_unicode_line_style(), set_var_from_str(), and SpecialTags().

 {
     while (n-- > 0)
     {
         unsigned char ch1 = (unsigned char) *s1++;
         unsigned char ch2 = (unsigned char) *s2++;
 
         if (ch1 != ch2)
         {
             if (ch1 >= 'A' && ch1 <= 'Z')
                 ch1 += 'a' - 'A';
             else if (IS_HIGHBIT_SET(ch1) && isupper(ch1))
                 ch1 = tolower(ch1);
 
             if (ch2 >= 'A' && ch2 <= 'Z')
                 ch2 += 'a' - 'A';
             else if (IS_HIGHBIT_SET(ch2) && isupper(ch2))
                 ch2 = tolower(ch2);
 
             if (ch1 != ch2)
                 return (int) ch1 - (int) ch2;
         }
         if (ch1 == 0)
             break;
     }
     return 0;
 }

◆ pg_strong_random()

bool pg_strong_random	(	void *	buf,
		size_t	len
	)

Definition at line 100 of file pg_strong_random.c.

References i.

Referenced by BootStrapXLOG(), build_client_first_message(), build_server_first_message(), CheckMD5Auth(), drandom(), gen_random_uuid(), init_sess_key(), InitProcessGlobals(), mp_px_rand(), pad_eme_pkcs1_v15(), PerformRadiusTransaction(), pg_be_scram_build_verifier(), pg_fe_scram_build_verifier(), pg_random_bytes(), pgp_s2k_fill(), px_gen_salt(), RandomCancelKey(), set_random_seed(), and write_prefix().

 {
     /*
      * When built with OpenSSL, use OpenSSL's RAND_bytes function.
      */
 #if defined(USE_OPENSSL_RANDOM)
     int         i;
 
     /*
      * Check that OpenSSL's CSPRNG has been sufficiently seeded, and if not
      * add more seed data using RAND_poll().  With some older versions of
      * OpenSSL, it may be necessary to call RAND_poll() a number of times.
      */
 #define NUM_RAND_POLL_RETRIES 8
 
     for (i = 0; i < NUM_RAND_POLL_RETRIES; i++)
     {
         if (RAND_status() == 1)
         {
             /* The CSPRNG is sufficiently seeded */
             break;
         }
 
         if (RAND_poll() == 0)
         {
             /*
              * RAND_poll() failed to generate any seed data, which means that
              * RAND_bytes() will probably fail.  For now, just fall through
              * and let that happen.  XXX: maybe we could seed it some other
              * way.
              */
             break;
         }
     }
 
     if (RAND_bytes(buf, len) == 1)
         return true;
     return false;
 
     /*
      * Windows has CryptoAPI for strong cryptographic numbers.
      */
 #elif defined(USE_WIN32_RANDOM)
     if (hProvider == 0)
     {
         if (!CryptAcquireContext(&hProvider,
                                  NULL,
                                  MS_DEF_PROV,
                                  PROV_RSA_FULL,
                                  CRYPT_VERIFYCONTEXT | CRYPT_SILENT))
         {
             /*
              * On failure, set back to 0 in case the value was for some reason
              * modified.
              */
             hProvider = 0;
         }
     }
     /* Re-check in case we just retrieved the provider */
     if (hProvider != 0)
     {
         if (CryptGenRandom(hProvider, len, buf))
             return true;
     }
     return false;
 
     /*
      * Read /dev/urandom ourselves.
      */
 #elif defined(USE_DEV_URANDOM)
     if (random_from_file("/dev/urandom", buf, len))
         return true;
     return false;
 
 #else
     /* The autoconf script should not have allowed this */
 #error no source of random numbers configured
 #endif
 }

◆ pg_strsignal()

const char* pg_strsignal ( int signum )

Definition at line 37 of file pgstrsignal.c.

Referenced by log_child_failure(), LogChildExit(), pgarch_archiveXlog(), and wait_result_to_str().

 {
     const char *result;
 
     /*
      * If we have strsignal(3), use that --- but check its result for NULL.
      */
 #ifdef HAVE_STRSIGNAL
     result = strsignal(signum);
     if (result)
         return result;
 #else
 
     /*
      * We used to have code here to try to use sys_siglist[] if available.
      * However, it seems that all platforms with sys_siglist[] have also had
      * strsignal() for many years now, so that was just a waste of code.
      */
 #endif
 
     /*
      * Fallback case: just return "unrecognized signal".  Project style is for
      * callers to print the numeric signal value along with the result of this
      * function, so there's no need to work harder than this.
      */
     result = "unrecognized signal";
     return result;
 }

◆ pg_tolower()

unsigned char pg_tolower ( unsigned char ch )

Definition at line 122 of file pgstrcasecmp.c.

References IS_HIGHBIT_SET.

Referenced by dir_strcmp(), ParseDateTime(), PGTYPESdate_defmt_asc(), PQfnumber(), processSQLNamePattern(), SB_lower_char(), seq_search(), str_initcap(), str_tolower(), and validateTzEntry().

 {
     if (ch >= 'A' && ch <= 'Z')
         ch += 'a' - 'A';
     else if (IS_HIGHBIT_SET(ch) && isupper(ch))
         ch = tolower(ch);
     return ch;
 }

◆ pg_toupper()

unsigned char pg_toupper ( unsigned char ch )

Definition at line 105 of file pgstrcasecmp.c.

References IS_HIGHBIT_SET.

Referenced by cash_words(), DetermineTimeZoneAbbrevOffsetInternal(), pg_timezone_abbrevs(), pg_tzset(), seq_search(), str_initcap(), and str_toupper().

 {
     if (ch >= 'a' && ch <= 'z')
         ch += 'A' - 'a';
     else if (IS_HIGHBIT_SET(ch) && islower(ch))
         ch = toupper(ch);
     return ch;
 }

◆ pg_usleep()

void pg_usleep ( long microsec )

Definition at line 53 of file signal.c.

References Assert, EINTR, FALSE, pgwin32_dispatch_queued_signals(), pgwin32_signal_event, and select.

Referenced by auth_delay_checks(), AutoVacLauncherMain(), AutoVacWorkerMain(), backend_read_statsfile(), BackendInitialize(), BackgroundWriterMain(), CheckpointerMain(), CheckpointWriteDelay(), ConditionalXactLockTableWait(), CountOtherDBBackends(), CreateCheckPoint(), CustomizableNextWALFileReady(), do_pg_stop_backup(), do_promote(), do_restart(), do_stop(), do_watch(), exec_prog(), FileRead(), FileWrite(), GetMultiXactIdMembers(), InitPostgres(), lazy_truncate_heap(), main(), perform_spin_delay(), pgarch_ArchiverCopyLoop(), pgwin32_recv(), read_local_xlog_page(), recoveryPausesHere(), RegisterSyncRequest(), regression_main(), RequestCheckpoint(), ResolveRecoveryConflictWithDatabase(), ResolveRecoveryConflictWithVirtualXIDs(), RestoreWALFileForRecovery(), ServerLoop(), ShutdownWalRcv(), StartBackgroundWorker(), StartupXLOG(), StreamConnection(), threadRun(), vacuum_delay_point(), wait_for_postmaster(), wait_pid(), WaitExceedsMaxStandbyDelay(), WalSndWaitStopping(), WalWriterMain(), XactLockTableWait(), XLogDumpXLogRead(), and XLogFlush().

 {
     Assert(pgwin32_signal_event != NULL);
     if (WaitForSingleObject(pgwin32_signal_event,
                             (microsec < 500 ? 1 : (microsec + 500) / 1000))
         == WAIT_OBJECT_0)
     {
         pgwin32_dispatch_queued_signals();
         errno = EINTR;
         return;
     }
 }

◆ pg_vfprintf()

int int pg_vfprintf	(	FILE *	stream,
		const char *	fmt,
		va_list	args
	)

Definition at line 242 of file snprintf.c.

References PrintfTarget::bufend, PrintfTarget::bufptr, PrintfTarget::bufstart, dopr(), PrintfTarget::failed, flushbuffer(), PrintfTarget::nchars, and PrintfTarget::stream.

Referenced by pg_fprintf(), pg_printf(), and pg_vprintf().

 {
     PrintfTarget target;
     char        buffer[1024];   /* size is arbitrary */
 
     if (stream == NULL)
     {
         errno = EINVAL;
         return -1;
     }
     target.bufstart = target.bufptr = buffer;
     target.bufend = buffer + sizeof(buffer);    /* use the whole buffer */
     target.stream = stream;
     target.nchars = 0;
     target.failed = false;
     dopr(&target, fmt, args);
     /* dump any remaining buffer contents */
     flushbuffer(&target);
     return target.failed ? -1 : target.nchars;
 }

◆ pg_vprintf()

int int pg_vprintf	(	const char *	fmt,
		va_list	args
	)

Definition at line 276 of file snprintf.c.

References pg_vfprintf(), and generate_unaccent_rules::stdout.

 {
     return pg_vfprintf(stdout, fmt, args);
 }

◆ pg_vsnprintf()

int pg_vsnprintf	(	char *	str,
		size_t	count,
		const char *	fmt,
		va_list	args
	)

Definition at line 174 of file snprintf.c.

References PrintfTarget::bufend, PrintfTarget::bufptr, PrintfTarget::bufstart, dopr(), PrintfTarget::failed, PrintfTarget::nchars, generate_unaccent_rules::str, and PrintfTarget::stream.

Referenced by pg_snprintf().

 {
     PrintfTarget target;
     char        onebyte[1];
 
     /*
      * C99 allows the case str == NULL when count == 0.  Rather than
      * special-casing this situation further down, we substitute a one-byte
      * local buffer.  Callers cannot tell, since the function result doesn't
      * depend on count.
      */
     if (count == 0)
     {
         str = onebyte;
         count = 1;
     }
     target.bufstart = target.bufptr = str;
     target.bufend = str + count - 1;
     target.stream = NULL;
     target.nchars = 0;
     target.failed = false;
     dopr(&target, fmt, args);
     *(target.bufptr) = '\0';
     return target.failed ? -1 : (target.bufptr - target.bufstart
                                  + target.nchars);
 }

◆ pg_vsprintf()

int int pg_vsprintf	(	char *	str,
		const char *	fmt,
		va_list	args
	)

Definition at line 214 of file snprintf.c.

References PrintfTarget::bufend, PrintfTarget::bufptr, PrintfTarget::bufstart, dopr(), PrintfTarget::failed, PrintfTarget::nchars, generate_unaccent_rules::str, and PrintfTarget::stream.

Referenced by pg_sprintf().

 {
     PrintfTarget target;
 
     target.bufstart = target.bufptr = str;
     target.bufend = NULL;
     target.stream = NULL;
     target.nchars = 0;          /* not really used in this case */
     target.failed = false;
     dopr(&target, fmt, args);
     *(target.bufptr) = '\0';
     return target.failed ? -1 : (target.bufptr - target.bufstart
                                  + target.nchars);
 }

◆ pgfnames()

char** pgfnames ( const char * path )

Definition at line 37 of file pgfnames.c.

References closedir(), dirent::d_name, opendir(), palloc(), pg_log_warning, pstrdup(), readdir(), and repalloc().

Referenced by convert_sourcefiles_in(), rmtree(), and scan_available_timezones().

 {
     DIR        *dir;
     struct dirent *file;
     char      **filenames;
     int         numnames = 0;
     int         fnsize = 200;   /* enough for many small dbs */
 
     dir = opendir(path);
     if (dir == NULL)
     {
         pg_log_warning("could not open directory \"%s\": %m", path);
         return NULL;
     }
 
     filenames = (char **) palloc(fnsize * sizeof(char *));
 
     while (errno = 0, (file = readdir(dir)) != NULL)
     {
         if (strcmp(file->d_name, ".") != 0 && strcmp(file->d_name, "..") != 0)
         {
             if (numnames + 1 >= fnsize)
             {
                 fnsize *= 2;
                 filenames = (char **) repalloc(filenames,
                                                fnsize * sizeof(char *));
             }
             filenames[numnames++] = pstrdup(file->d_name);
         }
     }
 
     if (errno)
         pg_log_warning("could not read directory \"%s\": %m", path);
 
     filenames[numnames] = NULL;
 
     if (closedir(dir))
         pg_log_warning("could not close directory \"%s\": %m", path);
 
     return filenames;
 }

◆ pgfnames_cleanup()

void pgfnames_cleanup ( char ** filenames )

Definition at line 86 of file pgfnames.c.

References fn(), and pfree().

Referenced by convert_sourcefiles_in(), rmtree(), and scan_available_timezones().

 {
     char      **fn;
 
     for (fn = filenames; *fn; fn++)
         pfree(*fn);
 
     pfree(filenames);
 }

◆ pqGethostbyname()

int pqGethostbyname	(	const char *	name,
		struct hostent *	resultbuf,
		char *	buffer,
		size_t	buflen,
		struct hostent **	result,
		int *	herrno
	)

Definition at line 90 of file thread.c.

Referenced by getaddrinfo().

 {
 #if defined(FRONTEND) && defined(ENABLE_THREAD_SAFETY) && defined(HAVE_GETHOSTBYNAME_R)
 
     /*
      * broken (well early POSIX draft) gethostbyname_r() which returns 'struct
      * hostent *'
      */
     *result = gethostbyname_r(name, resultbuf, buffer, buflen, herrno);
     return (*result == NULL) ? -1 : 0;
 #else
 
     /* no gethostbyname_r(), just use gethostbyname() */
     *result = gethostbyname(name);
 
     if (*result != NULL)
         *herrno = h_errno;
 
     if (*result != NULL)
         return 0;
     else
         return -1;
 #endif
 }

◆ pqGetpwuid()

int pqGetpwuid	(	uid_t	uid,
		struct passwd *	resultbuf,
		char *	buffer,
		size_t	buflen,
		struct passwd **	result
	)

Definition at line 68 of file thread.c.

Referenced by get_home_path(), pg_fe_getauthname(), PQconnectPoll(), and pqGetHomeDirectory().

 {
 #if defined(FRONTEND) && defined(ENABLE_THREAD_SAFETY) && defined(HAVE_GETPWUID_R)
     return getpwuid_r(uid, resultbuf, buffer, buflen, result);
 #else
     /* no getpwuid_r() available, just use getpwuid() */
     errno = 0;
     *result = getpwuid(uid);
     /* paranoia: ensure we return zero on success */
     return (*result == NULL) ? errno : 0;
 #endif
 }

◆ pqsignal()

pqsigfunc pqsignal	(	int	signo,
		pqsigfunc	func
	)

Definition at line 170 of file signal.c.

References pg_signal_array, PG_SIGNAL_COUNT, SIG_ERR, and SIGCHLD.

Referenced by ApplyLauncherMain(), ApplyWorkerMain(), autoprewarm_database_main(), autoprewarm_main(), AutoVacLauncherMain(), AutoVacWorkerMain(), BackendInitialize(), BackgroundWriterMain(), bootstrap_signals(), CheckpointerMain(), disable_sigpipe_trap(), do_start(), initialize_worker_spi(), InitializeTimeouts(), main(), OpenPipeStream(), ParallelBackupStart(), ParallelWorkerMain(), pg_crc32c_armv8_available(), PgArchiverMain(), PgstatCollectorMain(), plperl_init_interp(), PostgresMain(), PostmasterDeathSignalInit(), PostmasterMain(), PQprint(), restore_sigpipe_trap(), setalarm(), setup_cancel_handler(), setup_signals(), sigquit_handler(), sigTermHandler(), StartBackgroundWorker(), StartupProcessMain(), stop_postmaster(), SysLoggerMain(), test_shm_mq_main(), trap_sigint_during_startup(), trapsig(), WalReceiverMain(), WalSndSignals(), and WalWriterMain().

 {
     pqsigfunc   prevfunc;
 
     if (signum >= PG_SIGNAL_COUNT || signum < 0)
         return SIG_ERR;
     prevfunc = pg_signal_array[signum];
     pg_signal_array[signum] = handler;
     return prevfunc;
 }

◆ pqsignal_no_restart()

pqsigfunc pqsignal_no_restart	(	int	signo,
		pqsigfunc	func
	)

Definition at line 71 of file pqsignal.c.

References SIG_ERR, and SIGCHLD.

Referenced by PostmasterMain().

 {
     struct sigaction act,
                 oact;
 
     act.sa_handler = func;
     sigemptyset(&act.sa_mask);
     act.sa_flags = 0;
 #ifdef SA_NOCLDSTOP
     if (signo == SIGCHLD)
         act.sa_flags |= SA_NOCLDSTOP;
 #endif
     if (sigaction(signo, &act, &oact) < 0)
         return SIG_ERR;
     return oact.sa_handler;
 }

◆ qsort_arg()

void qsort_arg	(	void *	base,
		size_t	nel,
		size_t	elsize,
		qsort_arg_comparator	cmp,
		void *	arg
	)

Definition at line 113 of file qsort_arg.c.

References cmp(), med3(), Min, swap, SWAPINIT, and vecswap.

Referenced by _bt_sort_array_elements(), build_column_frequencies(), build_sorted_items(), compute_range_stats(), compute_scalar_stats(), create_list_bounds(), create_range_bounds(), gbt_num_picksplit(), gbt_var_picksplit(), ginExtractEntries(), isort(), mcelem_array_selec(), ndistinct_for_combination(), range_gist_double_sorting_split(), range_gist_single_sorting_split(), SortAndUniqItems(), spg_range_quad_picksplit(), startScanKey(), statext_mcv_serialize(), tbm_prepare_shared_iterate(), tsvectorrecv(), uniqueentry(), and uniqueifyJsonbObject().

 {
     char       *pa,
                *pb,
                *pc,
                *pd,
                *pl,
                *pm,
                *pn;
     size_t      d1,
                 d2;
     int         r,
                 swaptype,
                 presorted;
 
 loop:SWAPINIT(a, es);
     if (n < 7)
     {
         for (pm = (char *) a + es; pm < (char *) a + n * es; pm += es)
             for (pl = pm; pl > (char *) a && cmp(pl - es, pl, arg) > 0;
                  pl -= es)
                 swap(pl, pl - es);
         return;
     }
     presorted = 1;
     for (pm = (char *) a + es; pm < (char *) a + n * es; pm += es)
     {
         if (cmp(pm - es, pm, arg) > 0)
         {
             presorted = 0;
             break;
         }
     }
     if (presorted)
         return;
     pm = (char *) a + (n / 2) * es;
     if (n > 7)
     {
         pl = (char *) a;
         pn = (char *) a + (n - 1) * es;
         if (n > 40)
         {
             size_t      d = (n / 8) * es;
 
             pl = med3(pl, pl + d, pl + 2 * d, cmp, arg);
             pm = med3(pm - d, pm, pm + d, cmp, arg);
             pn = med3(pn - 2 * d, pn - d, pn, cmp, arg);
         }
         pm = med3(pl, pm, pn, cmp, arg);
     }
     swap(a, pm);
     pa = pb = (char *) a + es;
     pc = pd = (char *) a + (n - 1) * es;
     for (;;)
     {
         while (pb <= pc && (r = cmp(pb, a, arg)) <= 0)
         {
             if (r == 0)
             {
                 swap(pa, pb);
                 pa += es;
             }
             pb += es;
         }
         while (pb <= pc && (r = cmp(pc, a, arg)) >= 0)
         {
             if (r == 0)
             {
                 swap(pc, pd);
                 pd -= es;
             }
             pc -= es;
         }
         if (pb > pc)
             break;
         swap(pb, pc);
         pb += es;
         pc -= es;
     }
     pn = (char *) a + n * es;
     d1 = Min(pa - (char *) a, pb - pa);
     vecswap(a, pb - d1, d1);
     d1 = Min(pd - pc, pn - pd - es);
     vecswap(pb, pn - d1, d1);
     d1 = pb - pa;
     d2 = pd - pc;
     if (d1 <= d2)
     {
         /* Recurse on left partition, then iterate on right partition */
         if (d1 > es)
             qsort_arg(a, d1 / es, es, cmp, arg);
         if (d2 > es)
         {
             /* Iterate rather than recurse to save stack space */
             /* qsort_arg(pn - d2, d2 / es, es, cmp, arg); */
             a = pn - d2;
             n = d2 / es;
             goto loop;
         }
     }
     else
     {
         /* Recurse on right partition, then iterate on left partition */
         if (d2 > es)
             qsort_arg(pn - d2, d2 / es, es, cmp, arg);
         if (d1 > es)
         {
             /* Iterate rather than recurse to save stack space */
             /* qsort_arg(a, d1 / es, es, cmp, arg); */
             n = d1 / es;
             goto loop;
         }
     }
 }

◆ random()

long random ( void )

Definition at line 22 of file random.c.

References pg_lrand48().

Referenced by _bt_findinsertloc(), acquire_sample_rows(), anl_init_selection_state(), anl_random_fract(), bt_check_every_level(), check_log_duration(), choose_dsm_implementation(), create_and_test_bloom(), dsm_create(), dsm_postmaster_startup(), ExecInitSampleScan(), explain_ExecutorStart(), get_normal_pair(), get_random_uint64(), GetPermutation(), gistchoose(), perform_spin_delay(), prepare_buf(), reservoir_init_selection_state(), SetTempTablespaces(), spgdoinsert(), StartTransaction(), and testdelete().

 {
     return pg_lrand48();
 }

◆ rint()

double rint ( double x )

Definition at line 21 of file rint.c.

Referenced by acquire_inherited_sample_rows(), AdjustFractSeconds(), bernoulli_beginsamplescan(), btcostestimate(), calculatePagesPerBuffer(), cash_div_flt4(), cash_div_flt8(), cash_mul_flt4(), cash_mul_flt8(), check_effective_io_concurrency(), clamp_row_est(), convert_int_from_base_unit(), convert_real_from_base_unit(), convert_to_base_unit(), create_modifytable_path(), DecodeInterval(), DecodeNumberField(), dround(), dtoi2(), dtoi4(), dtoi8(), estimate_rel_size(), ExecInitBitmapHeapScan(), final_cost_hashjoin(), final_cost_nestloop(), float4_to_char(), float8_timestamptz(), float8_to_char(), flt4_mul_cash(), flt8_mul_cash(), ftoi2(), ftoi4(), ftoi8(), genericcostestimate(), gincostestimate(), initial_cost_mergejoin(), interval_div(), interval_mul(), make_interval(), make_time(), make_timestamp_internal(), optimal_k(), parse_int(), ParseFractionalSecond(), set_append_rel_size(), system_beginsamplescan(), and table_block_relation_estimate_size().

 {
     double      x_orig;
     double      r;
 
     /* Per POSIX, NaNs must be returned unchanged. */
     if (isnan(x))
         return x;
 
     if (x <= 0.0)
     {
         /* Both positive and negative zero should be returned unchanged. */
         if (x == 0.0)
             return x;
 
         /*
          * Subtracting 0.5 from a number very close to -0.5 can round to
          * exactly -1.0, producing incorrect results, so we take the opposite
          * approach: add 0.5 to the negative number, so that it goes closer to
          * zero (or at most to +0.5, which is dealt with next), avoiding the
          * precision issue.
          */
         x_orig = x;
         x += 0.5;
 
         /*
          * Be careful to return minus zero when input+0.5 >= 0, as that's what
          * rint() should return with negative input.
          */
         if (x >= 0.0)
             return -0.0;
 
         /*
          * For very big numbers the input may have no decimals.  That case is
          * detected by testing x+0.5 == x+1.0; if that happens, the input is
          * returned unchanged.  This also covers the case of minus infinity.
          */
         if (x == x_orig + 1.0)
             return x_orig;
 
         /* Otherwise produce a rounded estimate. */
         r = floor(x);
 
         /*
          * If the rounding did not produce exactly input+0.5 then we're done.
          */
         if (r != x)
             return r;
 
         /*
          * The original fractional part was exactly 0.5 (since
          * floor(input+0.5) == input+0.5).  We need to round to nearest even.
          * Dividing input+0.5 by 2, taking the floor and multiplying by 2
          * yields the closest even number.  This part assumes that division by
          * 2 is exact, which should be OK because underflow is impossible
          * here: x is an integer.
          */
         return floor(x * 0.5) * 2.0;
     }
     else
     {
         /*
          * The positive case is similar but with signs inverted and using
          * ceil() instead of floor().
          */
         x_orig = x;
         x -= 0.5;
         if (x <= 0.0)
             return 0.0;
         if (x == x_orig - 1.0)
             return x_orig;
         r = ceil(x);
         if (r != x)
             return r;
         return ceil(x * 0.5) * 2.0;
     }
 }

◆ rmtree()

bool rmtree	(	const char *	path,
		bool	rmtopdir
	)

Definition at line 42 of file rmtree.c.

References filename, lstat, MAXPGPATH, pg_log_warning, pgfnames(), pgfnames_cleanup(), rmtree(), S_ISDIR, snprintf, and stat.

Referenced by cleanup_directories_atexit(), convert_sourcefiles_in(), create_tablespace_directories(), CreateSlotOnDisk(), dbase_redo(), movedb(), movedb_failure_callback(), regression_main(), remove_dbtablespaces(), remove_new_subdir(), ReplicationSlotDropPtr(), RestoreSlotFromDisk(), rmtree(), and StartupReplicationSlots().

 {
     bool        result = true;
     char        pathbuf[MAXPGPATH];
     char      **filenames;
     char      **filename;
     struct stat statbuf;
 
     /*
      * we copy all the names out of the directory before we start modifying
      * it.
      */
     filenames = pgfnames(path);
 
     if (filenames == NULL)
         return false;
 
     /* now we have the names we can start removing things */
     for (filename = filenames; *filename; filename++)
     {
         snprintf(pathbuf, MAXPGPATH, "%s/%s", path, *filename);
 
         /*
          * It's ok if the file is not there anymore; we were just about to
          * delete it anyway.
          *
          * This is not an academic possibility. One scenario where this
          * happens is when bgwriter has a pending unlink request for a file in
          * a database that's being dropped. In dropdb(), we call
          * ForgetDatabaseSyncRequests() to flush out any such pending unlink
          * requests, but because that's asynchronous, it's not guaranteed that
          * the bgwriter receives the message in time.
          */
         if (lstat(pathbuf, &statbuf) != 0)
         {
             if (errno != ENOENT)
             {
                 pg_log_warning("could not stat file or directory \"%s\": %m",
                                pathbuf);
                 result = false;
             }
             continue;
         }
 
         if (S_ISDIR(statbuf.st_mode))
         {
             /* call ourselves recursively for a directory */
             if (!rmtree(pathbuf, true))
             {
                 /* we already reported the error */
                 result = false;
             }
         }
         else
         {
             if (unlink(pathbuf) != 0)
             {
                 if (errno != ENOENT)
                 {
                     pg_log_warning("could not remove file or directory \"%s\": %m",
                                    pathbuf);
                     result = false;
                 }
             }
         }
     }
 
     if (rmtopdir)
     {
         if (rmdir(path) != 0)
         {
             pg_log_warning("could not remove file or directory \"%s\": %m",
                            path);
             result = false;
         }
     }
 
     pgfnames_cleanup(filenames);
 
     return result;
 }

◆ set_pglocale_pgservice()

void set_pglocale_pgservice	(	const char *	argv0,
		const char *	app
	)

Definition at line 565 of file exec.c.

References _, AddUserToTokenDacl(), canonicalize_path(), cleanup(), errcode(), FALSE, find_my_exec(), get_etc_path(), get_locale_path(), i, log_error, MAXPGPATH, my_exec_path, PG_TEXTDOMAIN, putenv, setlocale, snprintf, and TRUE.

Referenced by main(), and regression_main().

 {
     char        path[MAXPGPATH];
     char        my_exec_path[MAXPGPATH];
     char        env_path[MAXPGPATH + sizeof("PGSYSCONFDIR=")];  /* longer than
                                                                  * PGLOCALEDIR */
     char       *dup_path;
 
     /* don't set LC_ALL in the backend */
     if (strcmp(app, PG_TEXTDOMAIN("postgres")) != 0)
     {
         setlocale(LC_ALL, "");
 
         /*
          * One could make a case for reproducing here PostmasterMain()'s test
          * for whether the process is multithreaded.  Unlike the postmaster,
          * no frontend program calls sigprocmask() or otherwise provides for
          * mutual exclusion between signal handlers.  While frontends using
          * fork(), if multithreaded, are formally exposed to undefined
          * behavior, we have not witnessed a concrete bug.  Therefore,
          * complaining about multithreading here may be mere pedantry.
          */
     }
 
     if (find_my_exec(argv0, my_exec_path) < 0)
         return;
 
 #ifdef ENABLE_NLS
     get_locale_path(my_exec_path, path);
     bindtextdomain(app, path);
     textdomain(app);
 
     if (getenv("PGLOCALEDIR") == NULL)
     {
         /* set for libpq to use */
         snprintf(env_path, sizeof(env_path), "PGLOCALEDIR=%s", path);
         canonicalize_path(env_path + 12);
         dup_path = strdup(env_path);
         if (dup_path)
             putenv(dup_path);
     }
 #endif
 
     if (getenv("PGSYSCONFDIR") == NULL)
     {
         get_etc_path(my_exec_path, path);
 
         /* set for libpq to use */
         snprintf(env_path, sizeof(env_path), "PGSYSCONFDIR=%s", path);
         canonicalize_path(env_path + 13);
         dup_path = strdup(env_path);
         if (dup_path)
             putenv(dup_path);
     }
 }

◆ simple_prompt()

void simple_prompt	(	const char *	prompt,
		char *	destination,
		size_t	destlen,
		bool	echo
	)

Definition at line 37 of file sprompt.c.

References _, and buf.

Referenced by _connectDB(), connectDatabase(), ConnectDatabase(), doConnect(), exec_command_password(), exec_command_prompt(), get_su_pwd(), GetConnection(), main(), prompt_for_password(), sql_conn(), vacuumlo(), and yesno_prompt().

 {
     int         length;
     FILE       *termin,
                *termout;
 
 #if defined(HAVE_TERMIOS_H)
     struct termios t_orig,
                 t;
 #elif defined(WIN32)
     HANDLE      t = NULL;
     DWORD       t_orig = 0;
 #endif
 
 #ifdef WIN32
 
     /*
      * A Windows console has an "input code page" and an "output code page";
      * these usually match each other, but they rarely match the "Windows ANSI
      * code page" defined at system boot and expected of "char *" arguments to
      * Windows API functions.  The Microsoft CRT write() implementation
      * automatically converts text between these code pages when writing to a
      * console.  To identify such file descriptors, it calls GetConsoleMode()
      * on the underlying HANDLE, which in turn requires GENERIC_READ access on
      * the HANDLE.  Opening termout in mode "w+" allows that detection to
      * succeed.  Otherwise, write() would not recognize the descriptor as a
      * console, and non-ASCII characters would display incorrectly.
      *
      * XXX fgets() still receives text in the console's input code page.  This
      * makes non-ASCII credentials unportable.
      *
      * Unintuitively, we also open termin in mode "w+", even though we only
      * read it; that's needed for SetConsoleMode() to succeed.
      */
     termin = fopen("CONIN$", "w+");
     termout = fopen("CONOUT$", "w+");
 #else
 
     /*
      * Do not try to collapse these into one "w+" mode file. Doesn't work on
      * some platforms (eg, HPUX 10.20).
      */
     termin = fopen("/dev/tty", "r");
     termout = fopen("/dev/tty", "w");
 #endif
     if (!termin || !termout
 #ifdef WIN32
 
     /*
      * Direct console I/O does not work from the MSYS 1.0.10 console.  Writes
      * reach nowhere user-visible; reads block indefinitely.  XXX This affects
      * most Windows terminal environments, including rxvt, mintty, Cygwin
      * xterm, Cygwin sshd, and PowerShell ISE.  Switch to a more-generic test.
      */
         || (getenv("OSTYPE") && strcmp(getenv("OSTYPE"), "msys") == 0)
 #endif
         )
     {
         if (termin)
             fclose(termin);
         if (termout)
             fclose(termout);
         termin = stdin;
         termout = stderr;
     }
 
     if (!echo)
     {
 #if defined(HAVE_TERMIOS_H)
         /* disable echo via tcgetattr/tcsetattr */
         tcgetattr(fileno(termin), &t);
         t_orig = t;
         t.c_lflag &= ~ECHO;
         tcsetattr(fileno(termin), TCSAFLUSH, &t);
 #elif defined(WIN32)
         /* need the file's HANDLE to turn echo off */
         t = (HANDLE) _get_osfhandle(_fileno(termin));
 
         /* save the old configuration first */
         GetConsoleMode(t, &t_orig);
 
         /* set to the new mode */
         SetConsoleMode(t, ENABLE_LINE_INPUT | ENABLE_PROCESSED_INPUT);
 #endif
     }
 
     if (prompt)
     {
         fputs(_(prompt), termout);
         fflush(termout);
     }
 
     if (fgets(destination, destlen, termin) == NULL)
         destination[0] = '\0';
 
     length = strlen(destination);
     if (length > 0 && destination[length - 1] != '\n')
     {
         /* eat rest of the line */
         char        buf[128];
         int         buflen;
 
         do
         {
             if (fgets(buf, sizeof(buf), termin) == NULL)
                 break;
             buflen = strlen(buf);
         } while (buflen > 0 && buf[buflen - 1] != '\n');
     }
 
     if (length > 0 && destination[length - 1] == '\n')
         /* remove trailing newline */
         destination[length - 1] = '\0';
 
     if (!echo)
     {
         /* restore previous echo behavior, then echo \n */
 #if defined(HAVE_TERMIOS_H)
         tcsetattr(fileno(termin), TCSAFLUSH, &t_orig);
         fputs("\n", termout);
         fflush(termout);
 #elif defined(WIN32)
         SetConsoleMode(t, t_orig);
         fputs("\n", termout);
         fflush(termout);
 #endif
     }
 
     if (termin != stdin)
     {
         fclose(termin);
         fclose(termout);
     }
 }

◆ srandom()

void srandom ( unsigned int seed )

Definition at line 22 of file srandom.c.

References pg_srand48().

Referenced by choose_dsm_implementation(), InitProcessGlobals(), and update_spins_per_delay().

 {
     pg_srand48((long int) seed);
 }

◆ strlcat()

size_t strlcat	(	char *	dst,
		const char *	src,
		size_t	siz
	)

Definition at line 33 of file strlcat.c.

Referenced by _PrepParallelRestore(), CreateLockFile(), get_configdata(), get_prompt(), and validate_exec().

 {
     char       *d = dst;
     const char *s = src;
     size_t      n = siz;
     size_t      dlen;
 
     /* Find the end of dst and adjust bytes left but don't go past end */
     while (n-- != 0 && *d != '\0')
         d++;
     dlen = d - dst;
     n = siz - dlen;
 
     if (n == 0)
         return (dlen + strlen(s));
     while (*s != '\0')
     {
         if (n != 1)
         {
             *d++ = *s;
             n--;
         }
         s++;
     }
     *d = '\0';
 
     return (dlen + (s - src));  /* count does not include NUL */
 }

◆ strlcpy()

size_t strlcpy	(	char *	dst,
		const char *	src,
		size_t	siz
	)

Definition at line 45 of file strlcpy.c.

Referenced by _tarGetHeader(), AuxiliaryProcessMain(), BaseBackup(), be_tls_get_peer_issuer_name(), be_tls_get_peer_serial(), be_tls_get_peer_subject_name(), ChooseExtendedStatisticNameAddition(), ChooseForeignKeyConstraintNameAddition(), ChooseIndexNameAddition(), CleanupPriorWALFiles(), ConvertTimeZoneAbbrevs(), create_script_for_old_cluster_deletion(), createNewConnection(), descriptor_variable(), DetermineTimeZoneAbbrevOffsetInternal(), expand_tilde(), fetch_fp_info(), find_in_dynamic_libpath(), find_other_exec_or_die(), from_char_parse_int_len(), from_char_seq_search(), fsync_parent_path(), get_configdata(), get_control_data(), get_home_path(), get_prompt(), get_tablespace_mapping(), gnuish_strerror_r(), hash_create(), ident_inet(), identify_system_timezone(), initCreatePKeys(), initialize_SSL(), InitPostgres(), internal_cancel(), isolation_init(), join_path_components(), KeepFileRestoredFromArchive(), logfile_getname(), main(), make_oper_cache_key(), make_relative_path(), mdsyncfiletag(), mdunlinkfiletag(), ParseAbortRecord(), parseCommandLine(), ParseCommitRecord(), ParseLongOption(), parseServiceInfo(), pg_getnameinfo_all(), pg_GSS_error_int(), pg_open_tzfile(), pg_perm_setlocale(), pg_stat_get_wal_receiver(), pg_timezone_abbrevs(), pg_TZDIR(), pg_tzenumerate_next(), pgarch_archiveXlog(), pgstat_bestart(), PostmasterMarkPIDForWorkerNotify(), postprocess_sql_command(), PQcancel(), pqGetErrorNotice3(), pqGetHomeDirectory(), pqParseInput2(), pqParseInput3(), PQrequestCancel(), process_file(), process_postgres_switches(), ReceiveAndUnpackTarFile(), recoveryStopsAfter(), replace_string(), RequestXLogStreaming(), resolve_symlinks(), results_differ(), scan_available_timezones(), scan_directory(), scan_directory_ci(), SerializeLibraryState(), set_ps_display(), setup_bin_paths(), SetWALFileNameForCleanup(), SimpleLruInit(), SSLerrmessage(), tar_close(), tarCreateHeader(), timestamptz_to_str(), uuid_generate_internal(), validate_exec(), WalReceiverMain(), and XLogRestorePoint().

 {
     char       *d = dst;
     const char *s = src;
     size_t      n = siz;
 
     /* Copy as many bytes as will fit */
     if (n != 0)
     {
         while (--n != 0)
         {
             if ((*d++ = *s++) == '\0')
                 break;
         }
     }
 
     /* Not enough room in dst, add NUL and traverse rest of src */
     if (n == 0)
     {
         if (siz != 0)
             *d = '\0';          /* NUL-terminate dst */
         while (*s++)
             ;
     }
 
     return (s - src - 1);       /* count does not include NUL */
 }

◆ strnlen()

size_t strnlen	(	const char *	str,
		size_t	maxlen
	)

Definition at line 26 of file strnlen.c.

References generate_unaccent_rules::str.

Referenced by fmtstr(), pnstrdup(), and xml_is_document().

 {
     const char *p = str;
 
     while (maxlen-- > 0 && *p)
         p++;
     return p - str;
 }

◆ strtof()

float strtof	(	const char *	nptr,
		char **	endptr
	)

Definition at line 28 of file strtof.c.

References isinf().

Referenced by float4in().

 {
     int         caller_errno = errno;
     double      dresult;
     float       fresult;
 
     errno = 0;
     dresult = strtod(nptr, endptr);
     fresult = (float) dresult;
 
     if (errno == 0)
     {
         /*
          * Value might be in-range for double but not float.
          */
         if (dresult != 0 && fresult == 0)
             caller_errno = ERANGE;  /* underflow */
         if (!isinf(dresult) && isinf(fresult))
             caller_errno = ERANGE;  /* overflow */
     }
     else
         caller_errno = errno;
 
     errno = caller_errno;
     return fresult;
 }

◆ unsetenv()

void unsetenv ( const char * name )

Definition at line 20 of file unsetenv.c.

References malloc, putenv, and sprintf.

 {
     char       *envstr;
 
     if (getenv(name) == NULL)
         return;                 /* no work */
 
     /*
      * The technique embodied here works if libc follows the Single Unix Spec
      * and actually uses the storage passed to putenv() to hold the environ
      * entry.  When we clobber the entry in the second step we are ensuring
      * that we zap the actual environ member.  However, there are some libc
      * implementations (notably recent BSDs) that do not obey SUS but copy the
      * presented string.  This method fails on such platforms.  Hopefully all
      * such platforms have unsetenv() and thus won't be using this hack. See:
      * http://www.greenend.org.uk/rjk/2008/putenv.html
      *
      * Note that repeatedly setting and unsetting a var using this code will
      * leak memory.
      */
 
     envstr = (char *) malloc(strlen(name) + 2);
     if (!envstr)                /* not much we can do if no memory */
         return;
 
     /* Override the existing setting by forcibly defining the var */
     sprintf(envstr, "%s=", name);
     putenv(envstr);
 
     /* Now we can clobber the variable definition this way: */
     strcpy(envstr, "=");
 
     /*
      * This last putenv cleans up if we have multiple zero-length names as a
      * result of unsetting multiple things.
      */
     putenv(envstr);
 }

◆ wait_result_is_any_signal()

bool wait_result_is_any_signal	(	int	exit_status,
		bool	include_command_not_found
	)

Definition at line 111 of file wait_error.c.

References WEXITSTATUS, WIFEXITED, and WIFSIGNALED.

Referenced by ExecuteRecoveryCommand(), pgarch_archiveXlog(), and RestoreArchivedFile().

 {
     if (WIFSIGNALED(exit_status))
         return true;
     if (WIFEXITED(exit_status) &&
         WEXITSTATUS(exit_status) > (include_command_not_found ? 125 : 128))
         return true;
     return false;
 }

◆ wait_result_is_signal()

bool wait_result_is_signal	(	int	exit_status,
		int	signum
	)

Definition at line 92 of file wait_error.c.

References WEXITSTATUS, WIFEXITED, WIFSIGNALED, and WTERMSIG.

Referenced by ClosePipeToProgram(), and RestoreArchivedFile().

 {
     if (WIFSIGNALED(exit_status) && WTERMSIG(exit_status) == signum)
         return true;
     if (WIFEXITED(exit_status) && WEXITSTATUS(exit_status) == 128 + signum)
         return true;
     return false;
 }

◆ wait_result_to_str()

char* wait_result_to_str ( int exit_status )

Definition at line 32 of file wait_error.c.

References _, pg_strsignal(), pstrdup(), snprintf, generate_unaccent_rules::str, WEXITSTATUS, WIFEXITED, WIFSIGNALED, and WTERMSIG.

Referenced by BaseBackup(), ClosePipeToProgram(), do_copy(), ExecuteRecoveryCommand(), pclose_check(), RestoreArchivedFile(), and run_ssl_passphrase_command().

 {
     char        str[512];
 
     if (WIFEXITED(exitstatus))
     {
         /*
          * Give more specific error message for some common exit codes that
          * have a special meaning in shells.
          */
         switch (WEXITSTATUS(exitstatus))
         {
             case 126:
                 snprintf(str, sizeof(str), _("command not executable"));
                 break;
 
             case 127:
                 snprintf(str, sizeof(str), _("command not found"));
                 break;
 
             default:
                 snprintf(str, sizeof(str),
                          _("child process exited with exit code %d"),
                          WEXITSTATUS(exitstatus));
         }
     }
     else if (WIFSIGNALED(exitstatus))
     {
 #if defined(WIN32)
         snprintf(str, sizeof(str),
                  _("child process was terminated by exception 0x%X"),
                  WTERMSIG(exitstatus));
 #else
         snprintf(str, sizeof(str),
                  _("child process was terminated by signal %d: %s"),
                  WTERMSIG(exitstatus), pg_strsignal(WTERMSIG(exitstatus)));
 #endif
     }
     else
         snprintf(str, sizeof(str),
                  _("child process exited with unrecognized status %d"),
                  exitstatus);
 
     return pstrdup(str);
 }

Macros

Typedefs

Functions

Macro Definition Documentation

◆ closesocket

◆ DEVNULL

◆ EXE

◆ fprintf

◆ fseeko

◆ ftello

◆ is_absolute_path

◆ IS_DIR_SEP

◆ pg_backend_random

◆ PG_BACKEND_VERSIONSTR

◆ PG_IOLBF

◆ PG_STRERROR_R_BUFLEN

◆ PGINVALID_SOCKET

◆ pgoff_t

◆ printf

◆ qsort

◆ RTLD_GLOBAL

◆ RTLD_NOW

◆ snprintf

◆ sprintf

◆ SSL_get_current_compression

◆ strerror

◆ strerror_r

◆ TIMEZONE_GLOBAL

◆ TZNAME_GLOBAL

◆ USE_REPL_SNPRINTF

◆ vfprintf

◆ vprintf

◆ vsnprintf

◆ vsprintf

Typedef Documentation

◆ pgsocket

◆ pqsigfunc

◆ qsort_arg_comparator

Function Documentation

◆ canonicalize_path()

◆ cleanup_path()

◆ crypt()

◆ dlclose()

◆ dlerror()

◆ dlopen()

◆ dlsym()

◆ escape_single_quotes_ascii()

◆ find_my_exec()

◆ find_other_exec()

◆ first_dir_separator()

◆ first_path_var_separator()

◆ fls()

◆ get_doc_path()

◆ get_etc_path()

◆ get_home_path()

◆ get_html_path()

◆ get_include_path()

◆ get_includeserver_path()

◆ get_lib_path()

◆ get_locale_path()

◆ get_man_path()

◆ get_parent_directory()

◆ get_pkginclude_path()

◆ get_pkglib_path()

◆ get_progname()

◆ get_share_path()

◆ getpeereid()

◆ has_drive_prefix()

◆ inet_aton()

◆ inet_net_ntop()

◆ isinf()

◆ join_path_components()

◆ last_dir_separator()

◆ make_absolute_path()

◆ make_native_path()

◆ mkdtemp()

◆ path_contains_parent_reference()

◆ path_is_prefix_of_path()

◆ path_is_relative_and_below_cwd()

◆ pclose_check()