Commit 2d00bd17 authored by Joe Perches's avatar Joe Perches Committed by Greg Kroah-Hartman
Browse files

staging: lustre: Coalesce string fragments 



Join the string fragments to make it easier to grep.

Ignored all the 80+ column lines.
Added many missing spaces when coalescing formats.

Signed-off-by: default avatarJoe Perches <joe@perches.com>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@linuxfoundation.org>
parent 962dbfd6

drivers/staging/lustre/lnet/klnds/o2iblnd/o2iblnd.c

+4 −8
Original line number Diff line number Diff line
@@ -930,8 +930,7 @@ kiblnd_close_peer_conns_locked (kib_peer_t *peer, int why) 
	list_for_each_safe (ctmp, cnxt, &peer->ibp_conns) {

		conn = list_entry(ctmp, kib_conn_t, ibc_list);



		CDEBUG(D_NET, "Closing conn -> %s, "

			      "version: %x, reason: %d\n",

		CDEBUG(D_NET, "Closing conn -> %s, version: %x, reason: %d\n",

		       libcfs_nid2str(peer->ibp_nid),

		       conn->ibc_version, why);
@@ -958,8 +957,7 @@ kiblnd_close_stale_conns_locked (kib_peer_t *peer, 
		    conn->ibc_incarnation == incarnation)

			continue;



		CDEBUG(D_NET, "Closing stale conn -> %s version: %x, "

			      "incarnation:%#llx(%x, %#llx)\n",

		CDEBUG(D_NET, "Closing stale conn -> %s version: %x, incarnation:%#llx(%x, %#llx)\n",

		       libcfs_nid2str(peer->ibp_nid),

		       conn->ibc_version, conn->ibc_incarnation,

		       version, incarnation);
@@ -1599,8 +1597,7 @@ kiblnd_fmr_pool_map(kib_fmr_poolset_t *fps, __u64 *pages, int npages, 


	if (fps->fps_increasing) {

		spin_unlock(&fps->fps_lock);

		CDEBUG(D_NET, "Another thread is allocating new "

		       "FMR pool, waiting for her to complete\n");

		CDEBUG(D_NET, "Another thread is allocating new FMR pool, waiting for her to complete\n");

		schedule();

		goto again;
@@ -1801,8 +1798,7 @@ kiblnd_pool_alloc_node(kib_poolset_t *ps) 
	if (ps->ps_increasing) {

		/* another thread is allocating a new pool */

		spin_unlock(&ps->ps_lock);

		CDEBUG(D_NET, "Another thread is allocating new "

		       "%s pool, waiting for her to complete\n",

		CDEBUG(D_NET, "Another thread is allocating new %s pool, waiting for her to complete\n",

		       ps->ps_name);

		schedule();

		goto again;

drivers/staging/lustre/lnet/klnds/o2iblnd/o2iblnd_cb.c

+12 −22
Original line number Diff line number Diff line
@@ -1116,8 +1116,7 @@ kiblnd_init_rdma (kib_conn_t *conn, kib_tx_t *tx, int type, 
		}



		if (tx->tx_nwrq == IBLND_RDMA_FRAGS(conn->ibc_version)) {

			CERROR("RDMA too fragmented for %s (%d): "

			       "%d/%d src %d/%d dst frags\n",

			CERROR("RDMA too fragmented for %s (%d): %d/%d src %d/%d dst frags\n",

			       libcfs_nid2str(conn->ibc_peer->ibp_nid),

			       IBLND_RDMA_FRAGS(conn->ibc_version),

			       srcidx, srcrd->rd_nfrags,
@@ -2254,8 +2253,8 @@ kiblnd_passive_connect (struct rdma_cm_id *cmid, void *priv, int priv_nob) 
	if (ni == NULL ||			 /* no matching net */

	    ni->ni_nid != reqmsg->ibm_dstnid ||   /* right NET, wrong NID! */

	    net->ibn_dev != ibdev) {	      /* wrong device */

		CERROR("Can't accept %s on %s (%s:%d:%pI4h): "

		       "bad dst nid %s\n", libcfs_nid2str(nid),

		CERROR("Can't accept %s on %s (%s:%d:%pI4h): bad dst nid %s\n",

		       libcfs_nid2str(nid),

		       ni == NULL ? "NA" : libcfs_nid2str(ni->ni_nid),

		       ibdev->ibd_ifname, ibdev->ibd_nnets,

		       &ibdev->ibd_ifip,
@@ -2295,8 +2294,7 @@ kiblnd_passive_connect (struct rdma_cm_id *cmid, void *priv, int priv_nob) 


	if (reqmsg->ibm_u.connparams.ibcp_max_frags !=

	    IBLND_RDMA_FRAGS(version)) {

		CERROR("Can't accept %s(version %x): "

		       "incompatible max_frags %d (%d wanted)\n",

		CERROR("Can't accept %s(version %x): incompatible max_frags %d (%d wanted)\n",

		       libcfs_nid2str(nid), version,

		       reqmsg->ibm_u.connparams.ibcp_max_frags,

		       IBLND_RDMA_FRAGS(version));
@@ -2502,8 +2500,7 @@ kiblnd_reconnect (kib_conn_t *conn, int version, 
		break;

	}



	CNETERR("%s: retrying (%s), %x, %x, "

		"queue_dep: %d, max_frag: %d, msg_size: %d\n",

	CNETERR("%s: retrying (%s), %x, %x, queue_dep: %d, max_frag: %d, msg_size: %d\n",

		libcfs_nid2str(peer->ibp_nid),

		reason, IBLND_MSG_VERSION, version,

		cp != NULL? cp->ibcp_queue_depth :IBLND_MSG_QUEUE_SIZE(version),
@@ -2679,8 +2676,7 @@ kiblnd_check_connreply (kib_conn_t *conn, void *priv, int priv_nob) 
	}



	if (ver != msg->ibm_version) {

		CERROR("%s replied version %x is different with "

		       "requested version %x\n",

		CERROR("%s replied version %x is different with requested version %x\n",

		       libcfs_nid2str(peer->ibp_nid), msg->ibm_version, ver);

		rc = -EPROTO;

		goto failed;
@@ -2724,8 +2720,7 @@ kiblnd_check_connreply (kib_conn_t *conn, void *priv, int priv_nob) 
	read_unlock_irqrestore(&kiblnd_data.kib_global_lock, flags);



	if (rc != 0) {

		CERROR("Bad connection reply from %s, rc = %d, "

		       "version: %x max_frags: %d\n",

		CERROR("Bad connection reply from %s, rc = %d, version: %x max_frags: %d\n",

		       libcfs_nid2str(peer->ibp_nid), rc,

		       msg->ibm_version, msg->ibm_u.connparams.ibcp_max_frags);

		goto failed;
@@ -3060,8 +3055,7 @@ kiblnd_check_conns (int idx) 
			}



			if (timedout) {

				CERROR("Timed out RDMA with %s (%lu): "

				       "c: %u, oc: %u, rc: %u\n",

				CERROR("Timed out RDMA with %s (%lu): c: %u, oc: %u, rc: %u\n",

				       libcfs_nid2str(peer->ibp_nid),

				       cfs_duration_sec(cfs_time_current() -

							peer->ibp_last_alive),
@@ -3334,10 +3328,8 @@ kiblnd_scheduler(void *arg) 


	rc = cfs_cpt_bind(lnet_cpt_table(), sched->ibs_cpt);

	if (rc != 0) {

		CWARN("Failed to bind on CPT %d, please verify whether "

		      "all CPUs are healthy and reload modules if necessary, "

		      "otherwise your system might under risk of low "

		      "performance\n", sched->ibs_cpt);

		CWARN("Failed to bind on CPT %d, please verify whether all CPUs are healthy and reload modules if necessary, otherwise your system might under risk of low performance\n",

		      sched->ibs_cpt);

	}



	spin_lock_irqsave(&sched->ibs_lock, flags);
@@ -3369,8 +3361,7 @@ kiblnd_scheduler(void *arg) 
				rc = ib_req_notify_cq(conn->ibc_cq,

						      IB_CQ_NEXT_COMP);

				if (rc < 0) {

					CWARN("%s: ib_req_notify_cq failed: %d, "

					      "closing connection\n",

					CWARN("%s: ib_req_notify_cq failed: %d, closing connection\n",

					      libcfs_nid2str(conn->ibc_peer->ibp_nid), rc);

					kiblnd_close_conn(conn, -EIO);

					kiblnd_conn_decref(conn);
@@ -3383,8 +3374,7 @@ kiblnd_scheduler(void *arg) 
			}



			if (rc < 0) {

				CWARN("%s: ib_poll_cq failed: %d, "

				      "closing connection\n",

				CWARN("%s: ib_poll_cq failed: %d, closing connection\n",

				      libcfs_nid2str(conn->ibc_peer->ibp_nid),

				      rc);

				kiblnd_close_conn(conn, -EIO);

drivers/staging/lustre/lnet/klnds/o2iblnd/o2iblnd_modparams.c

+1 −2
Original line number Diff line number Diff line
@@ -222,8 +222,7 @@ kiblnd_tunables_init (void) 
		*kiblnd_tunables.kib_concurrent_sends = *kiblnd_tunables.kib_peertxcredits / 2;



	if (*kiblnd_tunables.kib_concurrent_sends < *kiblnd_tunables.kib_peertxcredits) {

		CWARN("Concurrent sends %d is lower than message queue size: %d, "

		      "performance may drop slightly.\n",

		CWARN("Concurrent sends %d is lower than message queue size: %d, performance may drop slightly.\n",

		      *kiblnd_tunables.kib_concurrent_sends, *kiblnd_tunables.kib_peertxcredits);

	}

drivers/staging/lustre/lnet/klnds/socklnd/socklnd.c

+20 −29
Original line number Diff line number Diff line
@@ -337,8 +337,7 @@ ksocknal_associate_route_conn_locked(ksock_route_t *route, ksock_conn_t *conn) 
			       &route->ksnr_ipaddr,

			       &conn->ksnc_myipaddr);

		} else {

			CDEBUG(D_NET, "Rebinding %s %pI4h from "

			       "%pI4h to %pI4h\n",

			CDEBUG(D_NET, "Rebinding %s %pI4h from %pI4h to %pI4h\n",

			       libcfs_id2str(peer->ksnp_id),

			       &route->ksnr_ipaddr,

			       &route->ksnr_myipaddr,
@@ -974,8 +973,7 @@ ksocknal_accept (lnet_ni_t *ni, struct socket *sock) 


	LIBCFS_ALLOC(cr, sizeof(*cr));

	if (cr == NULL) {

		LCONSOLE_ERROR_MSG(0x12f, "Dropping connection request from "

				   "%pI4h: memory exhausted\n",

		LCONSOLE_ERROR_MSG(0x12f, "Dropping connection request from %pI4h: memory exhausted\n",

				   &peer_ip);

		return -ENOMEM;

	}
@@ -1288,8 +1286,7 @@ ksocknal_create_conn (lnet_ni_t *ni, ksock_route_t *route, 
	 *	socket callbacks.

	 */



	CDEBUG(D_NET, "New conn %s p %d.x %pI4h -> %pI4h/%d"

	       " incarnation:%lld sched[%d:%d]\n",

	CDEBUG(D_NET, "New conn %s p %d.x %pI4h -> %pI4h/%d incarnation:%lld sched[%d:%d]\n",

	       libcfs_id2str(peerid), conn->ksnc_proto->pro_version,

	       &conn->ksnc_myipaddr, &conn->ksnc_ipaddr,

	       conn->ksnc_port, incarnation, cpt,
@@ -1638,9 +1635,7 @@ ksocknal_destroy_conn (ksock_conn_t *conn) 
	case SOCKNAL_RX_LNET_PAYLOAD:

		last_rcv = conn->ksnc_rx_deadline -

			   cfs_time_seconds(*ksocknal_tunables.ksnd_timeout);

		CERROR("Completing partial receive from %s[%d]"

		       ", ip %pI4h:%d, with error, wanted: %d, left: %d, "

		       "last alive is %ld secs ago\n",

		CERROR("Completing partial receive from %s[%d], ip %pI4h:%d, with error, wanted: %d, left: %d, last alive is %ld secs ago\n",

		       libcfs_id2str(conn->ksnc_peer->ksnp_id), conn->ksnc_type,

		       &conn->ksnc_ipaddr, conn->ksnc_port,

		       conn->ksnc_rx_nob_wanted, conn->ksnc_rx_nob_left,
@@ -1651,24 +1646,21 @@ ksocknal_destroy_conn (ksock_conn_t *conn) 
		break;

	case SOCKNAL_RX_LNET_HEADER:

		if (conn->ksnc_rx_started)

			CERROR("Incomplete receive of lnet header from %s"

			       ", ip %pI4h:%d, with error, protocol: %d.x.\n",

			CERROR("Incomplete receive of lnet header from %s, ip %pI4h:%d, with error, protocol: %d.x.\n",

			       libcfs_id2str(conn->ksnc_peer->ksnp_id),

			       &conn->ksnc_ipaddr, conn->ksnc_port,

			       conn->ksnc_proto->pro_version);

		break;

	case SOCKNAL_RX_KSM_HEADER:

		if (conn->ksnc_rx_started)

			CERROR("Incomplete receive of ksock message from %s"

			       ", ip %pI4h:%d, with error, protocol: %d.x.\n",

			CERROR("Incomplete receive of ksock message from %s, ip %pI4h:%d, with error, protocol: %d.x.\n",

			       libcfs_id2str(conn->ksnc_peer->ksnp_id),

			       &conn->ksnc_ipaddr, conn->ksnc_port,

			       conn->ksnc_proto->pro_version);

		break;

	case SOCKNAL_RX_SLOP:

		if (conn->ksnc_rx_started)

			CERROR("Incomplete receive of slops from %s"

			       ", ip %pI4h:%d, with error\n",

			CERROR("Incomplete receive of slops from %s, ip %pI4h:%d, with error\n",

			       libcfs_id2str(conn->ksnc_peer->ksnp_id),

			       &conn->ksnc_ipaddr, conn->ksnc_port);

	       break;
@@ -2511,9 +2503,8 @@ ksocknal_debug_peerhash (lnet_ni_t *ni) 
		ksock_route_t *route;

		ksock_conn_t  *conn;



		CWARN ("Active peer on shutdown: %s, ref %d, scnt %d, "

		       "closing %d, accepting %d, err %d, zcookie %llu, "

		       "txq %d, zc_req %d\n", libcfs_id2str(peer->ksnp_id),

		CWARN("Active peer on shutdown: %s, ref %d, scnt %d, closing %d, accepting %d, err %d, zcookie %llu, txq %d, zc_req %d\n",

		      libcfs_id2str(peer->ksnp_id),

		      atomic_read(&peer->ksnp_refcount),

		      peer->ksnp_sharecount, peer->ksnp_closing,

		      peer->ksnp_accepting, peer->ksnp_error,
@@ -2523,8 +2514,8 @@ ksocknal_debug_peerhash (lnet_ni_t *ni) 


		list_for_each (tmp, &peer->ksnp_routes) {

			route = list_entry(tmp, ksock_route_t, ksnr_list);

			CWARN ("Route: ref %d, schd %d, conn %d, cnted %d, "

			       "del %d\n", atomic_read(&route->ksnr_refcount),

			CWARN("Route: ref %d, schd %d, conn %d, cnted %d, del %d\n",

			      atomic_read(&route->ksnr_refcount),

			      route->ksnr_scheduled, route->ksnr_connecting,

			      route->ksnr_connected, route->ksnr_deleted);

		}

drivers/staging/lustre/lnet/klnds/socklnd/socklnd_cb.c

+35 −54
Original line number Diff line number Diff line
@@ -551,19 +551,16 @@ ksocknal_process_transmit (ksock_conn_t *conn, ksock_tx_t *tx) 
	if (!conn->ksnc_closing) {

		switch (rc) {

		case -ECONNRESET:

			LCONSOLE_WARN("Host %pI4h reset our connection "

				      "while we were sending data; it may have "

				      "rebooted.\n",

			LCONSOLE_WARN("Host %pI4h reset our connection while we were sending data; it may have rebooted.\n",

				      &conn->ksnc_ipaddr);

			break;

		default:

			LCONSOLE_WARN("There was an unexpected network error "

				      "while writing to %pI4h: %d.\n",

			LCONSOLE_WARN("There was an unexpected network error while writing to %pI4h: %d.\n",

				      &conn->ksnc_ipaddr, rc);

			break;

		}

		CDEBUG(D_NET, "[%p] Error %d on write to %s"

		       " ip %pI4h:%d\n", conn, rc,

		CDEBUG(D_NET, "[%p] Error %d on write to %s ip %pI4h:%d\n",

		       conn, rc,

		       libcfs_id2str(conn->ksnc_peer->ksnp_id),

		       &conn->ksnc_ipaddr,

		       conn->ksnc_port);
@@ -799,8 +796,7 @@ ksocknal_find_connectable_route_locked (ksock_peer_t *peer) 
		if (!(route->ksnr_retry_interval == 0 || /* first attempt */

		      cfs_time_aftereq(now, route->ksnr_timeout))) {

			CDEBUG(D_NET,

			       "Too soon to retry route %pI4h "

			       "(cnted %d, interval %ld, %ld secs later)\n",

			       "Too soon to retry route %pI4h (cnted %d, interval %ld, %ld secs later)\n",

			       &route->ksnr_ipaddr,

			       route->ksnr_connected,

			       route->ksnr_retry_interval,
@@ -874,8 +870,8 @@ ksocknal_launch_packet (lnet_ni_t *ni, ksock_tx_t *tx, lnet_process_id_t id) 
		write_unlock_bh(g_lock);



		if ((id.pid & LNET_PID_USERFLAG) != 0) {

			CERROR("Refusing to create a connection to "

			       "userspace process %s\n", libcfs_id2str(id));

			CERROR("Refusing to create a connection to userspace process %s\n",

			       libcfs_id2str(id));

			return -EHOSTUNREACH;

		}
@@ -1132,14 +1128,13 @@ ksocknal_process_receive (ksock_conn_t *conn) 
			LASSERT (rc != -EAGAIN);



			if (rc == 0)

				CDEBUG(D_NET, "[%p] EOF from %s"

					" ip %pI4h:%d\n", conn,

				CDEBUG(D_NET, "[%p] EOF from %s ip %pI4h:%d\n",

				       conn,

				       libcfs_id2str(conn->ksnc_peer->ksnp_id),

				       &conn->ksnc_ipaddr,

				       conn->ksnc_port);

			else if (!conn->ksnc_closing)

				CERROR("[%p] Error %d on read from %s"

					" ip %pI4h:%d\n",

				CERROR("[%p] Error %d on read from %s ip %pI4h:%d\n",

				       conn, rc,

				       libcfs_id2str(conn->ksnc_peer->ksnp_id),

				       &conn->ksnc_ipaddr,
@@ -1724,8 +1719,8 @@ ksocknal_recv_hello (lnet_ni_t *ni, ksock_conn_t *conn, 
	    hello->kshm_magic != __swab32(LNET_PROTO_MAGIC) &&

	    hello->kshm_magic != le32_to_cpu (LNET_PROTO_TCP_MAGIC)) {

		/* Unexpected magic! */

		CERROR("Bad magic(1) %#08x (%#08x expected) from "

			"%pI4h\n", __cpu_to_le32 (hello->kshm_magic),

		CERROR("Bad magic(1) %#08x (%#08x expected) from %pI4h\n",

		       __cpu_to_le32 (hello->kshm_magic),

		       LNET_PROTO_TCP_MAGIC,

		       &conn->ksnc_ipaddr);

		return -EPROTO;
@@ -1755,8 +1750,7 @@ ksocknal_recv_hello (lnet_ni_t *ni, ksock_conn_t *conn, 
			ksocknal_send_hello(ni, conn, ni->ni_nid, hello);

		}



		CERROR("Unknown protocol version (%d.x expected)"

			" from %pI4h\n",

		CERROR("Unknown protocol version (%d.x expected) from %pI4h\n",

		       conn->ksnc_proto->pro_version,

		       &conn->ksnc_ipaddr);
@@ -1778,8 +1772,8 @@ ksocknal_recv_hello (lnet_ni_t *ni, ksock_conn_t *conn, 
	*incarnation = hello->kshm_src_incarnation;



	if (hello->kshm_src_nid == LNET_NID_ANY) {

		CERROR("Expecting a HELLO hdr with a NID, but got LNET_NID_ANY"

		       "from %pI4h\n", &conn->ksnc_ipaddr);

		CERROR("Expecting a HELLO hdr with a NID, but got LNET_NID_ANY from %pI4h\n",

		       &conn->ksnc_ipaddr);

		return -EPROTO;

	}
@@ -1810,10 +1804,7 @@ ksocknal_recv_hello (lnet_ni_t *ni, ksock_conn_t *conn, 


	if (peerid->pid != recv_id.pid ||

	    peerid->nid != recv_id.nid) {

		LCONSOLE_ERROR_MSG(0x130, "Connected successfully to %s on host"

				   " %pI4h, but they claimed they were "

				   "%s; please check your Lustre "

				   "configuration.\n",

		LCONSOLE_ERROR_MSG(0x130, "Connected successfully to %s on host %pI4h, but they claimed they were %s; please check your Lustre configuration.\n",

				   libcfs_id2str(*peerid),

				   &conn->ksnc_ipaddr,

				   libcfs_id2str(recv_id));
@@ -2199,8 +2190,7 @@ ksocknal_connd (void *arg) 
			if (ksocknal_connect(route)) {

				/* consecutive retry */

				if (cons_retry++ > SOCKNAL_INSANITY_RECONN) {

					CWARN("massive consecutive "

					      "re-connecting to %pI4h\n",

					CWARN("massive consecutive re-connecting to %pI4h\n",

					      &route->ksnr_ipaddr);

					cons_retry = 0;

				}
@@ -2264,25 +2254,20 @@ ksocknal_find_timed_out_conn (ksock_peer_t *peer) 


			switch (error) {

			case ECONNRESET:

				CNETERR("A connection with %s "

					"(%pI4h:%d) was reset; "

					"it may have rebooted.\n",

				CNETERR("A connection with %s (%pI4h:%d) was reset; it may have rebooted.\n",

					libcfs_id2str(peer->ksnp_id),

					&conn->ksnc_ipaddr,

					conn->ksnc_port);

				break;

			case ETIMEDOUT:

				CNETERR("A connection with %s "

					"(%pI4h:%d) timed out; the "

					"network or node may be down.\n",

				CNETERR("A connection with %s (%pI4h:%d) timed out; the network or node may be down.\n",

					libcfs_id2str(peer->ksnp_id),

					&conn->ksnc_ipaddr,

					conn->ksnc_port);

				break;

			default:

				CNETERR("An unexpected network error %d "

					"occurred with %s "

					"(%pI4h:%d\n", error,

				CNETERR("An unexpected network error %d occurred with %s (%pI4h:%d\n",

					error,

					libcfs_id2str(peer->ksnp_id),

					&conn->ksnc_ipaddr,

					conn->ksnc_port);
@@ -2297,8 +2282,7 @@ ksocknal_find_timed_out_conn (ksock_peer_t *peer) 
				     conn->ksnc_rx_deadline)) {

			/* Timed out incomplete incoming message */

			ksocknal_conn_addref(conn);

			CNETERR("Timeout receiving from %s (%pI4h:%d), "

				"state %d wanted %d left %d\n",

			CNETERR("Timeout receiving from %s (%pI4h:%d), state %d wanted %d left %d\n",

				libcfs_id2str(peer->ksnp_id),

				&conn->ksnc_ipaddr,

				conn->ksnc_port,
@@ -2315,8 +2299,7 @@ ksocknal_find_timed_out_conn (ksock_peer_t *peer) 
			/* Timed out messages queued for sending or

			 * buffered in the socket's send buffer */

			ksocknal_conn_addref(conn);

			CNETERR("Timeout sending data to %s (%pI4h:%d) "

				"the network or that node may be down.\n",

			CNETERR("Timeout sending data to %s (%pI4h:%d) the network or that node may be down.\n",

				libcfs_id2str(peer->ksnp_id),

				&conn->ksnc_ipaddr,

				conn->ksnc_port);
@@ -2500,9 +2483,7 @@ ksocknal_check_peer_timeouts (int idx) 
		spin_unlock(&peer->ksnp_lock);

		read_unlock(&ksocknal_data.ksnd_global_lock);



		CERROR("Total %d stale ZC_REQs for peer %s detected; the "

		       "oldest(%p) timed out %ld secs ago, "

		       "resid: %d, wmem: %d\n",

		CERROR("Total %d stale ZC_REQs for peer %s detected; the oldest(%p) timed out %ld secs ago, resid: %d, wmem: %d\n",

		       n, libcfs_nid2str(peer->ksnp_id.nid), tx,

		       cfs_duration_sec(cfs_time_current() - deadline),

		       resid, conn->ksnc_sock->sk->sk_wmem_queued);