[Pvfs2-cvs] commit by slang in pvfs2/src/io/job: job-desc-queue.c job.c

[CVS commit program]

Update of /projects/cvsroot/pvfs2/src/io/job
In directory parlweb1:/tmp/cvs-serv25008/src/io/job

Modified Files:
	job-desc-queue.c job.c 
Log Message:
more fixes related to id_gen_fast/safe


Index: job-desc-queue.c
===================================================================
RCS file: /projects/cvsroot/pvfs2/src/io/job/job-desc-queue.c,v
diff -p -u -r1.17 -r1.18
--- job-desc-queue.c	22 Aug 2007 16:12:48 -0000	1.17
+++ job-desc-queue.c	11 Oct 2007 23:11:33 -0000	1.18
@@ -38,7 +38,7 @@ struct job_desc *alloc_job_desc(int type
     }
     memset(jd, 0, sizeof(struct job_desc));
 
-    id_gen_fast_register(&(jd->job_id), jd);
+    id_gen_safe_register(&(jd->job_id), jd);
 
     jd->type = type;
     return (jd);
@@ -52,7 +52,7 @@ struct job_desc *alloc_job_desc(int type
  */
 void dealloc_job_desc(struct job_desc *jd)
 {
-    id_gen_fast_unregister(jd->job_id);
+    id_gen_safe_unregister(jd->job_id);
     free(jd);
 }
 

Index: job.c
===================================================================
RCS file: /projects/cvsroot/pvfs2/src/io/job/job.c,v
diff -p -u -r1.175 -r1.176
--- job.c	11 Oct 2007 21:50:47 -0000	1.175
+++ job.c	11 Oct 2007 23:11:33 -0000	1.176
@@ -159,6 +159,8 @@ int job_initialize(int flags)
     assert(ret == 0);
 #endif
 
+    id_gen_safe_initialize();
+
     gen_mutex_lock(&initialized_mutex);
     initialized = 1;
     gen_mutex_unlock(&initialized_mutex);
@@ -177,6 +179,8 @@ int job_finalize(void)
     gen_mutex_lock(&initialized_mutex);
     initialized = 0;
     gen_mutex_unlock(&initialized_mutex);
+
+    id_gen_safe_finalize();
 
     PINT_thread_mgr_bmi_stop();
 #ifdef __PVFS2_CLIENT__