SetupLoadTest(config, num_threads_);
}
- virtual ~SynchronousClient() {}
+ ~SynchronousClient() override {}
virtual bool InitThreadFuncImpl(size_t thread_idx) = 0;
virtual bool ThreadFuncImpl(HistogramEntry* entry, size_t thread_idx) = 0;
: SynchronousClient(config) {
StartThreads(num_threads_);
}
- ~SynchronousUnaryClient() {}
+ ~SynchronousUnaryClient() override {}
bool InitThreadFuncImpl(size_t /*thread_idx*/) override { return true; }
}
private:
- void DestroyMultithreading() override final { EndThreads(); }
+ void DestroyMultithreading() final { EndThreads(); }
};
template <class StreamType>
messages_issued_(num_threads_) {
StartThreads(num_threads_);
}
- virtual ~SynchronousStreamingClient() {
+ ~SynchronousStreamingClient() override {
CleanupAllStreams([this](size_t thread_idx) {
// Don't log any kind of error since we may have canceled this
stream_[thread_idx]->Finish().IgnoreError();
}
private:
- void DestroyMultithreading() override final {
+ void DestroyMultithreading() final {
CleanupAllStreams(
[this](size_t thread_idx) { context_[thread_idx].TryCancel(); });
EndThreads();
public:
SynchronousStreamingPingPongClient(const ClientConfig& config)
: SynchronousStreamingClient(config) {}
- ~SynchronousStreamingPingPongClient() {
+ ~SynchronousStreamingPingPongClient() override {
CleanupAllStreams(
[this](size_t thread_idx) { stream_[thread_idx]->WritesDone(); });
}
public:
SynchronousStreamingFromClientClient(const ClientConfig& config)
: SynchronousStreamingClient(config), last_issue_(num_threads_) {}
- ~SynchronousStreamingFromClientClient() {
+ ~SynchronousStreamingFromClientClient() override {
CleanupAllStreams(
[this](size_t thread_idx) { stream_[thread_idx]->WritesDone(); });
}
public:
SynchronousStreamingFromServerClient(const ClientConfig& config)
: SynchronousStreamingClient(config), last_recv_(num_threads_) {}
- ~SynchronousStreamingFromServerClient() {}
+ ~SynchronousStreamingFromServerClient() override {}
private:
std::vector<double> last_recv_;
public:
SynchronousStreamingBothWaysClient(const ClientConfig& config)
: SynchronousStreamingClient(config) {}
- ~SynchronousStreamingBothWaysClient() {
+ ~SynchronousStreamingBothWaysClient() override {
CleanupAllStreams(
[this](size_t thread_idx) { stream_[thread_idx]->WritesDone(); });
}