Streaming examples: Set WAN as default transport

ax3l · Aug 18, 2023 · 4a4bb7a · 4a4bb7a
1 parent dd53961
commit 4a4bb7a
Show file tree

Hide file tree

Showing 4 changed files with 24 additions and 4 deletions.
diff --git a/examples/10_streaming_read.cpp b/examples/10_streaming_read.cpp
@@ -19,7 +19,16 @@ int main()
         return 0;
     }
 
-    Series series = Series("electrons.sst", Access::READ_LINEAR);
+    Series series = Series("electrons.sst", Access::READ_LINEAR, R"(
+{
+  "adios2": {
+    "engine": {
+      "parameters": {
+        "DataTransport": "WAN"
+      }
+    }
+  }
+})");
 
     // `Series::writeIterations()` and `Series::readIterations()` are
     // intentionally restricted APIs that ensure a workflow which also works

diff --git a/examples/10_streaming_read.py b/examples/10_streaming_read.py
@@ -7,7 +7,8 @@
 # pass-through for ADIOS2 engine parameters
 # https://adios2.readthedocs.io/en/latest/engines/engines.html
 config = {'adios2': {'engine': {}, 'dataset': {}}}
-config['adios2']['engine'] = {'parameters': {'Threads': '4'}}
+config['adios2']['engine'] = {'parameters':
+                              {'Threads': '4', 'DataTransport': 'WAN'}}
 config['adios2']['dataset'] = {'operators': [{'type': 'bzip2'}]}
 
 if __name__ == "__main__":

diff --git a/examples/10_streaming_write.cpp b/examples/10_streaming_write.cpp
@@ -20,7 +20,16 @@ int main()
     }
 
     // open file for writing
-    Series series = Series("electrons.sst", Access::CREATE);
+    Series series = Series("electrons.sst", Access::CREATE, R"(
+{
+  "adios2": {
+    "engine": {
+      "parameters": {
+        "DataTransport": "WAN"
+      }
+    }
+  }
+})");
 
     Datatype datatype = determineDatatype<position_t>();
     constexpr unsigned long length = 10ul;

diff --git a/examples/10_streaming_write.py b/examples/10_streaming_write.py
@@ -8,7 +8,8 @@
 # pass-through for ADIOS2 engine parameters
 # https://adios2.readthedocs.io/en/latest/engines/engines.html
 config = {'adios2': {'engine': {}, 'dataset': {}}}
-config['adios2']['engine'] = {'parameters': {'Threads': '4'}}
+config['adios2']['engine'] = {'parameters':
+                              {'Threads': '4', 'DataTransport': 'WAN'}}
 config['adios2']['dataset'] = {'operators': [{'type': 'bzip2'}]}
 
 if __name__ == "__main__":