pqexpbuffer.c File Reference

#include "postgres_fe.h"
#include <limits.h>
#include "pqexpbuffer.h"

Include dependency graph for pqexpbuffer.c:

Go to the source code of this file.

Functions
static void	markPQExpBufferBroken (PQExpBuffer str)
PQExpBuffer	createPQExpBuffer (void)
void	initPQExpBuffer (PQExpBuffer str)
void	destroyPQExpBuffer (PQExpBuffer str)
void	termPQExpBuffer (PQExpBuffer str)
void	resetPQExpBuffer (PQExpBuffer str)
int	enlargePQExpBuffer (PQExpBuffer str, size_t needed)
void	printfPQExpBuffer (PQExpBuffer str, const char *fmt,...)
void	appendPQExpBuffer (PQExpBuffer str, const char *fmt,...)
bool	appendPQExpBufferVA (PQExpBuffer str, const char *fmt, va_list args)
void	appendPQExpBufferStr (PQExpBuffer str, const char *data)
void	appendPQExpBufferChar (PQExpBuffer str, char ch)
void	appendBinaryPQExpBuffer (PQExpBuffer str, const char *data, size_t datalen)

Variables
static const char	oom_buffer [1] = ""
static const char *const	oom_buffer_ptr = oom_buffer

Function Documentation

appendBinaryPQExpBuffer()

void appendBinaryPQExpBuffer	(	PQExpBuffer	str,
		const char *	data,
		size_t	datalen
	)

Definition at line 397 of file pqexpbuffer.c.

{
    /* Make more room if needed */
    if (!enlargePQExpBuffer(str, datalen))
        return;
 
    /* OK, append the data */
    memcpy(str->data + str->len, data, datalen);
    str->len += datalen;
 
    /*
     * Keep a trailing null in place, even though it's probably useless for
     * binary data...
     */
    str->data[str->len] = '\0';
}

References data, enlargePQExpBuffer(), and str.

Referenced by append_data(), append_urlencoded(), appendPQExpBufferStr(), createViewAsClause(), dumpTableSchema(), evaluate_backtick(), pg_GSS_error_int(), pqGets_internal(), psqlscan_emit(), test_gb18030_json(), and test_one_vector_escape().

appendPQExpBuffer()

void appendPQExpBuffer	(	PQExpBuffer	str,
		const char *	fmt,
			...
	)

Definition at line 265 of file pqexpbuffer.c.

{
    int         save_errno = errno;
    va_list     args;
    bool        done;
 
    if (PQExpBufferBroken(str))
        return;                 /* already failed */
 
    /* Loop in case we have to retry after enlarging the buffer. */
    do
    {
        errno = save_errno;
        va_start(args, fmt);
        done = appendPQExpBufferVA(str, fmt, args);
        va_end(args);
    } while (!done);
}

References appendPQExpBufferVA(), generate_unaccent_rules::args, PQExpBufferBroken, and str.

Referenced by _getObjectDescription(), _printTableAccessMethodNoStorage(), _selectOutputSchema(), _selectTableAccessMethod(), _selectTablespace(), add_tablespace_footer(), AddAcl(), addFooterToPublicationDesc(), append_db_pattern_cte(), append_depends_on_extension(), append_rel_pattern_filtered_cte(), append_rel_pattern_raw_cte(), AppendIntegerCommandOption(), appendNamedArgument(), AppendPlainCommandOption(), appendReloptionsArray(), AppendStringCommandOption(), binary_upgrade_extension_member(), binary_upgrade_set_pg_class_oids(), binary_upgrade_set_type_oids_by_type_oid(), bootstrap_template1(), build_client_final_message(), build_client_first_message(), buildACLCommands(), buildDefaultACLCommands(), buildShSecLabelQuery(), check_and_drop_existing_subscriptions(), client_initial_response(), cluster_conn_opts(), compile_relation_list_one_db(), connectFailureMessage(), constructConnStr(), create_logical_replication_slot(), create_logical_replication_slots(), create_publication(), create_subscription(), createDummyViewAsClause(), createPartitions(), CreateReplicationSlot(), createViewAsClause(), debug_callback(), describeAccessMethods(), describeAggregates(), describeConfigurationParameters(), describeFunctions(), describeOneTableDetails(), describeOneTSConfig(), describeOperators(), describePublications(), DescribeQuery(), describeRoleGrants(), describeRoles(), describeSubscriptions(), describeTablespaces(), describeTypes(), determineNotNullFlags(), drop_existing_subscriptions(), drop_publication(), drop_replication_slot(), DropReplicationSlot(), dumpAccessMethod(), dumpACL(), dumpAgg(), dumpAttrDef(), dumpBaseType(), dumpCast(), dumpCollation(), dumpCommentExtended(), dumpCompositeType(), dumpCompositeTypeColComments(), dumpConstraint(), dumpConversion(), dumpDatabase(), dumpDefaultACL(), dumpDomain(), dumpEnumType(), dumpEventTrigger(), dumpExtension(), dumpForeignDataWrapper(), dumpForeignServer(), dumpFunc(), dumpIndex(), dumpIndexAttach(), dumpLO(), dumpNamespace(), dumpOpclass(), dumpOpfamily(), dumpOpr(), dumpPolicy(), dumpProcLang(), dumpPublication(), dumpPublicationNamespace(), dumpPublicationTable(), dumpRangeType(), dumpRelationStats_dumper(), dumpRoleMembership(), dumpRoles(), dumpRule(), dumpSecLabel(), dumpSequence(), dumpSequenceData(), dumpShellType(), dumpStatisticsExt(), dumpStdStrings(), dumpSubscription(), dumpSubscriptionTable(), dumpTableAttach(), dumpTableComment(), dumpTableConstraintComment(), dumpTableData(), dumpTableData_copy(), dumpTableData_insert(), dumpTableSchema(), dumpTableSecLabel(), dumpTablespaces(), dumpTransform(), dumpTrigger(), dumpTSConfig(), dumpTSDictionary(), dumpTSParser(), dumpTSTemplate(), dumpUndefinedType(), dumpUserMappings(), emitHostIdentityInfo(), emitShSecLabels(), enable_subscription(), escapify(), executeMetaCommand(), expand_table_name_patterns(), fmtQualifiedIdEnc(), format_aggregate_signature(), format_function_arguments(), format_function_signature(), gen_reindex_command(), GenerateRecoveryConfig(), get_create_object_cmd(), get_db_conn(), get_language_name(), get_rel_infos_query(), getAggregates(), getAnotherTuple(), getCasts(), getConstraints(), getFormattedTypeName(), getFuncs(), getIndexes(), getParamDescriptions(), getPolicies(), getPublications(), getRowDescriptions(), GetSlotInformation(), getSubscriptions(), getTableAttrs(), getTables(), getTransforms(), getTriggers(), initCreatePKeys(), initCreateTables(), is_load_via_partition_root(), libpqrcv_get_conninfo(), listAllDbs(), listCasts(), listCollations(), listConversions(), listDomains(), listEventTriggers(), listExtendedStats(), listForeignDataWrappers(), listForeignServers(), listForeignTables(), listLanguages(), listLargeObjects(), listOperatorClasses(), listOperatorFamilies(), listOpFamilyFunctions(), listOpFamilyOperators(), listPartitionedTables(), listPublications(), listSchemas(), listTables(), listTSDictionaries(), listUserMappings(), lockTableForWorker(), lookup_object_oid(), main(), makeAlterConfigCommand(), objectDescription(), parseAclItem(), permissionsList(), pg_fe_run_oauth_flow_impl(), pg_GSS_error(), pq_verify_peer_name_matches_certificate(), pqBuildErrorMessage3(), pqsecure_open_gss(), prepare_btree_command(), prepare_heap_command(), prepare_vacuum_command(), printACLColumn(), printVerboseErrorMessages(), process_data_type_check(), processSQLNamePattern(), ReceiveArchiveStreamChunk(), ReceiveBackupManifestInMemoryChunk(), record_token_error(), refreshMatViewData(), replace_guc_value(), reportErrorPosition(), RestoreArchive(), retrieve_objects(), runInitSteps(), runPgDump(), set_replication_progress(), set_restrict_relation_kind(), setup_connection(), setup_recovery(), start_conn(), start_standby_server(), StreamLogicalLog(), syntax_error(), test_gb18030_json(), test_gb18030_page_multiple(), test_one_vector_escape(), test_psql_parse(), test_specific_config_settings(), and upgrade_task_add_step().

appendPQExpBufferChar()

void appendPQExpBufferChar	(	PQExpBuffer	str,
		char	ch
	)

Definition at line 378 of file pqexpbuffer.c.

{
    /* Make more room if needed */
    if (!enlargePQExpBuffer(str, 1))
        return;
 
    /* OK, append the character */
    str->data[str->len] = ch;
    str->len++;
    str->data[str->len] = '\0';
}

References enlargePQExpBuffer(), and str.

Referenced by _doSetSessionAuth(), AddAcl(), append_db_pattern_cte(), append_rel_pattern_raw_cte(), append_urlencoded(), appendConnStrItem(), appendConnStrVal(), appendPGArray(), AppendPlainCommandOption(), appendPsqlMetaConnect(), appendShellStringNoError(), appendStringLiteralConn(), appendStringLiteralDQ(), binary_upgrade_set_pg_class_oids(), build_client_first_message(), build_urlencoded(), cluster_conn_opts(), cluster_one_database(), conninfo_uri_parse_options(), constructConnStr(), createDummyViewAsClause(), createPartitions(), CreateReplicationSlot(), debug_callback(), dequoteAclUserName(), describeOneTableDetails(), DescribeQuery(), describeRoles(), determineNotNullFlags(), do_edit(), dumpCompositeType(), dumpConstraint(), dumpEnumType(), dumpEventTrigger(), dumpExtension(), dumpPublication(), dumpRule(), dumpTableData_insert(), dumpTableSchema(), dumpUserConfig(), escape_replace(), escape_string(), escape_string_conn(), escapify(), ExecuteSimpleCommands(), fetchAttributeStats(), fmtCopyColumnList(), fmtIdEnc(), format_aggregate_signature(), format_function_signature(), gather_boolean_expression(), gen_reindex_command(), GenerateRecoveryConfig(), get_create_object_cmd(), get_parallel_tables_list(), getAggregates(), getConstraints(), getFuncs(), getIndexes(), getNamespaces(), getPolicies(), getTableAttrs(), getTriggers(), indent_lines(), libpq_append_conn_error(), libpq_append_error(), main(), MainLoop(), minimal_error_message(), output_completion_banner(), patternToSQLRegex(), pg_append_history(), pg_fe_run_oauth_flow_impl(), pg_GSS_error(), pg_GSS_error_int(), pq_verify_peer_name_matches_certificate(), pqBuildErrorMessage3(), PQconnectPoll(), prepare_vacuum_command(), processSQLNamePattern(), psqlscan_emit(), quoteAclUserName(), read_pattern(), read_quoted_string(), reindex_one_database(), replace_guc_value(), reportErrorPosition(), start_standby_server(), StreamLogicalLog(), test_one_vector_escape(), and test_psql_parse().

appendPQExpBufferStr()

void appendPQExpBufferStr	(	PQExpBuffer	str,
		const char *	data
	)

Definition at line 367 of file pqexpbuffer.c.

{
    appendBinaryPQExpBuffer(str, data, strlen(data));
}

References appendBinaryPQExpBuffer(), data, and str.

Referenced by _doSetSessionAuth(), _getObjectDescription(), _printTableAccessMethodNoStorage(), _selectOutputSchema(), _selectTablespace(), add_role_attribute(), AddAcl(), append_db_pattern_cte(), append_rel_pattern_filtered_cte(), append_rel_pattern_raw_cte(), append_urlencoded(), appendConnStrItem(), appendConnStrVal(), appendNamedArgument(), appendPGArray(), AppendPlainCommandOption(), appendPsqlMetaConnect(), appendQualifiedRelation(), appendReloptionsArray(), appendShellStringNoError(), appendStringLiteralDQ(), binary_upgrade_extension_member(), binary_upgrade_set_pg_class_oids(), binary_upgrade_set_type_oids_by_type_oid(), bootstrap_template1(), build_client_final_message(), build_client_first_message(), buildACLCommands(), buildMatViewRefreshDependencies(), check_for_incompatible_polymorphics(), cluster_conn_opts(), cluster_one_database(), collectComments(), collectSecLabels(), compile_database_list(), compile_relation_list_one_db(), concat_conninfo_dbname(), conninfo_uri_parse_options(), copy_previous_query(), create_logical_replication_slots(), create_sql_command(), createDummyViewAsClause(), createPartitions(), CreateReplicationSlot(), describeAccessMethods(), describeAggregates(), describeConfigurationParameters(), describeFunctions(), describeOneTableDetails(), describeOperators(), describePublications(), DescribeQuery(), describeRoleGrants(), describeRoles(), describeSubscriptions(), describeTableDetails(), describeTablespaces(), describeTypes(), determineNotNullFlags(), do_copy(), do_edit(), dumpAccessMethod(), dumpACL(), dumpAgg(), dumpBaseType(), dumpCast(), dumpCollation(), dumpCommentExtended(), dumpCompositeType(), dumpCompositeTypeColComments(), dumpConstraint(), dumpConversion(), dumpDatabase(), dumpDomain(), dumpEncoding(), dumpEnumType(), dumpEventTrigger(), dumpExtension(), dumpForeignDataWrapper(), dumpForeignServer(), dumpFunc(), dumpNamespace(), dumpOpclass(), dumpOpfamily(), dumpOpr(), dumpPolicy(), dumpProcLang(), dumpPublication(), dumpPublicationTable(), dumpRangeType(), dumpRelationStats_dumper(), dumpRoleMembership(), dumpRoles(), dumpRule(), dumpSearchPath(), dumpSecLabel(), dumpSequence(), dumpSequenceData(), dumpSubscription(), dumpSubscriptionTable(), dumpTable(), dumpTableAttach(), dumpTableComment(), dumpTableData_copy(), dumpTableData_insert(), dumpTableSchema(), dumpTableSecLabel(), dumpTablespaces(), dumpTransform(), dumpTrigger(), dumpTSConfig(), dumpTSDictionary(), dumpUserMappings(), emitShSecLabels(), ensureCleanShutdown(), escape_fmt_id(), escape_identifier(), escape_literal(), escape_replace(), escape_string_conn(), escapify(), exec_command_ef_ev(), expand_dbname_patterns(), expand_extension_name_patterns(), expand_foreign_server_name_patterns(), expand_schema_name_patterns(), expand_table_name_patterns(), fetchAttributeStats(), fmtCopyColumnList(), fmtIdEnc(), fmtQualifiedIdEnc(), format_aggregate_signature(), format_function_arguments(), format_function_signature(), gather_boolean_expression(), gen_reindex_command(), generate_old_dump(), GenerateRecoveryConfig(), get_create_object_cmd(), get_db_conn(), get_dbnames_list_to_restore(), get_parallel_tabidx_list(), get_parallel_tables_list(), get_rel_infos_query(), getAccessMethods(), getAdditionalACLs(), getAggregates(), getCasts(), getCollations(), getConstraints(), getConversions(), getDefaultACLs(), getDependencies(), getDomainConstraints(), getEventTriggers(), getExtendedStatistics(), getExtensionMembership(), getExtensions(), getForeignDataWrappers(), getForeignServers(), getFuncs(), getIndexes(), getInherits(), getLOs(), getNamespaces(), getOpclasses(), getOperators(), getOpfamilies(), getPartitioningInfo(), getPolicies(), getProcLangs(), getPublicationNamespaces(), getPublications(), getPublicationTables(), getRestoreCommand(), getRules(), gets_fromFile(), getSubscriptions(), getTableAttrs(), getTables(), getTransforms(), getTSConfigurations(), getTSDictionaries(), getTSParsers(), getTSTemplates(), getTypes(), indent_lines(), initCreatePKeys(), listAllDbs(), listCasts(), listCollations(), listConversions(), listDbRoleSettings(), listDefaultACLs(), listDomains(), listEventTriggers(), listExtendedStats(), listExtensionContents(), listExtensions(), listForeignDataWrappers(), listForeignServers(), listForeignTables(), listLanguages(), listLargeObjects(), listOperatorClasses(), listOperatorFamilies(), listOpFamilyFunctions(), listOpFamilyOperators(), listPartitionedTables(), listPublications(), listSchemas(), listTables(), listTSConfigs(), listTSConfigsVerbose(), listTSDictionaries(), listTSParsers(), listTSParsersVerbose(), listTSTemplates(), listUserMappings(), lookup_object_oid(), main(), makeAlterConfigCommand(), minimal_error_message(), objectDescription(), output_completion_banner(), patternToSQLRegex(), permissionsList(), pg_append_history(), pg_fe_run_oauth_flow_impl(), pg_fe_sendauth(), pg_GSS_write(), pg_SASL_init(), pgtls_read(), pgtls_write(), pqBuildErrorMessage3(), pqCheckInBufferSpace(), pqCheckOutBufferSpace(), pqConnectDBStart(), pqGetErrorNotice3(), pqPipelineSyncInternal(), pqSaveWriteError(), prepare_vacuum_command(), printVerboseErrorMessages(), processSQLNamePattern(), psqlscan_escape_variable(), psqlscan_test_variable(), read_pattern(), replace_guc_value(), reportErrorPosition(), RestoreArchive(), retrieve_objects(), runInitSteps(), runPgDump(), setup_connection(), setup_recovery(), start_conn(), start_postmaster(), start_standby_server(), StreamLogicalLog(), test_gb18030_json(), and test_one_vector_escape().

appendPQExpBufferVA()

bool appendPQExpBufferVA	(	PQExpBuffer	str,
		const char *	fmt,
		va_list	args
	)

Definition at line 294 of file pqexpbuffer.c.

{
    size_t      avail;
    size_t      needed;
    int         nprinted;
 
    /*
     * Try to format the given string into the available space; but if there's
     * hardly any space, don't bother trying, just enlarge the buffer first.
     */
    if (str->maxlen > str->len + 16)
    {
        avail = str->maxlen - str->len;
 
        nprinted = vsnprintf(str->data + str->len, avail, fmt, args);
 
        /*
         * If vsnprintf reports an error, fail (we assume this means there's
         * something wrong with the format string).
         */
        if (unlikely(nprinted < 0))
        {
            markPQExpBufferBroken(str);
            return true;
        }
 
        if ((size_t) nprinted < avail)
        {
            /* Success.  Note nprinted does not include trailing null. */
            str->len += nprinted;
            return true;
        }
 
        /*
         * We assume a C99-compliant vsnprintf, so believe its estimate of the
         * required space, and add one for the trailing null.  (If it's wrong,
         * the logic will still work, but we may loop multiple times.)
         *
         * Choke if the required space would exceed INT_MAX, since str->maxlen
         * can't represent more than that.
         */
        if (unlikely(nprinted > INT_MAX - 1))
        {
            markPQExpBufferBroken(str);
            return true;
        }
        needed = nprinted + 1;
    }
    else
    {
        /*
         * We have to guess at how much to enlarge, since we're skipping the
         * formatting work.  Fortunately, because of enlargePQExpBuffer's
         * preference for power-of-2 sizes, this number isn't very sensitive;
         * the net effect is that we'll double the buffer size before trying
         * to run vsnprintf, which seems sensible.
         */
        needed = 32;
    }
 
    /* Increase the buffer size and try again. */
    if (!enlargePQExpBuffer(str, needed))
        return true;            /* oops, out of memory */
 
    return false;
}

References generate_unaccent_rules::args, enlargePQExpBuffer(), markPQExpBufferBroken(), str, unlikely, and vsnprintf.

Referenced by appendPQExpBuffer(), libpq_append_conn_error(), libpq_append_error(), and printfPQExpBuffer().

createPQExpBuffer()

PQExpBuffer createPQExpBuffer

(

void

)

Definition at line 72 of file pqexpbuffer.c.

{
    PQExpBuffer res;
 
    res = (PQExpBuffer) malloc(sizeof(PQExpBufferData));
    if (res != NULL)
        initPQExpBuffer(res);
 
    return res;
}

References initPQExpBuffer(), and malloc.

Referenced by _doSetSessionAuth(), _printTableAccessMethodNoStorage(), _selectOutputSchema(), _selectTableAccessMethod(), _selectTablespace(), _WriteLOData(), append_depends_on_extension(), appendStringLiteralDQ(), binary_upgrade_set_type_oids_by_type_oid(), buildACLCommands(), buildDefaultACLCommands(), buildMatViewRefreshDependencies(), buildShSecLabels(), check_and_drop_existing_subscriptions(), cluster_conn_opts(), collectComments(), collectSecLabels(), concat_conninfo_dbname(), constructConnStr(), create_logical_replication_slot(), create_logical_replication_slots(), create_publication(), create_subscription(), createDummyViewAsClause(), CreateReplicationSlot(), createViewAsClause(), determineNotNullFlags(), drop_existing_subscriptions(), drop_publication(), drop_replication_slot(), DropReplicationSlot(), dropRoles(), dump_lo_buf(), dumpAccessMethod(), dumpACL(), dumpAgg(), dumpAttrDef(), dumpBaseType(), dumpCast(), dumpCollation(), dumpCommentExtended(), dumpCompositeType(), dumpCompositeTypeColComments(), dumpConstraint(), dumpConversion(), dumpDatabase(), dumpDatabaseConfig(), dumpDefaultACL(), dumpDomain(), dumpEncoding(), dumpEnumType(), dumpEventTrigger(), dumpExtension(), dumpForeignDataWrapper(), dumpForeignServer(), dumpFunc(), dumpIndex(), dumpIndexAttach(), dumpLO(), dumpNamespace(), dumpOpclass(), dumpOpfamily(), dumpOpr(), dumpPolicy(), dumpProcLang(), dumpPublication(), dumpPublicationNamespace(), dumpPublicationTable(), dumpRangeType(), dumpRelationStats_dumper(), dumpRoleGUCPrivs(), dumpRoleMembership(), dumpRoles(), dumpRule(), dumpSearchPath(), dumpSecLabel(), dumpSequence(), dumpSequenceData(), dumpShellType(), dumpStatisticsExt(), dumpStdStrings(), dumpSubscription(), dumpSubscriptionTable(), dumpTable(), dumpTableAttach(), dumpTableComment(), dumpTableConstraintComment(), dumpTableData(), dumpTableData_copy(), dumpTableData_insert(), dumpTableSchema(), dumpTableSecLabel(), dumpTablespaces(), dumpTransform(), dumpTrigger(), dumpTSConfig(), dumpTSDictionary(), dumpTSParser(), dumpTSTemplate(), dumpUndefinedType(), dumpUserConfig(), dumpUserMappings(), enable_subscription(), ensureCleanShutdown(), exec_command_sf_sv(), ExecuteSimpleCommands(), expand_dbname_patterns(), expand_extension_name_patterns(), expand_foreign_server_name_patterns(), expand_schema_name_patterns(), expand_table_name_patterns(), fetchAttributeStats(), fmtQualifiedIdEnc(), gather_boolean_expression(), GenerateRecoveryConfig(), get_base_conninfo(), get_create_object_cmd(), get_dbnames_list_to_restore(), get_language_name(), get_sub_conninfo(), getAccessMethods(), getAdditionalACLs(), getAggregates(), getCasts(), getCollations(), getConstraints(), getConversions(), getDefaultACLs(), getDependencies(), getDomainConstraints(), getEventTriggers(), getExtendedStatistics(), getExtensionMembership(), getExtensions(), getForeignDataWrappers(), getForeignServers(), getFormattedTypeName(), getFuncs(), getIndexes(), getInherits(), getLOs(), getNamespaces(), getOpclasses(), getOperators(), getOpfamilies(), getPartitioningInfo(), getPolicies(), getProcLangs(), getPublicationNamespaces(), getPublications(), getPublicationTables(), getRestoreCommand(), getRules(), gets_fromFile(), GetSlotInformation(), getSubscriptions(), getTableAttrs(), getTables(), getTransforms(), getTriggers(), getTSConfigurations(), getTSDictionaries(), getTSParsers(), getTSTemplates(), getTypes(), is_load_via_partition_root(), lockTableForWorker(), lookup_object_oid(), main(), MainLoop(), minimal_error_message(), printVerboseErrorMessages(), process_data_type_check(), processExtensionTables(), ReceiveArchiveStreamChunk(), refreshMatViewData(), replace_guc_value(), RestoreArchive(), set_replication_progress(), set_restrict_relation_kind(), setup_connection(), start_standby_server(), StreamLogicalLog(), test_gb18030_json(), test_gb18030_page_multiple(), test_one_vector_escape(), test_psql_parse(), and upgrade_task_create().

destroyPQExpBuffer()

void destroyPQExpBuffer

(

PQExpBuffer

str

)

Definition at line 114 of file pqexpbuffer.c.

{
    if (str)
    {
        termPQExpBuffer(str);
        free(str);
    }
}

References free, str, and termPQExpBuffer().

Referenced by _doSetSessionAuth(), _printTableAccessMethodNoStorage(), _selectOutputSchema(), _selectTableAccessMethod(), _selectTablespace(), _WriteLOData(), append_depends_on_extension(), appendStringLiteralDQ(), BaseBackup(), binary_upgrade_set_type_oids_by_type_oid(), buildACLCommands(), buildDefaultACLCommands(), buildMatViewRefreshDependencies(), buildShSecLabels(), check_and_drop_existing_subscriptions(), check_for_data_types_usage(), collectComments(), collectSecLabels(), concat_conninfo_dbname(), constructConnStr(), create_logical_replication_slot(), create_logical_replication_slots(), create_publication(), create_subscription(), CreateReplicationSlot(), createViewAsClause(), DeCloneArchive(), drop_existing_subscriptions(), drop_publication(), drop_replication_slot(), DropReplicationSlot(), dropRoles(), dump_lo_buf(), dumpAccessMethod(), dumpACL(), dumpAgg(), dumpAttrDef(), dumpBaseType(), dumpCast(), dumpCollation(), dumpCommentExtended(), dumpCompositeType(), dumpCompositeTypeColComments(), dumpConstraint(), dumpConversion(), dumpDatabase(), dumpDatabaseConfig(), dumpDefaultACL(), dumpDomain(), dumpEncoding(), dumpEnumType(), dumpEventTrigger(), dumpExtension(), dumpForeignDataWrapper(), dumpForeignServer(), dumpFunc(), dumpIndex(), dumpIndexAttach(), dumpLO(), dumpNamespace(), dumpOpclass(), dumpOpfamily(), dumpOpr(), dumpPolicy(), dumpProcLang(), dumpPublication(), dumpPublicationNamespace(), dumpPublicationTable(), dumpRangeType(), dumpRelationStats_dumper(), dumpRoleGUCPrivs(), dumpRoleMembership(), dumpRoles(), dumpRule(), dumpSearchPath(), dumpSecLabel(), dumpSequence(), dumpSequenceData(), dumpShellType(), dumpStatisticsExt(), dumpStdStrings(), dumpSubscription(), dumpSubscriptionTable(), dumpTable(), dumpTableAttach(), dumpTableComment(), dumpTableConstraintComment(), dumpTableData(), dumpTableData_copy(), dumpTableData_insert(), dumpTableSchema(), dumpTableSecLabel(), dumpTablespaces(), dumpTransform(), dumpTrigger(), dumpTSConfig(), dumpTSDictionary(), dumpTSParser(), dumpTSTemplate(), dumpUndefinedType(), dumpUserConfig(), dumpUserMappings(), enable_subscription(), ensureCleanShutdown(), exec_command_sf_sv(), expand_dbname_patterns(), expand_extension_name_patterns(), expand_foreign_server_name_patterns(), expand_schema_name_patterns(), expand_table_name_patterns(), fetchAttributeStats(), fmtQualifiedIdEnc(), get_base_conninfo(), get_create_object_cmd(), get_dbnames_list_to_restore(), get_language_name(), get_sub_conninfo(), getAccessMethods(), getAdditionalACLs(), getAggregates(), getCasts(), getCollations(), getConstraints(), getConversions(), getDefaultACLs(), getDependencies(), getDomainConstraints(), getEventTriggers(), getExtendedStatistics(), getExtensionMembership(), getExtensions(), getForeignDataWrappers(), getForeignServers(), getFormattedTypeName(), getFuncs(), getIndexes(), getInherits(), getLOs(), getNamespaces(), getOpclasses(), getOperators(), getOpfamilies(), getPartitioningInfo(), getPolicies(), getProcLangs(), getPublicationNamespaces(), getPublications(), getPublicationTables(), getRestoreCommand(), getRules(), GetSlotInformation(), getSubscriptions(), getTableAttrs(), getTables(), getTransforms(), getTriggers(), getTSConfigurations(), getTSDictionaries(), getTSParsers(), getTSTemplates(), getTypes(), ignore_boolean_expression(), is_load_via_partition_root(), is_true_boolean_expression(), lockTableForWorker(), lookup_object_oid(), main(), MainLoop(), minimal_error_message(), processExtensionTables(), ReceiveArchiveStream(), refreshMatViewData(), RestoreArchive(), set_replication_progress(), set_restrict_relation_kind(), setup_connection(), start_standby_server(), StreamLogicalLog(), test_gb18030_json(), test_gb18030_page_multiple(), test_one_vector_escape(), test_psql_parse(), and upgrade_task_free().

enlargePQExpBuffer()

int enlargePQExpBuffer	(	PQExpBuffer	str,
		size_t	needed
	)

Definition at line 172 of file pqexpbuffer.c.

{
    size_t      newlen;
    char       *newdata;
 
    if (PQExpBufferBroken(str))
        return 0;               /* already failed */
 
    /*
     * Guard against ridiculous "needed" values, which can occur if we're fed
     * bogus data.  Without this, we can get an overflow or infinite loop in
     * the following.
     */
    if (needed >= ((size_t) INT_MAX - str->len))
    {
        markPQExpBufferBroken(str);
        return 0;
    }
 
    needed += str->len + 1;     /* total space required now */
 
    /* Because of the above test, we now have needed <= INT_MAX */
 
    if (needed <= str->maxlen)
        return 1;               /* got enough space already */
 
    /*
     * We don't want to allocate just a little more space with each append;
     * for efficiency, double the buffer size each time it overflows.
     * Actually, we might need to more than double it if 'needed' is big...
     */
    newlen = (str->maxlen > 0) ? (2 * str->maxlen) : 64;
    while (needed > newlen)
        newlen = 2 * newlen;
 
    /*
     * Clamp to INT_MAX in case we went past it.  Note we are assuming here
     * that INT_MAX <= UINT_MAX/2, else the above loop could overflow.  We
     * will still have newlen >= needed.
     */
    if (newlen > (size_t) INT_MAX)
        newlen = (size_t) INT_MAX;
 
    newdata = (char *) realloc(str->data, newlen);
    if (newdata != NULL)
    {
        str->data = newdata;
        str->maxlen = newlen;
        return 1;
    }
 
    markPQExpBufferBroken(str);
    return 0;
}

References markPQExpBufferBroken(), PQExpBufferBroken, realloc, and str.

Referenced by appendBinaryPQExpBuffer(), appendByteaLiteral(), appendPQExpBufferChar(), appendPQExpBufferVA(), appendStringLiteral(), appendStringLiteralConn(), build_client_final_message(), escape_string(), escape_string_conn(), fmtIdEnc(), and passwordFromFile().

initPQExpBuffer()

void initPQExpBuffer

(

PQExpBuffer

str

)

Definition at line 90 of file pqexpbuffer.c.

{
    str->data = (char *) malloc(INITIAL_EXPBUFFER_SIZE);
    if (str->data == NULL)
    {
        str->data = unconstify(char *, oom_buffer_ptr); /* see comment above */
        str->maxlen = 0;
        str->len = 0;
    }
    else
    {
        str->maxlen = INITIAL_EXPBUFFER_SIZE;
        str->len = 0;
        str->data[0] = '\0';
    }
}

References INITIAL_EXPBUFFER_SIZE, malloc, oom_buffer_ptr, str, and unconstify.

Referenced by _printTocEntry(), _reconnectToDB(), add_tablespace_footer(), append_database_pattern(), append_relation_pattern_helper(), append_schema_pattern(), appendPsqlMetaConnect(), appendQualifiedRelation(), BaseBackup(), bootstrap_template1(), build_client_final_message(), build_client_first_message(), check_for_incompatible_polymorphics(), client_initial_response(), cluster_one_database(), compile_database_list(), compile_relation_list_one_db(), conninfo_uri_parse_options(), create_sql_command(), createPartitions(), createPQExpBuffer(), debug_callback(), describeAccessMethods(), describeAggregates(), describeConfigurationParameters(), describeFunctions(), describeOneTableDetails(), describeOneTSConfig(), describeOneTSParser(), describeOperators(), describePublications(), DescribeQuery(), describeRoleGrants(), describeRoles(), describeSubscriptions(), describeTableDetails(), describeTablespaces(), describeTypes(), do_copy(), dumpRelationStats_dumper(), evaluate_backtick(), exec_command_password(), executeMetaCommand(), expand_schema_name_patterns(), expand_table_name_patterns(), filter_read_item(), format_aggregate_signature(), format_function_arguments(), format_function_signature(), generate_old_dump(), GenerateRecoveryConfig(), get_db_conn(), get_parallel_tabidx_list(), get_parallel_tables_list(), get_rel_infos_query(), getCasts(), getParameterStatus(), getTransforms(), handle_oauth_sasl_error(), helpSQL(), helpVariables(), indent_lines(), initCreatePKeys(), initCreateTables(), initGenerateDataServerSide(), initialize_data_directory(), initPopulateTable(), libpqrcv_get_conninfo(), listAllDbs(), listCasts(), listCollations(), listConversions(), listDbRoleSettings(), listDefaultACLs(), listDomains(), listEventTriggers(), listExtendedStats(), listExtensionContents(), listExtensions(), listForeignDataWrappers(), listForeignServers(), listForeignTables(), listLanguages(), listLargeObjects(), listOneExtensionContents(), listOperatorClasses(), listOperatorFamilies(), listOpFamilyFunctions(), listOpFamilyOperators(), listPartitionedTables(), listPublications(), listSchemas(), listTables(), listTSConfigs(), listTSConfigsVerbose(), listTSDictionaries(), listTSParsers(), listTSParsersVerbose(), listTSTemplates(), listUserMappings(), main(), objectDescription(), old_9_6_invalidate_hash_indexes(), output_completion_banner(), ParseScript(), passwordFromFile(), patternToSQLRegex(), permissionsList(), pg_fe_run_oauth_flow_impl(), pg_SASL_init(), PQchangePassword(), PQconndefaults(), PQconninfo(), PQconninfoParse(), pqGetErrorNotice3(), pqMakeEmptyPGconn(), PQresultVerboseErrorMessage(), process_backslash_command(), process_extension_updates(), processSQLNamePattern(), psql_get_variable(), psql_scan_slash_command(), psql_scan_slash_option(), ReceiveTarFile(), reindex_one_database(), resetPQExpBuffer(), retrieve_objects(), runInitSteps(), runPgDump(), slashUsage(), start_conn(), start_postmaster(), syntax_error(), test_specific_config_settings(), urlencode(), usage(), vacuum_one_database(), and validateSQLNamePattern().

markPQExpBufferBroken()

static void markPQExpBufferBroken ( PQExpBuffer  str )

static

Definition at line 50 of file pqexpbuffer.c.

{
    if (str->data != oom_buffer)
        free(str->data);
 
    /*
     * Casting away const here is a bit ugly, but it seems preferable to not
     * marking oom_buffer const.  We want to do that to encourage the compiler
     * to put oom_buffer in read-only storage, so that anyone who tries to
     * scribble on a broken PQExpBuffer will get a failure.
     */
    str->data = unconstify(char *, oom_buffer_ptr);
    str->len = 0;
    str->maxlen = 0;
}

References free, oom_buffer, oom_buffer_ptr, str, and unconstify.

Referenced by appendPQExpBufferVA(), and enlargePQExpBuffer().

printfPQExpBuffer()

void printfPQExpBuffer	(	PQExpBuffer	str,
		const char *	fmt,
			...
	)

Definition at line 235 of file pqexpbuffer.c.

{
    int         save_errno = errno;
    va_list     args;
    bool        done;
 
    resetPQExpBuffer(str);
 
    if (PQExpBufferBroken(str))
        return;                 /* already failed */
 
    /* Loop in case we have to retry after enlarging the buffer. */
    do
    {
        errno = save_errno;
        va_start(args, fmt);
        done = appendPQExpBufferVA(str, fmt, args);
        va_end(args);
    } while (!done);
}

References appendPQExpBufferVA(), generate_unaccent_rules::args, PQExpBufferBroken, resetPQExpBuffer(), and str.

Referenced by add_tablespace_footer(), addFooterToPublicationDesc(), binary_upgrade_set_type_oids_by_type_oid(), bootstrap_template1(), buildACLCommands(), createPartitions(), describeAccessMethods(), describeAggregates(), describeConfigurationParameters(), describeFunctions(), describeOneTableDetails(), describeOneTSConfig(), describeOneTSParser(), describeOperators(), describePublications(), DescribeQuery(), describeRoleGrants(), describeRoles(), describeSubscriptions(), describeTableDetails(), describeTablespaces(), describeTypes(), do_copy(), dropRoles(), dumpAgg(), dumpBaseType(), dumpCompositeType(), dumpDatabaseConfig(), dumpDomain(), dumpEnumType(), dumpFunc(), dumpOpr(), dumpRangeType(), dumpRoleMembership(), dumpRoles(), dumpRule(), dumpTable(), dumpTableAttach(), dumpTableData(), dumpUserConfig(), exec_command_password(), executeMetaCommand(), get_create_object_cmd(), get_next_possible_free_pg_type_oid(), getAdditionalACLs(), getDomainConstraints(), getPolicies(), getTableAttrs(), initAccount(), initBranch(), initCreateTables(), initGenerateDataServerSide(), initialize_data_directory(), initTeller(), listAllDbs(), listCasts(), listCollations(), listConversions(), listDbRoleSettings(), listDefaultACLs(), listDomains(), listEventTriggers(), listExtendedStats(), listExtensionContents(), listExtensions(), listForeignDataWrappers(), listForeignServers(), listForeignTables(), listLanguages(), listLargeObjects(), listOneExtensionContents(), listOperatorClasses(), listOperatorFamilies(), listOpFamilyFunctions(), listOpFamilyOperators(), listPartitionedTables(), listPublications(), listSchemas(), listTables(), listTSConfigs(), listTSConfigsVerbose(), listTSDictionaries(), listTSParsers(), listTSParsersVerbose(), listTSTemplates(), listUserMappings(), main(), minimal_error_message(), parseAclItem(), permissionsList(), PQchangePassword(), printVerboseErrorMessages(), processExtensionTables(), runPgDump(), syntax_error(), and test_specific_config_settings().

resetPQExpBuffer()

void resetPQExpBuffer

(

PQExpBuffer

str

)

Definition at line 146 of file pqexpbuffer.c.

{
    if (str)
    {
        if (str->data != oom_buffer)
        {
            str->len = 0;
            str->data[0] = '\0';
        }
        else
        {
            /* try to reinitialize to valid state */
            initPQExpBuffer(str);
        }
    }
}

References initPQExpBuffer(), oom_buffer, and str.

Referenced by cluster_conn_opts(), create_logical_replication_slots(), create_publication(), dequoteAclUserName(), describeOneTableDetails(), describeRoles(), do_edit(), dumpCompositeTypeColComments(), dumpDatabase(), dumpOpclass(), dumpOpfamily(), dumpRelationStats_dumper(), dumpRoleMembership(), dumpRoles(), dumpSequence(), dumpSequenceData(), dumpTableComment(), dumpTableData_insert(), dumpTableSchema(), dumpTableSecLabel(), dumpTrigger(), dumpTSConfig(), dumpUserConfig(), dumpUserMappings(), exec_command_edit(), exec_command_ef_ev(), exec_command_reset(), exec_command_watch(), ExecuteSimpleCommands(), expand_dbname_patterns(), expand_extension_name_patterns(), expand_foreign_server_name_patterns(), expand_schema_name_patterns(), expand_table_name_patterns(), expr_lex_one_word(), get_create_object_cmd(), get_dbnames_list_to_restore(), getNamespaces(), gets_fromFile(), getTableAttrs(), getTables(), initCreatePKeys(), MainLoop(), parseAclItem(), ParseScript(), pg_send_history(), PQcancelPoll(), pqGetErrorNotice3(), pqGets_internal(), prepare_btree_command(), prepare_heap_command(), prepare_vacuum_command(), printfPQExpBuffer(), printVerboseErrorMessages(), retrieve_objects(), set_replication_progress(), start_device_authz(), start_request(), start_token_request(), StreamLogicalLog(), and test_psql_parse().

termPQExpBuffer()

void termPQExpBuffer

(

PQExpBuffer

str

)

Definition at line 129 of file pqexpbuffer.c.

{
    if (str->data != oom_buffer)
        free(str->data);
    /* just for luck, make the buffer validly empty. */
    str->data = unconstify(char *, oom_buffer_ptr); /* see comment above */
    str->maxlen = 0;
    str->len = 0;
}

References free, oom_buffer, oom_buffer_ptr, str, and unconstify.

Referenced by _printTocEntry(), _reconnectToDB(), add_tablespace_footer(), append_database_pattern(), append_relation_pattern_helper(), append_schema_pattern(), append_urlencoded(), appendPsqlMetaConnect(), appendQualifiedRelation(), bootstrap_template1(), build_client_final_message(), build_client_first_message(), check_for_incompatible_polymorphics(), client_initial_response(), cluster_one_database(), compile_database_list(), compile_relation_list_one_db(), conninfo_uri_parse_options(), createPartitions(), debug_callback(), describeAccessMethods(), describeAggregates(), describeConfigurationParameters(), describeFunctions(), describeOneTableDetails(), describeOneTSConfig(), describeOneTSParser(), describeOperators(), describePublications(), DescribeQuery(), describeRoleGrants(), describeRoles(), describeSubscriptions(), describeTableDetails(), describeTablespaces(), describeTypes(), destroyPQExpBuffer(), do_copy(), evaluate_backtick(), exec_command_password(), executeMetaCommand(), expand_schema_name_patterns(), expand_table_name_patterns(), free_async_ctx(), free_command(), freePGconn(), generate_old_dump(), GenerateRecoveryConfig(), get_db_conn(), get_parallel_tabidx_list(), get_parallel_tables_list(), getParameterStatus(), handle_oauth_sasl_error(), helpSQL(), helpVariables(), indent_lines(), initCreatePKeys(), initCreateTables(), initGenerateDataServerSide(), initialize_data_directory(), initPopulateTable(), libpqrcv_get_conninfo(), listAllDbs(), listCasts(), listCollations(), listConversions(), listDbRoleSettings(), listDefaultACLs(), listDomains(), listEventTriggers(), listExtendedStats(), listExtensionContents(), listExtensions(), listForeignDataWrappers(), listForeignServers(), listForeignTables(), listLanguages(), listLargeObjects(), listOneExtensionContents(), listOperatorClasses(), listOperatorFamilies(), listOpFamilyFunctions(), listOpFamilyOperators(), listPartitionedTables(), listPublications(), listSchemas(), listTables(), listTSConfigs(), listTSConfigsVerbose(), listTSDictionaries(), listTSParsers(), listTSParsersVerbose(), listTSTemplates(), listUserMappings(), main(), objectDescription(), old_9_6_invalidate_hash_indexes(), output_completion_banner(), ParseScript(), passwordFromFile(), patternToSQLRegex(), permissionsList(), pg_SASL_init(), PQchangePassword(), PQconndefaults(), PQconninfo(), PQconninfoParse(), pqGetErrorNotice3(), PQresultVerboseErrorMessage(), process_backslash_command(), process_extension_updates(), processSQLNamePattern(), psql_scan_slash_option(), ReceiveTarFile(), reindex_one_database(), retrieve_objects(), runInitSteps(), runPgDump(), slashUsage(), start_conn(), start_postmaster(), syntax_error(), test_specific_config_settings(), usage(), vacuum_one_database(), and validateSQLNamePattern().

Variable Documentation

oom_buffer

const char oom_buffer[1] = ""

static

Definition at line 38 of file pqexpbuffer.c.

Referenced by markPQExpBufferBroken(), resetPQExpBuffer(), and termPQExpBuffer().

oom_buffer_ptr

const char* const oom_buffer_ptr = oom_buffer

static

Definition at line 41 of file pqexpbuffer.c.

Referenced by initPQExpBuffer(), markPQExpBufferBroken(), and termPQExpBuffer().