Commit 8690bfa1 authored by Andy Grover's avatar Andy Grover

RDS: cleanup: remove "== NULL"s and "!= NULL"s in ptr comparisons

Favor "if (foo)" style over "if (foo != NULL)".
Signed-off-by: default avatarAndy Grover <andy.grover@oracle.com>
parent 2dc39357
...@@ -62,7 +62,7 @@ static int rds_release(struct socket *sock) ...@@ -62,7 +62,7 @@ static int rds_release(struct socket *sock)
struct rds_sock *rs; struct rds_sock *rs;
unsigned long flags; unsigned long flags;
if (sk == NULL) if (!sk)
goto out; goto out;
rs = rds_sk_to_rs(sk); rs = rds_sk_to_rs(sk);
......
...@@ -121,7 +121,7 @@ static int rds_add_bound(struct rds_sock *rs, __be32 addr, __be16 *port) ...@@ -121,7 +121,7 @@ static int rds_add_bound(struct rds_sock *rs, __be32 addr, __be16 *port)
do { do {
if (rover == 0) if (rover == 0)
rover++; rover++;
if (rds_bind_tree_walk(addr, cpu_to_be16(rover), rs) == NULL) { if (!rds_bind_tree_walk(addr, cpu_to_be16(rover), rs)) {
*port = cpu_to_be16(rover); *port = cpu_to_be16(rover);
ret = 0; ret = 0;
break; break;
...@@ -184,7 +184,7 @@ int rds_bind(struct socket *sock, struct sockaddr *uaddr, int addr_len) ...@@ -184,7 +184,7 @@ int rds_bind(struct socket *sock, struct sockaddr *uaddr, int addr_len)
goto out; goto out;
trans = rds_trans_get_preferred(sin->sin_addr.s_addr); trans = rds_trans_get_preferred(sin->sin_addr.s_addr);
if (trans == NULL) { if (!trans) {
ret = -EADDRNOTAVAIL; ret = -EADDRNOTAVAIL;
rds_remove_bound(rs); rds_remove_bound(rs);
if (printk_ratelimit()) if (printk_ratelimit())
......
...@@ -141,7 +141,7 @@ static struct rds_cong_map *rds_cong_from_addr(__be32 addr) ...@@ -141,7 +141,7 @@ static struct rds_cong_map *rds_cong_from_addr(__be32 addr)
unsigned long flags; unsigned long flags;
map = kzalloc(sizeof(struct rds_cong_map), GFP_KERNEL); map = kzalloc(sizeof(struct rds_cong_map), GFP_KERNEL);
if (map == NULL) if (!map)
return NULL; return NULL;
map->m_addr = addr; map->m_addr = addr;
...@@ -159,7 +159,7 @@ static struct rds_cong_map *rds_cong_from_addr(__be32 addr) ...@@ -159,7 +159,7 @@ static struct rds_cong_map *rds_cong_from_addr(__be32 addr)
ret = rds_cong_tree_walk(addr, map); ret = rds_cong_tree_walk(addr, map);
spin_unlock_irqrestore(&rds_cong_lock, flags); spin_unlock_irqrestore(&rds_cong_lock, flags);
if (ret == NULL) { if (!ret) {
ret = map; ret = map;
map = NULL; map = NULL;
} }
...@@ -205,7 +205,7 @@ int rds_cong_get_maps(struct rds_connection *conn) ...@@ -205,7 +205,7 @@ int rds_cong_get_maps(struct rds_connection *conn)
conn->c_lcong = rds_cong_from_addr(conn->c_laddr); conn->c_lcong = rds_cong_from_addr(conn->c_laddr);
conn->c_fcong = rds_cong_from_addr(conn->c_faddr); conn->c_fcong = rds_cong_from_addr(conn->c_faddr);
if (conn->c_lcong == NULL || conn->c_fcong == NULL) if (!(conn->c_lcong && conn->c_fcong))
return -ENOMEM; return -ENOMEM;
return 0; return 0;
......
...@@ -148,7 +148,7 @@ static struct rds_connection *__rds_conn_create(__be32 laddr, __be32 faddr, ...@@ -148,7 +148,7 @@ static struct rds_connection *__rds_conn_create(__be32 laddr, __be32 faddr,
goto out; goto out;
conn = kmem_cache_zalloc(rds_conn_slab, gfp); conn = kmem_cache_zalloc(rds_conn_slab, gfp);
if (conn == NULL) { if (!conn) {
conn = ERR_PTR(-ENOMEM); conn = ERR_PTR(-ENOMEM);
goto out; goto out;
} }
...@@ -502,7 +502,7 @@ int __init rds_conn_init(void) ...@@ -502,7 +502,7 @@ int __init rds_conn_init(void)
rds_conn_slab = kmem_cache_create("rds_connection", rds_conn_slab = kmem_cache_create("rds_connection",
sizeof(struct rds_connection), sizeof(struct rds_connection),
0, 0, NULL); 0, 0, NULL);
if (rds_conn_slab == NULL) if (!rds_conn_slab)
return -ENOMEM; return -ENOMEM;
rds_info_register_func(RDS_INFO_CONNECTIONS, rds_conn_info); rds_info_register_func(RDS_INFO_CONNECTIONS, rds_conn_info);
......
...@@ -230,7 +230,7 @@ static int rds_ib_setup_qp(struct rds_connection *conn) ...@@ -230,7 +230,7 @@ static int rds_ib_setup_qp(struct rds_connection *conn)
* the rds_ibdev at all. * the rds_ibdev at all.
*/ */
rds_ibdev = ib_get_client_data(dev, &rds_ib_client); rds_ibdev = ib_get_client_data(dev, &rds_ib_client);
if (rds_ibdev == NULL) { if (!rds_ibdev) {
if (printk_ratelimit()) if (printk_ratelimit())
printk(KERN_NOTICE "RDS/IB: No client_data for device %s\n", printk(KERN_NOTICE "RDS/IB: No client_data for device %s\n",
dev->name); dev->name);
...@@ -306,7 +306,7 @@ static int rds_ib_setup_qp(struct rds_connection *conn) ...@@ -306,7 +306,7 @@ static int rds_ib_setup_qp(struct rds_connection *conn)
ic->i_send_ring.w_nr * ic->i_send_ring.w_nr *
sizeof(struct rds_header), sizeof(struct rds_header),
&ic->i_send_hdrs_dma, GFP_KERNEL); &ic->i_send_hdrs_dma, GFP_KERNEL);
if (ic->i_send_hdrs == NULL) { if (!ic->i_send_hdrs) {
ret = -ENOMEM; ret = -ENOMEM;
rdsdebug("ib_dma_alloc_coherent send failed\n"); rdsdebug("ib_dma_alloc_coherent send failed\n");
goto out; goto out;
...@@ -316,7 +316,7 @@ static int rds_ib_setup_qp(struct rds_connection *conn) ...@@ -316,7 +316,7 @@ static int rds_ib_setup_qp(struct rds_connection *conn)
ic->i_recv_ring.w_nr * ic->i_recv_ring.w_nr *
sizeof(struct rds_header), sizeof(struct rds_header),
&ic->i_recv_hdrs_dma, GFP_KERNEL); &ic->i_recv_hdrs_dma, GFP_KERNEL);
if (ic->i_recv_hdrs == NULL) { if (!ic->i_recv_hdrs) {
ret = -ENOMEM; ret = -ENOMEM;
rdsdebug("ib_dma_alloc_coherent recv failed\n"); rdsdebug("ib_dma_alloc_coherent recv failed\n");
goto out; goto out;
...@@ -324,14 +324,14 @@ static int rds_ib_setup_qp(struct rds_connection *conn) ...@@ -324,14 +324,14 @@ static int rds_ib_setup_qp(struct rds_connection *conn)
ic->i_ack = ib_dma_alloc_coherent(dev, sizeof(struct rds_header), ic->i_ack = ib_dma_alloc_coherent(dev, sizeof(struct rds_header),
&ic->i_ack_dma, GFP_KERNEL); &ic->i_ack_dma, GFP_KERNEL);
if (ic->i_ack == NULL) { if (!ic->i_ack) {
ret = -ENOMEM; ret = -ENOMEM;
rdsdebug("ib_dma_alloc_coherent ack failed\n"); rdsdebug("ib_dma_alloc_coherent ack failed\n");
goto out; goto out;
} }
ic->i_sends = vmalloc(ic->i_send_ring.w_nr * sizeof(struct rds_ib_send_work)); ic->i_sends = vmalloc(ic->i_send_ring.w_nr * sizeof(struct rds_ib_send_work));
if (ic->i_sends == NULL) { if (!ic->i_sends) {
ret = -ENOMEM; ret = -ENOMEM;
rdsdebug("send allocation failed\n"); rdsdebug("send allocation failed\n");
goto out; goto out;
...@@ -339,7 +339,7 @@ static int rds_ib_setup_qp(struct rds_connection *conn) ...@@ -339,7 +339,7 @@ static int rds_ib_setup_qp(struct rds_connection *conn)
memset(ic->i_sends, 0, ic->i_send_ring.w_nr * sizeof(struct rds_ib_send_work)); memset(ic->i_sends, 0, ic->i_send_ring.w_nr * sizeof(struct rds_ib_send_work));
ic->i_recvs = vmalloc(ic->i_recv_ring.w_nr * sizeof(struct rds_ib_recv_work)); ic->i_recvs = vmalloc(ic->i_recv_ring.w_nr * sizeof(struct rds_ib_recv_work));
if (ic->i_recvs == NULL) { if (!ic->i_recvs) {
ret = -ENOMEM; ret = -ENOMEM;
rdsdebug("recv allocation failed\n"); rdsdebug("recv allocation failed\n");
goto out; goto out;
...@@ -693,7 +693,7 @@ int rds_ib_conn_alloc(struct rds_connection *conn, gfp_t gfp) ...@@ -693,7 +693,7 @@ int rds_ib_conn_alloc(struct rds_connection *conn, gfp_t gfp)
/* XXX too lazy? */ /* XXX too lazy? */
ic = kzalloc(sizeof(struct rds_ib_connection), GFP_KERNEL); ic = kzalloc(sizeof(struct rds_ib_connection), GFP_KERNEL);
if (ic == NULL) if (!ic)
return -ENOMEM; return -ENOMEM;
INIT_LIST_HEAD(&ic->ib_node); INIT_LIST_HEAD(&ic->ib_node);
......
...@@ -53,7 +53,7 @@ static void rds_ib_frag_drop_page(struct rds_page_frag *frag) ...@@ -53,7 +53,7 @@ static void rds_ib_frag_drop_page(struct rds_page_frag *frag)
static void rds_ib_frag_free(struct rds_page_frag *frag) static void rds_ib_frag_free(struct rds_page_frag *frag)
{ {
rdsdebug("frag %p page %p\n", frag, frag->f_page); rdsdebug("frag %p page %p\n", frag, frag->f_page);
BUG_ON(frag->f_page != NULL); BUG_ON(frag->f_page);
kmem_cache_free(rds_ib_frag_slab, frag); kmem_cache_free(rds_ib_frag_slab, frag);
} }
...@@ -143,14 +143,14 @@ static int rds_ib_recv_refill_one(struct rds_connection *conn, ...@@ -143,14 +143,14 @@ static int rds_ib_recv_refill_one(struct rds_connection *conn,
struct ib_sge *sge; struct ib_sge *sge;
int ret = -ENOMEM; int ret = -ENOMEM;
if (recv->r_ibinc == NULL) { if (!recv->r_ibinc) {
if (!atomic_add_unless(&rds_ib_allocation, 1, rds_ib_sysctl_max_recv_allocation)) { if (!atomic_add_unless(&rds_ib_allocation, 1, rds_ib_sysctl_max_recv_allocation)) {
rds_ib_stats_inc(s_ib_rx_alloc_limit); rds_ib_stats_inc(s_ib_rx_alloc_limit);
goto out; goto out;
} }
recv->r_ibinc = kmem_cache_alloc(rds_ib_incoming_slab, recv->r_ibinc = kmem_cache_alloc(rds_ib_incoming_slab,
kptr_gfp); kptr_gfp);
if (recv->r_ibinc == NULL) { if (!recv->r_ibinc) {
atomic_dec(&rds_ib_allocation); atomic_dec(&rds_ib_allocation);
goto out; goto out;
} }
...@@ -158,17 +158,17 @@ static int rds_ib_recv_refill_one(struct rds_connection *conn, ...@@ -158,17 +158,17 @@ static int rds_ib_recv_refill_one(struct rds_connection *conn,
rds_inc_init(&recv->r_ibinc->ii_inc, conn, conn->c_faddr); rds_inc_init(&recv->r_ibinc->ii_inc, conn, conn->c_faddr);
} }
if (recv->r_frag == NULL) { if (!recv->r_frag) {
recv->r_frag = kmem_cache_alloc(rds_ib_frag_slab, kptr_gfp); recv->r_frag = kmem_cache_alloc(rds_ib_frag_slab, kptr_gfp);
if (recv->r_frag == NULL) if (!recv->r_frag)
goto out; goto out;
INIT_LIST_HEAD(&recv->r_frag->f_item); INIT_LIST_HEAD(&recv->r_frag->f_item);
recv->r_frag->f_page = NULL; recv->r_frag->f_page = NULL;
} }
if (ic->i_frag.f_page == NULL) { if (!ic->i_frag.f_page) {
ic->i_frag.f_page = alloc_page(page_gfp); ic->i_frag.f_page = alloc_page(page_gfp);
if (ic->i_frag.f_page == NULL) if (!ic->i_frag.f_page)
goto out; goto out;
ic->i_frag.f_offset = 0; ic->i_frag.f_offset = 0;
} }
...@@ -757,7 +757,7 @@ static void rds_ib_process_recv(struct rds_connection *conn, ...@@ -757,7 +757,7 @@ static void rds_ib_process_recv(struct rds_connection *conn,
* into the inc and save the inc so we can hang upcoming fragments * into the inc and save the inc so we can hang upcoming fragments
* off its list. * off its list.
*/ */
if (ibinc == NULL) { if (!ibinc) {
ibinc = recv->r_ibinc; ibinc = recv->r_ibinc;
recv->r_ibinc = NULL; recv->r_ibinc = NULL;
ic->i_ibinc = ibinc; ic->i_ibinc = ibinc;
...@@ -940,13 +940,13 @@ int __init rds_ib_recv_init(void) ...@@ -940,13 +940,13 @@ int __init rds_ib_recv_init(void)
rds_ib_incoming_slab = kmem_cache_create("rds_ib_incoming", rds_ib_incoming_slab = kmem_cache_create("rds_ib_incoming",
sizeof(struct rds_ib_incoming), sizeof(struct rds_ib_incoming),
0, 0, NULL); 0, 0, NULL);
if (rds_ib_incoming_slab == NULL) if (!rds_ib_incoming_slab)
goto out; goto out;
rds_ib_frag_slab = kmem_cache_create("rds_ib_frag", rds_ib_frag_slab = kmem_cache_create("rds_ib_frag",
sizeof(struct rds_page_frag), sizeof(struct rds_page_frag),
0, 0, NULL); 0, 0, NULL);
if (rds_ib_frag_slab == NULL) if (!rds_ib_frag_slab)
kmem_cache_destroy(rds_ib_incoming_slab); kmem_cache_destroy(rds_ib_incoming_slab);
else else
ret = 0; ret = 0;
......
...@@ -86,7 +86,7 @@ static void rds_ib_send_unmap_rm(struct rds_ib_connection *ic, ...@@ -86,7 +86,7 @@ static void rds_ib_send_unmap_rm(struct rds_ib_connection *ic,
rm->m_sg, rm->m_nents, rm->m_sg, rm->m_nents,
DMA_TO_DEVICE); DMA_TO_DEVICE);
if (rm->m_rdma_op != NULL) { if (rm->m_rdma_op) {
rds_ib_send_unmap_rdma(ic, rm->m_rdma_op); rds_ib_send_unmap_rdma(ic, rm->m_rdma_op);
/* If the user asked for a completion notification on this /* If the user asked for a completion notification on this
...@@ -525,7 +525,7 @@ int rds_ib_xmit(struct rds_connection *conn, struct rds_message *rm, ...@@ -525,7 +525,7 @@ int rds_ib_xmit(struct rds_connection *conn, struct rds_message *rm,
} }
/* map the message the first time we see it */ /* map the message the first time we see it */
if (ic->i_rm == NULL) { if (!ic->i_rm) {
/* /*
printk(KERN_NOTICE "rds_ib_xmit prep msg dport=%u flags=0x%x len=%d\n", printk(KERN_NOTICE "rds_ib_xmit prep msg dport=%u flags=0x%x len=%d\n",
be16_to_cpu(rm->m_inc.i_hdr.h_dport), be16_to_cpu(rm->m_inc.i_hdr.h_dport),
......
...@@ -135,7 +135,7 @@ void rds_ib_sysctl_exit(void) ...@@ -135,7 +135,7 @@ void rds_ib_sysctl_exit(void)
int __init rds_ib_sysctl_init(void) int __init rds_ib_sysctl_init(void)
{ {
rds_ib_sysctl_hdr = register_sysctl_paths(rds_ib_sysctl_path, rds_ib_sysctl_table); rds_ib_sysctl_hdr = register_sysctl_paths(rds_ib_sysctl_path, rds_ib_sysctl_table);
if (rds_ib_sysctl_hdr == NULL) if (!rds_ib_sysctl_hdr)
return -ENOMEM; return -ENOMEM;
return 0; return 0;
} }
...@@ -76,7 +76,7 @@ void rds_info_register_func(int optname, rds_info_func func) ...@@ -76,7 +76,7 @@ void rds_info_register_func(int optname, rds_info_func func)
BUG_ON(optname < RDS_INFO_FIRST || optname > RDS_INFO_LAST); BUG_ON(optname < RDS_INFO_FIRST || optname > RDS_INFO_LAST);
spin_lock(&rds_info_lock); spin_lock(&rds_info_lock);
BUG_ON(rds_info_funcs[offset] != NULL); BUG_ON(rds_info_funcs[offset]);
rds_info_funcs[offset] = func; rds_info_funcs[offset] = func;
spin_unlock(&rds_info_lock); spin_unlock(&rds_info_lock);
} }
...@@ -102,7 +102,7 @@ EXPORT_SYMBOL_GPL(rds_info_deregister_func); ...@@ -102,7 +102,7 @@ EXPORT_SYMBOL_GPL(rds_info_deregister_func);
*/ */
void rds_info_iter_unmap(struct rds_info_iterator *iter) void rds_info_iter_unmap(struct rds_info_iterator *iter)
{ {
if (iter->addr != NULL) { if (iter->addr) {
kunmap_atomic(iter->addr, KM_USER0); kunmap_atomic(iter->addr, KM_USER0);
iter->addr = NULL; iter->addr = NULL;
} }
...@@ -117,7 +117,7 @@ void rds_info_copy(struct rds_info_iterator *iter, void *data, ...@@ -117,7 +117,7 @@ void rds_info_copy(struct rds_info_iterator *iter, void *data,
unsigned long this; unsigned long this;
while (bytes) { while (bytes) {
if (iter->addr == NULL) if (!iter->addr)
iter->addr = kmap_atomic(*iter->pages, KM_USER0); iter->addr = kmap_atomic(*iter->pages, KM_USER0);
this = min(bytes, PAGE_SIZE - iter->offset); this = min(bytes, PAGE_SIZE - iter->offset);
...@@ -188,7 +188,7 @@ int rds_info_getsockopt(struct socket *sock, int optname, char __user *optval, ...@@ -188,7 +188,7 @@ int rds_info_getsockopt(struct socket *sock, int optname, char __user *optval,
>> PAGE_SHIFT; >> PAGE_SHIFT;
pages = kmalloc(nr_pages * sizeof(struct page *), GFP_KERNEL); pages = kmalloc(nr_pages * sizeof(struct page *), GFP_KERNEL);
if (pages == NULL) { if (!pages) {
ret = -ENOMEM; ret = -ENOMEM;
goto out; goto out;
} }
...@@ -206,7 +206,7 @@ int rds_info_getsockopt(struct socket *sock, int optname, char __user *optval, ...@@ -206,7 +206,7 @@ int rds_info_getsockopt(struct socket *sock, int optname, char __user *optval,
call_func: call_func:
func = rds_info_funcs[optname - RDS_INFO_FIRST]; func = rds_info_funcs[optname - RDS_INFO_FIRST];
if (func == NULL) { if (!func) {
ret = -ENOPROTOOPT; ret = -ENOPROTOOPT;
goto out; goto out;
} }
...@@ -234,7 +234,7 @@ int rds_info_getsockopt(struct socket *sock, int optname, char __user *optval, ...@@ -234,7 +234,7 @@ int rds_info_getsockopt(struct socket *sock, int optname, char __user *optval,
ret = -EFAULT; ret = -EFAULT;
out: out:
for (i = 0; pages != NULL && i < nr_pages; i++) for (i = 0; pages && i < nr_pages; i++)
put_page(pages[i]); put_page(pages[i]);
kfree(pages); kfree(pages);
......
...@@ -257,7 +257,7 @@ static int rds_iw_setup_qp(struct rds_connection *conn) ...@@ -257,7 +257,7 @@ static int rds_iw_setup_qp(struct rds_connection *conn)
* the rds_iwdev at all. * the rds_iwdev at all.
*/ */
rds_iwdev = ib_get_client_data(dev, &rds_iw_client); rds_iwdev = ib_get_client_data(dev, &rds_iw_client);
if (rds_iwdev == NULL) { if (!rds_iwdev) {
if (printk_ratelimit()) if (printk_ratelimit())
printk(KERN_NOTICE "RDS/IW: No client_data for device %s\n", printk(KERN_NOTICE "RDS/IW: No client_data for device %s\n",
dev->name); dev->name);
...@@ -292,7 +292,7 @@ static int rds_iw_setup_qp(struct rds_connection *conn) ...@@ -292,7 +292,7 @@ static int rds_iw_setup_qp(struct rds_connection *conn)
ic->i_send_ring.w_nr * ic->i_send_ring.w_nr *
sizeof(struct rds_header), sizeof(struct rds_header),
&ic->i_send_hdrs_dma, GFP_KERNEL); &ic->i_send_hdrs_dma, GFP_KERNEL);
if (ic->i_send_hdrs == NULL) { if (!ic->i_send_hdrs) {
ret = -ENOMEM; ret = -ENOMEM;
rdsdebug("ib_dma_alloc_coherent send failed\n"); rdsdebug("ib_dma_alloc_coherent send failed\n");
goto out; goto out;
...@@ -302,7 +302,7 @@ static int rds_iw_setup_qp(struct rds_connection *conn) ...@@ -302,7 +302,7 @@ static int rds_iw_setup_qp(struct rds_connection *conn)
ic->i_recv_ring.w_nr * ic->i_recv_ring.w_nr *
sizeof(struct rds_header), sizeof(struct rds_header),
&ic->i_recv_hdrs_dma, GFP_KERNEL); &ic->i_recv_hdrs_dma, GFP_KERNEL);
if (ic->i_recv_hdrs == NULL) { if (!ic->i_recv_hdrs) {
ret = -ENOMEM; ret = -ENOMEM;
rdsdebug("ib_dma_alloc_coherent recv failed\n"); rdsdebug("ib_dma_alloc_coherent recv failed\n");
goto out; goto out;
...@@ -310,14 +310,14 @@ static int rds_iw_setup_qp(struct rds_connection *conn) ...@@ -310,14 +310,14 @@ static int rds_iw_setup_qp(struct rds_connection *conn)
ic->i_ack = ib_dma_alloc_coherent(dev, sizeof(struct rds_header), ic->i_ack = ib_dma_alloc_coherent(dev, sizeof(struct rds_header),
&ic->i_ack_dma, GFP_KERNEL); &ic->i_ack_dma, GFP_KERNEL);
if (ic->i_ack == NULL) { if (!ic->i_ack) {
ret = -ENOMEM; ret = -ENOMEM;
rdsdebug("ib_dma_alloc_coherent ack failed\n"); rdsdebug("ib_dma_alloc_coherent ack failed\n");
goto out; goto out;
} }
ic->i_sends = vmalloc(ic->i_send_ring.w_nr * sizeof(struct rds_iw_send_work)); ic->i_sends = vmalloc(ic->i_send_ring.w_nr * sizeof(struct rds_iw_send_work));
if (ic->i_sends == NULL) { if (!ic->i_sends) {
ret = -ENOMEM; ret = -ENOMEM;
rdsdebug("send allocation failed\n"); rdsdebug("send allocation failed\n");
goto out; goto out;
...@@ -325,7 +325,7 @@ static int rds_iw_setup_qp(struct rds_connection *conn) ...@@ -325,7 +325,7 @@ static int rds_iw_setup_qp(struct rds_connection *conn)
rds_iw_send_init_ring(ic); rds_iw_send_init_ring(ic);
ic->i_recvs = vmalloc(ic->i_recv_ring.w_nr * sizeof(struct rds_iw_recv_work)); ic->i_recvs = vmalloc(ic->i_recv_ring.w_nr * sizeof(struct rds_iw_recv_work));
if (ic->i_recvs == NULL) { if (!ic->i_recvs) {
ret = -ENOMEM; ret = -ENOMEM;
rdsdebug("recv allocation failed\n"); rdsdebug("recv allocation failed\n");
goto out; goto out;
...@@ -696,7 +696,7 @@ int rds_iw_conn_alloc(struct rds_connection *conn, gfp_t gfp) ...@@ -696,7 +696,7 @@ int rds_iw_conn_alloc(struct rds_connection *conn, gfp_t gfp)
/* XXX too lazy? */ /* XXX too lazy? */
ic = kzalloc(sizeof(struct rds_iw_connection), GFP_KERNEL); ic = kzalloc(sizeof(struct rds_iw_connection), GFP_KERNEL);
if (ic == NULL) if (!ic)
return -ENOMEM; return -ENOMEM;
INIT_LIST_HEAD(&ic->iw_node); INIT_LIST_HEAD(&ic->iw_node);
......
...@@ -53,7 +53,7 @@ static void rds_iw_frag_drop_page(struct rds_page_frag *frag) ...@@ -53,7 +53,7 @@ static void rds_iw_frag_drop_page(struct rds_page_frag *frag)
static void rds_iw_frag_free(struct rds_page_frag *frag) static void rds_iw_frag_free(struct rds_page_frag *frag)
{ {
rdsdebug("frag %p page %p\n", frag, frag->f_page); rdsdebug("frag %p page %p\n", frag, frag->f_page);
BUG_ON(frag->f_page != NULL); BUG_ON(frag->f_page);
kmem_cache_free(rds_iw_frag_slab, frag); kmem_cache_free(rds_iw_frag_slab, frag);
} }
...@@ -143,14 +143,14 @@ static int rds_iw_recv_refill_one(struct rds_connection *conn, ...@@ -143,14 +143,14 @@ static int rds_iw_recv_refill_one(struct rds_connection *conn,
struct ib_sge *sge; struct ib_sge *sge;
int ret = -ENOMEM; int ret = -ENOMEM;
if (recv->r_iwinc == NULL) { if (!recv->r_iwinc) {
if (!atomic_add_unless(&rds_iw_allocation, 1, rds_iw_sysctl_max_recv_allocation)) { if (!atomic_add_unless(&rds_iw_allocation, 1, rds_iw_sysctl_max_recv_allocation)) {
rds_iw_stats_inc(s_iw_rx_alloc_limit); rds_iw_stats_inc(s_iw_rx_alloc_limit);
goto out; goto out;
} }
recv->r_iwinc = kmem_cache_alloc(rds_iw_incoming_slab, recv->r_iwinc = kmem_cache_alloc(rds_iw_incoming_slab,
kptr_gfp); kptr_gfp);
if (recv->r_iwinc == NULL) { if (!recv->r_iwinc) {
atomic_dec(&rds_iw_allocation); atomic_dec(&rds_iw_allocation);
goto out; goto out;
} }
...@@ -158,17 +158,17 @@ static int rds_iw_recv_refill_one(struct rds_connection *conn, ...@@ -158,17 +158,17 @@ static int rds_iw_recv_refill_one(struct rds_connection *conn,
rds_inc_init(&recv->r_iwinc->ii_inc, conn, conn->c_faddr); rds_inc_init(&recv->r_iwinc->ii_inc, conn, conn->c_faddr);
} }
if (recv->r_frag == NULL) { if (!recv->r_frag) {
recv->r_frag = kmem_cache_alloc(rds_iw_frag_slab, kptr_gfp); recv->r_frag = kmem_cache_alloc(rds_iw_frag_slab, kptr_gfp);
if (recv->r_frag == NULL) if (!recv->r_frag)
goto out; goto out;
INIT_LIST_HEAD(&recv->r_frag->f_item); INIT_LIST_HEAD(&recv->r_frag->f_item);
recv->r_frag->f_page = NULL; recv->r_frag->f_page = NULL;
} }
if (ic->i_frag.f_page == NULL) { if (!ic->i_frag.f_page) {
ic->i_frag.f_page = alloc_page(page_gfp); ic->i_frag.f_page = alloc_page(page_gfp);
if (ic->i_frag.f_page == NULL) if (!ic->i_frag.f_page)
goto out; goto out;
ic->i_frag.f_offset = 0; ic->i_frag.f_offset = 0;
} }
...@@ -716,7 +716,7 @@ static void rds_iw_process_recv(struct rds_connection *conn, ...@@ -716,7 +716,7 @@ static void rds_iw_process_recv(struct rds_connection *conn,
* into the inc and save the inc so we can hang upcoming fragments * into the inc and save the inc so we can hang upcoming fragments
* off its list. * off its list.
*/ */
if (iwinc == NULL) { if (!iwinc) {
iwinc = recv->r_iwinc; iwinc = recv->r_iwinc;
recv->r_iwinc = NULL; recv->r_iwinc = NULL;
ic->i_iwinc = iwinc; ic->i_iwinc = iwinc;
...@@ -899,13 +899,13 @@ int __init rds_iw_recv_init(void) ...@@ -899,13 +899,13 @@ int __init rds_iw_recv_init(void)
rds_iw_incoming_slab = kmem_cache_create("rds_iw_incoming", rds_iw_incoming_slab = kmem_cache_create("rds_iw_incoming",
sizeof(struct rds_iw_incoming), sizeof(struct rds_iw_incoming),
0, 0, NULL); 0, 0, NULL);
if (rds_iw_incoming_slab == NULL) if (!rds_iw_incoming_slab)
goto out; goto out;
rds_iw_frag_slab = kmem_cache_create("rds_iw_frag", rds_iw_frag_slab = kmem_cache_create("rds_iw_frag",
sizeof(struct rds_page_frag), sizeof(struct rds_page_frag),
0, 0, NULL); 0, 0, NULL);
if (rds_iw_frag_slab == NULL) if (!rds_iw_frag_slab)
kmem_cache_destroy(rds_iw_incoming_slab); kmem_cache_destroy(rds_iw_incoming_slab);
else else
ret = 0; ret = 0;
......
...@@ -86,7 +86,7 @@ static void rds_iw_send_unmap_rm(struct rds_iw_connection *ic, ...@@ -86,7 +86,7 @@ static void rds_iw_send_unmap_rm(struct rds_iw_connection *ic,
rm->m_sg, rm->m_nents, rm->m_sg, rm->m_nents,
DMA_TO_DEVICE); DMA_TO_DEVICE);
if (rm->m_rdma_op != NULL) { if (rm->m_rdma_op) {
rds_iw_send_unmap_rdma(ic, rm->m_rdma_op); rds_iw_send_unmap_rdma(ic, rm->m_rdma_op);
/* If the user asked for a completion notification on this /* If the user asked for a completion notification on this
...@@ -556,7 +556,7 @@ int rds_iw_xmit(struct rds_connection *conn, struct rds_message *rm, ...@@ -556,7 +556,7 @@ int rds_iw_xmit(struct rds_connection *conn, struct rds_message *rm,
} }
/* map the message the first time we see it */ /* map the message the first time we see it */
if (ic->i_rm == NULL) { if (!ic->i_rm) {
/* /*
printk(KERN_NOTICE "rds_iw_xmit prep msg dport=%u flags=0x%x len=%d\n", printk(KERN_NOTICE "rds_iw_xmit prep msg dport=%u flags=0x%x len=%d\n",
be16_to_cpu(rm->m_inc.i_hdr.h_dport), be16_to_cpu(rm->m_inc.i_hdr.h_dport),
......
...@@ -125,7 +125,7 @@ void rds_iw_sysctl_exit(void) ...@@ -125,7 +125,7 @@ void rds_iw_sysctl_exit(void)
int __init rds_iw_sysctl_init(void) int __init rds_iw_sysctl_init(void)
{ {
rds_iw_sysctl_hdr = register_sysctl_paths(rds_iw_sysctl_path, rds_iw_sysctl_table); rds_iw_sysctl_hdr = register_sysctl_paths(rds_iw_sysctl_path, rds_iw_sysctl_table);
if (rds_iw_sysctl_hdr == NULL) if (!rds_iw_sysctl_hdr)
return -ENOMEM; return -ENOMEM;
return 0; return 0;
} }
...@@ -112,7 +112,7 @@ static int rds_loop_conn_alloc(struct rds_connection *conn, gfp_t gfp) ...@@ -112,7 +112,7 @@ static int rds_loop_conn_alloc(struct rds_connection *conn, gfp_t gfp)
unsigned long flags; unsigned long flags;
lc = kzalloc(sizeof(struct rds_loop_connection), GFP_KERNEL); lc = kzalloc(sizeof(struct rds_loop_connection), GFP_KERNEL);
if (lc == NULL) if (!lc)
return -ENOMEM; return -ENOMEM;
INIT_LIST_HEAD(&lc->loop_node); INIT_LIST_HEAD(&lc->loop_node);
......
...@@ -240,7 +240,7 @@ struct rds_message *rds_message_map_pages(unsigned long *page_addrs, unsigned in ...@@ -240,7 +240,7 @@ struct rds_message *rds_message_map_pages(unsigned long *page_addrs, unsigned in
unsigned int i; unsigned int i;
rm = rds_message_alloc(ceil(total_len, PAGE_SIZE), GFP_KERNEL); rm = rds_message_alloc(ceil(total_len, PAGE_SIZE), GFP_KERNEL);
if (rm == NULL) if (!rm)
return ERR_PTR(-ENOMEM); return ERR_PTR(-ENOMEM);
set_bit(RDS_MSG_PAGEVEC, &rm->m_flags); set_bit(RDS_MSG_PAGEVEC, &rm->m_flags);
...@@ -284,7 +284,7 @@ struct rds_message *rds_message_copy_from_user(struct iovec *first_iov, ...@@ -284,7 +284,7 @@ struct rds_message *rds_message_copy_from_user(struct iovec *first_iov,
sg_off = 0; /* Dear gcc, sg->page will be null from kzalloc. */ sg_off = 0; /* Dear gcc, sg->page will be null from kzalloc. */
while (total_len) { while (total_len) {
if (sg_page(sg) == NULL) { if (!sg_page(sg)) {
ret = rds_page_remainder_alloc(sg, total_len, ret = rds_page_remainder_alloc(sg, total_len,
GFP_HIGHUSER); GFP_HIGHUSER);
if (ret) if (ret)
......
...@@ -116,7 +116,7 @@ int rds_page_remainder_alloc(struct scatterlist *scat, unsigned long bytes, ...@@ -116,7 +116,7 @@ int rds_page_remainder_alloc(struct scatterlist *scat, unsigned long bytes,
/* jump straight to allocation if we're trying for a huge page */ /* jump straight to allocation if we're trying for a huge page */
if (bytes >= PAGE_SIZE) { if (bytes >= PAGE_SIZE) {
page = alloc_page(gfp); page = alloc_page(gfp);
if (page == NULL) { if (!page) {
ret = -ENOMEM; ret = -ENOMEM;
} else { } else {
sg_set_page(scat, page, PAGE_SIZE, 0); sg_set_page(scat, page, PAGE_SIZE, 0);
...@@ -162,7 +162,7 @@ int rds_page_remainder_alloc(struct scatterlist *scat, unsigned long bytes, ...@@ -162,7 +162,7 @@ int rds_page_remainder_alloc(struct scatterlist *scat, unsigned long bytes,
rem = &per_cpu(rds_page_remainders, get_cpu()); rem = &per_cpu(rds_page_remainders, get_cpu());
local_irq_save(flags); local_irq_save(flags);
if (page == NULL) { if (!page) {
ret = -ENOMEM; ret = -ENOMEM;
break; break;
} }
......
...@@ -189,7 +189,7 @@ static int __rds_rdma_map(struct rds_sock *rs, struct rds_get_mr_args *args, ...@@ -189,7 +189,7 @@ static int __rds_rdma_map(struct rds_sock *rs, struct rds_get_mr_args *args,
goto out; goto out;
} }
if (rs->rs_transport->get_mr == NULL) { if (!rs->rs_transport->get_mr) {
ret = -EOPNOTSUPP; ret = -EOPNOTSUPP;
goto out; goto out;
} }
...@@ -205,13 +205,13 @@ static int __rds_rdma_map(struct rds_sock *rs, struct rds_get_mr_args *args, ...@@ -205,13 +205,13 @@ static int __rds_rdma_map(struct rds_sock *rs, struct rds_get_mr_args *args,
/* XXX clamp nr_pages to limit the size of this alloc? */ /* XXX clamp nr_pages to limit the size of this alloc? */
pages = kcalloc(nr_pages, sizeof(struct page *), GFP_KERNEL); pages = kcalloc(nr_pages, sizeof(struct page *), GFP_KERNEL);
if (pages == NULL) { if (!pages) {
ret = -ENOMEM; ret = -ENOMEM;
goto out; goto out;
} }
mr = kzalloc(sizeof(struct rds_mr), GFP_KERNEL); mr = kzalloc(sizeof(struct rds_mr), GFP_KERNEL);
if (mr == NULL) { if (!mr) {
ret = -ENOMEM; ret = -ENOMEM;
goto out; goto out;
} }
...@@ -244,7 +244,7 @@ static int __rds_rdma_map(struct rds_sock *rs, struct rds_get_mr_args *args, ...@@ -244,7 +244,7 @@ static int __rds_rdma_map(struct rds_sock *rs, struct rds_get_mr_args *args,
nents = ret; nents = ret;
sg = kcalloc(nents, sizeof(*sg), GFP_KERNEL); sg = kcalloc(nents, sizeof(*sg), GFP_KERNEL);
if (sg == NULL) { if (!sg) {
ret = -ENOMEM; ret = -ENOMEM;
goto out; goto out;
} }
...@@ -425,7 +425,7 @@ void rds_rdma_unuse(struct rds_sock *rs, u32 r_key, int force) ...@@ -425,7 +425,7 @@ void rds_rdma_unuse(struct rds_sock *rs, u32 r_key, int force)
/* May have to issue a dma_sync on this memory region. /* May have to issue a dma_sync on this memory region.
* Note we could avoid this if the operation was a RDMA READ, * Note we could avoid this if the operation was a RDMA READ,
* but at this point we can't tell. */ * but at this point we can't tell. */
if (mr != NULL) { if (mr) {
if (mr->r_trans->sync_mr) if (mr->r_trans->sync_mr)
mr->r_trans->sync_mr(mr->r_trans_private, DMA_FROM_DEVICE); mr->r_trans->sync_mr(mr->r_trans_private, DMA_FROM_DEVICE);
...@@ -511,13 +511,13 @@ static struct rds_rdma_op *rds_rdma_prepare(struct rds_sock *rs, ...@@ -511,13 +511,13 @@ static struct rds_rdma_op *rds_rdma_prepare(struct rds_sock *rs,
} }
pages = kcalloc(max_pages, sizeof(struct page *), GFP_KERNEL); pages = kcalloc(max_pages, sizeof(struct page *), GFP_KERNEL);
if (pages == NULL) { if (!pages) {
ret = -ENOMEM; ret = -ENOMEM;
goto out; goto out;
} }
op = kzalloc(offsetof(struct rds_rdma_op, r_sg[nr_pages]), GFP_KERNEL); op = kzalloc(offsetof(struct rds_rdma_op, r_sg[nr_pages]), GFP_KERNEL);
if (op == NULL) { if (!op) {
ret = -ENOMEM; ret = -ENOMEM;
goto out; goto out;
} }
...@@ -643,7 +643,7 @@ int rds_cmsg_rdma_args(struct rds_sock *rs, struct rds_message *rm, ...@@ -643,7 +643,7 @@ int rds_cmsg_rdma_args(struct rds_sock *rs, struct rds_message *rm,
struct rds_rdma_op *op; struct rds_rdma_op *op;
if (cmsg->cmsg_len < CMSG_LEN(sizeof(struct rds_rdma_args)) || if (cmsg->cmsg_len < CMSG_LEN(sizeof(struct rds_rdma_args)) ||
rm->m_rdma_op != NULL) rm->m_rdma_op)
return -EINVAL; return -EINVAL;
op = rds_rdma_prepare(rs, CMSG_DATA(cmsg)); op = rds_rdma_prepare(rs, CMSG_DATA(cmsg));
...@@ -681,7 +681,7 @@ int rds_cmsg_rdma_dest(struct rds_sock *rs, struct rds_message *rm, ...@@ -681,7 +681,7 @@ int rds_cmsg_rdma_dest(struct rds_sock *rs, struct rds_message *rm,
spin_lock_irqsave(&rs->rs_rdma_lock, flags); spin_lock_irqsave(&rs->rs_rdma_lock, flags);
mr = rds_mr_tree_walk(&rs->rs_rdma_keys, r_key, NULL); mr = rds_mr_tree_walk(&rs->rs_rdma_keys, r_key, NULL);
if (mr == NULL) if (!mr)
err = -EINVAL; /* invalid r_key */ err = -EINVAL; /* invalid r_key */
else else
atomic_inc(&mr->r_refcount); atomic_inc(&mr->r_refcount);
......
...@@ -210,7 +210,7 @@ void rds_recv_incoming(struct rds_connection *conn, __be32 saddr, __be32 daddr, ...@@ -210,7 +210,7 @@ void rds_recv_incoming(struct rds_connection *conn, __be32 saddr, __be32 daddr,
} }
rs = rds_find_bound(daddr, inc->i_hdr.h_dport); rs = rds_find_bound(daddr, inc->i_hdr.h_dport);
if (rs == NULL) { if (!rs) {
rds_stats_inc(s_recv_drop_no_sock); rds_stats_inc(s_recv_drop_no_sock);
goto out; goto out;
} }
...@@ -251,7 +251,7 @@ static int rds_next_incoming(struct rds_sock *rs, struct rds_incoming **inc) ...@@ -251,7 +251,7 @@ static int rds_next_incoming(struct rds_sock *rs, struct rds_incoming **inc)
{ {
unsigned long flags; unsigned long flags;
if (*inc == NULL) { if (!*inc) {
read_lock_irqsave(&rs->rs_recv_lock, flags); read_lock_irqsave(&rs->rs_recv_lock, flags);
if (!list_empty(&rs->rs_recv_queue)) { if (!list_empty(&rs->rs_recv_queue)) {
*inc = list_entry(rs->rs_recv_queue.next, *inc = list_entry(rs->rs_recv_queue.next,
......
...@@ -164,7 +164,7 @@ int rds_send_xmit(struct rds_connection *conn) ...@@ -164,7 +164,7 @@ int rds_send_xmit(struct rds_connection *conn)
* offset and S/G temporaries. * offset and S/G temporaries.
*/ */
rm = conn->c_xmit_rm; rm = conn->c_xmit_rm;
if (rm != NULL && if (rm &&
conn->c_xmit_hdr_off == sizeof(struct rds_header) && conn->c_xmit_hdr_off == sizeof(struct rds_header) &&
conn->c_xmit_sg == rm->m_nents) { conn->c_xmit_sg == rm->m_nents) {
conn->c_xmit_rm = NULL; conn->c_xmit_rm = NULL;
...@@ -180,8 +180,8 @@ int rds_send_xmit(struct rds_connection *conn) ...@@ -180,8 +180,8 @@ int rds_send_xmit(struct rds_connection *conn)
/* If we're asked to send a cong map update, do so. /* If we're asked to send a cong map update, do so.
*/ */
if (rm == NULL && test_and_clear_bit(0, &conn->c_map_queued)) { if (!rm && test_and_clear_bit(0, &conn->c_map_queued)) {
if (conn->c_trans->xmit_cong_map != NULL) { if (conn->c_trans->xmit_cong_map) {
conn->c_map_offset = 0; conn->c_map_offset = 0;
conn->c_map_bytes = sizeof(struct rds_header) + conn->c_map_bytes = sizeof(struct rds_header) +
RDS_CONG_MAP_BYTES; RDS_CONG_MAP_BYTES;
...@@ -204,7 +204,7 @@ int rds_send_xmit(struct rds_connection *conn) ...@@ -204,7 +204,7 @@ int rds_send_xmit(struct rds_connection *conn)
* the connction. We can use this ref while holding the * the connction. We can use this ref while holding the
* send_sem.. rds_send_reset() is serialized with it. * send_sem.. rds_send_reset() is serialized with it.
*/ */
if (rm == NULL) { if (!rm) {
unsigned int len; unsigned int len;
spin_lock_irqsave(&conn->c_lock, flags); spin_lock_irqsave(&conn->c_lock, flags);
...@@ -224,7 +224,7 @@ int rds_send_xmit(struct rds_connection *conn) ...@@ -224,7 +224,7 @@ int rds_send_xmit(struct rds_connection *conn)
spin_unlock_irqrestore(&conn->c_lock, flags); spin_unlock_irqrestore(&conn->c_lock, flags);
if (rm == NULL) { if (!rm) {
was_empty = 1; was_empty = 1;
break; break;
} }
...@@ -875,7 +875,7 @@ int rds_sendmsg(struct kiocb *iocb, struct socket *sock, struct msghdr *msg, ...@@ -875,7 +875,7 @@ int rds_sendmsg(struct kiocb *iocb, struct socket *sock, struct msghdr *msg,
goto out; goto out;
if ((rm->m_rdma_cookie || rm->m_rdma_op) && if ((rm->m_rdma_cookie || rm->m_rdma_op) &&
conn->c_trans->xmit_rdma == NULL) { !conn->c_trans->xmit_rdma) {
if (printk_ratelimit()) if (printk_ratelimit())
printk(KERN_NOTICE "rdma_op %p conn xmit_rdma %p\n", printk(KERN_NOTICE "rdma_op %p conn xmit_rdma %p\n",
rm->m_rdma_op, conn->c_trans->xmit_rdma); rm->m_rdma_op, conn->c_trans->xmit_rdma);
...@@ -961,7 +961,7 @@ rds_send_pong(struct rds_connection *conn, __be16 dport) ...@@ -961,7 +961,7 @@ rds_send_pong(struct rds_connection *conn, __be16 dport)
int ret = 0; int ret = 0;
rm = rds_message_alloc(0, GFP_ATOMIC); rm = rds_message_alloc(0, GFP_ATOMIC);
if (rm == NULL) { if (!rm) {
ret = -ENOMEM; ret = -ENOMEM;
goto out; goto out;
} }
......
...@@ -111,7 +111,7 @@ int __init rds_sysctl_init(void) ...@@ -111,7 +111,7 @@ int __init rds_sysctl_init(void)
rds_sysctl_reconnect_min_jiffies = rds_sysctl_reconnect_min; rds_sysctl_reconnect_min_jiffies = rds_sysctl_reconnect_min;
rds_sysctl_reg_table = register_sysctl_paths(rds_sysctl_path, rds_sysctl_rds_table); rds_sysctl_reg_table = register_sysctl_paths(rds_sysctl_path, rds_sysctl_rds_table);
if (rds_sysctl_reg_table == NULL) if (!rds_sysctl_reg_table)
return -ENOMEM; return -ENOMEM;
return 0; return 0;
} }
...@@ -200,7 +200,7 @@ static int rds_tcp_conn_alloc(struct rds_connection *conn, gfp_t gfp) ...@@ -200,7 +200,7 @@ static int rds_tcp_conn_alloc(struct rds_connection *conn, gfp_t gfp)
struct rds_tcp_connection *tc; struct rds_tcp_connection *tc;
tc = kmem_cache_alloc(rds_tcp_conn_slab, gfp); tc = kmem_cache_alloc(rds_tcp_conn_slab, gfp);
if (tc == NULL) if (!tc)
return -ENOMEM; return -ENOMEM;
tc->t_sock = NULL; tc->t_sock = NULL;
...@@ -283,7 +283,7 @@ int __init rds_tcp_init(void) ...@@ -283,7 +283,7 @@ int __init rds_tcp_init(void)
rds_tcp_conn_slab = kmem_cache_create("rds_tcp_connection", rds_tcp_conn_slab = kmem_cache_create("rds_tcp_connection",
sizeof(struct rds_tcp_connection), sizeof(struct rds_tcp_connection),
0, 0, NULL); 0, 0, NULL);
if (rds_tcp_conn_slab == NULL) { if (!rds_tcp_conn_slab) {
ret = -ENOMEM; ret = -ENOMEM;
goto out; goto out;
} }
......
...@@ -45,7 +45,7 @@ void rds_tcp_state_change(struct sock *sk) ...@@ -45,7 +45,7 @@ void rds_tcp_state_change(struct sock *sk)
read_lock(&sk->sk_callback_lock); read_lock(&sk->sk_callback_lock);
conn = sk->sk_user_data; conn = sk->sk_user_data;
if (conn == NULL) { if (!conn) {
state_change = sk->sk_state_change; state_change = sk->sk_state_change;
goto out; goto out;
} }
......
...@@ -116,7 +116,7 @@ void rds_tcp_listen_data_ready(struct sock *sk, int bytes) ...@@ -116,7 +116,7 @@ void rds_tcp_listen_data_ready(struct sock *sk, int bytes)
read_lock(&sk->sk_callback_lock); read_lock(&sk->sk_callback_lock);
ready = sk->sk_user_data; ready = sk->sk_user_data;
if (ready == NULL) { /* check for teardown race */ if (!ready) { /* check for teardown race */
ready = sk->sk_data_ready; ready = sk->sk_data_ready;
goto out; goto out;
} }
...@@ -178,7 +178,7 @@ void rds_tcp_listen_stop(void) ...@@ -178,7 +178,7 @@ void rds_tcp_listen_stop(void)
struct socket *sock = rds_tcp_listen_sock; struct socket *sock = rds_tcp_listen_sock;
struct sock *sk; struct sock *sk;
if (sock == NULL) if (!sock)
return; return;
sk = sock->sk; sk = sock->sk;
......
...@@ -190,10 +190,10 @@ static int rds_tcp_data_recv(read_descriptor_t *desc, struct sk_buff *skb, ...@@ -190,10 +190,10 @@ static int rds_tcp_data_recv(read_descriptor_t *desc, struct sk_buff *skb,
* processing. * processing.
*/ */
while (left) { while (left) {
if (tinc == NULL) { if (!tinc) {
tinc = kmem_cache_alloc(rds_tcp_incoming_slab, tinc = kmem_cache_alloc(rds_tcp_incoming_slab,
arg->gfp); arg->gfp);
if (tinc == NULL) { if (!tinc) {
desc->error = -ENOMEM; desc->error = -ENOMEM;
goto out; goto out;
} }
...@@ -229,7 +229,7 @@ static int rds_tcp_data_recv(read_descriptor_t *desc, struct sk_buff *skb, ...@@ -229,7 +229,7 @@ static int rds_tcp_data_recv(read_descriptor_t *desc, struct sk_buff *skb,
if (left && tc->t_tinc_data_rem) { if (left && tc->t_tinc_data_rem) {
clone = skb_clone(skb, arg->gfp); clone = skb_clone(skb, arg->gfp);
if (clone == NULL) { if (!clone) {
desc->error = -ENOMEM; desc->error = -ENOMEM;
goto out; goto out;
} }
...@@ -326,7 +326,7 @@ void rds_tcp_data_ready(struct sock *sk, int bytes) ...@@ -326,7 +326,7 @@ void rds_tcp_data_ready(struct sock *sk, int bytes)
read_lock(&sk->sk_callback_lock); read_lock(&sk->sk_callback_lock);
conn = sk->sk_user_data; conn = sk->sk_user_data;
if (conn == NULL) { /* check for teardown race */ if (!conn) { /* check for teardown race */
ready = sk->sk_data_ready; ready = sk->sk_data_ready;
goto out; goto out;
} }
...@@ -347,7 +347,7 @@ int __init rds_tcp_recv_init(void) ...@@ -347,7 +347,7 @@ int __init rds_tcp_recv_init(void)
rds_tcp_incoming_slab = kmem_cache_create("rds_tcp_incoming", rds_tcp_incoming_slab = kmem_cache_create("rds_tcp_incoming",
sizeof(struct rds_tcp_incoming), sizeof(struct rds_tcp_incoming),
0, 0, NULL); 0, 0, NULL);
if (rds_tcp_incoming_slab == NULL) if (!rds_tcp_incoming_slab)
return -ENOMEM; return -ENOMEM;
return 0; return 0;
} }
......
...@@ -226,7 +226,7 @@ void rds_tcp_write_space(struct sock *sk) ...@@ -226,7 +226,7 @@ void rds_tcp_write_space(struct sock *sk)
read_lock(&sk->sk_callback_lock); read_lock(&sk->sk_callback_lock);
conn = sk->sk_user_data; conn = sk->sk_user_data;
if (conn == NULL) { if (!conn) {
write_space = sk->sk_write_space; write_space = sk->sk_write_space;
goto out; goto out;
} }
......
...@@ -215,7 +215,7 @@ void rds_threads_exit(void) ...@@ -215,7 +215,7 @@ void rds_threads_exit(void)
int __init rds_threads_init(void) int __init rds_threads_init(void)
{ {
rds_wq = create_workqueue("krdsd"); rds_wq = create_workqueue("krdsd");
if (rds_wq == NULL) if (!rds_wq)
return -ENOMEM; return -ENOMEM;
return 0; return 0;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment