blob: 689216c61c2672b7226604a731eba549f729d4a9 (
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
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
// request.h
#pragma once
#include "../stdafx.h"
#include "../util/message.h"
#include "../db/dbmessage.h"
#include "config.h"
#include "util.h"
namespace mongo {
class ClientInfo;
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;
}
bool isShardingEnabled(){
return _config->isShardingEnabled();
}
ChunkManager * getChunkManager(){
return _chunkManager;
}
int getClientId(){
return _clientId;
}
ClientInfo * getClientInfo(){
return _clientInfo;
}
// ---- 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 * _chunkManager;
int _clientId;
ClientInfo * _clientInfo;
};
typedef map<int,ClientInfo*> ClientCache;
class ClientInfo {
public:
ClientInfo( int clientId );
~ClientInfo();
void addShard( const string& shard );
set<string> * getPrev() const { return _prev; };
void newRequest();
void disconnect();
static ClientInfo * get( int clientId = 0 , bool create = true );
private:
int _id;
set<string> _a;
set<string> _b;
set<string> * _cur;
set<string> * _prev;
int _lastAccess;
static boost::mutex _clientsLock;
static ClientCache _clients;
static boost::thread_specific_ptr<ClientInfo> _tlInfo;
};
}
#include "strategy.h"
|
