gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

minor TODO and debugging info changes

Browse Source
This commit is contained in:
antirez 2010-01-13 09:40:50 -05:00
parent 72e9fd40b6
commit b74880b4ed
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
TODO
View File

@ -17,6 +17,7 @@ Virtual Memory sub-TODO:
* vm-swap-file <filename>. The swap file should go where the user wants, and if it's already there and of the right size we can avoid to create it again. * vm-swap-file <filename>. The swap file should go where the user wants, and if it's already there and of the right size we can avoid to create it again.
* it should be possible to give the vm-max-memory option in megabyte, gigabyte, ..., just using 2GB, 100MB, and so forth. * it should be possible to give the vm-max-memory option in megabyte, gigabyte, ..., just using 2GB, 100MB, and so forth.
* Make sure to wait all the IO threads are done before to fork() for BGSAVE and BGREWRITEAOF * Make sure to wait all the IO threads are done before to fork() for BGSAVE and BGREWRITEAOF
* Enlarge the stack of threads, to problems when calling LZF lib.
VERSION 1.6 TODO (Virtual memory) VERSION 1.6 TODO (Virtual memory)
================================= =================================

6
redis.c
View File

@ -7594,7 +7594,7 @@ static void *IOThreadEntryPoint(void *arg) {
lockThreadedIO(); lockThreadedIO();
if (listLength(server.io_newjobs) == 0) { if (listLength(server.io_newjobs) == 0) {
/* No new jobs in queue, exit. */ /* No new jobs in queue, exit. */
redisLog(REDIS_DEBUG,"Thread %lld exiting, nothing to do\n", redisLog(REDIS_DEBUG,"Thread %lld exiting, nothing to do",
(long long) pthread_self()); (long long) pthread_self());
server.io_active_threads--; server.io_active_threads--;
unlockThreadedIO(); unlockThreadedIO();
@ -7608,7 +7608,7 @@ static void *IOThreadEntryPoint(void *arg) {
listAddNodeTail(server.io_processing,j); listAddNodeTail(server.io_processing,j);
ln = listLast(server.io_processing); /* We use ln later to remove it */ ln = listLast(server.io_processing); /* We use ln later to remove it */
unlockThreadedIO(); unlockThreadedIO();
redisLog(REDIS_DEBUG,"Thread %lld got a new job (type %d): %p about key '%s'\n", redisLog(REDIS_DEBUG,"Thread %lld got a new job (type %d): %p about key '%s'",
(long long) pthread_self(), j->type, (void*)j, (char*)j->key->ptr); (long long) pthread_self(), j->type, (void*)j, (char*)j->key->ptr);
/* Process the Job */ /* Process the Job */
@ -7623,7 +7623,7 @@ static void *IOThreadEntryPoint(void *arg) {
} }
/* Done: insert the job into the processed queue */ /* Done: insert the job into the processed queue */
redisLog(REDIS_DEBUG,"Thread %lld completed the job: %p (key %s)\n", redisLog(REDIS_DEBUG,"Thread %lld completed the job: %p (key %s)",
(long long) pthread_self(), (void*)j, (char*)j->key->ptr); (long long) pthread_self(), (void*)j, (char*)j->key->ptr);
lockThreadedIO(); lockThreadedIO();
listDelNode(server.io_processing,ln); listDelNode(server.io_processing,ln);