diff options
author | Julius Bünger <buenger@mytum.de> | 2018-10-20 14:21:02 +0200 |
---|---|---|
committer | Julius Bünger <buenger@mytum.de> | 2018-10-20 14:47:31 +0200 |
commit | d2bdef77c4f13b1e51ac72340b7e1cc1535f6bb3 (patch) | |
tree | 25b0af7a6fb8389827e0cf7fbb22730bda266ee0 /src/rps/rps-test_util.c | |
parent | 061e86b157b1f13062ef879656a1c2678a8b6f35 (diff) | |
download | gnunet-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.c | 72 |
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 | */ |
58 | static unsigned num_bits_buf_unaligned; | 58 | static unsigned num_bits_buf_unaligned; |
59 | 59 | ||
60 | void | ||
61 | to_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 | ||
131 | void | 61 | void |
132 | to_file_raw (const char *file_name, const char *buf, size_t size_buf) | 62 | to_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 | ||
460 | const char * | 390 | char * |
461 | store_prefix_file_name (const struct GNUNET_PeerIdentity *peer, | 391 | store_prefix_file_name (const struct GNUNET_PeerIdentity *peer, |
462 | const char *prefix) | 392 | const char *prefix) |
463 | { | 393 | { |