hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

make sure the RPC_NET_DELAY is monotonically increasing

Browse Source
This commit is contained in:
liucc1997
2025-03-27 04:45:57 +00:00
committed by ob-robot
parent 2c7850f495
commit c7be3f588a
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/observer/ob_srv_deliver.cpp
View File

@ -582,6 +582,10 @@ int ObSrvDeliver::deliver_rpc_request(ObRequest &req)
}
}
int64_t rpc_net_delay = req.get_receive_timestamp() - req.get_send_timestamp();
if (rpc_net_delay < 0) {
rpc_net_delay = 0;
}
if (!OB_SUCC(ret)) {
} else if (NULL != queue) {
@ -591,8 +595,7 @@ int ObSrvDeliver::deliver_rpc_request(ObRequest &req)
EVENT_INC(RPC_PACKET_IN);
EVENT_ADD(RPC_PACKET_IN_BYTES,
pkt.get_encoded_size() + OB_NET_HEADER_LENGTH);
EVENT_ADD(RPC_NET_DELAY,
req.get_receive_timestamp() - req.get_send_timestamp());
EVENT_ADD(RPC_NET_DELAY, rpc_net_delay);
EVENT_ADD(RPC_NET_FRAME_DELAY,
now - req.get_receive_timestamp());
}
@ -630,8 +633,7 @@ int ObSrvDeliver::deliver_rpc_request(ObRequest &req)
EVENT_INC(RPC_PACKET_IN);
EVENT_ADD(RPC_PACKET_IN_BYTES,
pkt.get_encoded_size() + OB_NET_HEADER_LENGTH);
EVENT_ADD(RPC_NET_DELAY,
req.get_receive_timestamp() - req.get_send_timestamp());
EVENT_ADD(RPC_NET_DELAY, rpc_net_delay);
EVENT_ADD(RPC_NET_FRAME_DELAY,
now - req.get_receive_timestamp());
}