| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| H A D | load_balancer_api.cc | 115 grpc_core::GrpcLbClientStats* client_stats) { in grpc_grpclb_load_report_request_create() argument
119 req->client_stats.has_timestamp = true; in grpc_grpclb_load_report_request_create()
121 req->client_stats.has_num_calls_started = true; in grpc_grpclb_load_report_request_create()
122 req->client_stats.has_num_calls_finished = true; in grpc_grpclb_load_report_request_create()
125 req->client_stats.has_num_calls_finished_known_received = true; in grpc_grpclb_load_report_request_create()
126 req->client_stats.calls_finished_with_drop.funcs.encode = encode_drops; in grpc_grpclb_load_report_request_create()
129 client_stats->Get( in grpc_grpclb_load_report_request_create()
130 &req->client_stats.num_calls_started, in grpc_grpclb_load_report_request_create()
131 &req->client_stats.num_calls_finished, in grpc_grpclb_load_report_request_create()
132 &req->client_stats.num_calls_finished_with_client_failed_to_send, in grpc_grpclb_load_report_request_create()
[all …]
|
| H A D | client_load_reporting_filter.cc | 41 grpc_core::RefCountedPtr<grpc_core::GrpcLbClientStats> client_stats; member
82 if (calld->client_stats != nullptr) { in destroy_call_elem()
85 calld->client_stats->AddCallFinished( in destroy_call_elem()
103 grpc_core::GrpcLbClientStats* client_stats = in start_transport_stream_op_batch() local
106 if (client_stats != nullptr) { in start_transport_stream_op_batch()
107 calld->client_stats = client_stats->Ref(); in start_transport_stream_op_batch()
|
| H A D | grpclb.cc | 237 GrpcLbClientStats* client_stats) const;
265 RefCountedPtr<GrpcLbClientStats> client_stats) in Picker() argument
269 client_stats_(std::move(client_stats)) {} in Picker()
492 GrpcLbClientStats* client_stats) const { in GetServerAddressList()
510 if (client_stats != nullptr) { in GetServerAddressList()
513 client_stats->Ref().release()) == client_stats); in GetServerAddressList()
593 if (client_stats != nullptr) { in Pick()
594 client_stats->AddCallStarted(); in Pick()
694 RefCountedPtr<GrpcLbClientStats> client_stats; in UpdateState() local
696 parent_->lb_calld_->client_stats() != nullptr) { in UpdateState()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/ext/filters/client_channel/lb_policy/xds/ |
| H A D | xds_load_balancer_api.cc | 115 grpc_core::XdsLbClientStats* client_stats) { in xds_grpclb_load_report_request_create_locked() argument
119 req->client_stats.has_timestamp = true; in xds_grpclb_load_report_request_create_locked()
121 req->client_stats.has_num_calls_started = true; in xds_grpclb_load_report_request_create_locked()
122 req->client_stats.has_num_calls_finished = true; in xds_grpclb_load_report_request_create_locked()
125 req->client_stats.has_num_calls_finished_known_received = true; in xds_grpclb_load_report_request_create_locked()
126 req->client_stats.calls_finished_with_drop.funcs.encode = encode_drops; in xds_grpclb_load_report_request_create_locked()
129 client_stats->GetLocked( in xds_grpclb_load_report_request_create_locked()
130 &req->client_stats.num_calls_started, in xds_grpclb_load_report_request_create_locked()
131 &req->client_stats.num_calls_finished, in xds_grpclb_load_report_request_create_locked()
132 &req->client_stats.num_calls_finished_with_client_failed_to_send, in xds_grpclb_load_report_request_create_locked()
[all …]
|
| /dports/www/h2o-devel/h2o-dcc7134/examples/libh2o/ |
| H A D | latency-optimization.c | 50 } client_stats; variable
143 if (client_stats.sig_received_at == 0) { in client_on_read_second()
146 client_stats.sig_received_at = h2o_now(h2o_socket_get_loop(sock)); in client_on_read_second()
149 ++client_stats.bytes_before_sig; in client_on_read_second()
152 client_stats.bytes_received += sock->input->size; in client_on_read_second()
155 if (client_stats.bytes_received >= 1024 * 1024) { in client_on_read_second()
158 client_stats.sig_received_at - client_stats.resp_start_at); in client_on_read_second()
159 …rintf("Total: %" PRIu64 " octets, %" PRIu64 " ms\n", client_stats.bytes_received, now - client_sta… in client_on_read_second()
172 client_stats.resp_start_at = h2o_now(h2o_socket_get_loop(sock)); in client_on_read_first()
173 client_stats.bytes_before_sig = sock->input->size; in client_on_read_first()
[all …]
|
| /dports/devel/grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| H A D | client_load_reporting_filter.cc | 44 grpc_core::RefCountedPtr<grpc_core::GrpcLbClientStats> client_stats; member
87 if (calld->client_stats != nullptr) { in clr_destroy_call_elem()
90 calld->client_stats->AddCallFinished( in clr_destroy_call_elem()
109 grpc_core::GrpcLbClientStats* client_stats = in clr_start_transport_stream_op_batch() local
113 if (client_stats != nullptr) { in clr_start_transport_stream_op_batch()
114 calld->client_stats.reset(client_stats); in clr_start_transport_stream_op_batch()
|
| H A D | grpclb.cc | 306 GrpcLbClientStats* client_stats) const;
573 GrpcLbClientStats* client_stats) const { in GetServerAddressList()
575 if (client_stats != nullptr) stats = client_stats->Ref(); in GetServerAddressList()
649 GrpcLbClientStats* client_stats = subchannel_wrapper->client_stats(); in Pick() local
650 if (client_stats != nullptr) { in Pick()
659 client_stats->AddCallStarted(); in Pick()
694 RefCountedPtr<GrpcLbClientStats> client_stats = attribute->client_stats(); in CreateSubchannel() local
699 std::move(client_stats)); in CreateSubchannel()
724 RefCountedPtr<GrpcLbClientStats> client_stats; in UpdateState() local
727 client_stats = parent_->lb_calld_->client_stats()->Ref(); in UpdateState()
[all …]
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| H A D | client_load_reporting_filter.cc | 44 grpc_core::RefCountedPtr<grpc_core::GrpcLbClientStats> client_stats; member
87 if (calld->client_stats != nullptr) { in clr_destroy_call_elem()
90 calld->client_stats->AddCallFinished( in clr_destroy_call_elem()
109 grpc_core::GrpcLbClientStats* client_stats = in clr_start_transport_stream_op_batch() local
113 if (client_stats != nullptr) { in clr_start_transport_stream_op_batch()
114 calld->client_stats.reset(client_stats); in clr_start_transport_stream_op_batch()
|
| H A D | grpclb.cc | 306 GrpcLbClientStats* client_stats) const;
573 GrpcLbClientStats* client_stats) const { in GetServerAddressList()
575 if (client_stats != nullptr) stats = client_stats->Ref(); in GetServerAddressList()
649 GrpcLbClientStats* client_stats = subchannel_wrapper->client_stats(); in Pick() local
650 if (client_stats != nullptr) { in Pick()
659 client_stats->AddCallStarted(); in Pick()
694 RefCountedPtr<GrpcLbClientStats> client_stats = attribute->client_stats(); in CreateSubchannel() local
699 std::move(client_stats)); in CreateSubchannel()
724 RefCountedPtr<GrpcLbClientStats> client_stats; in UpdateState() local
727 client_stats = parent_->lb_calld_->client_stats()->Ref(); in UpdateState()
[all …]
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| H A D | client_load_reporting_filter.cc | 44 grpc_core::RefCountedPtr<grpc_core::GrpcLbClientStats> client_stats; member
87 if (calld->client_stats != nullptr) { in clr_destroy_call_elem()
90 calld->client_stats->AddCallFinished( in clr_destroy_call_elem()
109 grpc_core::GrpcLbClientStats* client_stats = in clr_start_transport_stream_op_batch() local
113 if (client_stats != nullptr) { in clr_start_transport_stream_op_batch()
114 calld->client_stats.reset(client_stats); in clr_start_transport_stream_op_batch()
|
| H A D | grpclb.cc | 306 GrpcLbClientStats* client_stats) const;
573 GrpcLbClientStats* client_stats) const { in GetServerAddressList()
575 if (client_stats != nullptr) stats = client_stats->Ref(); in GetServerAddressList()
649 GrpcLbClientStats* client_stats = subchannel_wrapper->client_stats(); in Pick() local
650 if (client_stats != nullptr) { in Pick()
659 client_stats->AddCallStarted(); in Pick()
694 RefCountedPtr<GrpcLbClientStats> client_stats = attribute->client_stats(); in CreateSubchannel() local
699 std::move(client_stats)); in CreateSubchannel()
724 RefCountedPtr<GrpcLbClientStats> client_stats; in UpdateState() local
727 client_stats = parent_->lb_calld_->client_stats()->Ref(); in UpdateState()
[all …]
|
| /dports/devel/grpc134/grpc-1.34.1/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| H A D | client_load_reporting_filter.cc | 44 grpc_core::RefCountedPtr<grpc_core::GrpcLbClientStats> client_stats; member
87 if (calld->client_stats != nullptr) { in clr_destroy_call_elem()
90 calld->client_stats->AddCallFinished( in clr_destroy_call_elem()
114 grpc_core::GrpcLbClientStats* client_stats = in clr_start_transport_stream_op_batch() local
118 if (client_stats != nullptr) { in clr_start_transport_stream_op_batch()
119 calld->client_stats.reset(client_stats); in clr_start_transport_stream_op_batch()
|
| H A D | grpclb.cc | 245 client_stats_(std::move(client_stats)) {} in SubchannelWrapper()
306 GrpcLbClientStats* client_stats) const;
554 GrpcLbClientStats* client_stats) const { in GetServerAddressList()
556 if (client_stats != nullptr) stats = client_stats->Ref(); in GetServerAddressList()
631 GrpcLbClientStats* client_stats = subchannel_wrapper->client_stats(); in Pick() local
632 if (client_stats != nullptr) { in Pick()
641 client_stats->AddCallStarted(); in Pick()
676 RefCountedPtr<GrpcLbClientStats> client_stats = attribute->client_stats(); in CreateSubchannel() local
705 RefCountedPtr<GrpcLbClientStats> client_stats; in UpdateState() local
708 client_stats = parent_->lb_calld_->client_stats()->Ref(); in UpdateState()
[all …]
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| H A D | client_load_reporting_filter.cc | 44 grpc_core::RefCountedPtr<grpc_core::GrpcLbClientStats> client_stats; member
87 if (calld->client_stats != nullptr) { in clr_destroy_call_elem()
90 calld->client_stats->AddCallFinished( in clr_destroy_call_elem()
114 grpc_core::GrpcLbClientStats* client_stats = in clr_start_transport_stream_op_batch() local
118 if (client_stats != nullptr) { in clr_start_transport_stream_op_batch()
119 calld->client_stats.reset(client_stats); in clr_start_transport_stream_op_batch()
|
| H A D | grpclb.cc | 244 GrpcLbClientStats* client_stats) const;
276 client_stats_(std::move(client_stats)) {} in Picker()
475 client_stats->Ref().release(); in client_stats_copy()
480 client_stats->Unref(); in client_stats_destroy()
530 GrpcLbClientStats* client_stats) const { in GetServerAddressList()
561 if (client_stats != nullptr) { in GetServerAddressList()
620 GrpcLbClientStats* client_stats = in Pick() local
630 client_stats->AddCallStarted(); in Pick()
698 RefCountedPtr<GrpcLbClientStats> client_stats; in UpdateState() local
700 parent_->lb_calld_->client_stats() != nullptr) { in UpdateState()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/remoting/protocol/ |
| H A D | performance_tracker.cc | 181 DCHECK(!stats.client_stats.time_received.is_null()); in OnVideoFrameStats()
185 DCHECK(!stats.client_stats.time_rendered.is_null()); in OnVideoFrameStats()
186 DCHECK(!stats.client_stats.time_decoded.is_null()); in OnVideoFrameStats()
188 stats.client_stats.time_decoded - stats.client_stats.time_received; in OnVideoFrameStats()
196 stats.client_stats.time_rendered - stats.client_stats.time_decoded; in OnVideoFrameStats()
211 ? stats.client_stats.time_rendered in OnVideoFrameStats()
212 : stats.client_stats.time_received; in OnVideoFrameStats()
234 (time_rendered - stats.client_stats.time_received); in OnVideoFrameStats()
|
| H A D | webrtc_video_renderer_adapter.cc | 149 frame_stats.client_stats = client_stats_queue_.front().second; in OnVideoFrameStats()
203 std::unique_ptr<ClientFrameStats> client_stats) { in FrameRendered() argument
209 client_stats->time_rendered = base::TimeTicks::Now(); in FrameRendered()
231 client_stats_queue_.push_back(std::make_pair(frame_id, *client_stats)); in FrameRendered()
241 frame_stats.client_stats = *client_stats; in FrameRendered()
|
| H A D | connection_unittest.cc | 623 EXPECT_FALSE(stats.client_stats.time_received.is_null()); in TEST_P()
624 EXPECT_FALSE(stats.client_stats.time_decoded.is_null()); in TEST_P()
625 EXPECT_FALSE(stats.client_stats.time_rendered.is_null()); in TEST_P()
632 stats.client_stats.time_received); in TEST_P()
633 EXPECT_LE(stats.client_stats.time_received, stats.client_stats.time_decoded); in TEST_P()
634 EXPECT_LE(stats.client_stats.time_decoded, stats.client_stats.time_rendered); in TEST_P()
635 EXPECT_LE(stats.client_stats.time_rendered, finish_time); in TEST_P()
|
| /dports/devel/grpc130/grpc-1.30.2/test/cpp/end2end/ |
| H A D | grpclb_end2end_test.cc | 275 request.client_stats() in BalanceLoad()
472 ClientStats client_stats; in WaitForLoadReports() local
476 return client_stats; in WaitForLoadReports()
1840 ClientStats client_stats; in TEST_F() local
1842 client_stats += WaitForLoadReports(); in TEST_F()
1843 } while (client_stats.num_calls_finished != in TEST_F()
1846 client_stats.num_calls_started); in TEST_F()
1907 client_stats = WaitForLoadReports(); in TEST_F()
1966 client_stats.num_calls_started); in TEST_F()
1969 client_stats.num_calls_finished); in TEST_F()
[all …]
|
| /dports/devel/grpc/grpc-1.42.0/test/cpp/end2end/ |
| H A D | grpclb_end2end_test.cc | 255 request.client_stats() in BalanceLoad()
442 ClientStats client_stats; in WaitForLoadReports() local
446 return client_stats; in WaitForLoadReports()
1883 ClientStats client_stats; in TEST_F() local
1885 client_stats += WaitForLoadReports(); in TEST_F()
1886 } while (client_stats.num_calls_finished != in TEST_F()
1889 client_stats.num_calls_started); in TEST_F()
1948 client_stats = WaitForLoadReports(); in TEST_F()
2007 client_stats.num_calls_started); in TEST_F()
2010 client_stats.num_calls_finished); in TEST_F()
[all …]
|
| /dports/devel/grpc134/grpc-1.34.1/test/cpp/end2end/ |
| H A D | grpclb_end2end_test.cc | 291 request.client_stats() in BalanceLoad()
475 ClientStats client_stats; in WaitForLoadReports() local
479 return client_stats; in WaitForLoadReports()
1870 ClientStats client_stats; in TEST_F() local
1872 client_stats += WaitForLoadReports(); in TEST_F()
1873 } while (client_stats.num_calls_finished != in TEST_F()
1876 client_stats.num_calls_started); in TEST_F()
1935 client_stats = WaitForLoadReports(); in TEST_F()
1994 client_stats.num_calls_started); in TEST_F()
1997 client_stats.num_calls_finished); in TEST_F()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/test/cpp/end2end/ |
| H A D | grpclb_end2end_test.cc | 263 request.client_stats().num_calls_started(); in BalanceLoad()
267 request.client_stats() in BalanceLoad()
451 ClientStats client_stats; in WaitForLoadReports() local
455 return client_stats; in WaitForLoadReports()
1859 client_stats.num_calls_started); in TEST_F()
1861 client_stats.num_calls_finished); in TEST_F()
1887 ClientStats client_stats = WaitForLoadReports(); in TEST_F() local
1920 client_stats = WaitForLoadReports(); in TEST_F()
1979 client_stats.num_calls_started); in TEST_F()
1982 client_stats.num_calls_finished); in TEST_F()
[all …]
|
| /dports/www/domoticz/domoticz-2020.2/extern/mosquitto/src/db_dump/ |
| H A D | db_dump.c | 59 static int client_stats = 0; variable
161 if(client_stats){ in dump__client_chunk_process()
203 if(client_stats){ in dump__client_msg_chunk_process()
295 if(client_stats){ in dump__msg_store_chunk_process()
359 if(client_stats){ in dump__sub_chunk_process()
396 client_stats = 1; in main()
468 if(client_stats){ in main()
|
| /dports/net/mosquitto/mosquitto-2.0.13/apps/db_dump/ |
| H A D | db_dump.c | 64 static int client_stats = 0; variable
164 if(client_stats){ in dump__client_chunk_process()
206 if(client_stats){ in dump__client_msg_chunk_process()
311 if(client_stats){ in dump__msg_store_chunk_process()
375 if(client_stats){ in dump__sub_chunk_process()
411 client_stats = 1; in main()
489 if(client_stats){ in main()
|
| /dports/devel/grpc/grpc-1.42.0/src/php/tests/qps/generated_code/Grpc/Testing/ |
| H A D | ScenarioResult.php | 35 private $client_stats; variable in Grpc\\Testing\\ScenarioResult
161 return $this->client_stats;
174 $this->client_stats = $arr;
|