This is an automated email from the ASF dual-hosted git repository.
chenBright pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/brpc.git
The following commit(s) were added to refs/heads/master by this push:
new a23c6bb4 Fix event dispatcher latency units (#3681)
a23c6bb4 is described below
commit a23c6bb48a7a8aec870893267f80029f4645d41f
Author: Dongsheng He <[email protected]>
AuthorDate: Tue Nov 3 14:11:00 2026 +0800
Fix event dispatcher latency units (#3681)
---
src/brpc/event_dispatcher_epoll.cpp | 8 ++++----
src/brpc/event_dispatcher_kqueue.cpp | 8 ++++----
2 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/src/brpc/event_dispatcher_epoll.cpp
b/src/brpc/event_dispatcher_epoll.cpp
index e57ab902..1a3e74ef 100644
--- a/src/brpc/event_dispatcher_epoll.cpp
+++ b/src/brpc/event_dispatcher_epoll.cpp
@@ -232,18 +232,18 @@ void EventDispatcher::Run() {
|| (e[i].events & has_epollrdhup)
#endif
) {
- int64_t start_ns = butil::cpuwide_time_ns();
+ int64_t start_us = butil::cpuwide_time_us();
// We don't care about the return value.
CallInputEventCallback(e[i].data.u64, e[i].events,
_thread_attr);
- (*g_edisp_read_lantency) << (butil::cpuwide_time_ns() -
start_ns);
+ (*g_edisp_read_lantency) << (butil::cpuwide_time_us() -
start_us);
}
}
for (int i = 0; i < n; ++i) {
if (e[i].events & (EPOLLOUT | EPOLLERR | EPOLLHUP)) {
- int64_t start_ns = butil::cpuwide_time_ns();
+ int64_t start_us = butil::cpuwide_time_us();
// We don't care about the return value.
CallOutputEventCallback(e[i].data.u64, e[i].events,
_thread_attr);
- (*g_edisp_write_lantency) << (butil::cpuwide_time_ns() -
start_ns);
+ (*g_edisp_write_lantency) << (butil::cpuwide_time_us() -
start_us);
}
}
}
diff --git a/src/brpc/event_dispatcher_kqueue.cpp
b/src/brpc/event_dispatcher_kqueue.cpp
index 111c21fb..8bec41aa 100644
--- a/src/brpc/event_dispatcher_kqueue.cpp
+++ b/src/brpc/event_dispatcher_kqueue.cpp
@@ -210,20 +210,20 @@ void EventDispatcher::Run() {
}
for (int i = 0; i < n; ++i) {
if ((e[i].flags & EV_ERROR) || e[i].filter == EVFILT_READ) {
- int64_t start_ns = butil::cpuwide_time_ns();
+ int64_t start_us = butil::cpuwide_time_us();
// We don't care about the return value.
CallInputEventCallback((IOEventDataId)e[i].udata,
e[i].filter, _thread_attr);
- (*g_edisp_read_lantency) << (butil::cpuwide_time_ns() -
start_ns);
+ (*g_edisp_read_lantency) << (butil::cpuwide_time_us() -
start_us);
}
}
for (int i = 0; i < n; ++i) {
if ((e[i].flags & EV_ERROR) || e[i].filter == EVFILT_WRITE) {
- int64_t start_ns = butil::cpuwide_time_ns();
+ int64_t start_us = butil::cpuwide_time_us();
// We don't care about the return value.
CallOutputEventCallback((IOEventDataId)e[i].udata,
e[i].filter, _thread_attr);
- (*g_edisp_write_lantency) << (butil::cpuwide_time_ns() -
start_ns);
+ (*g_edisp_write_lantency) << (butil::cpuwide_time_us() -
start_us);
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
