[master] ef4557c Align backend/waiter debugs properly, they may be here for some time.

Poul-Henning Kamp phk at FreeBSD.org
Wed Feb 25 11:37:34 CET 2015


commit ef4557c4c021afce51d9396e1c9da65d93d92d32
Author: Poul-Henning Kamp <phk at FreeBSD.org>
Date:   Wed Feb 25 10:19:12 2015 +0000

    Align backend/waiter debugs properly, they may be here for some time.

diff --git a/bin/varnishd/cache/cache_backend_tcp.c b/bin/varnishd/cache/cache_backend_tcp.c
index e82b27d..19a47a2 100644
--- a/bin/varnishd/cache/cache_backend_tcp.c
+++ b/bin/varnishd/cache/cache_backend_tcp.c
@@ -93,22 +93,28 @@ tcp_handle(struct waited *w, enum wait_event ev, double now)
 	tp = vbc->backend->tcp_pool;			// NB: Incestous
 
 	Lck_Lock(&tp->mtx);
+	VSL(SLT_Debug, 0,
+	    "------> Handler fd %d in_w %d state %d ev %d stolen %d",
+	    vbc->fd, vbc->in_waiter, vbc->state, ev, vbc->stolen);
 	AN(vbc->in_waiter);
-VSL(SLT_Debug, 0, "------> Handler fd %d in_w %d state %d ev %d stolen %d", vbc->fd, vbc->in_waiter, vbc->state, ev, vbc->stolen);
 
 	switch(vbc->state) {
 	case VBC_STATE_AVAIL:
 		if (ev != WAITER_ACTION || !vbc->stolen) {
-VSL(SLT_Debug, 0, "------> Handler avail + !action -> close");
+			VSL(SLT_Debug,
+			    0, "------> Handler avail + !action -> close");
 			VTCP_close(&vbc->fd);
 			VTAILQ_REMOVE(&tp->connlist, vbc, list);
 			tp->n_conn--;
 			FREE_OBJ(vbc);
 		} else {
-VSL(SLT_Debug, 0, "------> Handler avail + action -> re-wait");
+			VSL(SLT_Debug, 0,
+			    "------> Handler avail + action -> re-wait");
 			vbc->stolen = 0;
 			if (Wait_Enter(tp->waiter, vbc->waited)) {
-VSL(SLT_Debug, 0, "------> Handler avail + !timeout -> re-wait failed");
+			VSL(SLT_Debug, 0,
+			    "------> Handler avail + "
+			    "!timeout -> re-wait failed");
 				VTCP_close(&vbc->fd);
 				VTAILQ_REMOVE(&tp->connlist, vbc, list);
 				tp->n_conn--;
@@ -117,11 +123,11 @@ VSL(SLT_Debug, 0, "------> Handler avail + !timeout -> re-wait failed");
 		}
 		break;
 	case VBC_STATE_USED:
-VSL(SLT_Debug, 0, "------> Handler used");
+		VSL(SLT_Debug, 0, "------> Handler used");
 		vbc->in_waiter = 0;
 		break;
 	case VBC_STATE_CLEANUP:
-VSL(SLT_Debug, 0, "------> Handler cleanup");
+		VSL(SLT_Debug, 0, "------> Handler cleanup");
 		VTCP_close(&vbc->fd);
 		tp->n_kill--;
 		VTAILQ_REMOVE(&tp->killlist, vbc, list);
@@ -288,14 +294,15 @@ VBT_Recycle(struct tcp_pool *tp, struct vbc **vbcp)
 	Lck_Lock(&tp->mtx);
 	tp->n_used--;
 
-VSL(SLT_Debug, 0, "------> Recycle fd %d in_w %d", vbc->fd, vbc->in_waiter);
+	VSL(SLT_Debug, 0, "------> Recycle fd %d in_w %d",
+	    vbc->fd, vbc->in_waiter);
 
 	if (!vbc->in_waiter) {
 		vbc->in_waiter = 1;
 		vbc->waited->ptr = vbc;
 		vbc->waited->fd = vbc->fd;
 		vbc->waited->idle = VTIM_real();
-VSL(SLT_Debug, 0, "------> Recycle fd %d Wait_Enter", vbc->fd);
+		VSL(SLT_Debug, 0, "------> Recycle fd %d Wait_Enter", vbc->fd);
 		if (Wait_Enter(tp->waiter, vbc->waited)) {
 			VTCP_close(&vbc->fd);
 			FREE_OBJ(vbc);
@@ -345,7 +352,8 @@ VBT_Close(struct tcp_pool *tp, struct vbc **vbcp)
 
 	assert(vbc->state == VBC_STATE_USED);
 	assert(vbc->fd > 0);
-VSL(SLT_Debug, 0, "------> Close fd %d in_w %d", vbc->fd, vbc->in_waiter);
+	VSL(SLT_Debug, 0, "------> Close fd %d in_w %d",
+	    vbc->fd, vbc->in_waiter);
 
 	Lck_Lock(&tp->mtx);
 	tp->n_used--;
@@ -378,7 +386,7 @@ VBT_Get(struct tcp_pool *tp, double tmo)
 		CHECK_OBJ_NOTNULL(vbc, VBC_MAGIC);
 
 		assert(vbc->state == VBC_STATE_AVAIL);
-VSL(SLT_Debug, 0, "------> Steal fd %d", vbc->fd);
+		VSL(SLT_Debug, 0, "------> Steal fd %d", vbc->fd);
 
 		VTAILQ_REMOVE(&tp->connlist, vbc, list);
 		tp->n_conn--;
@@ -399,11 +407,11 @@ VSL(SLT_Debug, 0, "------> Steal fd %d", vbc->fd);
 	if (vbc->fd < 0)
 		FREE_OBJ(vbc);
 	if (vbc == NULL) {
-VSL(SLT_Debug, 0, "------> No new fd");
+		VSL(SLT_Debug, 0, "------> No new fd");
 		Lck_Lock(&tp->mtx);
 		tp->n_used--;		// Nope, didn't work after all.
 		Lck_Unlock(&tp->mtx);
 	} else
-VSL(SLT_Debug, 0, "------> New fd %d", vbc->fd);
+		VSL(SLT_Debug, 0, "------> New fd %d", vbc->fd);
 	return (vbc);
 }
diff --git a/bin/varnishd/waiter/cache_waiter_poll.c b/bin/varnishd/waiter/cache_waiter_poll.c
index b604ca4..d3cbe4e 100644
--- a/bin/varnishd/waiter/cache_waiter_poll.c
+++ b/bin/varnishd/waiter/cache_waiter_poll.c
@@ -149,7 +149,8 @@ vwp_main(void *priv)
 				break;
 			CHECK_OBJ_NOTNULL(sp, WAITED_MAGIC);
 			fd = sp->fd;
-VSL(SLT_Debug, 0, "POLL Handle %d %x", fd, vwp->pollfd[fd].revents);
+			VSL(SLT_Debug, 0,
+			    "POLL Handle %d %x", fd, vwp->pollfd[fd].revents);
 			assert(fd >= 0);
 			assert(fd <= vwp->hpoll);
 			assert(fd < vwp->npoll);



More information about the varnish-commit mailing list