pg.ddx.io  pgsql-bugs@postgresql.org mailing list archive  
help / color / mirror / Atom feed
From: PG Bug reporting form <noreply@postgresql.org>
To: pgsql-bugs@lists.postgresql.org
Cc: fft_665665@163.com
Subject: BUG #17441: shm_mq receive less data than the sender sends
Date: Sun, 20 Mar 2022 08:39:01 +0000
Message-ID: <17441-b67dc542f085e3ba@postgresql.org> (raw)

The following bug has been logged on the website:

Bug reference:      17441
Logged by:          ytf
Email address:      fft_665665@163.com
PostgreSQL version: 10.17
Operating system:   centos
Description:        

Dears, 

I launch one dynamic worker as the sender, use shm_mq send data to the
SELECT, which I register a copy hook to receive data from sender.
Each data length is 800.

When I set shm_mq SIZE to 16, there is no problem. Only speed is very
slow.

However, when I set shm_mq Size to 8192 or larger, I meet a problem. 

I first receive 800 length data , and after a few times, I only receive 732
length data. 

I registered the shm_mq like following :
#define QUEUE_SIZE 8192
mq = shm_mq_create(shm_toc_allocate(pcxt->toc, QUEUE_SIZE), QUEUE_SIZE);
shm_toc_insert(pcxt->toc, COS_KEY_QUEUE, mq);
shm_mq_set_receiver(mq, MyProc);



view thread (3+ messages)  latest in thread

Message-ID: <17441-b67dc542f085e3ba@postgresql.org>
Permalink:  ../17441-b67dc542f085e3ba@postgresql.org/
Also on:    postgresql.org/message-id/17441-b67dc542f085e3ba@postgresql.org

 · 

reply

Reply instructions:

You may reply publicly to this message via plain-text email
using any one of the following methods:

* Reply to all the recipients using the --to and --cc options:
  reply via email

  To: pgsql-bugs@postgresql.org
  Cc: noreply@postgresql.org, pgsql-bugs@lists.postgresql.org, fft_665665@163.com
  Subject: Re: BUG #17441: shm_mq receive less data than the sender sends
  In-Reply-To: <17441-b67dc542f085e3ba@postgresql.org>

* Save the following mbox file, import it into your mail client,
  and reply-to-all from there: mbox

This inbox is served by DDX for PostgreSQL; see mirroring instructions
for how to clone and mirror all data and code used for this inbox