diff --git a/src/pika_client_conn.cc b/src/pika_client_conn.cc index 1ad2d2cc76..3ce101d8e7 100644 --- a/src/pika_client_conn.cc +++ b/src/pika_client_conn.cc @@ -146,7 +146,7 @@ std::shared_ptr PikaClientConn::DoCmd(const PikaCmdArgsType& argv, const st void PikaClientConn::ProcessSlowlog(const PikaCmdArgsType& argv, uint64_t do_duration) { if (time_stat_->total_time() > g_pika_conf->slowlog_slower_than()) { - g_pika_server->SlowlogPushEntry(argv, time_stat_->start_ts(), time_stat_->total_time()); + g_pika_server->SlowlogPushEntry(argv, time_stat_->start_ts() / 1000000, time_stat_->total_time()); if (g_pika_conf->slowlog_write_errorlog()) { bool trim = false; std::string slow_log; diff --git a/tests/integration/slowlog_test.go b/tests/integration/slowlog_test.go index 3fcce4d1c3..fa6f96a7c9 100644 --- a/tests/integration/slowlog_test.go +++ b/tests/integration/slowlog_test.go @@ -81,7 +81,8 @@ var _ = Describe("Slowlog Commands", func() { Expect(err).NotTo(HaveOccurred()) for i := 0; i < 10; i++ { - Expect(isBetween(time1.UnixNano(), time2.UnixNano(), time.Unix(0, result[i].Time.Unix()*1e3).UnixNano())).To(Equal(true)) + Expect(result[i].Time.Unix()).To(BeNumerically("~", 0, 9999999999)) + Expect(isBetween(time1.Unix(), time2.Unix(), result[i].Time.Unix())).To(Equal(true)) } }) })