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 */
_______________________________________________
GNUnet-SVN mailing list
GNUnet-SVN@gnu.org
http://lists.gnu.org/mailman/listinfo/gnunet-svn
