RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-03-10 10:19: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@236 29311d96-e01e-0410-9327-a35deaab8ce9
This commit is contained in:
sage 2005-05-19 06:16:55 +00:00
parent 00fadaaebc
commit a7fb4bcf2c
2 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
ceph/mds/OSDMonitor.cc
View File

@ -2,6 +2,7 @@
#include "OSDMonitor.h"
#include "msg/Message.h"
#include "messages/MPing.h"
#include "common/Timer.h"
@ -17,14 +18,22 @@ mds->messenger->send_message(messageptr,
timer example:
class C_Test : public Context {
OSDMonitor *om;
public:
C_Test(OSDMonitor *om) {
this->om = om;
}
void finish(int r) {
cout << "C_Test->finish(" << r << ")" << endl;
om->check_for_ping_timeouts_or_something();
}
};
g_timer.add_event_after(10, new C_Test);
to tell which mds we are, mds->get_nodeid() (out of mds->get_cluster()->get_num_mds())
*/

7
ceph/mds/OSDMonitor.h
View File

@ -1,12 +1,19 @@
#ifndef __OSDMONITOR_H
#define __OSDMONITOR_H
#include <map>
using namespace std;
class MDS;
class Message;
class OSDMonitor {
MDS *mds;
map<int,time_t> last_heard_from_osd;
map<int,time_t> last_pinged_osd;
// etc..
public:
OSDMonitor(MDS *mds) {
this->mds = mds;