aboutsummaryrefslogtreecommitdiff
path: root/src/backend/libpq/pqmq.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/backend/libpq/pqmq.c')
-rw-r--r--src/backend/libpq/pqmq.c18
1 files changed, 1 insertions, 17 deletions
diff --git a/src/backend/libpq/pqmq.c b/src/backend/libpq/pqmq.c
index f468441b7a2..d1a1f47a788 100644
--- a/src/backend/libpq/pqmq.c
+++ b/src/backend/libpq/pqmq.c
@@ -33,8 +33,6 @@ static int mq_flush_if_writable(void);
static bool mq_is_send_pending(void);
static int mq_putmessage(char msgtype, const char *s, size_t len);
static void mq_putmessage_noblock(char msgtype, const char *s, size_t len);
-static void mq_startcopyout(void);
-static void mq_endcopyout(bool errorAbort);
static const PQcommMethods PqCommMqMethods = {
mq_comm_reset,
@@ -42,9 +40,7 @@ static const PQcommMethods PqCommMqMethods = {
mq_flush_if_writable,
mq_is_send_pending,
mq_putmessage,
- mq_putmessage_noblock,
- mq_startcopyout,
- mq_endcopyout
+ mq_putmessage_noblock
};
/*
@@ -195,18 +191,6 @@ mq_putmessage_noblock(char msgtype, const char *s, size_t len)
elog(ERROR, "not currently supported");
}
-static void
-mq_startcopyout(void)
-{
- /* Nothing to do. */
-}
-
-static void
-mq_endcopyout(bool errorAbort)
-{
- /* Nothing to do. */
-}
-
/*
* Parse an ErrorResponse or NoticeResponse payload and populate an ErrorData
* structure with the results.