consider the fetch log bandwidth is set as a very small value

This commit is contained in:
liucc1997 2023-07-13 11:47:55 +00:00 committed by ob-robot
parent ac62ba8388
commit 647ba966b3
3 changed files with 6 additions and 2 deletions

View File

@ -80,7 +80,7 @@ static void sock_destroy(sock_t* s) {
static void eloop_handle_sock_event(sock_t* s) { static void eloop_handle_sock_event(sock_t* s) {
int err = 0; int err = 0;
if (skt(s, ERR) || skt(s, HUP)) { if (skt(s, ERR) || skt(s, HUP)) {
rk_info("sock destroy: sock=%p, connection=%s, err=%d", s, T2S(sock_fd, s->fd), err); rk_info("sock destroy: sock=%p, connection=%s, s->mask=0x%x", s, T2S(sock_fd, s->fd), s->mask);
sock_destroy(s); sock_destroy(s);
} else if (0 == (err = s->handle_event(s))) { } else if (0 == (err = s->handle_event(s))) {
// yield // yield

View File

@ -65,7 +65,10 @@ static int rl_timerfd_handle_event(rl_timerfd_t* s) {
} }
} else { } else {
// read data // read data
int64_t avail_bytes = 65536; // read only up to 64k once int64_t avail_bytes = rl->bw * 0.1 + 1;
if (avail_bytes > 65536) {
avail_bytes = 65536; // read only up to 64k once
}
int64_t temp_bytes = avail_bytes; int64_t temp_bytes = avail_bytes;
int rl_err = 0; int rl_err = 0;
dlink_t* last_dlink = rl_queue->prev; dlink_t* last_dlink = rl_queue->prev;

View File

@ -114,6 +114,7 @@ int ObNetEndpointIngressManager::collect_predict_bw(ObNetEndpointKVArray &update
const ObNetEndpointKey &endpoint_key = delete_keys[i]; const ObNetEndpointKey &endpoint_key = delete_keys[i];
if (OB_FAIL(ingress_plan_map_.erase_refactored(endpoint_key))) { if (OB_FAIL(ingress_plan_map_.erase_refactored(endpoint_key))) {
LOG_ERROR("failed to erase endpoint", K(ret), K(endpoint_key)); LOG_ERROR("failed to erase endpoint", K(ret), K(endpoint_key));
ret = OB_SUCCESS; // ignore error
} }
} }
} }