async.c的 ?
static void? NotifyMyFrontEnd(const char *channel, const char *payload, int32 srcPid) 函數中的主要邏輯是這樣的：
復制代碼 if (whereToSendOutput == DestRemote)? { ? ? StringInfoData buf; ? ? pq_beginmessage(&buf, 'A'); ? ? //cursor 為 A ? ? pq_sendint(&buf, srcPid, sizeof(int32)); //追加 srcPid ? ? pq_sendstring(&buf, channel); ? ? //追加消息通道名 ? ?
if (PG_PROTOCOL_MAJOR(FrontendProtocol) >= 3) ? ? pq_sendstring(&buf, payload); ? ? //追加消息字節流 ? ? pq_endmessage(&buf); ? ? //發送消息 ...... ? ? } 復制代碼 從上面看到，向StringInfoData 數據結構填充信息，就表示信息發送結束。
static void?
NotifyMyFrontEnd(const char *channel, const char *payload, int32 srcPid)
pq_endmessage是 pqformat.c 中函數它 調用 pqcomm.c 中的 pq_putmessage函數 pq_putmessage 調用 internal_putbyes函數 internal_putbyes 中 對pqSendPointer 進行操作
關于 pqSendPointer/pqRevPointer，有如下定義：
-------------------------------------------------------------------------------------------- static char PqSendBuffer[PQ_BUFFER_SIZE]; static int PqSendPointer; /* Next index to store a byte in PqSendBuffer */
static char PqRecvBuffer[PQ_BUFFER_SIZE]; static int c; /* Next index to read a byte from PqRecvBuffer */ static int PqRecvLength; /* End of data available in PqRecvBuffer */ ---------------------------------------------------------------------------------------------
查閱文檔資料：《PostgreSQL數據庫內核分析》中2.6.6中也有所說明。
從 internal_putbyes 中的代碼邏輯看到，移動指針未加任何鎖定機制。
復制代碼 static int ? ? internal_putbytes(const char *s, size_t len) ? ? { ? ? size_t ? ? amount; ? ? while (len > 0) ? ? { ? ? /* If buffer is full, then flush it out */ ? ? if (PqSendPointer >= PQ_BUFFER_SIZE) ? ? if (internal_flush()) ? ? return EOF;

amount = PQ_BUFFER_SIZE - PqSendPointer; ? ? if (amount > len) ? ? amount = len;
memcpy(PqSendBuffer + PqSendPointer, s, amount); ? ? PqSendPointer += amount; ? ? s += amount; ? ? len -= amount; ? ? } ? ? return 0; ? ? } ? ? 復制代碼 既然未加鎖，那么就可以這樣推斷：
在每一對客戶端和服務器端進程之間，都有這樣一個內存緩沖區。 換句話說，有多少個客戶端，就會產生多少個這樣的 內存緩沖區。
具體如何，還需進一步的驗證。








本文轉自健哥的數據花園博客園博客，原文鏈接：http://www.cnblogs.com/gaojian/archive/2012/07/17/2594718.html，如需轉載請自行聯系原作者

總結

以上是生活随笔為你收集整理的NotifyMyFrontEnd 函数背后的数据缓冲区(一)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。