Commit Graph

3552 Commits (f93f85eadfeefadbc6d75dfd8d4ee367232b464d)

Author SHA1 Message Date
Onder Kalaci f93f85eadf Remove tracking old GUC 2020-04-08 19:23:19 +02:00
Onder Kalaci 2325a6c68a Remove tracking 2020-04-08 19:19:00 +02:00
Onder Kalaci b52e72dd48 Apply code review feedback 2020-04-08 19:05:21 +02:00
Onder Kalaci 501e57e78e Apply code review feedback 2020-04-08 18:50:35 +02:00
Onder Kalaci f3394b2283 Apply code review feedback 2020-04-08 18:11:42 +02:00
Onder Kalaci af587edea1 Reorder commands as Marco noted:
```
This could throw an OOM. We should do:

Create MultiConnection (can error)
dlist_push_tail (can error)
sharedCounterIncremented = true (cannot error)
increment the shared memory counter (cannot error)
any error after this will be handled correctly in the abort handler
```
2020-04-08 17:39:07 +02:00
Onder Kalaci eadb18e758 Receive cancellations 2020-04-08 16:26:27 +02:00
Onder Kalaci d1ac5c5e00 Get rid of PG_TRY/PG_CATCH 2020-04-08 16:09:08 +02:00
Onder Kalaci 2a58d89b90 Should finish the connection first, then Decrement 2020-04-08 15:25:22 +02:00
Onder Kalaci 3e6180367b Do not wait by default, only executor waits 2020-04-08 14:30:28 +02:00
Onder Kalaci 24ba897b17 Allow COPY always continue 2020-04-08 12:57:35 +02:00
Onder Kalaci 1e22bcc8e7 Add tests for intermediate results 2020-04-08 10:47:53 +02:00
Onder Kalaci bd12d90597 Enable compile 2020-04-08 10:13:42 +02:00
Onder Kalaci cb97957717 Remove nodes that do not have any connections 2020-04-08 10:13:42 +02:00
Onder Kalaci a7254db8fd Fix rebase conflict 2020-04-08 10:13:42 +02:00
Onder Kalaci 597651add4 Add assert back 2020-04-08 10:13:42 +02:00
Onder Kalaci 310a0cd442 Effectively do not remove any entries 2020-04-08 10:13:42 +02:00
Onder Kalaci ffd7dcc88f Fix rebase conflict 2020-04-08 10:13:42 +02:00
Onder Kalaci ab345ab4fb Style fix 2020-04-08 10:13:42 +02:00
Onder Kalaci 9311b4b953 WIP handle node operations 2020-04-08 10:13:42 +02:00
Onder Kalaci b6b47370dc WIP on update/delete 2020-04-08 10:13:42 +02:00
Onder Kalaci 7cad050b62 Improve comment 2020-04-08 10:13:42 +02:00
Onder Kalaci ef49e8ba04 Improve readability 2020-04-08 10:13:42 +02:00
Onder Kalaci dd36dd2530 Remove useless check 2020-04-08 10:13:42 +02:00
Onder Kalaci 7fbbb28ee1 Rebase to master - the version files 2020-04-08 10:13:42 +02:00
Onder Kalaci 6b6d00ef38 Properly add the external function 2020-04-08 10:13:42 +02:00
Onder Kalaci dfe2354378 Some indentation/style fixes 2020-04-08 10:13:42 +02:00
Onder Kalaci 156d12483d do not forget to rethrow 2020-04-08 10:13:42 +02:00
Onder Kalaci 217b6520cb Guard against any issues on StartConnectionEstablishment 2020-04-08 10:13:42 +02:00
Onder Kalaci 5083f058f8 Improve comments 2020-04-08 10:13:42 +02:00
Onder Kalaci e09811cfe0 When force_max_query_parallelization is enabled, do not wait 2020-04-08 10:13:42 +02:00
Onder Kalaci 7f578c9c68 citus_inden 2020-04-08 10:13:42 +02:00
Onder Kalaci cf32de7620 Disable failing tests 2020-04-08 10:13:42 +02:00
Onder Kalaci b780b42c93 Rely on condition variable again 2020-04-08 10:13:42 +02:00
Onder Kalaci 8a123fb8e8 Add debug message, shorten sleep 2020-04-08 10:13:42 +02:00
Onder Kalaci 75fb6556b5 Defer pool start to first session 2020-04-08 10:13:42 +02:00
Onder Kalaci 3961f4517b Revert "Use condition variable instead of sleep"
This reverts commit bc282e8ee53b78cb4c88c6e10ccc00b5da11898a.
2020-04-08 10:13:42 +02:00
Onder Kalaci 96613c6b2b Use condition variable instead of sleep 2020-04-08 10:13:42 +02:00
Onder Kalaci cd4b9fd004 Minor refactoring 2020-04-08 10:13:42 +02:00
Onder Kalaci 7bff12571d Implement master_update_node 2020-04-08 10:13:42 +02:00
Onder Kalaci 531de5d848 Introduce CanUseOptionalConnection() to consider cached connections 2020-04-08 10:13:42 +02:00
Onder Kalaci 275d9d83f8 Improve assert 2020-04-08 10:13:42 +02:00
Onder Kalaci 452d0b1dcf Add more tests 2020-04-08 10:13:42 +02:00
Onder Kalaci 72a3e1df29 Add the first set of regression tests 2020-04-08 10:13:42 +02:00
Onder Kalaci 3d242ff5f9 Use LwLocks again 2020-04-08 10:13:42 +02:00
Onder Kalaci 593a3be1a3 Properly implement retry timeout 2020-04-08 10:13:42 +02:00
Onder Kalaci bed023c03d Add the GUC for MaxSharedPoolSize 2020-04-08 10:13:42 +02:00
Onder Kalaci 34dec931f4 Remove MaxTrackedWorkerNodes use MaxWorkerNodesTracked 2020-04-08 10:13:42 +02:00
Onder Kalaci 188e571d3c Replace LwLock with spinLock 2020-04-08 10:13:42 +02:00
Onder Kalaci ebb0ebc3c8 Naive implementation for Optional connection concept 2020-04-08 10:13:42 +02:00