|
|
@ -18,6 +18,8 @@ |
|
|
|
|
|
|
|
|
|
|
|
#include <grpc/support/port_platform.h> |
|
|
|
#include <grpc/support/port_platform.h> |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#include <inttypes.h> |
|
|
|
|
|
|
|
|
|
|
|
#include "absl/memory/memory.h" |
|
|
|
#include "absl/memory/memory.h" |
|
|
|
|
|
|
|
|
|
|
|
#include "src/cpp/server/load_reporter/load_reporter_async_service_impl.h" |
|
|
|
#include "src/cpp/server/load_reporter/load_reporter_async_service_impl.h" |
|
|
@ -216,12 +218,12 @@ void LoadReporterAsyncServiceImpl::ReportLoadHandler::OnReadDone( |
|
|
|
load_report_interval_ms_ = |
|
|
|
load_report_interval_ms_ = |
|
|
|
static_cast<unsigned long>(load_report_interval.seconds() * 1000 + |
|
|
|
static_cast<unsigned long>(load_report_interval.seconds() * 1000 + |
|
|
|
load_report_interval.nanos() / 1000); |
|
|
|
load_report_interval.nanos() / 1000); |
|
|
|
gpr_log( |
|
|
|
gpr_log(GPR_INFO, |
|
|
|
GPR_INFO, |
|
|
|
"[LRS %p] Initial request received. Start load reporting (load " |
|
|
|
"[LRS %p] Initial request received. Start load reporting (load " |
|
|
|
"balanced host: %s, interval: %" PRIu64 |
|
|
|
"balanced host: %s, interval: %lu ms, lb_id_: %s, handler: %p)...", |
|
|
|
" ms, lb_id_: %s, handler: %p)...", |
|
|
|
service_, load_balanced_hostname_.c_str(), load_report_interval_ms_, |
|
|
|
service_, load_balanced_hostname_.c_str(), |
|
|
|
lb_id_.c_str(), this); |
|
|
|
load_report_interval_ms_, lb_id_.c_str(), this); |
|
|
|
SendReport(self, true /* ok */); |
|
|
|
SendReport(self, true /* ok */); |
|
|
|
// Expect this read to fail.
|
|
|
|
// Expect this read to fail.
|
|
|
|
{ |
|
|
|
{ |
|
|
|