diff options
| author | Guanjun He | 2012-07-09 04:50:33 +0200 |
|---|---|---|
| committer | Sage Weil | 2012-07-30 18:29:53 +0200 |
| commit | a2a3258417eb6a1799cf893350771428875a8287 (patch) | |
| tree | f8906aa980d79af72e7e02d5592512a914c4b721 /include/linux/ceph | |
| parent | libceph: fix messenger retry (diff) | |
| download | kernel-qcow2-linux-a2a3258417eb6a1799cf893350771428875a8287.tar.gz kernel-qcow2-linux-a2a3258417eb6a1799cf893350771428875a8287.tar.xz kernel-qcow2-linux-a2a3258417eb6a1799cf893350771428875a8287.zip | |
libceph: prevent the race of incoming work during teardown
Add an atomic variable 'stopping' as flag in struct ceph_messenger,
set this flag to 1 in function ceph_destroy_client(), and add the condition code
in function ceph_data_ready() to test the flag value, if true(1), just return.
Signed-off-by: Guanjun He <gjhe@suse.com>
Reviewed-by: Sage Weil <sage@inktank.com>
Diffstat (limited to 'include/linux/ceph')
| -rw-r--r-- | include/linux/ceph/messenger.h | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/include/linux/ceph/messenger.h b/include/linux/ceph/messenger.h index cfb1bbdac624..a310d7fe6e29 100644 --- a/include/linux/ceph/messenger.h +++ b/include/linux/ceph/messenger.h @@ -50,6 +50,7 @@ struct ceph_messenger { struct ceph_entity_inst inst; /* my name+address */ struct ceph_entity_addr my_enc_addr; + atomic_t stopping; bool nocrc; /* |