storaged: protect global proto_loaded
proto_loaded is not thread safe, so we must protect it with
a mutex proto_lock.
Signed-off-by: hanhongli@360.cn
Signed-off-by: gongguang@360.cn
Signed-off-by: Mark Salyzyn <salyzyn@google.com>
Bug: 170732441
Test: compile
Change-Id: I93416598b6047e890c66b922b360093aa42db8c5
(cherry picked from commit d179cbcdc2
)
This commit is contained in:
parent
69522b36f7
commit
79fc288f10
2 changed files with 7 additions and 0 deletions
|
@ -86,6 +86,7 @@ class storaged_t : public android::hardware::health::V2_0::IHealthInfoCallback,
|
|||
sp<android::hardware::health::V2_0::IHealth> health;
|
||||
unique_ptr<storage_info_t> storage_info;
|
||||
static const uint32_t current_version;
|
||||
Mutex proto_lock;
|
||||
unordered_map<userid_t, bool> proto_loaded;
|
||||
void load_proto(userid_t user_id);
|
||||
char* prepare_proto(userid_t user_id, StoragedProto* proto);
|
||||
|
|
|
@ -162,6 +162,8 @@ storaged_t::storaged_t(void) {
|
|||
}
|
||||
|
||||
void storaged_t::add_user_ce(userid_t user_id) {
|
||||
Mutex::Autolock _l(proto_lock);
|
||||
|
||||
if (!proto_loaded[user_id]) {
|
||||
load_proto(user_id);
|
||||
proto_loaded[user_id] = true;
|
||||
|
@ -169,6 +171,8 @@ void storaged_t::add_user_ce(userid_t user_id) {
|
|||
}
|
||||
|
||||
void storaged_t::remove_user_ce(userid_t user_id) {
|
||||
Mutex::Autolock _l(proto_lock);
|
||||
|
||||
proto_loaded[user_id] = false;
|
||||
mUidm.clear_user_history(user_id);
|
||||
RemoveFileIfExists(proto_path(user_id), nullptr);
|
||||
|
@ -298,6 +302,8 @@ void storaged_t::flush_proto(userid_t user_id, StoragedProto* proto) {
|
|||
}
|
||||
|
||||
void storaged_t::flush_protos(unordered_map<int, StoragedProto>* protos) {
|
||||
Mutex::Autolock _l(proto_lock);
|
||||
|
||||
for (auto& it : *protos) {
|
||||
/*
|
||||
* Don't flush proto if we haven't attempted to load it from file.
|
||||
|
|
Loading…
Reference in a new issue