Age Owner Branch data TLA Line data Source code
1 : : /*-------------------------------------------------------------------------
2 : : *
3 : : * pqformat.h
4 : : * Definitions for formatting and parsing frontend/backend messages
5 : : *
6 : : * Portions Copyright (c) 1996-2026, PostgreSQL Global Development Group
7 : : * Portions Copyright (c) 1994, Regents of the University of California
8 : : *
9 : : * src/include/libpq/pqformat.h
10 : : *
11 : : *-------------------------------------------------------------------------
12 : : */
13 : : #ifndef PQFORMAT_H
14 : : #define PQFORMAT_H
15 : :
16 : : #include "lib/stringinfo.h"
17 : : #include "mb/pg_wchar.h"
18 : : #include "port/pg_bswap.h"
19 : :
20 : : extern void pq_beginmessage(StringInfo buf, char msgtype);
21 : : extern void pq_beginmessage_reuse(StringInfo buf, char msgtype);
22 : : extern void pq_endmessage(StringInfo buf);
23 : : extern void pq_endmessage_reuse(StringInfo buf);
24 : :
25 : : extern void pq_sendbytes(StringInfo buf, const void *data, int datalen);
26 : : extern void pq_sendcountedtext(StringInfo buf, const char *str, int slen);
27 : : extern void pq_sendtext(StringInfo buf, const char *str, int slen);
28 : : extern void pq_sendstring(StringInfo buf, const char *str);
29 : : extern void pq_send_ascii_string(StringInfo buf, const char *str);
30 : : extern void pq_sendfloat4(StringInfo buf, float4 f);
31 : : extern void pq_sendfloat8(StringInfo buf, float8 f);
32 : :
33 : : /*
34 : : * Append a [u]int8 to a StringInfo buffer, which already has enough space
35 : : * preallocated.
36 : : *
37 : : * The use of pg_restrict allows the compiler to optimize the code based on
38 : : * the assumption that buf, buf->len, buf->data and *buf->data don't
39 : : * overlap. Without the annotation buf->len etc cannot be kept in a register
40 : : * over subsequent pq_writeintN calls.
41 : : *
42 : : * The use of StringInfoData * rather than StringInfo is due to MSVC being
43 : : * overly picky and demanding a * before a restrict.
44 : : */
45 : : static inline void
60 peter@eisentraut.org 46 :CBC 1916111 : pq_writeint8(StringInfoData *pg_restrict buf, uint8 i)
47 : : {
2819 andres@anarazel.de 48 : 1916111 : uint8 ni = i;
49 : :
50 [ - + ]: 1916111 : Assert(buf->len + (int) sizeof(uint8) <= buf->maxlen);
139 peter@eisentraut.org 51 :GNC 1916111 : memcpy(buf->data + buf->len, &ni, sizeof(uint8));
2819 andres@anarazel.de 52 :CBC 1916111 : buf->len += sizeof(uint8);
3077 53 : 1916111 : }
54 : :
55 : : /*
56 : : * Append a [u]int16 to a StringInfo buffer, which already has enough space
57 : : * preallocated.
58 : : */
59 : : static inline void
60 peter@eisentraut.org 60 : 6985695 : pq_writeint16(StringInfoData *pg_restrict buf, uint16 i)
61 : : {
2819 andres@anarazel.de 62 : 6985695 : uint16 ni = pg_hton16(i);
63 : :
64 [ - + ]: 6985695 : Assert(buf->len + (int) sizeof(uint16) <= buf->maxlen);
139 peter@eisentraut.org 65 :GNC 6985695 : memcpy(buf->data + buf->len, &ni, sizeof(uint16));
2819 andres@anarazel.de 66 :CBC 6985695 : buf->len += sizeof(uint16);
3077 67 : 6985695 : }
68 : :
69 : : /*
70 : : * Append a [u]int32 to a StringInfo buffer, which already has enough space
71 : : * preallocated.
72 : : */
73 : : static inline void
60 peter@eisentraut.org 74 : 26257169 : pq_writeint32(StringInfoData *pg_restrict buf, uint32 i)
75 : : {
2819 andres@anarazel.de 76 : 26257169 : uint32 ni = pg_hton32(i);
77 : :
78 [ - + ]: 26257169 : Assert(buf->len + (int) sizeof(uint32) <= buf->maxlen);
139 peter@eisentraut.org 79 :GNC 26257169 : memcpy(buf->data + buf->len, &ni, sizeof(uint32));
2819 andres@anarazel.de 80 :CBC 26257169 : buf->len += sizeof(uint32);
3077 81 : 26257169 : }
82 : :
83 : : /*
84 : : * Append a [u]int64 to a StringInfo buffer, which already has enough space
85 : : * preallocated.
86 : : */
87 : : static inline void
60 peter@eisentraut.org 88 : 1594439 : pq_writeint64(StringInfoData *pg_restrict buf, uint64 i)
89 : : {
2819 andres@anarazel.de 90 : 1594439 : uint64 ni = pg_hton64(i);
91 : :
92 [ - + ]: 1594439 : Assert(buf->len + (int) sizeof(uint64) <= buf->maxlen);
139 peter@eisentraut.org 93 :GNC 1594439 : memcpy(buf->data + buf->len, &ni, sizeof(uint64));
2819 andres@anarazel.de 94 :CBC 1594439 : buf->len += sizeof(uint64);
3077 95 : 1594439 : }
96 : :
97 : : /*
98 : : * Append a null-terminated text string (with conversion) to a buffer with
99 : : * preallocated space.
100 : : *
101 : : * NB: The pre-allocated space needs to be sufficient for the string after
102 : : * converting to client encoding.
103 : : *
104 : : * NB: passed text string must be null-terminated, and so is the data
105 : : * sent to the frontend.
106 : : */
107 : : static inline void
60 peter@eisentraut.org 108 : 553946 : pq_writestring(StringInfoData *pg_restrict buf, const char *pg_restrict str)
109 : : {
3077 andres@anarazel.de 110 : 553946 : int slen = strlen(str);
111 : : char *p;
112 : :
113 : 553946 : p = pg_server_to_client(str, slen);
114 [ + + ]: 553946 : if (p != str) /* actual conversion has been done? */
115 : 18 : slen = strlen(p);
116 : :
117 [ - + ]: 553946 : Assert(buf->len + slen + 1 <= buf->maxlen);
118 : :
139 peter@eisentraut.org 119 :GNC 553946 : memcpy(buf->data + buf->len, p, slen + 1);
3077 andres@anarazel.de 120 :CBC 553946 : buf->len += slen + 1;
121 : :
122 [ + + ]: 553946 : if (p != str)
123 : 18 : pfree(p);
124 : 553946 : }
125 : :
126 : : /* append a binary [u]int8 to a StringInfo buffer */
127 : : static inline void
2819 128 : 1916111 : pq_sendint8(StringInfo buf, uint8 i)
129 : : {
130 : 1916111 : enlargeStringInfo(buf, sizeof(uint8));
3077 131 : 1916111 : pq_writeint8(buf, i);
132 : 1916111 : }
133 : :
134 : : /* append a binary [u]int16 to a StringInfo buffer */
135 : : static inline void
2819 136 : 5323857 : pq_sendint16(StringInfo buf, uint16 i)
137 : : {
138 : 5323857 : enlargeStringInfo(buf, sizeof(uint16));
3077 139 : 5323857 : pq_writeint16(buf, i);
140 : 5323857 : }
141 : :
142 : : /* append a binary [u]int32 to a StringInfo buffer */
143 : : static inline void
2819 144 : 24595331 : pq_sendint32(StringInfo buf, uint32 i)
145 : : {
146 : 24595331 : enlargeStringInfo(buf, sizeof(uint32));
3077 147 : 24595331 : pq_writeint32(buf, i);
148 : 24595331 : }
149 : :
150 : : /* append a binary [u]int64 to a StringInfo buffer */
151 : : static inline void
2819 152 : 1594439 : pq_sendint64(StringInfo buf, uint64 i)
153 : : {
154 : 1594439 : enlargeStringInfo(buf, sizeof(uint64));
3077 155 : 1594439 : pq_writeint64(buf, i);
156 : 1594439 : }
157 : :
158 : : /* append a binary byte to a StringInfo buffer */
159 : : static inline void
2819 160 : 1916094 : pq_sendbyte(StringInfo buf, uint8 byt)
161 : : {
3077 162 : 1916094 : pq_sendint8(buf, byt);
163 : 1916094 : }
164 : :
165 : : /*
166 : : * Append a binary integer to a StringInfo buffer
167 : : *
168 : : * This function is deprecated; prefer use of the functions above.
169 : : */
170 : : static inline void
2819 171 : 115163 : pq_sendint(StringInfo buf, uint32 i, int b)
172 : : {
3077 173 [ - - + - ]: 115163 : switch (b)
174 : : {
3077 andres@anarazel.de 175 :UBC 0 : case 1:
2819 176 : 0 : pq_sendint8(buf, (uint8) i);
3077 177 : 0 : break;
178 : 0 : case 2:
2819 179 : 0 : pq_sendint16(buf, (uint16) i);
3077 180 : 0 : break;
3077 andres@anarazel.de 181 :CBC 115163 : case 4:
2819 182 : 115163 : pq_sendint32(buf, (uint32) i);
3077 183 : 115163 : break;
3077 andres@anarazel.de 184 :UBC 0 : default:
185 [ # # ]: 0 : elog(ERROR, "unsupported integer size %d", b);
186 : : break;
187 : : }
3077 andres@anarazel.de 188 :CBC 115163 : }
189 : :
190 : :
191 : : extern void pq_begintypsend(StringInfo buf);
192 : : extern bytea *pq_endtypsend(StringInfo buf);
193 : :
194 : : extern void pq_puttextmessage(char msgtype, const char *str);
195 : : extern void pq_putemptymessage(char msgtype);
196 : :
197 : : extern int pq_getmsgbyte(StringInfo msg);
198 : : extern unsigned int pq_getmsgint(StringInfo msg, int b);
199 : : extern int64 pq_getmsgint64(StringInfo msg);
200 : : extern float4 pq_getmsgfloat4(StringInfo msg);
201 : : extern float8 pq_getmsgfloat8(StringInfo msg);
202 : : extern const char *pq_getmsgbytes(StringInfo msg, int datalen);
203 : : extern void pq_copymsgbytes(StringInfo msg, void *buf, int datalen);
204 : : extern char *pq_getmsgtext(StringInfo msg, int rawbytes, int *nbytes);
205 : : extern const char *pq_getmsgstring(StringInfo msg);
206 : : extern const char *pq_getmsgrawstring(StringInfo msg);
207 : : extern void pq_getmsgend(StringInfo msg);
208 : :
209 : : #endif /* PQFORMAT_H */
|
