pdxx
/
libserverframe
mirror of https://github.com/happyfish100/libserverframe.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

generate seq_id only once per RPC

replication_quorum
YuQing 2022-06-29 15:02:38 +08:00
parent 990ef2d173
commit f63ede788e
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/idempotency/client/rpc_wrapper.h
View File

@ -44,7 +44,6 @@
&client_ctx->common_cfg.net_retry_cfg.interval_mm, \ &client_ctx->common_cfg.net_retry_cfg.interval_mm, \
&client_ctx->common_cfg.net_retry_cfg.network); \ &client_ctx->common_cfg.net_retry_cfg.network); \
\ \
while (1) { \
if (idempotency_enabled) { \ if (idempotency_enabled) { \
req_id = idempotency_client_channel_next_seq_id( \ req_id = idempotency_client_channel_next_seq_id( \
connection_params->channel); \ connection_params->channel); \
@ -52,6 +51,7 @@
req_id = 0; \ req_id = 0; \
} \ } \
\ \
while (1) { \
old_channel = connection_params != NULL ? \ old_channel = connection_params != NULL ? \
connection_params->channel : NULL; \ connection_params->channel : NULL; \
i = 0; \ i = 0; \