GRPC Core  9.0.0
grpclb_client_stats.h
Go to the documentation of this file.
1 /*
2  *
3  * Copyright 2017 gRPC authors.
4  *
5  * Licensed under the Apache License, Version 2.0 (the "License");
6  * you may not use this file except in compliance with the License.
7  * You may obtain a copy of the License at
8  *
9  * http://www.apache.org/licenses/LICENSE-2.0
10  *
11  * Unless required by applicable law or agreed to in writing, software
12  * distributed under the License is distributed on an "AS IS" BASIS,
13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14  * See the License for the specific language governing permissions and
15  * limitations under the License.
16  *
17  */
18 
19 #ifndef GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_LB_POLICY_GRPCLB_GRPCLB_CLIENT_STATS_H
20 #define GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_LB_POLICY_GRPCLB_GRPCLB_CLIENT_STATS_H
21 
23 
24 #include <grpc/support/atm.h>
25 
30 
31 namespace grpc_core {
32 
33 class GrpcLbClientStats : public RefCounted<GrpcLbClientStats> {
34  public:
35  struct DropTokenCount {
37  int64_t count;
38 
40  : token(std::move(token)), count(count) {}
41  };
42 
44 
45  void AddCallStarted();
46  void AddCallFinished(bool finished_with_client_failed_to_send,
47  bool finished_known_received);
48 
49  void AddCallDropped(const char* token);
50 
51  void Get(int64_t* num_calls_started, int64_t* num_calls_finished,
52  int64_t* num_calls_finished_with_client_failed_to_send,
53  int64_t* num_calls_finished_known_received,
54  std::unique_ptr<DroppedCallCounts>* drop_token_counts);
55 
56  // A destruction function to use as the user_data key when attaching
57  // client stats to a grpc_mdelem.
58  static void Destroy(void* arg) {
59  static_cast<GrpcLbClientStats*>(arg)->Unref();
60  }
61 
62  private:
63  gpr_atm num_calls_started_ = 0;
64  gpr_atm num_calls_finished_ = 0;
65  gpr_atm num_calls_finished_with_client_failed_to_send_ = 0;
66  gpr_atm num_calls_finished_known_received_ = 0;
67  Mutex drop_count_mu_; // Guards drop_token_counts_.
68  std::unique_ptr<DroppedCallCounts> drop_token_counts_;
69 };
70 
71 } // namespace grpc_core
72 
73 #endif /* GRPC_CORE_EXT_FILTERS_CLIENT_CHANNEL_LB_POLICY_GRPCLB_GRPCLB_CLIENT_STATS_H \
74  */
Definition: inlined_vector.h:60
DropTokenCount(grpc_core::UniquePtr< char > token, int64_t count)
Definition: grpclb_client_stats.h:39
InlinedVector< DropTokenCount, 10 > DroppedCallCounts
Definition: grpclb_client_stats.h:43
Definition: grpclb_client_stats.h:35
void AddCallStarted()
Definition: grpclb_client_stats.cc:32
Definition: grpclb_client_stats.h:33
Round Robin Policy.
Definition: backend_metric.cc:24
static void Destroy(void *arg)
Definition: grpclb_client_stats.h:58
void AddCallFinished(bool finished_with_client_failed_to_send, bool finished_known_received)
Definition: grpclb_client_stats.cc:36
intptr_t gpr_atm
Definition: atm_gcc_atomic.h:30
void Unref()
Definition: ref_counted.h:268
std::unique_ptr< T, DefaultDeleteChar > UniquePtr
Definition: memory.h:45
int64_t count
Definition: grpclb_client_stats.h:37
Definition: ref_counted.h:248
void AddCallDropped(const char *token)
Definition: grpclb_client_stats.cc:48
grpc_core::UniquePtr< char > token
Definition: grpclb_client_stats.h:36
Definition: sync.h:40
void Get(int64_t *num_calls_started, int64_t *num_calls_finished, int64_t *num_calls_finished_with_client_failed_to_send, int64_t *num_calls_finished_known_received, std::unique_ptr< DroppedCallCounts > *drop_token_counts)
Definition: grpclb_client_stats.cc:76