summaryrefslogtreecommitdiffstats
path: root/net/rds/connection.c
diff options
context:
space:
mode:
authorLinus Torvalds <torvalds@linux-foundation.org>2018-01-31 17:31:10 -0500
committerLinus Torvalds <torvalds@linux-foundation.org>2018-01-31 17:31:10 -0500
commitb2fe5fa68642860e7de76167c3111623aa0d5de1 (patch)
treeb7f9b89b7039ecefbc35fe3c8e73a6ff972641dd /net/rds/connection.c
parenta103950e0dd2058df5e8a8d4a915707bdcf205f0 (diff)
parenta54667f6728c2714a400f3c884727da74b6d1717 (diff)
Merge git://git.kernel.org/pub/scm/linux/kernel/git/davem/net-next
Pull networking updates from David Miller: 1) Significantly shrink the core networking routing structures. Result of http://vger.kernel.org/~davem/seoul2017_netdev_keynote.pdf 2) Add netdevsim driver for testing various offloads, from Jakub Kicinski. 3) Support cross-chip FDB operations in DSA, from Vivien Didelot. 4) Add a 2nd listener hash table for TCP, similar to what was done for UDP. From Martin KaFai Lau. 5) Add eBPF based queue selection to tun, from Jason Wang. 6) Lockless qdisc support, from John Fastabend. 7) SCTP stream interleave support, from Xin Long. 8) Smoother TCP receive autotuning, from Eric Dumazet. 9) Lots of erspan tunneling enhancements, from William Tu. 10) Add true function call support to BPF, from Alexei Starovoitov. 11) Add explicit support for GRO HW offloading, from Michael Chan. 12) Support extack generation in more netlink subsystems. From Alexander Aring, Quentin Monnet, and Jakub Kicinski. 13) Add 1000BaseX, flow control, and EEE support to mvneta driver. From Russell King. 14) Add flow table abstraction to netfilter, from Pablo Neira Ayuso. 15) Many improvements and simplifications to the NFP driver bpf JIT, from Jakub Kicinski. 16) Support for ipv6 non-equal cost multipath routing, from Ido Schimmel. 17) Add resource abstration to devlink, from Arkadi Sharshevsky. 18) Packet scheduler classifier shared filter block support, from Jiri Pirko. 19) Avoid locking in act_csum, from Davide Caratti. 20) devinet_ioctl() simplifications from Al viro. 21) More TCP bpf improvements from Lawrence Brakmo. 22) Add support for onlink ipv6 route flag, similar to ipv4, from David Ahern. * git://git.kernel.org/pub/scm/linux/kernel/git/davem/net-next: (1925 commits) tls: Add support for encryption using async offload accelerator ip6mr: fix stale iterator net/sched: kconfig: Remove blank help texts openvswitch: meter: Use 64-bit arithmetic instead of 32-bit tcp_nv: fix potential integer overflow in tcpnv_acked r8169: fix RTL8168EP take too long to complete driver initialization. qmi_wwan: Add support for Quectel EP06 rtnetlink: enable IFLA_IF_NETNSID for RTM_NEWLINK ipmr: Fix ptrdiff_t print formatting ibmvnic: Wait for device response when changing MAC qlcnic: fix deadlock bug tcp: release sk_frag.page in tcp_disconnect ipv4: Get the address of interface correctly. net_sched: gen_estimator: fix lockdep splat net: macb: Handle HRESP error net/mlx5e: IPoIB, Fix copy-paste bug in flow steering refactoring ipv6: addrconf: break critical section in addrconf_verify_rtnl() ipv6: change route cache aging logic i40e/i40evf: Update DESC_NEEDED value to reflect larger value bnxt_en: cleanup DIM work on device shutdown ...
Diffstat (limited to 'net/rds/connection.c')
-rw-r--r--net/rds/connection.c27
1 files changed, 21 insertions, 6 deletions
diff --git a/net/rds/connection.c b/net/rds/connection.c
index 7ee2d5d68b78..b10c0ef36d8d 100644
--- a/net/rds/connection.c
+++ b/net/rds/connection.c
@@ -230,8 +230,8 @@ static struct rds_connection *__rds_conn_create(struct net *net,
230 230
231 rdsdebug("allocated conn %p for %pI4 -> %pI4 over %s %s\n", 231 rdsdebug("allocated conn %p for %pI4 -> %pI4 over %s %s\n",
232 conn, &laddr, &faddr, 232 conn, &laddr, &faddr,
233 trans->t_name ? trans->t_name : "[unknown]", 233 strnlen(trans->t_name, sizeof(trans->t_name)) ? trans->t_name :
234 is_outgoing ? "(outgoing)" : ""); 234 "[unknown]", is_outgoing ? "(outgoing)" : "");
235 235
236 /* 236 /*
237 * Since we ran without holding the conn lock, someone could 237 * Since we ran without holding the conn lock, someone could
@@ -382,10 +382,13 @@ static void rds_conn_path_destroy(struct rds_conn_path *cp)
382{ 382{
383 struct rds_message *rm, *rtmp; 383 struct rds_message *rm, *rtmp;
384 384
385 set_bit(RDS_DESTROY_PENDING, &cp->cp_flags);
386
385 if (!cp->cp_transport_data) 387 if (!cp->cp_transport_data)
386 return; 388 return;
387 389
388 /* make sure lingering queued work won't try to ref the conn */ 390 /* make sure lingering queued work won't try to ref the conn */
391 synchronize_rcu();
389 cancel_delayed_work_sync(&cp->cp_send_w); 392 cancel_delayed_work_sync(&cp->cp_send_w);
390 cancel_delayed_work_sync(&cp->cp_recv_w); 393 cancel_delayed_work_sync(&cp->cp_recv_w);
391 394
@@ -403,6 +406,11 @@ static void rds_conn_path_destroy(struct rds_conn_path *cp)
403 if (cp->cp_xmit_rm) 406 if (cp->cp_xmit_rm)
404 rds_message_put(cp->cp_xmit_rm); 407 rds_message_put(cp->cp_xmit_rm);
405 408
409 WARN_ON(delayed_work_pending(&cp->cp_send_w));
410 WARN_ON(delayed_work_pending(&cp->cp_recv_w));
411 WARN_ON(delayed_work_pending(&cp->cp_conn_w));
412 WARN_ON(work_pending(&cp->cp_down_w));
413
406 cp->cp_conn->c_trans->conn_free(cp->cp_transport_data); 414 cp->cp_conn->c_trans->conn_free(cp->cp_transport_data);
407} 415}
408 416
@@ -424,7 +432,6 @@ void rds_conn_destroy(struct rds_connection *conn)
424 "%pI4\n", conn, &conn->c_laddr, 432 "%pI4\n", conn, &conn->c_laddr,
425 &conn->c_faddr); 433 &conn->c_faddr);
426 434
427 conn->c_destroy_in_prog = 1;
428 /* Ensure conn will not be scheduled for reconnect */ 435 /* Ensure conn will not be scheduled for reconnect */
429 spin_lock_irq(&rds_conn_lock); 436 spin_lock_irq(&rds_conn_lock);
430 hlist_del_init_rcu(&conn->c_hash_node); 437 hlist_del_init_rcu(&conn->c_hash_node);
@@ -445,7 +452,6 @@ void rds_conn_destroy(struct rds_connection *conn)
445 */ 452 */
446 rds_cong_remove_conn(conn); 453 rds_cong_remove_conn(conn);
447 454
448 put_net(conn->c_net);
449 kfree(conn->c_path); 455 kfree(conn->c_path);
450 kmem_cache_free(rds_conn_slab, conn); 456 kmem_cache_free(rds_conn_slab, conn);
451 457
@@ -684,10 +690,13 @@ void rds_conn_path_drop(struct rds_conn_path *cp, bool destroy)
684{ 690{
685 atomic_set(&cp->cp_state, RDS_CONN_ERROR); 691 atomic_set(&cp->cp_state, RDS_CONN_ERROR);
686 692
687 if (!destroy && cp->cp_conn->c_destroy_in_prog) 693 rcu_read_lock();
694 if (!destroy && test_bit(RDS_DESTROY_PENDING, &cp->cp_flags)) {
695 rcu_read_unlock();
688 return; 696 return;
689 697 }
690 queue_work(rds_wq, &cp->cp_down_w); 698 queue_work(rds_wq, &cp->cp_down_w);
699 rcu_read_unlock();
691} 700}
692EXPORT_SYMBOL_GPL(rds_conn_path_drop); 701EXPORT_SYMBOL_GPL(rds_conn_path_drop);
693 702
@@ -704,9 +713,15 @@ EXPORT_SYMBOL_GPL(rds_conn_drop);
704 */ 713 */
705void rds_conn_path_connect_if_down(struct rds_conn_path *cp) 714void rds_conn_path_connect_if_down(struct rds_conn_path *cp)
706{ 715{
716 rcu_read_lock();
717 if (test_bit(RDS_DESTROY_PENDING, &cp->cp_flags)) {
718 rcu_read_unlock();
719 return;
720 }
707 if (rds_conn_path_state(cp) == RDS_CONN_DOWN && 721 if (rds_conn_path_state(cp) == RDS_CONN_DOWN &&
708 !test_and_set_bit(RDS_RECONNECT_PENDING, &cp->cp_flags)) 722 !test_and_set_bit(RDS_RECONNECT_PENDING, &cp->cp_flags))
709 queue_delayed_work(rds_wq, &cp->cp_conn_w, 0); 723 queue_delayed_work(rds_wq, &cp->cp_conn_w, 0);
724 rcu_read_unlock();
710} 725}
711EXPORT_SYMBOL_GPL(rds_conn_path_connect_if_down); 726EXPORT_SYMBOL_GPL(rds_conn_path_connect_if_down);
712 727