X-Git-Url: https://git.saurik.com/redis.git/blobdiff_plain/21dbc6499a538af07f52a41742cf1683f3fc9c23..401c3e213c89d98bbeda399b4e17fbd636b80ac0:/src/vm.c?ds=inline diff --git a/src/vm.c b/src/vm.c index 1aad95d7..ac0d92e3 100644 --- a/src/vm.c +++ b/src/vm.c @@ -96,7 +96,6 @@ void vmInit(void) { server.io_processed = listCreate(); server.io_ready_clients = listCreate(); pthread_mutex_init(&server.io_mutex,NULL); - pthread_mutex_init(&server.obj_freelist_mutex,NULL); pthread_mutex_init(&server.io_swapfile_mutex,NULL); server.io_active_threads = 0; if (pipe(pipefds) == -1) { @@ -264,7 +263,7 @@ int vmWriteObjectOnSwap(robj *o, off_t page) { * If we can't find enough contiguous empty pages to swap the object on disk * NULL is returned. */ vmpointer *vmSwapObjectBlocking(robj *val) { - off_t pages = rdbSavedObjectPages(val,NULL); + off_t pages = rdbSavedObjectPages(val); off_t page; vmpointer *vp; @@ -822,9 +821,7 @@ void *IOThreadEntryPoint(void *arg) { vmpointer *vp = (vmpointer*)j->id; j->val = vmReadObjectFromSwap(j->page,vp->vtype); } else if (j->type == REDIS_IOJOB_PREPARE_SWAP) { - FILE *fp = fopen("/dev/null","w+"); - j->pages = rdbSavedObjectPages(j->val,fp); - fclose(fp); + j->pages = rdbSavedObjectPages(j->val); } else if (j->type == REDIS_IOJOB_DO_SWAP) { if (vmWriteObjectOnSwap(j->val,j->page) == REDIS_ERR) j->canceled = 1;