tree 1ac79c971e25cc7fdc1710720016b809a7e5ba29
parent 543e51c7ecd842056f93859defd23b851bfe842e
author Yunze Xu <xyzinfernity@163.com> 1709175380 +0800
committer GitHub <noreply@github.com> 1709175380 +0800
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsFcBAABCAAQBQJl3/JUCRC1aQ7uu5UhlAAAaK0QAEk7rRlmzdwX8Hebt8gov0P1
 9t33V9RdAVr43IpfbA2wOX/vaabQ7roljsbxQt7LvvKgpzsQ9M5pvX40/tCSIS3a
 DmJZjM7pDCv2w9HWODYQQEjJdOWsroITRsWYyPJB2Ur4GjHfxreZvxG/6M+Yufk4
 IjOpl/gTrUROHIvvuCpYdA75mYktEMacstroS5Vhm/Cn7fnSpOZ0ePRf4DoTg4wG
 lKFm0yS6m6Q0Lcsf9wHBul8JN860yNywHB3yZZoIxld3wu12VuwxU/B3InaS1lbP
 2U+b2+lGnDC0hgu+8t82WiBEPG1GM5+ZAs60HqIlYHTwdREVPYkAJCiTiL3OppXL
 PoY/W2mBjoPZ1beJ5WbmqGkwBTkacMuiUDm5O0JlyqTPvZgE0RI3vKqEr2JMpHoB
 97dJWdfhNZ/uSyEckeYdZXP5sgnu8KV9dd62PAuY0YO0lIrsX1w3cEUAm1m5SomP
 tGuq7MA53rMi0H74+5uUP3Dxi/WTbuWFVNuny/4gk0X4SfpfMazG2kGgYMewQwoQ
 UfXFqaCerNpyqU3jIIyelh/2QMs+dWWW7qM0yeqdVSC9bJtTEUC5P0xA9TzfT7T8
 y/+n3t3IUhtMXGJQGpCMAHc4FNgH4VkAYLPTniMZLEMoUg2qeSrTd0SnVlPeeY+C
 MnueOG0wep1Ld98wHmmP
 =DnZe
 -----END PGP SIGNATURE-----
 

Fix blue-green migration might be stuck due to an existing reconnection (#406)

Fixes https://github.com/apache/pulsar-client-cpp/issues/405

### Motivation

After triggering a blue-green migration, the socket will be disconnected
and then schedule a reconnection to the blue cluster. However, the blue
cluster could never respond with a response for Producer or Subscribe
commands. Take producer as example, it means `connectionOpened` will not
complete and `reconnectionPending_` will not become false.

Then, after receiving a `CommandProducerClose` command from the blue
cluster, a new reconnection will be scheduled to the green cluster but
it will be skipped because `reconnectionPending_` is true, which means
the previous `connectionOpened` future is not completed until the 30s
timeout is reached.

```
2024-02-26 06:09:30.251 INFO  [139737465607744] HandlerBase:101 | [persistent://public/unload-test/topic-1708927732, sub, 0] Ignoring reconnection attempt since there's already a pending reconnection
2024-02-26 06:10:00.035 WARN  [139737859880512] ProducerImpl:291 | [persistent://public/unload-test/topic-1708927732, cluster-a-0-0] Failed to reconnect producer: TimeOut
```

### Modifications

When receiving the `TOPIC_MIGRATED` command, cancel the pending
`Producer` and `Subscribe` commands so that `connectionOpened` will fail
with a retryable error. In the next time of reconnection, the green
cluster will be connected.

Fix the `ExtensibleLoadManagerTest` with a more strict timeout check.
After this change, it will pass in about 3 seconds locally, while in CI
even if it passed, it takes about 70 seconds before.

Besides, fix the possible crash on macOS when closing the client, see
https://github.com/apache/pulsar-client-cpp/issues/405#issuecomment-1963969215