mirror of
https://github.com/flutter/flutter.git
synced 2026-02-20 02:29:02 +08:00
Revert "Guard the service protocol's global handlers list with a reader/writer lock (#6888)" (flutter/engine#6893)
This reverts commit e740d7f1dbdb69dc4fd38e39c887dd3cccae7c3d. (shared_timed_mutex is unavailable in the iOS build)
This commit is contained in:
parent
0e9ae6d602
commit
7449dc427e
@ -176,7 +176,6 @@ FILE: ../../../flutter/fml/platform/win/wstring_conversion.h
|
||||
FILE: ../../../flutter/fml/string_view.cc
|
||||
FILE: ../../../flutter/fml/string_view.h
|
||||
FILE: ../../../flutter/fml/string_view_unittest.cc
|
||||
FILE: ../../../flutter/fml/synchronization/atomic_object.h
|
||||
FILE: ../../../flutter/fml/synchronization/count_down_latch.cc
|
||||
FILE: ../../../flutter/fml/synchronization/count_down_latch.h
|
||||
FILE: ../../../flutter/fml/synchronization/count_down_latch_unittests.cc
|
||||
|
||||
@ -46,7 +46,6 @@ source_set("fml") {
|
||||
"paths.h",
|
||||
"string_view.cc",
|
||||
"string_view.h",
|
||||
"synchronization/atomic_object.h",
|
||||
"synchronization/count_down_latch.cc",
|
||||
"synchronization/count_down_latch.h",
|
||||
"synchronization/thread_annotations.h",
|
||||
|
||||
@ -1,30 +0,0 @@
|
||||
// Copyright 2013 The Flutter Authors. All rights reserved.
|
||||
// Use of this source code is governed by a BSD-style license that can be
|
||||
// found in the LICENSE file.
|
||||
|
||||
#include <mutex>
|
||||
|
||||
namespace fml {
|
||||
|
||||
template <typename T>
|
||||
class AtomicObject {
|
||||
public:
|
||||
AtomicObject() = default;
|
||||
AtomicObject(T object) : object_(object) {}
|
||||
|
||||
T Load() const {
|
||||
std::lock_guard<std::mutex> lock(mutex_);
|
||||
return object_;
|
||||
}
|
||||
|
||||
void Store(const T& object) {
|
||||
std::lock_guard<std::mutex> lock(mutex_);
|
||||
object_ = object;
|
||||
}
|
||||
|
||||
private:
|
||||
mutable std::mutex mutex_;
|
||||
T object_;
|
||||
};
|
||||
|
||||
} // namespace fml
|
||||
@ -53,21 +53,21 @@ ServiceProtocol::~ServiceProtocol() {
|
||||
|
||||
void ServiceProtocol::AddHandler(Handler* handler,
|
||||
Handler::Description description) {
|
||||
std::unique_lock<std::shared_timed_mutex> lock(handlers_mutex_);
|
||||
std::lock_guard<std::mutex> lock(handlers_mutex_);
|
||||
handlers_.emplace(handler, description);
|
||||
}
|
||||
|
||||
void ServiceProtocol::RemoveHandler(Handler* handler) {
|
||||
std::unique_lock<std::shared_timed_mutex> lock(handlers_mutex_);
|
||||
std::lock_guard<std::mutex> lock(handlers_mutex_);
|
||||
handlers_.erase(handler);
|
||||
}
|
||||
|
||||
void ServiceProtocol::SetHandlerDescription(Handler* handler,
|
||||
Handler::Description description) {
|
||||
std::shared_lock<std::shared_timed_mutex> lock(handlers_mutex_);
|
||||
std::lock_guard<std::mutex> lock(handlers_mutex_);
|
||||
auto it = handlers_.find(handler);
|
||||
if (it != handlers_.end())
|
||||
it->second.Store(description);
|
||||
it->second = description;
|
||||
}
|
||||
|
||||
void ServiceProtocol::ToggleHooks(bool set) {
|
||||
@ -175,7 +175,7 @@ bool ServiceProtocol::HandleMessage(fml::StringView method,
|
||||
return HandleListViewsMethod(response);
|
||||
}
|
||||
|
||||
std::shared_lock<std::shared_timed_mutex> lock(handlers_mutex_);
|
||||
std::lock_guard<std::mutex> lock(handlers_mutex_);
|
||||
|
||||
if (handlers_.size() == 0) {
|
||||
WriteServerErrorResponse(response,
|
||||
@ -246,11 +246,12 @@ void ServiceProtocol::Handler::Description::Write(
|
||||
|
||||
bool ServiceProtocol::HandleListViewsMethod(
|
||||
rapidjson::Document& response) const {
|
||||
std::shared_lock<std::shared_timed_mutex> lock(handlers_mutex_);
|
||||
// Collect handler descriptions on their respective task runners.
|
||||
std::lock_guard<std::mutex> lock(handlers_mutex_);
|
||||
std::vector<std::pair<intptr_t, Handler::Description>> descriptions;
|
||||
for (const auto& handler : handlers_) {
|
||||
descriptions.emplace_back(reinterpret_cast<intptr_t>(handler.first),
|
||||
handler.second.Load());
|
||||
handler.second);
|
||||
}
|
||||
|
||||
auto& allocator = response.GetAllocator();
|
||||
|
||||
@ -6,14 +6,13 @@
|
||||
#define FLUTTER_RUNTIME_SERVICE_PROTOCOL_H_
|
||||
|
||||
#include <map>
|
||||
#include <mutex>
|
||||
#include <set>
|
||||
#include <shared_mutex>
|
||||
#include <string>
|
||||
|
||||
#include "flutter/fml/compiler_specific.h"
|
||||
#include "flutter/fml/macros.h"
|
||||
#include "flutter/fml/string_view.h"
|
||||
#include "flutter/fml/synchronization/atomic_object.h"
|
||||
#include "flutter/fml/synchronization/thread_annotations.h"
|
||||
#include "flutter/fml/task_runner.h"
|
||||
#include "rapidjson/document.h"
|
||||
@ -73,8 +72,8 @@ class ServiceProtocol {
|
||||
|
||||
private:
|
||||
const std::set<fml::StringView> endpoints_;
|
||||
mutable std::shared_timed_mutex handlers_mutex_;
|
||||
std::map<Handler*, fml::AtomicObject<Handler::Description>> handlers_;
|
||||
mutable std::mutex handlers_mutex_;
|
||||
std::map<Handler*, Handler::Description> handlers_;
|
||||
|
||||
FML_WARN_UNUSED_RESULT
|
||||
static bool HandleMessage(const char* method,
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user