aboutsummaryrefslogtreecommitdiffstats
path: root/fs/ceph/mon_client.c
diff options
context:
space:
mode:
Diffstat (limited to 'fs/ceph/mon_client.c')
-rw-r--r--fs/ceph/mon_client.c16
1 files changed, 7 insertions, 9 deletions
diff --git a/fs/ceph/mon_client.c b/fs/ceph/mon_client.c
index 35f593e7e364..9900706fee75 100644
--- a/fs/ceph/mon_client.c
+++ b/fs/ceph/mon_client.c
@@ -191,7 +191,7 @@ static void __send_subscribe(struct ceph_mon_client *monc)
191 struct ceph_mon_subscribe_item *i; 191 struct ceph_mon_subscribe_item *i;
192 void *p, *end; 192 void *p, *end;
193 193
194 msg = ceph_msg_new(CEPH_MSG_MON_SUBSCRIBE, 96, 0, 0, NULL); 194 msg = ceph_msg_new(CEPH_MSG_MON_SUBSCRIBE, 96);
195 if (!msg) 195 if (!msg)
196 return; 196 return;
197 197
@@ -491,10 +491,10 @@ int ceph_monc_do_statfs(struct ceph_mon_client *monc, struct ceph_statfs *buf)
491 init_completion(&req->completion); 491 init_completion(&req->completion);
492 492
493 err = -ENOMEM; 493 err = -ENOMEM;
494 req->request = ceph_msg_new(CEPH_MSG_STATFS, sizeof(*h), 0, 0, NULL); 494 req->request = ceph_msg_new(CEPH_MSG_STATFS, sizeof(*h));
495 if (!req->request) 495 if (!req->request)
496 goto out; 496 goto out;
497 req->reply = ceph_msg_new(CEPH_MSG_STATFS_REPLY, 1024, 0, 0, NULL); 497 req->reply = ceph_msg_new(CEPH_MSG_STATFS_REPLY, 1024);
498 if (!req->reply) 498 if (!req->reply)
499 goto out; 499 goto out;
500 500
@@ -633,17 +633,15 @@ int ceph_monc_init(struct ceph_mon_client *monc, struct ceph_client *cl)
633 /* msg pools */ 633 /* msg pools */
634 err = -ENOMEM; 634 err = -ENOMEM;
635 monc->m_subscribe_ack = ceph_msg_new(CEPH_MSG_MON_SUBSCRIBE_ACK, 635 monc->m_subscribe_ack = ceph_msg_new(CEPH_MSG_MON_SUBSCRIBE_ACK,
636 sizeof(struct ceph_mon_subscribe_ack), 636 sizeof(struct ceph_mon_subscribe_ack));
637 0, 0, NULL);
638 if (!monc->m_subscribe_ack) 637 if (!monc->m_subscribe_ack)
639 goto out_monmap; 638 goto out_monmap;
640 639
641 monc->m_auth_reply = ceph_msg_new(CEPH_MSG_AUTH_REPLY, 4096, 0, 0, 640 monc->m_auth_reply = ceph_msg_new(CEPH_MSG_AUTH_REPLY, 4096);
642 NULL);
643 if (!monc->m_auth_reply) 641 if (!monc->m_auth_reply)
644 goto out_subscribe_ack; 642 goto out_subscribe_ack;
645 643
646 monc->m_auth = ceph_msg_new(CEPH_MSG_AUTH, 4096, 0, 0, NULL); 644 monc->m_auth = ceph_msg_new(CEPH_MSG_AUTH, 4096);
647 monc->pending_auth = 0; 645 monc->pending_auth = 0;
648 if (!monc->m_auth) 646 if (!monc->m_auth)
649 goto out_auth_reply; 647 goto out_auth_reply;
@@ -818,7 +816,7 @@ static struct ceph_msg *mon_alloc_msg(struct ceph_connection *con,
818 case CEPH_MSG_MON_MAP: 816 case CEPH_MSG_MON_MAP:
819 case CEPH_MSG_MDS_MAP: 817 case CEPH_MSG_MDS_MAP:
820 case CEPH_MSG_OSD_MAP: 818 case CEPH_MSG_OSD_MAP:
821 m = ceph_msg_new(type, front_len, 0, 0, NULL); 819 m = ceph_msg_new(type, front_len);
822 break; 820 break;
823 } 821 }
824 822