forked frompostgres/postgres
- Notifications
You must be signed in to change notification settings - Fork6
Commitd1e0272
committed
Replace the pg_listener-based LISTEN/NOTIFY mechanism with an in-memory queue.
In addition, add support for a "payload" string to be passed along witheach notify event.This implementation should be significantly more efficient than the old one,and is also more compatible with Hot Standby usage. There is not yet anyfacility for HS slaves to receive notifications generated on the master,although such a thing is possible in future.Joachim Wieland, reviewed by Jeff Davis; also hacked on by me.1 parentfc5173a commitd1e0272
File tree
37 files changed
+1843
-756
lines changed- doc/src/sgml
- ref
- src
- backend
- access/transam
- catalog
- commands
- nodes
- parser
- storage
- ipc
- lmgr
- tcop
- utils/adt
- bin
- initdb
- psql
- include
- access
- catalog
- commands
- nodes
- storage
- test/regress
- expected
- sql
37 files changed
+1843
-756
lines changedLines changed: 1 addition & 68 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 |
| - | |
| 1 | + | |
2 | 2 |
| |
3 | 3 |
| |
4 | 4 |
| |
| |||
168 | 168 |
| |
169 | 169 |
| |
170 | 170 |
| |
171 |
| - | |
172 |
| - | |
173 |
| - | |
174 |
| - | |
175 |
| - | |
176 | 171 |
| |
177 | 172 |
| |
178 | 173 |
| |
| |||
3253 | 3248 |
| |
3254 | 3249 |
| |
3255 | 3250 |
| |
3256 |
| - | |
3257 |
| - | |
3258 |
| - | |
3259 |
| - | |
3260 |
| - | |
3261 |
| - | |
3262 |
| - | |
3263 |
| - | |
3264 |
| - | |
3265 |
| - | |
3266 |
| - | |
3267 |
| - | |
3268 |
| - | |
3269 |
| - | |
3270 |
| - | |
3271 |
| - | |
3272 |
| - | |
3273 |
| - | |
3274 |
| - | |
3275 |
| - | |
3276 |
| - | |
3277 |
| - | |
3278 |
| - | |
3279 |
| - | |
3280 |
| - | |
3281 |
| - | |
3282 |
| - | |
3283 |
| - | |
3284 |
| - | |
3285 |
| - | |
3286 |
| - | |
3287 |
| - | |
3288 |
| - | |
3289 |
| - | |
3290 |
| - | |
3291 |
| - | |
3292 |
| - | |
3293 |
| - | |
3294 |
| - | |
3295 |
| - | |
3296 |
| - | |
3297 |
| - | |
3298 |
| - | |
3299 |
| - | |
3300 |
| - | |
3301 |
| - | |
3302 |
| - | |
3303 |
| - | |
3304 |
| - | |
3305 |
| - | |
3306 |
| - | |
3307 |
| - | |
3308 |
| - | |
3309 |
| - | |
3310 |
| - | |
3311 |
| - | |
3312 |
| - | |
3313 |
| - | |
3314 |
| - | |
3315 |
| - | |
3316 |
| - | |
3317 |
| - | |
3318 | 3251 |
| |
3319 | 3252 |
| |
3320 | 3253 |
| |
|
Lines changed: 17 additions & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 |
| - | |
| 1 | + | |
2 | 2 |
| |
3 | 3 |
| |
4 | 4 |
| |
| |||
11529 | 11529 |
| |
11530 | 11530 |
| |
11531 | 11531 |
| |
| 11532 | + | |
| 11533 | + | |
| 11534 | + | |
| 11535 | + | |
| 11536 | + | |
| 11537 | + | |
11532 | 11538 |
| |
11533 | 11539 |
| |
11534 | 11540 |
| |
| |||
11674 | 11680 |
| |
11675 | 11681 |
| |
11676 | 11682 |
| |
| 11683 | + | |
| 11684 | + | |
| 11685 | + | |
| 11686 | + | |
| 11687 | + | |
| 11688 | + | |
| 11689 | + | |
| 11690 | + | |
| 11691 | + | |
| 11692 | + | |
11677 | 11693 |
| |
11678 | 11694 |
| |
11679 | 11695 |
| |
|
Lines changed: 25 additions & 27 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 |
| - | |
| 1 | + | |
2 | 2 |
| |
3 | 3 |
| |
4 | 4 |
| |
| |||
307 | 307 |
| |
308 | 308 |
| |
309 | 309 |
| |
310 |
| - | |
| 310 | + | |
311 | 311 |
| |
312 |
| - | |
| 312 | + | |
313 | 313 |
| |
314 | 314 |
| |
315 | 315 |
| |
316 | 316 |
| |
317 |
| - | |
| 317 | + | |
318 | 318 |
| |
319 | 319 |
| |
320 | 320 |
| |
321 | 321 |
| |
322 | 322 |
| |
323 | 323 |
| |
324 |
| - | |
| 324 | + | |
325 | 325 |
| |
326 | 326 |
| |
327 | 327 |
| |
328 | 328 |
| |
329 | 329 |
| |
330 | 330 |
| |
331 |
| - | |
| 331 | + | |
332 | 332 |
| |
333 | 333 |
| |
334 | 334 |
| |
| |||
481 | 481 |
| |
482 | 482 |
| |
483 | 483 |
| |
484 |
| - | |
| 484 | + | |
485 | 485 |
| |
486 | 486 |
| |
487 | 487 |
| |
| |||
4111 | 4111 |
| |
4112 | 4112 |
| |
4113 | 4113 |
| |
4114 |
| - | |
| 4114 | + | |
4115 | 4115 |
| |
4116 |
| - | |
| 4116 | + | |
4117 | 4117 |
| |
4118 |
| - | |
4119 |
| - | |
4120 |
| - | |
4121 |
| - | |
4122 |
| - | |
4123 |
| - | |
| 4118 | + | |
| 4119 | + | |
4124 | 4120 |
| |
4125 | 4121 |
| |
4126 | 4122 |
| |
4127 | 4123 |
| |
4128 |
| - | |
| 4124 | + | |
| 4125 | + | |
4129 | 4126 |
| |
4130 | 4127 |
| |
4131 | 4128 |
| |
4132 | 4129 |
| |
4133 | 4130 |
| |
4134 | 4131 |
| |
4135 |
| - | |
4136 |
| - | |
4137 |
| - | |
4138 |
| - | |
4139 |
| - | |
4140 |
| - | |
| 4132 | + | |
| 4133 | + | |
| 4134 | + | |
| 4135 | + | |
| 4136 | + | |
| 4137 | + | |
4141 | 4138 |
| |
4142 | 4139 |
| |
4143 | 4140 |
| |
4144 | 4141 |
| |
4145 |
| - | |
| 4142 | + | |
4146 | 4143 |
| |
4147 |
| - | |
| 4144 | + | |
4148 | 4145 |
| |
4149 | 4146 |
| |
| 4147 | + | |
4150 | 4148 |
| |
4151 | 4149 |
| |
4152 | 4150 |
| |
4153 | 4151 |
| |
4154 | 4152 |
| |
4155 |
| - | |
4156 |
| - | |
4157 |
| - | |
| 4153 | + | |
| 4154 | + | |
| 4155 | + | |
4158 | 4156 |
| |
4159 | 4157 |
| |
4160 | 4158 |
| |
|
Lines changed: 10 additions & 13 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
1 |
| - | |
| 1 | + | |
2 | 2 |
| |
3 | 3 |
| |
4 | 4 |
| |
| |||
354 | 354 |
| |
355 | 355 |
| |
356 | 356 |
| |
357 |
| - | |
| 357 | + | |
358 | 358 |
| |
359 | 359 |
| |
360 | 360 |
| |
| |||
992 | 992 |
| |
993 | 993 |
| |
994 | 994 |
| |
995 |
| - | |
| 995 | + | |
996 | 996 |
| |
997 | 997 |
| |
998 | 998 |
| |
| |||
1117 | 1117 |
| |
1118 | 1118 |
| |
1119 | 1119 |
| |
1120 |
| - | |
| 1120 | + | |
1121 | 1121 |
| |
1122 | 1122 |
| |
1123 | 1123 |
| |
| |||
1340 | 1340 |
| |
1341 | 1341 |
| |
1342 | 1342 |
| |
1343 |
| - | |
| 1343 | + | |
1344 | 1344 |
| |
1345 | 1345 |
| |
1346 | 1346 |
| |
| |||
1951 | 1951 |
| |
1952 | 1952 |
| |
1953 | 1953 |
| |
1954 |
| - | |
| 1954 | + | |
1955 | 1955 |
| |
1956 | 1956 |
| |
1957 | 1957 |
| |
| |||
2500 | 2500 |
| |
2501 | 2501 |
| |
2502 | 2502 |
| |
2503 |
| - | |
| 2503 | + | |
2504 | 2504 |
| |
2505 | 2505 |
| |
2506 | 2506 |
| |
| |||
3187 | 3187 |
| |
3188 | 3188 |
| |
3189 | 3189 |
| |
3190 |
| - | |
| 3190 | + | |
3191 | 3191 |
| |
3192 | 3192 |
| |
3193 | 3193 |
| |
| |||
3197 | 3197 |
| |
3198 | 3198 |
| |
3199 | 3199 |
| |
3200 |
| - | |
3201 |
| - | |
3202 |
| - | |
| 3200 | + | |
3203 | 3201 |
| |
3204 | 3202 |
| |
3205 | 3203 |
| |
| |||
4353 | 4351 |
| |
4354 | 4352 |
| |
4355 | 4353 |
| |
4356 |
| - | |
| 4354 | + | |
4357 | 4355 |
| |
4358 | 4356 |
| |
4359 | 4357 |
| |
| |||
4364 | 4362 |
| |
4365 | 4363 |
| |
4366 | 4364 |
| |
4367 |
| - | |
4368 | 4365 |
|
0 commit comments
Comments
(0)