aboutsummaryrefslogtreecommitdiff
path: root/src/rps/rps-test_util.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/rps/rps-test_util.c')
-rw-r--r--src/rps/rps-test_util.c55
1 files changed, 26 insertions, 29 deletions
diff --git a/src/rps/rps-test_util.c b/src/rps/rps-test_util.c
index 7f54feca1..85829f247 100644
--- a/src/rps/rps-test_util.c
+++ b/src/rps/rps-test_util.c
@@ -80,41 +80,36 @@ get_file_handle (const char *name)
80 if (NULL == open_files) 80 if (NULL == open_files)
81 { 81 {
82 open_files = GNUNET_CONTAINER_multihashmap_create (16, 82 open_files = GNUNET_CONTAINER_multihashmap_create (16,
83 GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY); 83 GNUNET_NO);
84 LOG (GNUNET_ERROR_TYPE_DEBUG,
85 "Created map of open files.\n");
84 } 86 }
85 GNUNET_CRYPTO_hash (name, 87 GNUNET_CRYPTO_hash (name,
86 strnlen (name, 88 strlen (name),
87 512),
88 &hash); 89 &hash);
89 if (GNUNET_NO == GNUNET_CONTAINER_multihashmap_contains (open_files, 90 if (NULL != (fh = GNUNET_CONTAINER_multihashmap_get (open_files,
90 &hash)) 91 &hash)))
91 {
92 fh = GNUNET_DISK_file_open (name,
93 GNUNET_DISK_OPEN_WRITE |
94 GNUNET_DISK_OPEN_CREATE |
95 GNUNET_DISK_OPEN_APPEND,
96 GNUNET_DISK_PERM_USER_READ |
97 GNUNET_DISK_PERM_USER_WRITE |
98 GNUNET_DISK_PERM_GROUP_READ);
99 if (NULL == fh)
100 {
101 LOG (GNUNET_ERROR_TYPE_ERROR,
102 "Opening file `%s' failed.\n",
103 name);
104 GNUNET_assert (0);
105 }
106 GNUNET_CONTAINER_multihashmap_put (open_files,
107 &hash,
108 fh,
109 GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY);
110 return fh; 92 return fh;
111 } 93 fh = GNUNET_DISK_file_open (name,
112 else 94 GNUNET_DISK_OPEN_WRITE |
95 GNUNET_DISK_OPEN_CREATE |
96 GNUNET_DISK_OPEN_APPEND,
97 GNUNET_DISK_PERM_USER_READ |
98 GNUNET_DISK_PERM_USER_WRITE |
99 GNUNET_DISK_PERM_GROUP_READ);
100 if (NULL == fh)
113 { 101 {
114 fh = GNUNET_CONTAINER_multihashmap_get (open_files, 102 LOG (GNUNET_ERROR_TYPE_ERROR,
115 &hash); 103 "Opening file `%s' failed.\n",
116 return fh; 104 name);
105 GNUNET_assert (0);
117 } 106 }
107 GNUNET_assert (GNUNET_YES ==
108 GNUNET_CONTAINER_multihashmap_put (open_files,
109 &hash,
110 fh,
111 GNUNET_CONTAINER_MULTIHASHMAPOPTION_UNIQUE_ONLY));
112 return fh;
118} 113}
119 114
120 115
@@ -162,6 +157,7 @@ close_all_files ()
162 close_files_iter, 157 close_files_iter,
163 NULL); 158 NULL);
164 GNUNET_CONTAINER_multihashmap_destroy (open_files); 159 GNUNET_CONTAINER_multihashmap_destroy (open_files);
160 open_files = NULL;
165 return ret; 161 return ret;
166} 162}
167 163
@@ -491,6 +487,7 @@ static int ensure_folder_exist (void)
491 } 487 }
492 if (GNUNET_YES != GNUNET_DISK_directory_test ("/tmp/rps/", GNUNET_NO)) 488 if (GNUNET_YES != GNUNET_DISK_directory_test ("/tmp/rps/", GNUNET_NO))
493 { 489 {
490 LOG (GNUNET_ERROR_TYPE_ERROR, "Could not create directory `/tmp/rps'\n");
494 return GNUNET_SYSERR; 491 return GNUNET_SYSERR;
495 } 492 }
496 return GNUNET_YES; 493 return GNUNET_YES;