mirror of https://github.com/grpc/grpc.git
[EventEngine] Skip legacy fork handling for ExecCtx when in an EventEngine thread (#32229)
* [EventEngine] Implement EventEngine::IsWorkerThread() * lighter-weight thread pool check * add lightweight thread_local flag for EventEngine/iomgr fork * generate_projects; add files * fix * back out EE implementation changes * better description * fixpull/32272/head
AJ Heller
2 years ago
committed by
GitHub
parent
0893fca089
commit
a9e2ef199e
20 changed files with 109 additions and 9 deletions
@ -0,0 +1,29 @@ |
||||
// Copyright 2023 The gRPC Authors
|
||||
//
|
||||
// Licensed under the Apache License, Version 2.0 (the "License");
|
||||
// you may not use this file except in compliance with the License.
|
||||
// You may obtain a copy of the License at
|
||||
//
|
||||
// http://www.apache.org/licenses/LICENSE-2.0
|
||||
//
|
||||
// Unless required by applicable law or agreed to in writing, software
|
||||
// distributed under the License is distributed on an "AS IS" BASIS,
|
||||
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
// See the License for the specific language governing permissions and
|
||||
// limitations under the License.
|
||||
#include <grpc/support/port_platform.h> |
||||
|
||||
#include "src/core/lib/event_engine/thread_local.h" |
||||
|
||||
namespace grpc_event_engine { |
||||
namespace experimental { |
||||
|
||||
namespace { |
||||
thread_local bool g_thread_local{false}; |
||||
} // namespace
|
||||
|
||||
void ThreadLocal::SetIsEventEngineThread(bool is) { g_thread_local = is; } |
||||
bool ThreadLocal::IsEventEngineThread() { return g_thread_local; } |
||||
|
||||
} // namespace experimental
|
||||
} // namespace grpc_event_engine
|
||||
@ -0,0 +1,32 @@ |
||||
// Copyright 2023 The gRPC Authors
|
||||
//
|
||||
// Licensed under the Apache License, Version 2.0 (the "License");
|
||||
// you may not use this file except in compliance with the License.
|
||||
// You may obtain a copy of the License at
|
||||
//
|
||||
// http://www.apache.org/licenses/LICENSE-2.0
|
||||
//
|
||||
// Unless required by applicable law or agreed to in writing, software
|
||||
// distributed under the License is distributed on an "AS IS" BASIS,
|
||||
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
// See the License for the specific language governing permissions and
|
||||
// limitations under the License.
|
||||
#ifndef GRPC_SRC_CORE_LIB_EVENT_ENGINE_THREAD_LOCAL_H |
||||
#define GRPC_SRC_CORE_LIB_EVENT_ENGINE_THREAD_LOCAL_H |
||||
#include <grpc/support/port_platform.h> |
||||
|
||||
namespace grpc_event_engine { |
||||
namespace experimental { |
||||
|
||||
/// A lightweight facility to allow gpr's fork handlers and
|
||||
/// EventEngine::Forkables to coordinate.
|
||||
class ThreadLocal { |
||||
public: |
||||
static void SetIsEventEngineThread(bool is_local); |
||||
static bool IsEventEngineThread(); |
||||
}; |
||||
|
||||
} // namespace experimental
|
||||
} // namespace grpc_event_engine
|
||||
|
||||
#endif // GRPC_SRC_CORE_LIB_EVENT_ENGINE_THREAD_LOCAL_H
|
||||
Loading…
Reference in new issue