We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7fd38fb commit 4522752Copy full SHA for 4522752
src/dmq.c
@@ -45,6 +45,7 @@
45
#include "storage/ipc.h"
46
#include "tcop/tcopprot.h"
47
#include "utils/dynahash.h"
48
+#include "utils/ps_status.h"
49
50
#define DMQ_MQ_SIZE ((Size) 65536)
51
#define DMQ_MQ_MAGIC 0x646d71
@@ -987,12 +988,16 @@ dmq_receiver_loop(PG_FUNCTION_ARGS)
987
988
StringInfoData s;
989
shm_mq_handle **mq_handles;
990
char *sender_name;
991
+ char *proc_name;
992
int i;
993
int receiver_id = -1;
994
double last_message_at = dmq_now();
995
996
sender_name = text_to_cstring(PG_GETARG_TEXT_PP(0));
997
998
+ proc_name = psprintf("mtm-dmq-receiver %s", sender_name);
999
+ set_ps_display(proc_name, true);
1000
+
1001
/* setup queues with backends */
1002
seg = dsm_create(dmq_toc_size(), 0);
1003
toc = shm_toc_create(DMQ_MQ_MAGIC, dsm_segment_address(seg),
0 commit comments