pqformat.h File Reference

#include "lib/stringinfo.h"
#include "mb/pg_wchar.h"
#include "port/pg_bswap.h"

Include dependency graph for pqformat.h:

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

Go to the source code of this file.

Functions
void	pq_beginmessage (StringInfo buf, char msgtype)
void	pq_beginmessage_reuse (StringInfo buf, char msgtype)
void	pq_endmessage (StringInfo buf)
void	pq_endmessage_reuse (StringInfo buf)
void	pq_sendbytes (StringInfo buf, const void *data, int datalen)
void	pq_sendcountedtext (StringInfo buf, const char *str, int slen, bool countincludesself)
void	pq_sendtext (StringInfo buf, const char *str, int slen)
void	pq_sendstring (StringInfo buf, const char *str)
void	pq_send_ascii_string (StringInfo buf, const char *str)
void	pq_sendfloat4 (StringInfo buf, float4 f)
void	pq_sendfloat8 (StringInfo buf, float8 f)
static void	pq_writeint8 (StringInfoData *pg_restrict buf, uint8 i)
static void	pq_writeint16 (StringInfoData *pg_restrict buf, uint16 i)
static void	pq_writeint32 (StringInfoData *pg_restrict buf, uint32 i)
static void	pq_writeint64 (StringInfoData *pg_restrict buf, uint64 i)
static void	pq_writestring (StringInfoData *pg_restrict buf, const char *pg_restrict str)
static void	pq_sendint8 (StringInfo buf, uint8 i)
static void	pq_sendint16 (StringInfo buf, uint16 i)
static void	pq_sendint32 (StringInfo buf, uint32 i)
static void	pq_sendint64 (StringInfo buf, uint64 i)
static void	pq_sendbyte (StringInfo buf, uint8 byt)
static void	pq_sendint (StringInfo buf, uint32 i, int b)
void	pq_begintypsend (StringInfo buf)
bytea *	pq_endtypsend (StringInfo buf)
void	pq_puttextmessage (char msgtype, const char *str)
void	pq_putemptymessage (char msgtype)
int	pq_getmsgbyte (StringInfo msg)
unsigned int	pq_getmsgint (StringInfo msg, int b)
int64	pq_getmsgint64 (StringInfo msg)
float4	pq_getmsgfloat4 (StringInfo msg)
float8	pq_getmsgfloat8 (StringInfo msg)
const char *	pq_getmsgbytes (StringInfo msg, int datalen)
void	pq_copymsgbytes (StringInfo msg, char *buf, int datalen)
char *	pq_getmsgtext (StringInfo msg, int rawbytes, int *nbytes)
const char *	pq_getmsgstring (StringInfo msg)
const char *	pq_getmsgrawstring (StringInfo msg)
void	pq_getmsgend (StringInfo msg)

Function Documentation

pq_beginmessage()

void pq_beginmessage	(	StringInfo	buf,
		char	msgtype
	)

Definition at line 88 of file pqformat.c.

{
    initStringInfo(buf);
 
    /*
     * We stash the message type into the buffer's cursor field, expecting
     * that the pq_sendXXX routines won't touch it.  We could alternatively
     * make it the first byte of the buffer contents, but this seems easier.
     */
    buf->cursor = msgtype;
}

References buf, and initStringInfo().

Referenced by bbsink_copystream_archive_contents(), bbsink_copystream_begin_archive(), bbsink_copystream_begin_manifest(), bbsink_copystream_end_archive(), NotifyMyFrontEnd(), ParallelWorkerMain(), PostgresMain(), printsimple(), printsimple_startup(), ReadyForQuery(), ReceiveCopyBegin(), ReportGUCOption(), send_message_to_frontend(), sendAuthRequest(), SendCopyBegin(), SendCopyOutResponse(), SendFunctionResult(), SendNegotiateProtocolVersion(), SendTimeLineHistory(), StartLogicalReplication(), and StartReplication().

pq_beginmessage_reuse()

void pq_beginmessage_reuse	(	StringInfo	buf,
		char	msgtype
	)

Definition at line 109 of file pqformat.c.

{
    resetStringInfo(buf);
 
    /*
     * We stash the message type into the buffer's cursor field, expecting
     * that the pq_sendXXX routines won't touch it.  We could alternatively
     * make it the first byte of the buffer contents, but this seems easier.
     */
    buf->cursor = msgtype;
}

References buf, and resetStringInfo().

Referenced by exec_describe_statement_message(), printtup(), and SendRowDescriptionMessage().

pq_begintypsend()

void pq_begintypsend

(

StringInfo

buf

)

Definition at line 329 of file pqformat.c.

{
    initStringInfo(buf);
    /* Reserve four bytes for the bytea length word */
    appendStringInfoCharMacro(buf, '\0');
    appendStringInfoCharMacro(buf, '\0');
    appendStringInfoCharMacro(buf, '\0');
    appendStringInfoCharMacro(buf, '\0');
}

References appendStringInfoCharMacro, buf, and initStringInfo().

Referenced by array_agg_array_serialize(), array_agg_serialize(), array_send(), boolsend(), box_send(), cash_send(), charsend(), cidsend(), circle_send(), complex_send(), cstring_send(), cube_send(), date_send(), enum_send(), float4send(), float8send(), hstore_send(), int2send(), int4send(), int8_avg_serialize(), int8send(), interval_send(), json_send(), jsonb_send(), jsonpath_send(), line_send(), lquery_send(), lseg_send(), ltree_send(), ltxtq_send(), macaddr8_send(), macaddr_send(), multirange_send(), namesend(), network_send(), numeric_avg_serialize(), numeric_poly_serialize(), numeric_send(), numeric_serialize(), oidsend(), path_send(), pg_lsn_send(), pg_snapshot_send(), point_send(), poly_send(), range_send(), record_send(), string_agg_serialize(), textsend(), tidsend(), time_send(), timestamp_send(), timestamptz_send(), timetz_send(), tsquerysend(), tsvectorsend(), unknownsend(), uuid_send(), varbit_send(), void_send(), xid8send(), xidsend(), and xml_send().

pq_copymsgbytes()

void pq_copymsgbytes	(	StringInfo	msg,
		char *	buf,
		int	datalen
	)

Definition at line 531 of file pqformat.c.

{
    if (datalen < 0 || datalen > (msg->len - msg->cursor))
        ereport(ERROR,
                (errcode(ERRCODE_PROTOCOL_VIOLATION),
                 errmsg("insufficient data left in message")));
    memcpy(buf, &msg->data[msg->cursor], datalen);
    msg->cursor += datalen;
}

References buf, StringInfoData::cursor, StringInfoData::data, ereport, errcode(), errmsg(), ERROR, and StringInfoData::len.

Referenced by bit_recv(), bytearecv(), CopyGetData(), logicalrep_read_tuple(), pq_getmsgint(), pq_getmsgint64(), and varbit_recv().

pq_endmessage()

void pq_endmessage

(

StringInfo

buf

)

Definition at line 299 of file pqformat.c.

{
    /* msgtype was saved in cursor field */
    (void) pq_putmessage(buf->cursor, buf->data, buf->len);
    /* no need to complain about any failure, since pqcomm.c already did */
    pfree(buf->data);
    buf->data = NULL;
}

References buf, pfree(), and pq_putmessage.

Referenced by bbsink_copystream_archive_contents(), bbsink_copystream_begin_archive(), bbsink_copystream_begin_manifest(), bbsink_copystream_end_archive(), HandleParallelMessage(), NotifyMyFrontEnd(), ParallelWorkerMain(), PostgresMain(), printsimple(), printsimple_startup(), ReadyForQuery(), ReceiveCopyBegin(), ReportGUCOption(), send_message_to_frontend(), sendAuthRequest(), SendCopyBegin(), SendCopyOutResponse(), SendFunctionResult(), SendNegotiateProtocolVersion(), SendTimeLineHistory(), StartLogicalReplication(), and StartReplication().

pq_endmessage_reuse()

void pq_endmessage_reuse

(

StringInfo

buf

)

Definition at line 317 of file pqformat.c.

{
    /* msgtype was saved in cursor field */
    (void) pq_putmessage(buf->cursor, buf->data, buf->len);
}

References buf, and pq_putmessage.

Referenced by exec_describe_statement_message(), printtup(), and SendRowDescriptionMessage().

pq_endtypsend()

bytea* pq_endtypsend

(

StringInfo

buf

)

Definition at line 349 of file pqformat.c.

{
    bytea      *result = (bytea *) buf->data;
 
    /* Insert correct length into bytea length word */
    Assert(buf->len >= VARHDRSZ);
    SET_VARSIZE(result, buf->len);
 
    return result;
}

References Assert(), buf, SET_VARSIZE, and VARHDRSZ.

Referenced by array_agg_array_serialize(), array_agg_serialize(), array_send(), boolsend(), box_send(), cash_send(), charsend(), cidsend(), circle_send(), complex_send(), cstring_send(), cube_send(), date_send(), enum_send(), float4send(), float8send(), hstore_send(), int2send(), int4send(), int8_avg_serialize(), int8send(), interval_send(), json_send(), jsonb_send(), jsonpath_send(), line_send(), lquery_send(), lseg_send(), ltree_send(), ltxtq_send(), macaddr8_send(), macaddr_send(), multirange_send(), namesend(), network_send(), numeric_avg_serialize(), numeric_poly_serialize(), numeric_send(), numeric_serialize(), oidsend(), path_send(), pg_lsn_send(), pg_snapshot_send(), point_send(), poly_send(), range_send(), record_send(), string_agg_serialize(), textsend(), tidsend(), time_send(), timestamp_send(), timestamptz_send(), timetz_send(), tsquerysend(), tsvectorsend(), unknownsend(), uuid_send(), varbit_send(), void_send(), xid8send(), xidsend(), and xml_send().

pq_getmsgbyte()

int pq_getmsgbyte

(

StringInfo

msg

)

Definition at line 402 of file pqformat.c.

{
    if (msg->cursor >= msg->len)
        ereport(ERROR,
                (errcode(ERRCODE_PROTOCOL_VIOLATION),
                 errmsg("no data left in message")));
    return (unsigned char) msg->data[msg->cursor++];
}

References StringInfoData::cursor, StringInfoData::data, ereport, errcode(), errmsg(), ERROR, and StringInfoData::len.

Referenced by apply_dispatch(), array_agg_deserialize(), boolrecv(), charrecv(), HandleParallelApplyMessage(), HandleParallelMessage(), LogicalParallelApplyLoop(), logicalrep_read_attrs(), logicalrep_read_commit(), logicalrep_read_commit_prepared(), logicalrep_read_delete(), logicalrep_read_insert(), logicalrep_read_prepare_common(), logicalrep_read_rel(), logicalrep_read_rollback_prepared(), logicalrep_read_stream_commit(), logicalrep_read_stream_start(), logicalrep_read_tuple(), logicalrep_read_update(), LogicalRepApplyLoop(), macaddr8_recv(), macaddr_recv(), network_recv(), path_recv(), PostgresMain(), pq_parse_errornotice(), ProcessStandbyMessage(), ProcessStandbyReplyMessage(), range_recv(), and XLogWalRcvProcessMsg().

pq_getmsgbytes()

const char* pq_getmsgbytes	(	StringInfo	msg,
		int	datalen
	)

Definition at line 511 of file pqformat.c.

{
    const char *result;
 
    if (datalen < 0 || datalen > (msg->len - msg->cursor))
        ereport(ERROR,
                (errcode(ERRCODE_PROTOCOL_VIOLATION),
                 errmsg("insufficient data left in message")));
    result = &msg->data[msg->cursor];
    msg->cursor += datalen;
    return result;
}

References StringInfoData::cursor, StringInfoData::data, ereport, errcode(), errmsg(), ERROR, and StringInfoData::len.

Referenced by array_agg_array_deserialize(), array_agg_deserialize(), CheckSASLAuth(), exec_bind_message(), multirange_recv(), parse_fcall_arguments(), range_recv(), string_agg_deserialize(), uuid_recv(), and xml_recv().

pq_getmsgend()

void pq_getmsgend

(

StringInfo

msg

)

Definition at line 638 of file pqformat.c.

{
    if (msg->cursor != msg->len)
        ereport(ERROR,
                (errcode(ERRCODE_PROTOCOL_VIOLATION),
                 errmsg("invalid message format")));
}

References StringInfoData::cursor, ereport, errcode(), errmsg(), ERROR, and StringInfoData::len.

Referenced by array_agg_array_deserialize(), array_agg_deserialize(), CheckSASLAuth(), exec_bind_message(), HandleFunctionRequest(), HandleParallelMessage(), int8_avg_deserialize(), multirange_recv(), numeric_avg_deserialize(), numeric_deserialize(), numeric_poly_deserialize(), PostgresMain(), pq_parse_errornotice(), range_recv(), and string_agg_deserialize().

pq_getmsgfloat4()

float4 pq_getmsgfloat4

(

StringInfo

msg

)

Definition at line 472 of file pqformat.c.

{
    union
    {
        float4      f;
        uint32      i;
    }           swap;
 
    swap.i = pq_getmsgint(msg, 4);
    return swap.f;
}

References i, and pq_getmsgint().

Referenced by float4recv().

pq_getmsgfloat8()

float8 pq_getmsgfloat8

(

StringInfo

msg

)

Definition at line 491 of file pqformat.c.

{
    union
    {
        float8      f;
        int64       i;
    }           swap;
 
    swap.i = pq_getmsgint64(msg);
    return swap.f;
}

References i, and pq_getmsgint64().

Referenced by box_recv(), circle_recv(), complex_recv(), cube_recv(), float8recv(), line_recv(), lseg_recv(), path_recv(), point_recv(), and poly_recv().

pq_getmsgint()

unsigned int pq_getmsgint	(	StringInfo	msg,
		int	b
	)

Definition at line 418 of file pqformat.c.

{
    unsigned int result;
    unsigned char n8;
    uint16      n16;
    uint32      n32;
 
    switch (b)
    {
        case 1:
            pq_copymsgbytes(msg, (char *) &n8, 1);
            result = n8;
            break;
        case 2:
            pq_copymsgbytes(msg, (char *) &n16, 2);
            result = pg_ntoh16(n16);
            break;
        case 4:
            pq_copymsgbytes(msg, (char *) &n32, 4);
            result = pg_ntoh32(n32);
            break;
        default:
            elog(ERROR, "unsupported integer size %d", b);
            result = 0;         /* keep compiler quiet */
            break;
    }
    return result;
}

References b, elog(), ERROR, pg_ntoh16, pg_ntoh32, and pq_copymsgbytes().

Referenced by array_agg_array_deserialize(), array_agg_deserialize(), array_recv(), bit_recv(), CheckSASLAuth(), cidrecv(), cube_recv(), date_recv(), exec_bind_message(), handle_streamed_transaction(), HandleFunctionRequest(), HandleParallelMessage(), hstore_recv(), int2recv(), int4recv(), interval_recv(), jsonb_recv(), jsonpath_recv(), logicalrep_read_attrs(), logicalrep_read_begin(), logicalrep_read_begin_prepare(), logicalrep_read_commit_prepared(), logicalrep_read_delete(), logicalrep_read_insert(), logicalrep_read_prepare_common(), logicalrep_read_rel(), logicalrep_read_rollback_prepared(), logicalrep_read_stream_abort(), logicalrep_read_stream_commit(), logicalrep_read_stream_start(), logicalrep_read_truncate(), logicalrep_read_tuple(), logicalrep_read_typ(), logicalrep_read_update(), lquery_recv(), ltree_recv(), ltxtq_recv(), multirange_recv(), numeric_avg_deserialize(), numeric_deserialize(), numeric_recv(), numericvar_deserialize(), oidrecv(), parse_fcall_arguments(), path_recv(), pg_snapshot_recv(), poly_recv(), PostgresMain(), pq_getmsgfloat4(), ProcessStandbyHSFeedbackMessage(), range_recv(), ReadArrayBinary(), record_recv(), string_agg_deserialize(), tidrecv(), timetz_recv(), tsqueryrecv(), tsvectorrecv(), varbit_recv(), and xidrecv().

pq_getmsgint64()

int64 pq_getmsgint64

(

StringInfo

msg

)

Definition at line 456 of file pqformat.c.

{
    uint64      n64;
 
    pq_copymsgbytes(msg, (char *) &n64, sizeof(n64));
 
    return pg_ntoh64(n64);
}

References pg_ntoh64, and pq_copymsgbytes().

Referenced by array_agg_deserialize(), cash_recv(), int8_avg_deserialize(), int8recv(), interval_recv(), logicalrep_read_begin(), logicalrep_read_begin_prepare(), logicalrep_read_commit(), logicalrep_read_commit_prepared(), logicalrep_read_origin(), logicalrep_read_prepare_common(), logicalrep_read_rollback_prepared(), logicalrep_read_stream_abort(), logicalrep_read_stream_commit(), LogicalRepApplyLoop(), numeric_avg_deserialize(), numeric_deserialize(), numeric_poly_deserialize(), pg_lsn_recv(), pg_snapshot_recv(), pq_getmsgfloat8(), ProcessStandbyHSFeedbackMessage(), ProcessStandbyReplyMessage(), time_recv(), timestamp_recv(), timestamptz_recv(), timetz_recv(), xid8recv(), and XLogWalRcvProcessMsg().

pq_getmsgrawstring()

const char* pq_getmsgrawstring

(

StringInfo

msg

)

Definition at line 611 of file pqformat.c.

{
    char       *str;
    int         slen;
 
    str = &msg->data[msg->cursor];
 
    /*
     * It's safe to use strlen() here because a StringInfo is guaranteed to
     * have a trailing null byte.  But check we found a null inside the
     * message.
     */
    slen = strlen(str);
    if (msg->cursor + slen >= msg->len)
        ereport(ERROR,
                (errcode(ERRCODE_PROTOCOL_VIOLATION),
                 errmsg("invalid string in message")));
    msg->cursor += slen + 1;
 
    return str;
}

References StringInfoData::cursor, StringInfoData::data, ereport, errcode(), errmsg(), ERROR, StringInfoData::len, and generate_unaccent_rules::str.

Referenced by CheckSASLAuth(), HandleParallelMessage(), and pq_parse_errornotice().

pq_getmsgstring()

const char* pq_getmsgstring

(

StringInfo

msg

)

Definition at line 582 of file pqformat.c.

{
    char       *str;
    int         slen;
 
    str = &msg->data[msg->cursor];
 
    /*
     * It's safe to use strlen() here because a StringInfo is guaranteed to
     * have a trailing null byte.  But check we found a null inside the
     * message.
     */
    slen = strlen(str);
    if (msg->cursor + slen >= msg->len)
        ereport(ERROR,
                (errcode(ERRCODE_PROTOCOL_VIOLATION),
                 errmsg("invalid string in message")));
    msg->cursor += slen + 1;
 
    return pg_client_to_server(str, slen);
}

References StringInfoData::cursor, StringInfoData::data, ereport, errcode(), errmsg(), ERROR, StringInfoData::len, pg_client_to_server(), and generate_unaccent_rules::str.

Referenced by CopyGetData(), exec_bind_message(), logicalrep_read_attrs(), logicalrep_read_begin_prepare(), logicalrep_read_commit_prepared(), logicalrep_read_namespace(), logicalrep_read_origin(), logicalrep_read_prepare_common(), logicalrep_read_rel(), logicalrep_read_rollback_prepared(), logicalrep_read_typ(), PostgresMain(), tsqueryrecv(), and tsvectorrecv().

pq_getmsgtext()

char* pq_getmsgtext	(	StringInfo	msg,
		int	rawbytes,
		int *	nbytes
	)

Definition at line 549 of file pqformat.c.

{
    char       *str;
    char       *p;
 
    if (rawbytes < 0 || rawbytes > (msg->len - msg->cursor))
        ereport(ERROR,
                (errcode(ERRCODE_PROTOCOL_VIOLATION),
                 errmsg("insufficient data left in message")));
    str = &msg->data[msg->cursor];
    msg->cursor += rawbytes;
 
    p = pg_client_to_server(str, rawbytes);
    if (p != str)               /* actual conversion has been done? */
        *nbytes = strlen(p);
    else
    {
        p = (char *) palloc(rawbytes + 1);
        memcpy(p, str, rawbytes);
        p[rawbytes] = '\0';
        *nbytes = rawbytes;
    }
    return p;
}

References StringInfoData::cursor, StringInfoData::data, ereport, errcode(), errmsg(), ERROR, StringInfoData::len, palloc(), pg_client_to_server(), and generate_unaccent_rules::str.

Referenced by bpcharrecv(), cstring_recv(), enum_recv(), hstore_recv(), json_recv(), jsonb_recv(), jsonpath_recv(), lquery_recv(), ltree_recv(), ltxtq_recv(), namerecv(), textrecv(), unknownrecv(), and varcharrecv().

pq_putemptymessage()

void pq_putemptymessage

(

char

msgtype

)

Definition at line 391 of file pqformat.c.

{
    (void) pq_putmessage(msgtype, NULL, 0);
}

References pq_putmessage.

Referenced by exec_bind_message(), exec_describe_portal_message(), exec_describe_statement_message(), exec_execute_message(), exec_parse_message(), NullCommand(), PostgresMain(), SendCopyDone(), and SendCopyEnd().

pq_puttextmessage()

void pq_puttextmessage	(	char	msgtype,
		const char *	str
	)

Definition at line 370 of file pqformat.c.

{
    int         slen = strlen(str);
    char       *p;
 
    p = pg_server_to_client(str, slen);
    if (p != str)               /* actual conversion has been done? */
    {
        (void) pq_putmessage(msgtype, p, strlen(p) + 1);
        pfree(p);
        return;
    }
    (void) pq_putmessage(msgtype, str, slen + 1);
}

References pfree(), pg_server_to_client(), pq_putmessage, and generate_unaccent_rules::str.

Referenced by bbsink_copystream_begin_backup(), and SendXlogRecPtrResult().

pq_send_ascii_string()

void pq_send_ascii_string	(	StringInfo	buf,
		const char *	str
	)

Definition at line 230 of file pqformat.c.

{
    while (*str)
    {
        char        ch = *str++;
 
        if (IS_HIGHBIT_SET(ch))
            ch = '?';
        appendStringInfoCharMacro(buf, ch);
    }
    appendStringInfoChar(buf, '\0');
}

References appendStringInfoChar(), appendStringInfoCharMacro, buf, IS_HIGHBIT_SET, and generate_unaccent_rules::str.

Referenced by err_sendstring().

pq_sendbyte()

static void pq_sendbyte ( StringInfo  buf, uint8  byt  )

inlinestatic

Definition at line 161 of file pqformat.h.

{
    pq_sendint8(buf, byt);
}

References buf, and pq_sendint8().

Referenced by array_agg_serialize(), bbsink_copystream_archive_contents(), bbsink_copystream_begin_archive(), bbsink_copystream_begin_manifest(), bbsink_copystream_end_archive(), boolsend(), charsend(), logicalrep_write_attrs(), logicalrep_write_begin(), logicalrep_write_begin_prepare(), logicalrep_write_commit(), logicalrep_write_commit_prepared(), logicalrep_write_delete(), logicalrep_write_insert(), logicalrep_write_message(), logicalrep_write_namespace(), logicalrep_write_origin(), logicalrep_write_prepare_common(), logicalrep_write_rel(), logicalrep_write_rollback_prepared(), logicalrep_write_stream_abort(), logicalrep_write_stream_commit(), logicalrep_write_stream_start(), logicalrep_write_stream_stop(), logicalrep_write_truncate(), logicalrep_write_tuple(), logicalrep_write_typ(), logicalrep_write_update(), macaddr8_send(), macaddr_send(), network_send(), path_send(), range_send(), ReadyForQuery(), ReceiveCopyBegin(), send_feedback(), send_message_to_frontend(), SendCopyBegin(), SendCopyOutResponse(), StartLogicalReplication(), StartReplication(), tsvectorsend(), WalSndKeepalive(), WalSndPrepareWrite(), XLogSendPhysical(), XLogWalRcvSendHSFeedback(), and XLogWalRcvSendReply().

pq_sendbytes()

void pq_sendbytes	(	StringInfo	buf,
		const void *	data,
		int	datalen
	)

Definition at line 126 of file pqformat.c.

{
    /* use variant that maintains a trailing null-byte, out of caution */
    appendBinaryStringInfo(buf, data, datalen);
}

References appendBinaryStringInfo(), buf, and data.

Referenced by array_agg_array_serialize(), array_agg_serialize(), array_send(), logicalrep_write_message(), logicalrep_write_tuple(), multirange_send(), printtup(), range_send(), record_send(), sendAuthRequest(), SendFunctionResult(), SendTimeLineHistory(), string_agg_serialize(), uuid_send(), and varbit_send().

pq_sendcountedtext()

void pq_sendcountedtext	(	StringInfo	buf,
		const char *	str,
		int	slen,
		bool	countincludesself
	)

Definition at line 143 of file pqformat.c.

{
    int         extra = countincludesself ? 4 : 0;
    char       *p;
 
    p = pg_server_to_client(str, slen);
    if (p != str)               /* actual conversion has been done? */
    {
        slen = strlen(p);
        pq_sendint32(buf, slen + extra);
        appendBinaryStringInfoNT(buf, p, slen);
        pfree(p);
    }
    else
    {
        pq_sendint32(buf, slen + extra);
        appendBinaryStringInfoNT(buf, str, slen);
    }
}

References appendBinaryStringInfoNT(), buf, pfree(), pg_server_to_client(), pq_sendint32(), and generate_unaccent_rules::str.

Referenced by logicalrep_write_tuple(), printsimple(), printtup(), and SendFunctionResult().

pq_sendfloat4()

void pq_sendfloat4	(	StringInfo	buf,
		float4	f
	)

Definition at line 255 of file pqformat.c.

{
    union
    {
        float4      f;
        uint32      i;
    }           swap;
 
    swap.f = f;
    pq_sendint32(buf, swap.i);
}

References buf, i, and pq_sendint32().

Referenced by float4send().

pq_sendfloat8()

void pq_sendfloat8	(	StringInfo	buf,
		float8	f
	)

Definition at line 279 of file pqformat.c.

{
    union
    {
        float8      f;
        int64       i;
    }           swap;
 
    swap.f = f;
    pq_sendint64(buf, swap.i);
}

References buf, i, and pq_sendint64().

Referenced by box_send(), circle_send(), complex_send(), cube_send(), float8send(), line_send(), lseg_send(), path_send(), point_send(), and poly_send().

pq_sendint()

static void pq_sendint ( StringInfo  buf, uint32  i, int  b  )

inlinestatic

Definition at line 172 of file pqformat.h.

{
    switch (b)
    {
        case 1:
            pq_sendint8(buf, (uint8) i);
            break;
        case 2:
            pq_sendint16(buf, (uint16) i);
            break;
        case 4:
            pq_sendint32(buf, (uint32) i);
            break;
        default:
            elog(ERROR, "unsupported integer size %d", b);
            break;
    }
}

References b, buf, elog(), ERROR, i, pq_sendint16(), pq_sendint32(), and pq_sendint8().

Referenced by logicalrep_write_tuple(), and string_agg_serialize().

pq_sendint16()

static void pq_sendint16 ( StringInfo  buf, uint16  i  )

inlinestatic

Definition at line 137 of file pqformat.h.

{
    enlargeStringInfo(buf, sizeof(uint16));
    pq_writeint16(buf, i);
}

References buf, enlargeStringInfo(), i, and pq_writeint16().

Referenced by array_agg_serialize(), exec_describe_statement_message(), int2send(), logicalrep_write_attrs(), logicalrep_write_tuple(), numeric_send(), numericvar_serialize(), pq_sendint(), printsimple(), printsimple_startup(), printtup(), ReceiveCopyBegin(), SendCopyBegin(), SendCopyOutResponse(), SendRowDescriptionMessage(), SendTimeLineHistory(), StartLogicalReplication(), StartReplication(), tidsend(), tsquerysend(), and tsvectorsend().

pq_sendint32()

static void pq_sendint32 ( StringInfo  buf, uint32  i  )

inlinestatic

Definition at line 145 of file pqformat.h.

{
    enlargeStringInfo(buf, sizeof(uint32));
    pq_writeint32(buf, i);
}

References buf, enlargeStringInfo(), i, and pq_writeint32().

Referenced by array_agg_array_serialize(), array_agg_serialize(), array_send(), cidsend(), cube_send(), date_send(), exec_describe_statement_message(), hstore_send(), int4send(), interval_send(), logicalrep_write_attrs(), logicalrep_write_begin(), logicalrep_write_begin_prepare(), logicalrep_write_commit_prepared(), logicalrep_write_delete(), logicalrep_write_insert(), logicalrep_write_message(), logicalrep_write_prepare_common(), logicalrep_write_rel(), logicalrep_write_rollback_prepared(), logicalrep_write_stream_abort(), logicalrep_write_stream_commit(), logicalrep_write_stream_start(), logicalrep_write_truncate(), logicalrep_write_typ(), logicalrep_write_update(), multirange_send(), NotifyMyFrontEnd(), numeric_avg_serialize(), numeric_serialize(), numericvar_serialize(), oidsend(), ParallelWorkerMain(), path_send(), pg_snapshot_send(), poly_send(), PostgresMain(), pq_sendcountedtext(), pq_sendfloat4(), pq_sendint(), printsimple(), printsimple_startup(), printtup(), range_send(), record_send(), sendAuthRequest(), SendFunctionResult(), SendNegotiateProtocolVersion(), SendTimeLineHistory(), tidsend(), timetz_send(), tsquerysend(), tsvectorsend(), varbit_send(), xidsend(), and XLogWalRcvSendHSFeedback().

pq_sendint64()

static void pq_sendint64 ( StringInfo  buf, uint64  i  )

inlinestatic

Definition at line 153 of file pqformat.h.

{
    enlargeStringInfo(buf, sizeof(uint64));
    pq_writeint64(buf, i);
}

References buf, enlargeStringInfo(), i, and pq_writeint64().

Referenced by array_agg_serialize(), bbsink_copystream_archive_contents(), bbsink_copystream_end_archive(), cash_send(), int8_avg_serialize(), int8send(), interval_send(), logicalrep_write_begin(), logicalrep_write_begin_prepare(), logicalrep_write_commit(), logicalrep_write_commit_prepared(), logicalrep_write_message(), logicalrep_write_origin(), logicalrep_write_prepare_common(), logicalrep_write_rollback_prepared(), logicalrep_write_stream_abort(), logicalrep_write_stream_commit(), numeric_avg_serialize(), numeric_poly_serialize(), numeric_serialize(), pg_lsn_send(), pg_snapshot_send(), pq_sendfloat8(), send_feedback(), time_send(), timestamp_send(), timestamptz_send(), timetz_send(), WalSndKeepalive(), WalSndPrepareWrite(), WalSndWriteData(), xid8send(), XLogSendPhysical(), XLogWalRcvSendHSFeedback(), and XLogWalRcvSendReply().

pq_sendint8()

static void pq_sendint8 ( StringInfo  buf, uint8  i  )

inlinestatic

Definition at line 129 of file pqformat.h.

{
    enlargeStringInfo(buf, sizeof(uint8));
    pq_writeint8(buf, i);
}

References buf, enlargeStringInfo(), i, and pq_writeint8().

Referenced by jsonb_send(), jsonpath_send(), logicalrep_write_message(), logicalrep_write_truncate(), lquery_send(), ltree_send(), ltxtq_send(), pq_sendbyte(), pq_sendint(), and tsquerysend().

pq_sendstring()

void pq_sendstring	(	StringInfo	buf,
		const char *	str
	)

Definition at line 198 of file pqformat.c.

{
    int         slen = strlen(str);
    char       *p;
 
    p = pg_server_to_client(str, slen);
    if (p != str)               /* actual conversion has been done? */
    {
        slen = strlen(p);
        appendBinaryStringInfoNT(buf, p, slen + 1);
        pfree(p);
    }
    else
        appendBinaryStringInfoNT(buf, str, slen + 1);
}

References appendBinaryStringInfoNT(), buf, pfree(), pg_server_to_client(), and generate_unaccent_rules::str.

Referenced by bbsink_copystream_begin_archive(), err_sendstring(), logicalrep_write_attrs(), logicalrep_write_begin_prepare(), logicalrep_write_commit_prepared(), logicalrep_write_message(), logicalrep_write_namespace(), logicalrep_write_origin(), logicalrep_write_prepare_common(), logicalrep_write_rel(), logicalrep_write_rollback_prepared(), logicalrep_write_typ(), NotifyMyFrontEnd(), printsimple_startup(), ReportGUCOption(), SendNegotiateProtocolVersion(), and tsquerysend().

pq_sendtext()

void pq_sendtext	(	StringInfo	buf,
		const char *	str,
		int	slen
	)

Definition at line 175 of file pqformat.c.

{
    char       *p;
 
    p = pg_server_to_client(str, slen);
    if (p != str)               /* actual conversion has been done? */
    {
        slen = strlen(p);
        appendBinaryStringInfo(buf, p, slen);
        pfree(p);
    }
    else
        appendBinaryStringInfo(buf, str, slen);
}

References appendBinaryStringInfo(), buf, pfree(), pg_server_to_client(), and generate_unaccent_rules::str.

Referenced by cstring_send(), enum_send(), hstore_send(), json_send(), jsonb_send(), jsonpath_send(), lquery_send(), ltree_send(), ltxtq_send(), namesend(), textsend(), tsvectorsend(), unknownsend(), and xml_send().

pq_writeint16()

static void pq_writeint16 ( StringInfoData *pg_restrict  buf, uint16  i  )

inlinestatic

Definition at line 61 of file pqformat.h.

{
    uint16      ni = pg_hton16(i);
 
    Assert(buf->len + (int) sizeof(uint16) <= buf->maxlen);
    memcpy((char *pg_restrict) (buf->data + buf->len), &ni, sizeof(uint16));
    buf->len += sizeof(uint16);
}

References Assert(), buf, i, and pg_hton16.

Referenced by pq_sendint16(), and SendRowDescriptionMessage().

pq_writeint32()

static void pq_writeint32 ( StringInfoData *pg_restrict  buf, uint32  i  )

inlinestatic

Definition at line 75 of file pqformat.h.

{
    uint32      ni = pg_hton32(i);
 
    Assert(buf->len + (int) sizeof(uint32) <= buf->maxlen);
    memcpy((char *pg_restrict) (buf->data + buf->len), &ni, sizeof(uint32));
    buf->len += sizeof(uint32);
}

References Assert(), buf, i, and pg_hton32.

Referenced by pq_sendint32(), and SendRowDescriptionMessage().

pq_writeint64()

static void pq_writeint64 ( StringInfoData *pg_restrict  buf, uint64  i  )

inlinestatic

Definition at line 89 of file pqformat.h.

{
    uint64      ni = pg_hton64(i);
 
    Assert(buf->len + (int) sizeof(uint64) <= buf->maxlen);
    memcpy((char *pg_restrict) (buf->data + buf->len), &ni, sizeof(uint64));
    buf->len += sizeof(uint64);
}

References Assert(), buf, i, and pg_hton64.

Referenced by pq_sendint64().

pq_writeint8()

static void pq_writeint8 ( StringInfoData *pg_restrict  buf, uint8  i  )

inlinestatic

Definition at line 47 of file pqformat.h.

{
    uint8       ni = i;
 
    Assert(buf->len + (int) sizeof(uint8) <= buf->maxlen);
    memcpy((char *pg_restrict) (buf->data + buf->len), &ni, sizeof(uint8));
    buf->len += sizeof(uint8);
}

References Assert(), buf, and i.

Referenced by pq_sendint8().

pq_writestring()

static void pq_writestring ( StringInfoData *pg_restrict  buf, const char *pg_restrict  str  )

inlinestatic

Definition at line 109 of file pqformat.h.

{
    int         slen = strlen(str);
    char       *p;
 
    p = pg_server_to_client(str, slen);
    if (p != str)               /* actual conversion has been done? */
        slen = strlen(p);
 
    Assert(buf->len + slen + 1 <= buf->maxlen);
 
    memcpy(((char *pg_restrict) buf->data + buf->len), p, slen + 1);
    buf->len += slen + 1;
 
    if (p != str)
        pfree(p);
}

References Assert(), buf, pfree(), pg_server_to_client(), and generate_unaccent_rules::str.

Referenced by SendRowDescriptionMessage().