blob: 2e9fefea6e38affb6116a0aa2ecb47911c7bddc9 (
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
|
// client.h
/*
* Copyright (C) 2010 10gen Inc.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License, version 3,
* as published by the Free Software Foundation.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#include "../pch.h"
namespace mongo {
/**
* holds information about a client connected to a mongos
* 1 per client socket
* currently implemented with a thread local
*/
class ClientInfo {
public:
ClientInfo();
~ClientInfo();
/** new request from client, adjusts internal state */
void newRequest( AbstractMessagingPort* p = 0 );
/** client disconnected */
void disconnect();
/**
* @return remote socket address of the client
*/
HostAndPort getRemote() const { return _remote; }
/**
* notes that this client use this shard
* keeps track of all shards accessed this request
*/
void addShard( const string& shard );
/**
* gets shards used on the previous request
*/
set<string> * getPrev() const { return _prev; };
/**
* gets all shards we've accessed since the last time we called clearSinceLastGetError
*/
const set<string>& sinceLastGetError() const { return _sinceLastGetError; }
/**
* clears list of shards we've talked to
*/
void clearSinceLastGetError() { _sinceLastGetError.clear(); }
/**
* resets the list of shards using to process the current request
*/
void clearCurrentShards(){ _cur->clear(); }
/**
* calls getLastError
* resets shards since get last error
* @return if the command was ok or if there was an error
*/
bool getLastError( const BSONObj& options , BSONObjBuilder& result , bool fromWriteBackListener = false );
/** @return if its ok to auto split from this client */
bool autoSplitOk() const { return _autoSplitOk; }
void noAutoSplit() { _autoSplitOk = false; }
static ClientInfo * get();
private:
struct WBInfo {
WBInfo( ConnectionId c , OID o ) : connectionId( c ) , id( o ) {}
ConnectionId connectionId;
OID id;
};
// for getLastError
void _addWriteBack( vector<WBInfo>& all , const BSONObj& o );
vector<BSONObj> _handleWriteBacks( vector<WBInfo>& all , bool fromWriteBackListener );
int _id; // unique client id
HostAndPort _remote; // server:port of remote socket end
// we use _a and _b to store shards we've talked to on the current request and the previous
// we use 2 so we can flip for getLastError type operations
set<string> _a; // actual set for _cur or _prev
set<string> _b; // "
set<string> * _cur; // pointer to _a or _b depending on state
set<string> * _prev; // ""
set<string> _sinceLastGetError; // all shards accessed since last getLastError
int _lastAccess;
bool _autoSplitOk;
static boost::thread_specific_ptr<ClientInfo> _tlInfo;
};
}
|
