Use UMF_MEM_MAP_SYNC for FSDAX in the FSDAX IPC example

Signed-off-by: Lukasz Dorau <[email protected]>

Author: ldorau

test/ipc_file_prov_consumer.c

@@ -5,8 +5,10 @@
  * SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
  */
 
+#include <stdbool.h>
 #include <stdio.h>
 #include <stdlib.h>
+#include <strings.h>
 
 #include <umf/providers/provider_file_memory.h>
 
@@ -15,17 +17,30 @@
 
 int main(int argc, char *argv[]) {
     if (argc < 3) {
-        fprintf(stderr, "usage: %s <port> <file_name>\n", argv[0]);
+        fprintf(stderr, "usage: %s <port> <file_name> <fsdax>\n", argv[0]);
+        fprintf(stderr, "       <fsdax> should be \"FSDAX\" or \"fsdax\" if "
+                        "<file_name> is located on FSDAX \n");
         return -1;
     }
 
     int port = atoi(argv[1]);
     char *file_name = argv[2];
+    bool is_fsdax = false;
+
+    if (argc >= 4) {
+        if (strncasecmp(argv[3], "FSDAX", strlen("FSDAX")) == 0) {
+            is_fsdax = true;
+        }
+    }
 
     umf_file_memory_provider_params_t file_params;
 
     file_params = umfFileMemoryProviderParamsDefault(file_name);
-    file_params.visibility = UMF_MEM_MAP_SHARED;
+    if (is_fsdax) {
+        file_params.visibility = UMF_MEM_MAP_SYNC;
+    } else {
+        file_params.visibility = UMF_MEM_MAP_SHARED;
+    }
 
     return run_consumer(port, umfFileMemoryProviderOps(), &file_params, memcopy,
                         NULL);

test/ipc_file_prov_producer.c

@@ -5,8 +5,10 @@
  * SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
  */
 
+#include <stdbool.h>
 #include <stdio.h>
 #include <stdlib.h>
+#include <strings.h>
 
 #include <umf/providers/provider_file_memory.h>
 
@@ -15,17 +17,30 @@
 
 int main(int argc, char *argv[]) {
     if (argc < 3) {
-        fprintf(stderr, "usage: %s <port> <file_name>\n", argv[0]);
+        fprintf(stderr, "usage: %s <port> <file_name> <fsdax>\n", argv[0]);
+        fprintf(stderr, "       <fsdax> should be \"FSDAX\" or \"fsdax\" if "
+                        "<file_name> is located on FSDAX \n");
         return -1;
     }
 
     int port = atoi(argv[1]);
     char *file_name = argv[2];
+    bool is_fsdax = false;
+
+    if (argc >= 4) {
+        if (strncasecmp(argv[3], "FSDAX", strlen("FSDAX")) == 0) {
+            is_fsdax = true;
+        }
+    }
 
     umf_file_memory_provider_params_t file_params;
 
     file_params = umfFileMemoryProviderParamsDefault(file_name);
-    file_params.visibility = UMF_MEM_MAP_SHARED;
+    if (is_fsdax) {
+        file_params.visibility = UMF_MEM_MAP_SYNC;
+    } else {
+        file_params.visibility = UMF_MEM_MAP_SHARED;
+    }
 
     return run_producer(port, umfFileMemoryProviderOps(), &file_params, memcopy,
                         NULL);