diff options
Diffstat (limited to 'src/fs/test_fs_namespace_list_updateable.c')
-rw-r--r-- | src/fs/test_fs_namespace_list_updateable.c | 108 |
1 files changed, 55 insertions, 53 deletions
diff --git a/src/fs/test_fs_namespace_list_updateable.c b/src/fs/test_fs_namespace_list_updateable.c index 9a28fcb1b..4311f0110 100644 --- a/src/fs/test_fs_namespace_list_updateable.c +++ b/src/fs/test_fs_namespace_list_updateable.c | |||
@@ -45,128 +45,130 @@ static struct GNUNET_FS_BlockOptions bo; | |||
45 | 45 | ||
46 | 46 | ||
47 | static void * | 47 | static void * |
48 | progress_cb(void *cls, const struct GNUNET_FS_ProgressInfo *event) | 48 | progress_cb (void *cls, const struct GNUNET_FS_ProgressInfo *event) |
49 | { | 49 | { |
50 | return NULL; | 50 | return NULL; |
51 | } | 51 | } |
52 | 52 | ||
53 | 53 | ||
54 | static void | 54 | static void |
55 | do_shutdown() | 55 | do_shutdown () |
56 | { | 56 | { |
57 | if (uri_this != NULL) | 57 | if (uri_this != NULL) |
58 | GNUNET_FS_uri_destroy(uri_this); | 58 | GNUNET_FS_uri_destroy (uri_this); |
59 | if (uri_next != NULL) | 59 | if (uri_next != NULL) |
60 | GNUNET_FS_uri_destroy(uri_next); | 60 | GNUNET_FS_uri_destroy (uri_next); |
61 | if (ns != NULL) | 61 | if (ns != NULL) |
62 | GNUNET_free(ns); | 62 | GNUNET_free (ns); |
63 | if (meta != NULL) | 63 | if (meta != NULL) |
64 | GNUNET_CONTAINER_meta_data_destroy(meta); | 64 | GNUNET_CONTAINER_meta_data_destroy (meta); |
65 | } | 65 | } |
66 | 66 | ||
67 | 67 | ||
68 | static void | 68 | static void |
69 | check_next(void *cls, const char *last_id, | 69 | check_next (void *cls, const char *last_id, |
70 | const struct GNUNET_FS_Uri *last_uri, | 70 | const struct GNUNET_FS_Uri *last_uri, |
71 | const struct GNUNET_CONTAINER_MetaData *last_meta, | 71 | const struct GNUNET_CONTAINER_MetaData *last_meta, |
72 | const char *next_id) | 72 | const char *next_id) |
73 | { | 73 | { |
74 | GNUNET_break(0 == strcmp(last_id, "next")); | 74 | GNUNET_break (0 == strcmp (last_id, "next")); |
75 | GNUNET_break(0 == strcmp(next_id, "future")); | 75 | GNUNET_break (0 == strcmp (next_id, "future")); |
76 | err -= 4; | 76 | err -= 4; |
77 | } | 77 | } |
78 | 78 | ||
79 | 79 | ||
80 | static void | 80 | static void |
81 | check_this_next(void *cls, const char *last_id, | 81 | check_this_next (void *cls, const char *last_id, |
82 | const struct GNUNET_FS_Uri *last_uri, | 82 | const struct GNUNET_FS_Uri *last_uri, |
83 | const struct GNUNET_CONTAINER_MetaData *last_meta, | 83 | const struct GNUNET_CONTAINER_MetaData *last_meta, |
84 | const char *next_id) | 84 | const char *next_id) |
85 | { | 85 | { |
86 | GNUNET_break(0 == strcmp(last_id, "this")); | 86 | GNUNET_break (0 == strcmp (last_id, "this")); |
87 | GNUNET_break(0 == strcmp(next_id, "next")); | 87 | GNUNET_break (0 == strcmp (next_id, "next")); |
88 | err -= 2; | 88 | err -= 2; |
89 | err += 4; | 89 | err += 4; |
90 | GNUNET_FS_namespace_list_updateable(fs, ns, next_id, &check_next, NULL); | 90 | GNUNET_FS_namespace_list_updateable (fs, ns, next_id, &check_next, NULL); |
91 | } | 91 | } |
92 | 92 | ||
93 | 93 | ||
94 | static void | 94 | static void |
95 | sks_cont_next(void *cls, const struct GNUNET_FS_Uri *uri, const char *emsg) | 95 | sks_cont_next (void *cls, const struct GNUNET_FS_Uri *uri, const char *emsg) |
96 | { | 96 | { |
97 | GNUNET_assert(NULL == emsg); | 97 | GNUNET_assert (NULL == emsg); |
98 | err += 2; | 98 | err += 2; |
99 | GNUNET_FS_namespace_list_updateable(fs, ns, NULL, &check_this_next, NULL); | 99 | GNUNET_FS_namespace_list_updateable (fs, ns, NULL, &check_this_next, NULL); |
100 | } | 100 | } |
101 | 101 | ||
102 | 102 | ||
103 | static void | 103 | static void |
104 | check_this(void *cls, const char *last_id, | 104 | check_this (void *cls, const char *last_id, |
105 | const struct GNUNET_FS_Uri *last_uri, | 105 | const struct GNUNET_FS_Uri *last_uri, |
106 | const struct GNUNET_CONTAINER_MetaData *last_meta, | 106 | const struct GNUNET_CONTAINER_MetaData *last_meta, |
107 | const char *next_id) | 107 | const char *next_id) |
108 | { | 108 | { |
109 | GNUNET_break(0 == strcmp(last_id, "this")); | 109 | GNUNET_break (0 == strcmp (last_id, "this")); |
110 | GNUNET_break(0 == strcmp(next_id, "next")); | 110 | GNUNET_break (0 == strcmp (next_id, "next")); |
111 | err -= 1; | 111 | err -= 1; |
112 | } | 112 | } |
113 | 113 | ||
114 | 114 | ||
115 | static void | 115 | static void |
116 | sks_cont_this(void *cls, const struct GNUNET_FS_Uri *uri, const char *emsg) | 116 | sks_cont_this (void *cls, const struct GNUNET_FS_Uri *uri, const char *emsg) |
117 | { | 117 | { |
118 | GNUNET_assert(NULL == emsg); | 118 | GNUNET_assert (NULL == emsg); |
119 | err = 1; | 119 | err = 1; |
120 | GNUNET_FS_namespace_list_updateable(fs, ns, NULL, &check_this, NULL); | 120 | GNUNET_FS_namespace_list_updateable (fs, ns, NULL, &check_this, NULL); |
121 | GNUNET_FS_publish_sks(fs, ns, "next", "future", meta, uri_next, &bo, | 121 | GNUNET_FS_publish_sks (fs, ns, "next", "future", meta, uri_next, &bo, |
122 | GNUNET_FS_PUBLISH_OPTION_NONE, &sks_cont_next, NULL); | 122 | GNUNET_FS_PUBLISH_OPTION_NONE, &sks_cont_next, NULL); |
123 | } | 123 | } |
124 | 124 | ||
125 | 125 | ||
126 | static void | 126 | static void |
127 | testNamespace() | 127 | testNamespace () |
128 | { | 128 | { |
129 | ns = GNUNET_CRYPTO_ecdsa_key_create(); | 129 | ns = GNUNET_CRYPTO_ecdsa_key_create (); |
130 | GNUNET_assert(NULL != ns); | 130 | GNUNET_assert (NULL != ns); |
131 | bo.content_priority = 1; | 131 | bo.content_priority = 1; |
132 | bo.anonymity_level = 1; | 132 | bo.anonymity_level = 1; |
133 | bo.replication_level = 0; | 133 | bo.replication_level = 0; |
134 | bo.expiration_time = | 134 | bo.expiration_time = |
135 | GNUNET_TIME_relative_to_absolute(GNUNET_TIME_UNIT_MINUTES); | 135 | GNUNET_TIME_relative_to_absolute (GNUNET_TIME_UNIT_MINUTES); |
136 | meta = GNUNET_CONTAINER_meta_data_create(); | 136 | meta = GNUNET_CONTAINER_meta_data_create (); |
137 | 137 | ||
138 | uri_this = | 138 | uri_this = |
139 | GNUNET_FS_uri_parse | 139 | GNUNET_FS_uri_parse |
140 | ("gnunet://fs/chk/C282GG70GKK41O4551011DO413KFBVTVMQG1OG30I0K4045N0G41HAPB82G680A02JRVVFO8URVRU2F159011DO41000000022RG820.RNVVVVOOLCLK065B5D04HTNVNSIB2AI022RG8200HSLK1CO1000ATQ98824DMA2032LIMG50CG0K057NVUVG200000H000004400000.42", | 140 | ( |
141 | "gnunet://fs/chk/C282GG70GKK41O4551011DO413KFBVTVMQG1OG30I0K4045N0G41HAPB82G680A02JRVVFO8URVRU2F159011DO41000000022RG820.RNVVVVOOLCLK065B5D04HTNVNSIB2AI022RG8200HSLK1CO1000ATQ98824DMA2032LIMG50CG0K057NVUVG200000H000004400000.42", | ||
141 | NULL); | 142 | NULL); |
142 | uri_next = | 143 | uri_next = |
143 | GNUNET_FS_uri_parse | 144 | GNUNET_FS_uri_parse |
144 | ("gnunet://fs/chk/C282GG70GKK41O4551011DO413KFBVTVMQG1OG30I0K4045N0G41HAPB82G680A02JRVVFO8URVRU2F159011DO41000000022RG820.RNVVVVOOLCLK065B5D04HTNVNSIB2AI022RG8200HSLK1CO1000ATQ98824DMA2032LIMG50CG0K057NVUVG200000H000004400000.43", | 145 | ( |
146 | "gnunet://fs/chk/C282GG70GKK41O4551011DO413KFBVTVMQG1OG30I0K4045N0G41HAPB82G680A02JRVVFO8URVRU2F159011DO41000000022RG820.RNVVVVOOLCLK065B5D04HTNVNSIB2AI022RG8200HSLK1CO1000ATQ98824DMA2032LIMG50CG0K057NVUVG200000H000004400000.43", | ||
145 | NULL); | 147 | NULL); |
146 | GNUNET_FS_publish_sks(fs, ns, "this", "next", meta, uri_this, &bo, | 148 | GNUNET_FS_publish_sks (fs, ns, "this", "next", meta, uri_this, &bo, |
147 | GNUNET_FS_PUBLISH_OPTION_NONE, &sks_cont_this, NULL); | 149 | GNUNET_FS_PUBLISH_OPTION_NONE, &sks_cont_this, NULL); |
148 | } | 150 | } |
149 | 151 | ||
150 | 152 | ||
151 | static void | 153 | static void |
152 | run(void *cls, | 154 | run (void *cls, |
153 | const struct GNUNET_CONFIGURATION_Handle *cfg, | 155 | const struct GNUNET_CONFIGURATION_Handle *cfg, |
154 | struct GNUNET_TESTING_Peer *peer) | 156 | struct GNUNET_TESTING_Peer *peer) |
155 | { | 157 | { |
156 | fs = GNUNET_FS_start(cfg, "test-fs-namespace", &progress_cb, NULL, | 158 | fs = GNUNET_FS_start (cfg, "test-fs-namespace", &progress_cb, NULL, |
157 | GNUNET_FS_FLAGS_NONE, GNUNET_FS_OPTIONS_END); | 159 | GNUNET_FS_FLAGS_NONE, GNUNET_FS_OPTIONS_END); |
158 | testNamespace(); | 160 | testNamespace (); |
159 | } | 161 | } |
160 | 162 | ||
161 | 163 | ||
162 | int | 164 | int |
163 | main(int argc, char *argv[]) | 165 | main (int argc, char *argv[]) |
164 | { | 166 | { |
165 | if (0 != GNUNET_TESTING_peer_run("test-fs-namespace-list-updateable", | 167 | if (0 != GNUNET_TESTING_peer_run ("test-fs-namespace-list-updateable", |
166 | "test_fs_namespace_data.conf", | 168 | "test_fs_namespace_data.conf", |
167 | &run, NULL)) | 169 | &run, NULL)) |
168 | return 1; | 170 | return 1; |
169 | do_shutdown(); | 171 | do_shutdown (); |
170 | return err; | 172 | return err; |
171 | } | 173 | } |
172 | 174 | ||