97 buf->cursor = msgtype;
118 buf->cursor = msgtype;
144 bool countincludesself)
146 int extra = countincludesself ? 4 : 0;
200 int slen = strlen(
str);
372 int slen = strlen(
str);
406 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
407 errmsg(
"no data left in message")));
408 return (
unsigned char) msg->
data[msg->
cursor++];
440 elog(
ERROR,
"unsupported integer size %d",
b);
515 if (datalen < 0 || datalen > (msg->
len - msg->
cursor))
517 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
518 errmsg(
"insufficient data left in message")));
533 if (datalen < 0 || datalen > (msg->
len - msg->
cursor))
535 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
536 errmsg(
"insufficient data left in message")));
554 if (rawbytes < 0 || rawbytes > (msg->
len - msg->
cursor))
556 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
557 errmsg(
"insufficient data left in message")));
566 p = (
char *)
palloc(rawbytes + 1);
567 memcpy(p,
str, rawbytes);
597 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
598 errmsg(
"invalid string in message")));
626 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
627 errmsg(
"invalid string in message")));
642 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
643 errmsg(
"invalid message format")));
#define IS_HIGHBIT_SET(ch)
elog(ERROR, "%s: %s", p2, msg)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
#define ereport(elevel,...)
#define pq_putmessage(msgtype, s, len)
Assert(fmt[strlen(fmt) - 1] !='\n')
char * pg_client_to_server(const char *s, int len)
char * pg_server_to_client(const char *s, int len)
void pfree(void *pointer)
void resetStringInfo(StringInfo str)
void appendBinaryStringInfoNT(StringInfo str, const void *data, int datalen)
void appendBinaryStringInfo(StringInfo str, const void *data, int datalen)
void appendStringInfoChar(StringInfo str, char ch)
void initStringInfo(StringInfo str)
#define appendStringInfoCharMacro(str, ch)
#define SET_VARSIZE(PTR, len)