[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r2513 - GNUnet/src/applications/datastore
From: |
grothoff |
Subject: |
[GNUnet-SVN] r2513 - GNUnet/src/applications/datastore |
Date: |
Tue, 14 Mar 2006 23:21:45 -0800 (PST) |
Author: grothoff
Date: 2006-03-14 23:21:44 -0800 (Tue, 14 Mar 2006)
New Revision: 2513
Modified:
GNUnet/src/applications/datastore/prefetch.c
Log:
fix
Modified: GNUnet/src/applications/datastore/prefetch.c
===================================================================
--- GNUnet/src/applications/datastore/prefetch.c 2006-03-15 07:14:40 UTC
(rev 2512)
+++ GNUnet/src/applications/datastore/prefetch.c 2006-03-15 07:21:44 UTC
(rev 2513)
@@ -88,7 +88,7 @@
memcpy(randomContentBuffer[rCBPos].value,
value,
ntohl(value->size));
- rCBPos++;
+ rCBPos = (rCBPos + 1) % RCB_SIZE;
MUTEX_UNLOCK(&lock);
load = getCPULoad(); /* FIXME: should use 'IO load' here */
if (load < 10)
@@ -200,10 +200,10 @@
SEMAPHORE_DOWN(doneSignal);
SEMAPHORE_FREE(acquireMoreSignal);
SEMAPHORE_FREE(doneSignal);
- MUTEX_DESTROY(&lock);
+ PTHREAD_JOIN(&gather_thread, &unused);
for (i=0;i<rCBPos;i++)
FREENONNULL(randomContentBuffer[i].value);
- PTHREAD_JOIN(&gather_thread, &unused);
+ MUTEX_DESTROY(&lock);
}
/* end of prefetch.c */
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r2513 - GNUnet/src/applications/datastore,
grothoff <=