aboutsummaryrefslogtreecommitdiff
path: root/src/rps/rps-test_util.c
diff options
context:
space:
mode:
authorJulius Bünger <buenger@mytum.de>2018-10-20 14:21:02 +0200
committerJulius Bünger <buenger@mytum.de>2018-10-20 14:47:31 +0200
commitd2bdef77c4f13b1e51ac72340b7e1cc1535f6bb3 (patch)
tree25b0af7a6fb8389827e0cf7fbb22730bda266ee0 /src/rps/rps-test_util.c
parent061e86b157b1f13062ef879656a1c2678a8b6f35 (diff)
downloadgnunet-d2bdef77c4f13b1e51ac72340b7e1cc1535f6bb3.tar.gz
gnunet-d2bdef77c4f13b1e51ac72340b7e1cc1535f6bb3.zip
RPS: Fix writing internals to disk
Diffstat (limited to 'src/rps/rps-test_util.c')
-rw-r--r--src/rps/rps-test_util.c72
1 files changed, 1 insertions, 71 deletions
diff --git a/src/rps/rps-test_util.c b/src/rps/rps-test_util.c
index ffd43f6b1..f3367e01b 100644
--- a/src/rps/rps-test_util.c
+++ b/src/rps/rps-test_util.c
@@ -57,76 +57,6 @@ static char buf_unaligned;
57 */ 57 */
58static unsigned num_bits_buf_unaligned; 58static unsigned num_bits_buf_unaligned;
59 59
60void
61to_file_ (const char *file_name, char *line)
62{
63 struct GNUNET_DISK_FileHandle *f;
64 char output_buffer[512];
65 size_t output_buffer_size = 512;
66 char *output_buffer_p;
67 //size_t size;
68 int size;
69 int size2;
70
71
72 if (NULL == (f = GNUNET_DISK_file_open (file_name,
73 GNUNET_DISK_OPEN_APPEND |
74 GNUNET_DISK_OPEN_WRITE |
75 GNUNET_DISK_OPEN_CREATE,
76 GNUNET_DISK_PERM_USER_READ |
77 GNUNET_DISK_PERM_USER_WRITE |
78 GNUNET_DISK_PERM_GROUP_READ |
79 GNUNET_DISK_PERM_OTHER_READ)))
80 {
81 LOG (GNUNET_ERROR_TYPE_WARNING,
82 "Not able to open file %s\n",
83 file_name);
84 return;
85 }
86 output_buffer_size = strlen (line) + 18;
87 if (512 < output_buffer_size)
88 {
89 output_buffer_p = GNUNET_malloc ((output_buffer_size) * sizeof (char));
90 } else {
91 output_buffer_p = &output_buffer[0];
92 }
93 size = GNUNET_snprintf (output_buffer_p,
94 output_buffer_size,
95 "%llu %s\n",
96 (GNUNET_TIME_absolute_get ().abs_value_us) / 1000000, // microsec -> sec
97 line);
98 if (0 > size)
99 {
100 LOG (GNUNET_ERROR_TYPE_WARNING,
101 "Failed to write string to buffer (size: %i)\n",
102 size);
103 return;
104 }
105
106 size2 = GNUNET_DISK_file_write (f, output_buffer_p, size);
107 if (size != size2)
108 {
109 LOG (GNUNET_ERROR_TYPE_WARNING,
110 "Unable to write to file! (Size: %u, size2: %u)\n",
111 size,
112 size2);
113
114 if (GNUNET_YES != GNUNET_DISK_file_close (f))
115 LOG (GNUNET_ERROR_TYPE_WARNING,
116 "Unable to close file\n");
117
118 return;
119 }
120
121 if (512 < output_buffer_size)
122 {
123 GNUNET_free (output_buffer_p);
124 }
125
126 if (GNUNET_YES != GNUNET_DISK_file_close (f))
127 LOG (GNUNET_ERROR_TYPE_WARNING,
128 "Unable to close file\n");
129}
130 60
131void 61void
132to_file_raw (const char *file_name, const char *buf, size_t size_buf) 62to_file_raw (const char *file_name, const char *buf, size_t size_buf)
@@ -457,7 +387,7 @@ static int ensure_folder_exist (void)
457 return GNUNET_YES; 387 return GNUNET_YES;
458} 388}
459 389
460const char * 390char *
461store_prefix_file_name (const struct GNUNET_PeerIdentity *peer, 391store_prefix_file_name (const struct GNUNET_PeerIdentity *peer,
462 const char *prefix) 392 const char *prefix)
463{ 393{