WARN_ON((flags & (CEPH_OSD_FLAG_READ|CEPH_OSD_FLAG_WRITE)) == 0);
/* create message; allow space for oid */
- msg_size += 40 + osdc->client->signed_ticket_len;
+ msg_size += 40;
if (snapc)
msg_size += sizeof(u64) * snapc->num_snaps;
msg = ceph_msg_new(CEPH_MSG_OSD_OP, msg_size, 0, 0, NULL);
op->payload_len = cpu_to_le32(*plen);
}
- /* fill in oid, ticket */
+ /* fill in oid */
head->object_len = cpu_to_le32(req->r_oid_len);
memcpy(p, req->r_oid, req->r_oid_len);
p += req->r_oid_len;
- head->ticket_len = cpu_to_le32(osdc->client->signed_ticket_len);
- memcpy(p, osdc->client->signed_ticket,
- osdc->client->signed_ticket_len);
- p += osdc->client->signed_ticket_len;
-
/* additional ops */
if (do_trunc) {
op++;
public:
object_t oid;
vector<OSDOp> ops;
- bufferlist ticket;
vector<snapid_t> snaps;
osd_peer_stat_t peer_stat;
int rmw_flags;
return peer_stat;
}
- bufferlist& get_ticket() { return ticket; }
-
//void inc_shed_count() { head.shed_count = get_shed_count() + 1; }
//int get_shed_count() { return head.shed_count; }
- MOSDOp(const bufferlist& tkt, int inc, long tid,
+ MOSDOp(int inc, long tid,
object_t& _oid, ceph_object_layout ol, epoch_t mapepoch,
int flags) :
Message(CEPH_MSG_OSD_OP),
oid(_oid),
- ticket(tkt),
rmw_flags(flags) {
memset(&head, 0, sizeof(head));
head.tid = tid;
head.object_len = oid.name.length();
head.num_snaps = snaps.size();
head.num_ops = ops.size();
- head.ticket_len = ticket.length();
::encode(head, payload);
for (unsigned i = 0; i < head.num_ops; i++) {
}
::encode_nohead(oid.name, payload);
- ::encode_nohead(ticket, payload);
::encode_nohead(snaps, payload);
if (head.flags & CEPH_OSD_FLAG_PEERSTAT)
::encode(peer_stat, payload);
off += ops[i].op.payload_len;
}
decode_nohead(head.object_len, oid.name, p);
- decode_nohead(head.ticket_len, ticket, p);
decode_nohead(head.num_snaps, snaps, p);
if (head.flags & CEPH_OSD_FLAG_PEERSTAT)
::decode(peer_stat, p);
if (op->onack)
flags |= CEPH_OSD_FLAG_ACK;
- bufferlist empty_ticket_fixme;
-#warning remove signed ticket ref
- MOSDOp *m = new MOSDOp(empty_ticket_fixme, client_inc, op->tid,
+ MOSDOp *m = new MOSDOp(client_inc, op->tid,
op->oid, op->layout, osdmap->get_epoch(),
flags);