[DRBD-cvs] drbd by phil; Renamed __drbd_queue_work() to drbd_queu...

drbd-user@lists.linbit.com drbd-user@lists.linbit.com
Sun, 18 Jan 2004 08:26:50 +0100 (CET)


DRBD CVS committal

Author  : phil
Module  : drbd

Dir     : drbd/drbd


Modified Files:
      Tag: rel-0_7-branch
	drbd_actlog.c drbd_dsender.c drbd_int.h 


Log Message:
Renamed __drbd_queue_work() to drbd_queue_work(). 
Introduced _drbd_queue_work() which should be used if you already
have the lock.

===================================================================
RCS file: /var/lib/cvs/drbd/drbd/drbd/Attic/drbd_actlog.c,v
retrieving revision 1.1.2.57
retrieving revision 1.1.2.58
diff -u -3 -r1.1.2.57 -r1.1.2.58
--- drbd_actlog.c	16 Jan 2004 17:34:30 -0000	1.1.2.57
+++ drbd_actlog.c	18 Jan 2004 07:26:50 -0000	1.1.2.58
@@ -512,7 +512,7 @@
 		D_ASSERT( mdev->resync_work.cb == w_resync_inactive );
 		// Could also call directly. This runs in worker's context.
 		mdev->resync_work.cb = w_resync_finished;
-		__drbd_queue_work(mdev,&mdev->data.work,&mdev->resync_work);
+		drbd_queue_work(mdev,&mdev->data.work,&mdev->resync_work);
 	}
 	
 	return 1;
@@ -568,7 +568,7 @@
 			}
 			udw->enr = enr*SM;
 			udw->w.cb = w_update_odbm;
-			__drbd_queue_work(mdev,&mdev->data.work,&udw->w);
+			drbd_queue_work(mdev,&mdev->data.work,&udw->w);
 			lc_del(mdev->resync,&ext->lce);
 		}
 	}
===================================================================
RCS file: /var/lib/cvs/drbd/drbd/drbd/Attic/drbd_dsender.c,v
retrieving revision 1.1.2.52
retrieving revision 1.1.2.53
diff -u -3 -r1.1.2.52 -r1.1.2.53
--- drbd_dsender.c	17 Jan 2004 20:05:34 -0000	1.1.2.52
+++ drbd_dsender.c	18 Jan 2004 07:26:50 -0000	1.1.2.53
@@ -69,7 +69,7 @@
 	list_del(&e->w.list);
 	spin_unlock_irqrestore(&mdev->ee_lock,flags);
 
-	__drbd_queue_work(mdev,&mdev->data.work,&e->w);
+	drbd_queue_work(mdev,&mdev->data.work,&e->w);
 }
 
 int w_resync_inactive(drbd_dev *mdev, struct drbd_work *w)
@@ -100,7 +100,7 @@
 
 	mdev = (drbd_dev*) data;
 
-	__drbd_queue_work(mdev,&mdev->data.work,&mdev->resync_work);
+	drbd_queue_work(mdev,&mdev->data.work,&mdev->resync_work);
 }
 
 STATIC int w_make_resync_request(drbd_dev* mdev, struct drbd_work* w)
@@ -256,7 +256,7 @@
 
 	if ( mdev->rs_left == 0 ) {
 		mdev->resync_work.cb = w_resync_finished;
-		__drbd_queue_work(mdev,&mdev->data.work,&mdev->resync_work);
+		drbd_queue_work(mdev,&mdev->data.work,&mdev->resync_work);
 		return;
 	}
 
@@ -264,7 +264,7 @@
 		mdev->gen_cnt[Flags] &= ~MDF_Consistent;
 		bm_reset(mdev->mbds_id);
 		mdev->resync_work.cb = w_make_resync_request;
-		__drbd_queue_work(mdev,&mdev->data.work,&mdev->resync_work);
+		drbd_queue_work(mdev,&mdev->data.work,&mdev->resync_work);
 	} else {
 		// If we are SyncSource we must be consistent :)
 		mdev->gen_cnt[Flags] |= MDF_Consistent;
===================================================================
RCS file: /var/lib/cvs/drbd/drbd/drbd/drbd_int.h,v
retrieving revision 1.58.2.96
retrieving revision 1.58.2.97
diff -u -3 -r1.58.2.96 -r1.58.2.97
--- drbd_int.h	17 Jan 2004 20:17:38 -0000	1.58.2.96
+++ drbd_int.h	18 Jan 2004 07:26:50 -0000	1.58.2.97
@@ -642,7 +642,7 @@
  *
  * To be general, this might need a spin_lock member.
  * For now, please use the mdev->req_lock to protect list_head,
- * see __drbd_queue_work below.
+ * see drbd_queue_work below.
  */
 struct drbd_work_queue {
 	struct list_head q;
@@ -1000,7 +1000,16 @@
  *************************/
 
 static inline void
-__drbd_queue_work(drbd_dev *mdev, struct drbd_work_queue *q,
+_drbd_queue_work(drbd_dev *mdev, struct drbd_work_queue *q,
+		  struct drbd_work *w)
+{
+	unsigned long flags;
+	list_add_tail(&w->list,&q->q);
+	up(&q->s);
+}
+
+static inline void
+drbd_queue_work(drbd_dev *mdev, struct drbd_work_queue *q,
 		  struct drbd_work *w)
 {
 	unsigned long flags;