Move address caching logic from AsyncSSLSocket to AsyncSocket.

[folly.git] / folly / Executor.h

diff --git a/folly/Executor.h b/folly/Executor.h
index 68670faada32c485fc4c66b12c2597ec5e3fbe92..b4f10779eb502e4eaba53ac12965fe28c4ad3095 100644 (file)
--- a/folly/Executor.h
+++ b/folly/Executor.h
@@ -1,5 +1,5 @@
 /*
- * Copyright 2016 Facebook, Inc.
+ * Copyright 2017 Facebook, Inc.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -55,6 +55,47 @@ class Executor {
   void addPtr(P fn) {
     this->add([fn]() mutable { (*fn)(); });
   }
+
+  class KeepAlive {
+   public:
+    KeepAlive() {}
+
+    void reset() {
+      executor_.reset();
+    }
+
+    explicit operator bool() const {
+      return executor_ != nullptr;
+    }
+
+   private:
+    friend class Executor;
+    explicit KeepAlive(folly::Executor* executor) : executor_(executor) {}
+
+    struct Deleter {
+      void operator()(folly::Executor* executor) {
+        executor->keepAliveRelease();
+      }
+    };
+    std::unique_ptr<folly::Executor, Deleter> executor_;
+  };
+
+  /// Returns a keep-alive token which guarantees that Executor will keep
+  /// processing tasks until the token is released. keep-alive token can only
+  /// be destroyed from within the task, scheduled to be run on an executor.
+  ///
+  /// If executor does not support keep-alive functionality - dummy token will
+  /// be returned.
+  virtual KeepAlive getKeepAliveToken() {
+    return {};
+  }
+
+ protected:
+  virtual void keepAliveRelease();
+
+  KeepAlive makeKeepAlive() {
+    return KeepAlive{this};
+  }
 };
 
 } // folly