diff options
Diffstat (limited to 'src/rps/rps-test_util.c')
-rw-r--r-- | src/rps/rps-test_util.c | 55 |
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; |