diff options
Diffstat (limited to 'fs/ceph/mon_client.c')
-rw-r--r-- | fs/ceph/mon_client.c | 16 |
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 | ||