|
30 | 30 | * |
31 | 31 | * |
32 | 32 | * IDENTIFICATION |
33 | | - * $PostgreSQL: pgsql/src/backend/replication/walsender.c,v 1.18 2010/04/28 16:10:42 heikki Exp $ |
| 33 | + * $PostgreSQL: pgsql/src/backend/replication/walsender.c,v 1.19 2010/04/28 16:54:15 tgl Exp $ |
34 | 34 | * |
35 | 35 | *------------------------------------------------------------------------- |
36 | 36 | */ |
@@ -268,8 +268,7 @@ WalSndHandshake(void) |
268 | 268 | if (wal_level==WAL_LEVEL_MINIMAL) |
269 | 269 | ereport(FATAL, |
270 | 270 | (errcode(ERRCODE_CANNOT_CONNECT_NOW), |
271 | | -errmsg("standby connections not allowed because wal_level='minimal'"))); |
272 | | - |
| 271 | +errmsg("standby connections not allowed because wal_level=\"minimal\""))); |
273 | 272 |
|
274 | 273 | /* Send a CopyOutResponse message, and start streaming */ |
275 | 274 | pq_beginmessage(&buf,'H'); |
@@ -838,21 +837,17 @@ WalSndShmemInit(void) |
838 | 837 | WalSndCtl= (WalSndCtlData*) |
839 | 838 | ShmemInitStruct("Wal Sender Ctl",WalSndShmemSize(),&found); |
840 | 839 |
|
841 | | -if (WalSndCtl==NULL) |
842 | | -ereport(FATAL, |
843 | | -(errcode(ERRCODE_OUT_OF_MEMORY), |
844 | | -errmsg("not enough shared memory for walsender"))); |
845 | | -if (found) |
846 | | -return;/* already initialized */ |
847 | | - |
848 | | -/* Initialize the data structures */ |
849 | | -MemSet(WalSndCtl,0,WalSndShmemSize()); |
850 | | - |
851 | | -for (i=0;i<max_wal_senders;i++) |
| 840 | +if (!found) |
852 | 841 | { |
853 | | -WalSnd*walsnd=&WalSndCtl->walsnds[i]; |
| 842 | +/* First time through, so initialize */ |
| 843 | +MemSet(WalSndCtl,0,WalSndShmemSize()); |
| 844 | + |
| 845 | +for (i=0;i<max_wal_senders;i++) |
| 846 | +{ |
| 847 | +WalSnd*walsnd=&WalSndCtl->walsnds[i]; |
854 | 848 |
|
855 | | -SpinLockInit(&walsnd->mutex); |
| 849 | +SpinLockInit(&walsnd->mutex); |
| 850 | +} |
856 | 851 | } |
857 | 852 | } |
858 | 853 |
|
|