goto fail;
err = ceph_msgpool_init(&client->msgpool_client_lease,
sizeof(struct ceph_mds_lease) + PATH_MAX, 1);
+ if (err < 0)
+ goto fail;
+ err = ceph_msgpool_init(&client->msgpool_client_caps, 4096, 1);
if (err < 0)
goto fail;
err = ceph_msgpool_init(&client->msgpool_osd_opreply, 4096, 1);
return &client->msgpool_client_request_forward;
case CEPH_MSG_CLIENT_LEASE:
return &client->msgpool_client_lease;
-
+ case CEPH_MSG_CLIENT_CAPS:
+ return &client->msgpool_client_caps;
case CEPH_MSG_OSD_OPREPLY:
return &client->msgpool_osd_opreply;
+ case CEPH_MSG_OSD_MAP:
case CEPH_MSG_CLIENT_REPLY:
- case CEPH_MSG_CLIENT_CAPS:
case CEPH_MSG_CLIENT_SNAP:
- case CEPH_MSG_OSD_MAP:
default:
return NULL;
}