Skip to content

Commit

Permalink
bio.c typos fixes to make it compile
Browse files Browse the repository at this point in the history
  • Loading branch information
antirez committed Sep 13, 2011
1 parent 02925dd commit f81a5f5
Showing 1 changed file with 9 additions and 4 deletions.
13 changes: 9 additions & 4 deletions src/bio.c
Original file line number Diff line number Diff line change
Expand Up @@ -33,23 +33,27 @@ list *bio_jobs;
struct bio_job {
int type; /* Job type, for instance BIO_JOB_CLOSE */
void *data; /* Job specific arguments pointer. */
}
};

void *bioProcessBackgroundJobs(void *arg);

/* Make sure we have enough stack to perform all the things we do in the
* main thread. */
#define REDIS_THREAD_STACK_SIZE (1024*1024*4)

/* Initialize the background system, spawning the thread. */
void bioInit(void) {
pthread_attr_t attr;
pthread_t thread;
size_t stacksize;

pthread_mutex_init(bio_mutex,NULL);
pthread_cond_init(bio_condvar,NULL);
pthread_mutex_init(&bio_mutex,NULL);
pthread_cond_init(&bio_condvar,NULL);
bio_jobs = listCreate();

/* Set the stack size as by default it may be small in some system */
pthread_attr_init(&attr);
pthread_attr_getstacksize(&attr);
pthread_attr_getstacksize(&attr,&stacksize);
if (!stacksize) stacksize = 1; /* The world is full of Solaris Fixes */
while (stacksize < REDIS_THREAD_STACK_SIZE) stacksize *= 2;
pthread_attr_setstacksize(&attr, stacksize);
Expand All @@ -73,6 +77,7 @@ void bioCreateBackgroundJob(int type, void *data) {

void *bioProcessBackgroundJobs(void *arg) {
struct bio_job *job;
REDIS_NOTUSED(arg);

pthread_detach(pthread_self());
pthread_mutex_lock(&bio_mutex);
Expand Down

0 comments on commit f81a5f5

Please sign in to comment.