Update Envoy to dee7021 (Aug 18th 2021).

bazel/repositories.bzl

@@ -1,7 +1,7 @@
 load("@bazel_tools//tools/build_defs/repo:http.bzl", "http_archive")
 
-ENVOY_COMMIT = "95038feabf260c3937465951d5da603d31ea3bd4"  # Aug 12, 2021
-ENVOY_SHA = "4a584b02c24ac24362eff2550977616f86a194e61106e15f723e1cf961ca145d"
+ENVOY_COMMIT = "dee7021c605243bb0b422a63be4d1c7bc7191bd5"  # Aug 18, 2021
+ENVOY_SHA = "4107f68f080f53130c4c44677322a5844dc62c44743d394722af66a40da949f8"
 
 HDR_HISTOGRAM_C_VERSION = "0.11.2"  # October 12th, 2020
 HDR_HISTOGRAM_C_SHA = "637f28b5f64de2e268131e4e34e6eef0b91cf5ff99167db447d9b2825eae6bad"

include/nighthawk/common/request_source.h

@@ -23,6 +23,12 @@ class RequestSource {
    * needed, for example).
    */
   virtual void initOnThread() PURE;
+
+  /**
+   * Will be called on an initialized and running worker thread, after the work
+   * has been done and just before the worker gets destroyed.
+   */
+  virtual void destroyOnThread() PURE;
 };
 
 using RequestSourcePtr = std::unique_ptr<RequestSource>;

source/client/client_worker_impl.cc

@@ -85,7 +85,10 @@ void ClientWorkerImpl::work() {
   // should be consistent.
 }
 
-void ClientWorkerImpl::shutdownThread() { benchmark_client_->terminate(); }
+void ClientWorkerImpl::shutdownThread() {
+  benchmark_client_->terminate();
+  request_generator_->destroyOnThread();
+}
 
 void ClientWorkerImpl::requestExecutionCancellation() {
   // We just bump a counter, which is watched by a static termination predicate.

source/common/request_source_impl.cc

@@ -61,6 +61,12 @@ void RemoteRequestSourceImpl::connectToRequestStreamGrpcService() {
 
 void RemoteRequestSourceImpl::initOnThread() { connectToRequestStreamGrpcService(); }
 
+void RemoteRequestSourceImpl::destroyOnThread() {
+  // The RequestStreamGrpcClientImpl uses Envoy::Grpc::AsyncClient which demands
+  // to be destroyed on the same thread it was constructed from.
+  grpc_client_.reset();
+}
+
 RequestGenerator RemoteRequestSourceImpl::get() {
   return [this]() -> RequestPtr { return grpc_client_->maybeDequeue(); };
 }

source/common/request_source_impl.h

@@ -27,6 +27,7 @@ class StaticRequestSourceImpl : public BaseRequestSourceImpl {
                           const uint64_t max_yields = UINT64_MAX);
   RequestGenerator get() override;
   void initOnThread() override{};
+  void destroyOnThread() override{};
 
 private:
   const HeaderMapPtr header_;
@@ -55,6 +56,7 @@ class RemoteRequestSourceImpl : public BaseRequestSourceImpl {
                           uint32_t header_buffer_length);
   RequestGenerator get() override;
   void initOnThread() override;
+  void destroyOnThread() override;
 
 private:
   void connectToRequestStreamGrpcService();

source/request_source/request_options_list_plugin_impl.cc

@@ -112,5 +112,6 @@ RequestGenerator OptionsListRequestSource::get() {
 }
 
 void OptionsListRequestSource::initOnThread() {}
+void OptionsListRequestSource::destroyOnThread() {}
 
-} // namespace Nighthawk
+} // namespace Nighthawk

source/request_source/request_options_list_plugin_impl.h

@@ -38,6 +38,7 @@ class OptionsListRequestSource : public RequestSource {
 
   // default implementation
   void initOnThread() override;
+  void destroyOnThread() override;
 
 private:
   Envoy::Http::RequestHeaderMapPtr header_;
@@ -104,4 +105,4 @@ class InLineOptionsListRequestSourceFactory : public virtual RequestSourcePlugin
 // This factory will be activated through RequestSourceFactory in factories.h
 DECLARE_FACTORY(InLineOptionsListRequestSourceFactory);
 
-} // namespace Nighthawk
+} // namespace Nighthawk

test/client_worker_test.cc

@@ -54,6 +54,7 @@ class ClientWorkerTest : public Test {
         .Times(1)
         .WillOnce(Return(ByMove(std::unique_ptr<RequestSource>(request_generator_))));
     EXPECT_CALL(*request_generator_, initOnThread());
+    EXPECT_CALL(*request_generator_, destroyOnThread());
 
     EXPECT_CALL(termination_predicate_factory_, create(_, _, _))
         .WillOnce(Return(ByMove(createMockTerminationPredicate())));

test/mocks/common/mock_request_source.h

@@ -11,6 +11,7 @@ class MockRequestSource : public RequestSource {
   MockRequestSource();
   MOCK_METHOD(RequestGenerator, get, ());
   MOCK_METHOD(void, initOnThread, ());
+  MOCK_METHOD(void, destroyOnThread, ());
 };
 
-} // namespace Nighthawk
+} // namespace Nighthawk

test/request_source/stub_plugin_impl.cc

@@ -43,5 +43,6 @@ RequestGenerator StubRequestSource::get() {
 }
 
 void StubRequestSource::initOnThread() {}
+void StubRequestSource::destroyOnThread() {}
 
-} // namespace Nighthawk
+} // namespace Nighthawk

test/request_source/stub_plugin_impl.h

@@ -23,6 +23,7 @@ class StubRequestSource : public RequestSource {
 
   // default implementation
   void initOnThread() override;
+  void destroyOnThread() override;
 
 private:
   const double test_value_;
@@ -53,4 +54,4 @@ class StubRequestSourcePluginConfigFactory : public virtual RequestSourcePluginC
 
 // This factory will be activated through RequestSourceFactory in factories.h
 DECLARE_FACTORY(StubRequestSourcePluginConfigFactory);
-} // namespace Nighthawk
+} // namespace Nighthawk