1 files changed, 39 insertions, 0 deletions
diff --git a/fnet/src/tests/sync_execute/sync_execute.cpp b/fnet/src/tests/sync_execute/sync_execute.cpp
new file mode 100644
index 00000000000..e24d63effd5
--- /dev/null
+++ b/fnet/src/tests/sync_execute/sync_execute.cpp
@@ -0,0 +1,39 @@
+// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+#include <vespa/vespalib/testkit/test_kit.h>
+#include <vespa/fnet/fnet.h>
+#include <vespa/vespalib/util/sync.h>
+
+struct DoIt : public FNET_IExecutable {
+    vespalib::Gate gate;
+    virtual void execute() {
+        gate.countDown();
+    }
+};
+
+TEST("sync execute") {
+    DoIt exe1;
+    DoIt exe2;
+    DoIt exe3;
+    DoIt exe4;
+    FastOS_ThreadPool pool(128 * 1024 * 1024);
+    FNET_Transport transport;
+    ASSERT_TRUE(transport.execute(&exe1));
+    ASSERT_TRUE(transport.Start(&pool));
+    exe1.gate.await();
+    ASSERT_TRUE(transport.execute(&exe2));
+    transport.sync();
+    ASSERT_TRUE(exe2.gate.getCount() == 0u);
+    ASSERT_TRUE(transport.execute(&exe3));
+    transport.ShutDown(false);
+    ASSERT_TRUE(!transport.execute(&exe4));
+    transport.sync();
+    transport.WaitFinished();
+    transport.sync();
+    pool.Close();
+    ASSERT_TRUE(exe1.gate.getCount() == 0u);
+    ASSERT_TRUE(exe2.gate.getCount() == 0u);
+    ASSERT_TRUE(exe3.gate.getCount() == 0u);
+    ASSERT_TRUE(exe4.gate.getCount() == 1u);
+}
+
+TEST_MAIN() { TEST_RUN_ALL(); }