diff options
author | Linus Torvalds <torvalds@linux-foundation.org> | 2012-07-31 22:25:39 -0400 |
---|---|---|
committer | Linus Torvalds <torvalds@linux-foundation.org> | 2012-07-31 22:25:39 -0400 |
commit | ac694dbdbc403c00e2c14d10bc7b8412cc378259 (patch) | |
tree | e37328cfbeaf43716dd5914cad9179e57e84df76 /net/sunrpc/xprtsock.c | |
parent | a40a1d3d0a2fd613fdec6d89d3c053268ced76ed (diff) | |
parent | 437ea90cc3afdca5229b41c6b1d38c4842756cb9 (diff) |
Merge branch 'akpm' (Andrew's patch-bomb)
Merge Andrew's second set of patches:
- MM
- a few random fixes
- a couple of RTC leftovers
* emailed patches from Andrew Morton <akpm@linux-foundation.org>: (120 commits)
rtc/rtc-88pm80x: remove unneed devm_kfree
rtc/rtc-88pm80x: assign ret only when rtc_register_driver fails
mm: hugetlbfs: close race during teardown of hugetlbfs shared page tables
tmpfs: distribute interleave better across nodes
mm: remove redundant initialization
mm: warn if pg_data_t isn't initialized with zero
mips: zero out pg_data_t when it's allocated
memcg: gix memory accounting scalability in shrink_page_list
mm/sparse: remove index_init_lock
mm/sparse: more checks on mem_section number
mm/sparse: optimize sparse_index_alloc
memcg: add mem_cgroup_from_css() helper
memcg: further prevent OOM with too many dirty pages
memcg: prevent OOM with too many dirty pages
mm: mmu_notifier: fix freed page still mapped in secondary MMU
mm: memcg: only check anon swapin page charges for swap cache
mm: memcg: only check swap cache pages for repeated charging
mm: memcg: split swapin charge function into private and public part
mm: memcg: remove needless !mm fixup to init_mm when charging
mm: memcg: remove unneeded shmem charge type
...
Diffstat (limited to 'net/sunrpc/xprtsock.c')
-rw-r--r-- | net/sunrpc/xprtsock.c | 43 |
1 files changed, 43 insertions, 0 deletions
diff --git a/net/sunrpc/xprtsock.c b/net/sunrpc/xprtsock.c index 926679459e71..400567243f84 100644 --- a/net/sunrpc/xprtsock.c +++ b/net/sunrpc/xprtsock.c | |||
@@ -1930,6 +1930,45 @@ out: | |||
1930 | current->flags &= ~PF_FSTRANS; | 1930 | current->flags &= ~PF_FSTRANS; |
1931 | } | 1931 | } |
1932 | 1932 | ||
1933 | #ifdef CONFIG_SUNRPC_SWAP | ||
1934 | static void xs_set_memalloc(struct rpc_xprt *xprt) | ||
1935 | { | ||
1936 | struct sock_xprt *transport = container_of(xprt, struct sock_xprt, | ||
1937 | xprt); | ||
1938 | |||
1939 | if (xprt->swapper) | ||
1940 | sk_set_memalloc(transport->inet); | ||
1941 | } | ||
1942 | |||
1943 | /** | ||
1944 | * xs_swapper - Tag this transport as being used for swap. | ||
1945 | * @xprt: transport to tag | ||
1946 | * @enable: enable/disable | ||
1947 | * | ||
1948 | */ | ||
1949 | int xs_swapper(struct rpc_xprt *xprt, int enable) | ||
1950 | { | ||
1951 | struct sock_xprt *transport = container_of(xprt, struct sock_xprt, | ||
1952 | xprt); | ||
1953 | int err = 0; | ||
1954 | |||
1955 | if (enable) { | ||
1956 | xprt->swapper++; | ||
1957 | xs_set_memalloc(xprt); | ||
1958 | } else if (xprt->swapper) { | ||
1959 | xprt->swapper--; | ||
1960 | sk_clear_memalloc(transport->inet); | ||
1961 | } | ||
1962 | |||
1963 | return err; | ||
1964 | } | ||
1965 | EXPORT_SYMBOL_GPL(xs_swapper); | ||
1966 | #else | ||
1967 | static void xs_set_memalloc(struct rpc_xprt *xprt) | ||
1968 | { | ||
1969 | } | ||
1970 | #endif | ||
1971 | |||
1933 | static void xs_udp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock) | 1972 | static void xs_udp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock) |
1934 | { | 1973 | { |
1935 | struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); | 1974 | struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt); |
@@ -1954,6 +1993,8 @@ static void xs_udp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock) | |||
1954 | transport->sock = sock; | 1993 | transport->sock = sock; |
1955 | transport->inet = sk; | 1994 | transport->inet = sk; |
1956 | 1995 | ||
1996 | xs_set_memalloc(xprt); | ||
1997 | |||
1957 | write_unlock_bh(&sk->sk_callback_lock); | 1998 | write_unlock_bh(&sk->sk_callback_lock); |
1958 | } | 1999 | } |
1959 | xs_udp_do_set_buffer_size(xprt); | 2000 | xs_udp_do_set_buffer_size(xprt); |
@@ -2081,6 +2122,8 @@ static int xs_tcp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock) | |||
2081 | if (!xprt_bound(xprt)) | 2122 | if (!xprt_bound(xprt)) |
2082 | goto out; | 2123 | goto out; |
2083 | 2124 | ||
2125 | xs_set_memalloc(xprt); | ||
2126 | |||
2084 | /* Tell the socket layer to start connecting... */ | 2127 | /* Tell the socket layer to start connecting... */ |
2085 | xprt->stat.connect_count++; | 2128 | xprt->stat.connect_count++; |
2086 | xprt->stat.connect_start = jiffies; | 2129 | xprt->stat.connect_start = jiffies; |