diff options
| author | Sage Weil <sage@inktank.com> | 2013-09-30 14:44:17 -0700 |
|---|---|---|
| committer | Sage Weil <sage@inktank.com> | 2013-09-30 14:44:17 -0700 |
| commit | 2126d7e7827cbd9c2cd7be006e8ebcdcf45276c1 (patch) | |
| tree | c87c1b7dea39bc47ca1c1bc5ce5742e9c36cc253 /src/client/Client.h | |
| parent | 67f5ef15d11a8d6ea5287e33ac7af00739ea0379 (diff) | |
| download | ceph-wip-client-kick.tar.gz | |
client: remove requests from closed MetaSessionwip-client-kick
If we get a CLOSED message on a session, remove/kick any requests on
that session before tearing it down. Otherwise, we get a crash like
2013-09-26 03:51:44.704446 7f4d35a46700 10 client.4111 kick_requests for mds.0
2013-09-26 03:51:45.014156 7f4d35a46700 -1 ./include/xlist.h: In function 'xlist<T>::~xlist() [with T = MetaRequest*]' thread 7f4d35a46700 time 2013-09-26 03:51:44.751908
./include/xlist.h: 69: FAILED assert(_size == 0)
ceph version 0.61.5 (8ee10dc4bb73bdd918873f29c70eedc3c7ef1979)
1: (MetaSession::~MetaSession()+0x425) [0x4e0105]
2: (Client::_closed_mds_session(MetaSession*)+0x116) [0x48a696]
3: (Client::handle_client_session(MClientSession*)+0x2bb) [0x48bf5b]
4: (Client::ms_dispatch(Message*)+0x56b) [0x4bfa0b]
5: (DispatchQueue::entry()+0x3f1) [0x621b31]
6: (DispatchQueue::DispatchThread::entry()+0xd) [0x6191bd]
7: (()+0x7851) [0x7f4d3c168851]
8: (clone()+0x6d) [0x7f4d3b09d90d]
Note that this can happen if we fail to reconnect do an MDS during its
reconnect interval. If that happens, we probably have inodes in our
cache with no caps and things are generally not going to work very well.
This is but one step in improving the situation.
Separate out the two methods since they share little/no behavior.
Signed-off-by: Sage Weil <sage@inktank.com>
Diffstat (limited to 'src/client/Client.h')
| -rw-r--r-- | src/client/Client.h | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/client/Client.h b/src/client/Client.h index c7c9cef0e0c..d1906a661a0 100644 --- a/src/client/Client.h +++ b/src/client/Client.h @@ -270,7 +270,8 @@ public: void connect_mds_targets(int mds); void send_request(MetaRequest *request, MetaSession *session); MClientRequest *build_client_request(MetaRequest *request); - void kick_requests(MetaSession *session, bool signal); + void kick_requests(MetaSession *session); + void kick_requests_closed(MetaSession *session); void handle_client_request_forward(MClientRequestForward *reply); void handle_client_reply(MClientReply *reply); |