RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-21 09:57:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

*** empty log message ***

Browse Source 
git-svn-id: https://ceph.svn.sf.net/svnroot/ceph@225 29311d96-e01e-0410-9327-a35deaab8ce9
This commit is contained in:
sage 2005-05-12 20:54:22 +00:00
parent 42faba4e01
commit a6e5fa53dd
3 changed files with 25 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ceph/messages/MOSDOp.h
View File

@ -26,7 +26,7 @@ class MOSDOp : public Message {
public:
long get_tid() { return st.tid; }
size_t get_len() { return st.len; }
object_t get_oid() { return st.oid; }
int get_op() { return st.op; }
// keep a pcid (procedure call id) to match up request+reply
@ -34,7 +34,7 @@ class MOSDOp : public Message {
long get_pcid() { return st.pcid; }
MOSDOp(long tid, object_t oid, int op) :
Message(MSG_OSD_READ) {
Message(MSG_OSD_OP) {
this->st.tid = tid;
this->st.oid = oid;
this->st.op = op;

39
ceph/osd/OSD.cc
View File

@ -87,23 +87,6 @@ void OSD::dispatch(Message *m)
void OSD::handle_op(MOSDOp *op)
{
switch (op->get_op()) {
case OSD_OP_DELETE:
dout(3) << "delete on " << r->get_oid() << endl;
{
char *f = get_filename(whoami, r->get_oid());
unlink(f);
}
// "ack"
messenger->send_messenger(op, op->get_source(), op->get_source_port());
break;
}
}
// -- osd_read
@ -139,6 +122,28 @@ char *get_dir(int osd)
void OSD::handle_op(MOSDOp *op)
{
switch (op->get_op()) {
case OSD_OP_DELETE:
dout(3) << "delete on " << op->get_oid() << endl;
{
char *f = get_filename(whoami, op->get_oid());
unlink(f);
}
// "ack"
messenger->send_message(op, op->get_source(), op->get_source_port());
break;
}
}
void OSD::read(MOSDRead *r)
{
MOSDReadReply *reply;

1
ceph/osd/OSD.h
View File

@ -24,6 +24,7 @@ class OSD : public Dispatcher {
virtual void dispatch(Message *m);
void handle_op(class MOSDOp *m);
void read(MOSDRead *m);
void write(MOSDWrite *m);
};