[packages/drbd.git] / drbd-kernel24.patch

--- drbd.orig/drbd/drbd.c	Fri May 25 13:13:22 2001
+++ drbd/drbd/drbd.c	Sat Sep  8 10:04:56 2001
@@ -404,7 +404,7 @@
 
 		rlen = rlen + sprintf(buf + rlen, "\n");
 
-		for (i = 0; i < NR_REQUEST; i++) {
+		for (i = 0; i < QUEUE_NR_REQUESTS; i++) {
 			if (my_all_requests[i].rq_status == RQ_INACTIVE) {
 				l = 'E';
 			} else {
@@ -1079,8 +1079,8 @@
 		unsigned long flags;
 		del_timer(&mdev->s_timeout);
 		spin_lock_irqsave(&current->sigmask_lock,flags);
-		if (sigismember(&current->signal, DRBD_SIG)) {
-			sigdelset(&current->signal, DRBD_SIG);
+		if (sigismember(&current->pending.signal, DRBD_SIG)) {
+			sigdelset(&current->pending.signal, DRBD_SIG);
 			recalc_sigpending(current);
 			spin_unlock_irqrestore(&current->sigmask_lock,flags);
 
@@ -1237,7 +1237,7 @@
 
 void drbd_dio_end(struct buffer_head *bh, int uptodate)
 {
-	struct request *req = bh->b_dev_id;
+	struct request *req = bh->b_private;
 
 	// READs are sorted out in drbd_end_req().
 	drbd_end_req(req, RQ_DRBD_WRITTEN, uptodate);
@@ -1356,7 +1356,7 @@
 #endif			
 
 			bh->b_list = BUF_LOCKED;
-			bh->b_dev_id = req;
+			bh->b_private = req;
 			bh->b_end_io = drbd_dio_end;
 			
 			if(req->cmd == WRITE) 
@@ -2222,8 +2222,8 @@
 			unsigned long flags;
 			del_timer(&accept_timeout);
 			spin_lock_irqsave(&current->sigmask_lock,flags);
-			if (sigismember(&current->signal, DRBD_SIG)) {
-				sigdelset(&current->signal, DRBD_SIG);
+			if (sigismember(&current->pending.signal, DRBD_SIG)) {
+				sigdelset(&current->pending.signal, DRBD_SIG);
 				recalc_sigpending(current);
 				spin_unlock_irqrestore(&current->sigmask_lock,
 						       flags);
@@ -2453,7 +2453,7 @@
 	        return FALSE;
 
 	mark_buffer_uptodate(bh, 0);
-	mark_buffer_dirty(bh, 1);
+	mark_buffer_dirty(bh);
 
 	if (drbd_conf[minor].conf.wire_protocol == DRBD_PROT_B
 	    && header.block_id != ID_SYNCER) {
@@ -2480,7 +2480,7 @@
 	 */
 
 	if (drbd_conf[minor].conf.wire_protocol == DRBD_PROT_C) {
-		if (drbd_conf[minor].unacked_cnt >= (NR_REQUEST / 4)) {
+		if (drbd_conf[minor].unacked_cnt >= (QUEUE_NR_REQUESTS / 4)) {
 			run_task_queue(&tq_disk);
 		}
 	}
@@ -2869,8 +2869,8 @@
 			thi->t_state = Running;
 			wake_up(&thi->wait);
 			spin_lock_irqsave(&current->sigmask_lock,flags);
-			if (sigismember(&current->signal, SIGTERM)) {
-				sigdelset(&current->signal, SIGTERM);
+			if (sigismember(&current->pending.signal, SIGTERM)) {
+				sigdelset(&current->pending.signal, SIGTERM);
 				recalc_sigpending(current);
 			}
 			spin_unlock_irqrestore(&current->sigmask_lock,flags);
Commit	Line	Data
adfef6a4 JB	1	--- drbd.orig/drbd/drbd.c Fri May 25 13:13:22 2001
	2	+++ drbd/drbd/drbd.c Sat Sep 8 10:04:56 2001
	3	@@ -404,7 +404,7 @@
	4
	5	rlen = rlen + sprintf(buf + rlen, "\n");
	6
	7	- for (i = 0; i < NR_REQUEST; i++) {
	8	+ for (i = 0; i < QUEUE_NR_REQUESTS; i++) {
	9	if (my_all_requests[i].rq_status == RQ_INACTIVE) {
	10	l = 'E';
	11	} else {
	12	@@ -1079,8 +1079,8 @@
	13	unsigned long flags;
	14	del_timer(&mdev->s_timeout);
	15	spin_lock_irqsave(&current->sigmask_lock,flags);
	16	- if (sigismember(&current->signal, DRBD_SIG)) {
	17	- sigdelset(&current->signal, DRBD_SIG);
	18	+ if (sigismember(&current->pending.signal, DRBD_SIG)) {
	19	+ sigdelset(&current->pending.signal, DRBD_SIG);
	20	recalc_sigpending(current);
	21	spin_unlock_irqrestore(&current->sigmask_lock,flags);
	22
	23	@@ -1237,7 +1237,7 @@
	24
	25	void drbd_dio_end(struct buffer_head *bh, int uptodate)
	26	{
	27	- struct request *req = bh->b_dev_id;
	28	+ struct request *req = bh->b_private;
	29
	30	// READs are sorted out in drbd_end_req().
	31	drbd_end_req(req, RQ_DRBD_WRITTEN, uptodate);
	32	@@ -1356,7 +1356,7 @@
	33	#endif
	34
	35	bh->b_list = BUF_LOCKED;
	36	- bh->b_dev_id = req;
	37	+ bh->b_private = req;
	38	bh->b_end_io = drbd_dio_end;
	39
	40	if(req->cmd == WRITE)
	41	@@ -2222,8 +2222,8 @@
	42	unsigned long flags;
	43	del_timer(&accept_timeout);
	44	spin_lock_irqsave(&current->sigmask_lock,flags);
	45	- if (sigismember(&current->signal, DRBD_SIG)) {
	46	- sigdelset(&current->signal, DRBD_SIG);
	47	+ if (sigismember(&current->pending.signal, DRBD_SIG)) {
	48	+ sigdelset(&current->pending.signal, DRBD_SIG);
	49	recalc_sigpending(current);
	50	spin_unlock_irqrestore(&current->sigmask_lock,
	51	flags);
	52	@@ -2453,7 +2453,7 @@
	53	return FALSE;
	54
	55	mark_buffer_uptodate(bh, 0);
	56	- mark_buffer_dirty(bh, 1);
	57	+ mark_buffer_dirty(bh);
	58
	59	if (drbd_conf[minor].conf.wire_protocol == DRBD_PROT_B
	60	&& header.block_id != ID_SYNCER) {
	61	@@ -2480,7 +2480,7 @@
	62	*/
	63
	64	if (drbd_conf[minor].conf.wire_protocol == DRBD_PROT_C) {
65	- if (drbd_conf[minor].unacked_cnt >= (NR_REQUEST / 4)) {
66	+ if (drbd_conf[minor].unacked_cnt >= (QUEUE_NR_REQUESTS / 4)) {
67	run_task_queue(&tq_disk);
68	}
69	}
70	@@ -2869,8 +2869,8 @@
71	thi->t_state = Running;
72	wake_up(&thi->wait);
73	spin_lock_irqsave(&current->sigmask_lock,flags);
74	- if (sigismember(&current->signal, SIGTERM)) {
75	- sigdelset(&current->signal, SIGTERM);
76	+ if (sigismember(&current->pending.signal, SIGTERM)) {
77	+ sigdelset(&current->pending.signal, SIGTERM);
78	recalc_sigpending(current);
79	}
80	spin_unlock_irqrestore(&current->sigmask_lock,flags);