blob: 58b8dca79806defee478e89a6a1ce9634fbcc7fa (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
// request.h
#pragma once
#include "../stdafx.h"
#include "../util/message.h"
#include "../db/dbmessage.h"
#include "config.h"
namespace mongo {
class Request : boost::noncopyable {
public:
Request( Message& m, AbstractMessagingPort* p );
// ---- message info -----
const char * getns(){
return _d.getns();
}
int op(){
return _m.data->operation();
}
bool expectResponse(){
return op() == dbQuery || op() == dbGetMore;
}
MSGID id(){
return _id;
}
DBConfig * getConfig(){
return _config;
}
ChunkManager * getChunkManager(){
return _shardInfo;
}
// ---- remote location info -----
string singleServerName();
const char * primaryName(){
return _config->getPrimary().c_str();
}
// ---- low level access ----
void reply( Message & response ){
_p->reply( _m , response , _id );
}
Message& m(){ return _m; }
DbMessage& d(){ return _d; }
AbstractMessagingPort* p(){ return _p; }
void process( int attempt = 0 );
private:
void reset( bool reload=false );
Message& _m;
DbMessage _d;
AbstractMessagingPort* _p;
MSGID _id;
DBConfig * _config;
ChunkManager * _shardInfo;
};
class StaleConfigException : public std::exception {
public:
StaleConfigException( const string& ns , const string& msg){
stringstream s;
s << "StaleConfigException ns: " << ns << " " << msg;
_msg = s.str();
}
virtual ~StaleConfigException() throw(){}
virtual const char* what() const throw(){
return _msg.c_str();
}
private:
string _msg;
};
}
#include "strategy.h"
|
