aboutsummaryrefslogtreecommitdiff
path: root/src/datastore
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-04-15 13:35:14 +0000
committerChristian Grothoff <christian@grothoff.org>2011-04-15 13:35:14 +0000
commit2aa54b413db70a100ebac53154e881cc9aadce63 (patch)
treec213a6bff078a43439043ee8d04985d9f405016d /src/datastore
parent83250d05b7a67c36350d7c1a8d6a7aacbfdcd316 (diff)
downloadgnunet-2aa54b413db70a100ebac53154e881cc9aadce63.tar.gz
gnunet-2aa54b413db70a100ebac53154e881cc9aadce63.zip
maybe
Diffstat (limited to 'src/datastore')
-rw-r--r--src/datastore/perf_datastore_api.c2
-rw-r--r--src/datastore/perf_plugin_datastore.c4
2 files changed, 3 insertions, 3 deletions
diff --git a/src/datastore/perf_datastore_api.c b/src/datastore/perf_datastore_api.c
index 07f856b23..f61b984b8 100644
--- a/src/datastore/perf_datastore_api.c
+++ b/src/datastore/perf_datastore_api.c
@@ -127,7 +127,7 @@ check_success (void *cls,
127 stored_ops++; 127 stored_ops++;
128 stored_entries++; 128 stored_entries++;
129 crc->j++; 129 crc->j++;
130 if (crc->j == PUT_10) 130 if (crc->j >= PUT_10)
131 { 131 {
132 crc->j = 0; 132 crc->j = 0;
133 crc->i++; 133 crc->i++;
diff --git a/src/datastore/perf_plugin_datastore.c b/src/datastore/perf_plugin_datastore.c
index 80926bb9f..d80bf0829 100644
--- a/src/datastore/perf_plugin_datastore.c
+++ b/src/datastore/perf_plugin_datastore.c
@@ -246,7 +246,7 @@ expiration_get (void *cls,
246 memcpy (&i, &cdata[4], sizeof (i)); 246 memcpy (&i, &cdata[4], sizeof (i));
247 hits[i/8] |= (1 << (i % 8)); 247 hits[i/8] |= (1 << (i % 8));
248 crc->cnt++; 248 crc->cnt++;
249 if (PUT_10 == crc->cnt) 249 if (PUT_10 <= crc->cnt)
250 { 250 {
251 char buf[256]; 251 char buf[256];
252 unsigned int bc; 252 unsigned int bc;
@@ -301,7 +301,7 @@ replication_get (void *cls,
301 memcpy (&i, &cdata[4], sizeof (i)); 301 memcpy (&i, &cdata[4], sizeof (i));
302 hits[i/8] |= (1 << (i % 8)); 302 hits[i/8] |= (1 << (i % 8));
303 crc->cnt++; 303 crc->cnt++;
304 if (PUT_10 == crc->cnt) 304 if (PUT_10 <= crc->cnt)
305 { 305 {
306 char buf[256]; 306 char buf[256];
307 unsigned int bc; 307 unsigned int bc;