summaryrefslogtreecommitdiff
path: root/src/rps/test_service_rps_view.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/rps/test_service_rps_view.c')
-rw-r--r--src/rps/test_service_rps_view.c183
1 files changed, 92 insertions, 91 deletions
diff --git a/src/rps/test_service_rps_view.c b/src/rps/test_service_rps_view.c
index 31aa8cf0b..5b668efe1 100644
--- a/src/rps/test_service_rps_view.c
+++ b/src/rps/test_service_rps_view.c
@@ -24,12 +24,13 @@
24#include <platform.h> 24#include <platform.h>
25#include "gnunet-service-rps_view.h" 25#include "gnunet-service-rps_view.h"
26 26
27#define ABORT() { fprintf(stderr, "Error at %s:%d\n", __FILE__, __LINE__); View_destroy(view); return 1; } 27#define ABORT() { fprintf (stderr, "Error at %s:%d\n", __FILE__, __LINE__); \
28#define CHECK(c) { if (!(c)) ABORT (); } 28 View_destroy (view); return 1; }
29#define CHECK(c) { if (! (c)) ABORT (); }
29 30
30 31
31static int 32static int
32check() 33check ()
33{ 34{
34 struct View *view; 35 struct View *view;
35 struct GNUNET_PeerIdentity k1; 36 struct GNUNET_PeerIdentity k1;
@@ -37,107 +38,107 @@ check()
37 const struct GNUNET_PeerIdentity *array; 38 const struct GNUNET_PeerIdentity *array;
38 unsigned int j; 39 unsigned int j;
39 40
40 view = View_create(3); 41 view = View_create (3);
41 memset(&k1, 0, sizeof(k1)); 42 memset (&k1, 0, sizeof(k1));
42 memset(&k2, 1, sizeof(k2)); 43 memset (&k2, 1, sizeof(k2));
43 CHECK(GNUNET_NO == View_contains_peer(view, &k1)); 44 CHECK (GNUNET_NO == View_contains_peer (view, &k1));
44 CHECK(GNUNET_NO == View_contains_peer(view, &k2)); 45 CHECK (GNUNET_NO == View_contains_peer (view, &k2));
45 CHECK(GNUNET_NO == View_remove_peer(view, &k1)); 46 CHECK (GNUNET_NO == View_remove_peer (view, &k1));
46 CHECK(GNUNET_NO == View_remove_peer(view, &k2)); 47 CHECK (GNUNET_NO == View_remove_peer (view, &k2));
47 CHECK(NULL == View_get_peer_by_index(view, 0)); 48 CHECK (NULL == View_get_peer_by_index (view, 0));
48 CHECK(NULL == View_get_peer_by_index(view, 1)); 49 CHECK (NULL == View_get_peer_by_index (view, 1));
49 View_clear(view); /* See if assertions trigger */ 50 View_clear (view); /* See if assertions trigger */
50 CHECK(0 == View_size(view)); 51 CHECK (0 == View_size (view));
51 52
52 CHECK(GNUNET_OK == View_put(view, &k1)); 53 CHECK (GNUNET_OK == View_put (view, &k1));
53 CHECK(1 == View_size(view)); 54 CHECK (1 == View_size (view));
54 CHECK(GNUNET_NO == View_put(view, &k1)); 55 CHECK (GNUNET_NO == View_put (view, &k1));
55 CHECK(1 == View_size(view)); 56 CHECK (1 == View_size (view));
56 CHECK(GNUNET_YES == View_contains_peer(view, &k1)); 57 CHECK (GNUNET_YES == View_contains_peer (view, &k1));
57 CHECK(GNUNET_OK == View_remove_peer(view, &k1)); 58 CHECK (GNUNET_OK == View_remove_peer (view, &k1));
58 CHECK(0 == View_size(view)); 59 CHECK (0 == View_size (view));
59 CHECK(GNUNET_NO == View_contains_peer(view, &k1)); 60 CHECK (GNUNET_NO == View_contains_peer (view, &k1));
60 CHECK(GNUNET_NO == View_contains_peer(view, &k2)); 61 CHECK (GNUNET_NO == View_contains_peer (view, &k2));
61 62
62 CHECK(GNUNET_OK == View_put(view, &k1)); 63 CHECK (GNUNET_OK == View_put (view, &k1));
63 CHECK(1 == View_size(view)); 64 CHECK (1 == View_size (view));
64 for (j = 0; j < 16; j++) 65 for (j = 0; j < 16; j++)
65 { 66 {
66 CHECK(GNUNET_NO == View_put(view, &k1)); 67 CHECK (GNUNET_NO == View_put (view, &k1));
67 } 68 }
68 CHECK(1 == View_size(view)); 69 CHECK (1 == View_size (view));
69 CHECK(GNUNET_OK == View_put(view, &k2)); 70 CHECK (GNUNET_OK == View_put (view, &k2));
70 CHECK(2 == View_size(view)); 71 CHECK (2 == View_size (view));
71 for (j = 0; j < 16; j++) 72 for (j = 0; j < 16; j++)
72 { 73 {
73 CHECK(GNUNET_NO == View_put(view, &k2)); 74 CHECK (GNUNET_NO == View_put (view, &k2));
74 } 75 }
75 CHECK(2 == View_size(view)); 76 CHECK (2 == View_size (view));
76 77
77 /* iterate */ 78 /* iterate */
78 for (j = 0; j < View_size(view); j++) 79 for (j = 0; j < View_size (view); j++)
79 { 80 {
80 CHECK(NULL != View_get_peer_by_index(view, j)); 81 CHECK (NULL != View_get_peer_by_index (view, j));
81 } 82 }
82 CHECK((0 == memcmp(View_get_peer_by_index(view, 0), 83 CHECK ((0 == memcmp (View_get_peer_by_index (view, 0),
83 &k1, sizeof(k1)))); 84 &k1, sizeof(k1))));
84 CHECK((0 == memcmp(View_get_peer_by_index(view, 1), 85 CHECK ((0 == memcmp (View_get_peer_by_index (view, 1),
85 &k2, sizeof(k2)))); 86 &k2, sizeof(k2))));
86 CHECK(GNUNET_OK == View_remove_peer(view, &k1)); 87 CHECK (GNUNET_OK == View_remove_peer (view, &k1));
87 CHECK(1 == View_size(view)); 88 CHECK (1 == View_size (view));
88 CHECK(GNUNET_NO == View_contains_peer(view, &k1)); 89 CHECK (GNUNET_NO == View_contains_peer (view, &k1));
89 CHECK(GNUNET_YES == View_contains_peer(view, &k2)); 90 CHECK (GNUNET_YES == View_contains_peer (view, &k2));
90 CHECK(NULL != View_get_peer_by_index(view, 0)); 91 CHECK (NULL != View_get_peer_by_index (view, 0));
91 CHECK(NULL == View_get_peer_by_index(view, 1)); 92 CHECK (NULL == View_get_peer_by_index (view, 1));
92 93
93 View_clear(view); 94 View_clear (view);
94 CHECK(0 == View_size(view)); 95 CHECK (0 == View_size (view));
95 96
96 CHECK(GNUNET_OK == View_put(view, &k1)); 97 CHECK (GNUNET_OK == View_put (view, &k1));
97 CHECK(1 == View_size(view)); 98 CHECK (1 == View_size (view));
98 CHECK(GNUNET_YES == View_contains_peer(view, &k1)); 99 CHECK (GNUNET_YES == View_contains_peer (view, &k1));
99 CHECK(GNUNET_OK == View_put(view, &k2)); 100 CHECK (GNUNET_OK == View_put (view, &k2));
100 CHECK(2 == View_size(view)); 101 CHECK (2 == View_size (view));
101 CHECK(GNUNET_YES == View_contains_peer(view, &k2)); 102 CHECK (GNUNET_YES == View_contains_peer (view, &k2));
102 array = View_get_as_array(view); 103 array = View_get_as_array (view);
103 CHECK(0 == memcmp(&array[0], &k1, sizeof(k1))); 104 CHECK (0 == memcmp (&array[0], &k1, sizeof(k1)));
104 CHECK(0 == memcmp(&array[1], &k2, sizeof(k2))); 105 CHECK (0 == memcmp (&array[1], &k2, sizeof(k2)));
105 View_clear(view); 106 View_clear (view);
106 CHECK(0 == View_size(view)); 107 CHECK (0 == View_size (view));
107 108
108 /*View_change_len () */ 109 /*View_change_len () */
109 CHECK(GNUNET_OK == View_put(view, &k1)); 110 CHECK (GNUNET_OK == View_put (view, &k1));
110 CHECK(GNUNET_OK == View_put(view, &k2)); 111 CHECK (GNUNET_OK == View_put (view, &k2));
111 CHECK(2 == View_size(view)); 112 CHECK (2 == View_size (view));
112 View_change_len(view, 4); 113 View_change_len (view, 4);
113 CHECK(2 == View_size(view)); 114 CHECK (2 == View_size (view));
114 CHECK(GNUNET_YES == View_contains_peer(view, &k1)); 115 CHECK (GNUNET_YES == View_contains_peer (view, &k1));
115 CHECK(GNUNET_YES == View_contains_peer(view, &k2)); 116 CHECK (GNUNET_YES == View_contains_peer (view, &k2));
116 array = View_get_as_array(view); 117 array = View_get_as_array (view);
117 CHECK(0 == memcmp(&array[0], &k1, sizeof(k1))); 118 CHECK (0 == memcmp (&array[0], &k1, sizeof(k1)));
118 CHECK(0 == memcmp(&array[1], &k2, sizeof(k2))); 119 CHECK (0 == memcmp (&array[1], &k2, sizeof(k2)));
119 View_change_len(view, 1); 120 View_change_len (view, 1);
120 CHECK(1 == View_size(view)); 121 CHECK (1 == View_size (view));
121 CHECK(GNUNET_YES == View_contains_peer(view, &k1)); 122 CHECK (GNUNET_YES == View_contains_peer (view, &k1));
122 CHECK(GNUNET_NO == View_contains_peer(view, &k2)); 123 CHECK (GNUNET_NO == View_contains_peer (view, &k2));
123 array = View_get_as_array(view); 124 array = View_get_as_array (view);
124 CHECK(0 == memcmp(&array[0], &k1, sizeof(k1))); 125 CHECK (0 == memcmp (&array[0], &k1, sizeof(k1)));
125 View_clear(view); 126 View_clear (view);
126 CHECK(0 == View_size(view)); 127 CHECK (0 == View_size (view));
127 128
128 View_destroy(view); 129 View_destroy (view);
129 130
130 return 0; 131 return 0;
131} 132}
132 133
133 134
134int 135int
135main() 136main ()
136{ 137{
137 GNUNET_log_setup("test_service_rps_peers", 138 GNUNET_log_setup ("test_service_rps_peers",
138 "WARNING", 139 "WARNING",
139 NULL); 140 NULL);
140 return check(); 141 return check ();
141} 142}
142 143
143/* end of test_service_rps_view.c */ 144/* end of test_service_rps_view.c */