fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-03-19 09:00:51 +00:00
Code Issues Projects Releases Wiki Activity

converted random printfs in debug logs

Browse Source
This commit is contained in:
antirez 2010-01-11 13:10:43 -05:00
parent b3e3d0d78e
commit 20f5b38867
1 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
redis.c
View File

@ -7385,10 +7385,6 @@ static void vmThreadedIOCompletedJob(aeEventLoop *el, int fd, void *privdata,
/* Post process it in the main thread, as there are things we /* Post process it in the main thread, as there are things we
* can do just here to avoid race conditions and/or invasive locks */ * can do just here to avoid race conditions and/or invasive locks */
redisLog(REDIS_DEBUG,"Job type: %d, key at %p (%s) refcount: %d\n", j->type, (void*)j->key, (char*)j->key->ptr, j->key->refcount); redisLog(REDIS_DEBUG,"Job type: %d, key at %p (%s) refcount: %d\n", j->type, (void*)j->key, (char*)j->key->ptr, j->key->refcount);
if (j->key->refcount <= 0) {
printf("Ooops ref count is <= 0!\n");
exit(1);
}
de = dictFind(j->db->dict,j->key); de = dictFind(j->db->dict,j->key);
assert(de != NULL); assert(de != NULL);
key = dictGetEntryKey(de); key = dictGetEntryKey(de);
@ -7523,7 +7519,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. */
printf("Thread %lld exiting, nothing to do\n", redisLog(REDIS_DEBUG,"Thread %lld exiting, nothing to do\n",
(long long) pthread_self()); (long long) pthread_self());
server.io_active_threads--; server.io_active_threads--;
unlockThreadedIO(); unlockThreadedIO();
@ -7537,7 +7533,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();
printf("Thread %lld got a new job: %p about key '%s'\n", redisLog(REDIS_DEBUG,"Thread %lld got a new job: %p about key '%s'\n",
(long long) pthread_self(), (void*)j, (char*)j->key->ptr); (long long) pthread_self(), (void*)j, (char*)j->key->ptr);
/* Process the Job */ /* Process the Job */
@ -7550,7 +7546,7 @@ static void *IOThreadEntryPoint(void *arg) {
} }
/* Done: insert the job into the processed queue */ /* Done: insert the job into the processed queue */
printf("Thread %lld completed the job: %p\n", redisLog(REDIS_DEBUG,"Thread %lld completed the job: %p\n",
(long long) pthread_self(), (void*)j); (long long) pthread_self(), (void*)j);
lockThreadedIO(); lockThreadedIO();
listDelNode(server.io_processing,ln); listDelNode(server.io_processing,ln);
@ -7721,7 +7717,6 @@ static void daemonize(void) {
FILE *fp; FILE *fp;
if (fork() != 0) exit(0); /* parent exits */ if (fork() != 0) exit(0); /* parent exits */
printf("New pid: %d\n", getpid());
setsid(); /* create a new session */ setsid(); /* create a new session */
/* Every output goes to /dev/null. If Redis is daemonized but /* Every output goes to /dev/null. If Redis is daemonized but