Till Rohrmann created FLINK-6179:
------------------------------------
Summary: Create SerialMainThreadValidatorUtil to support
TestingSerialRpcService
Key: FLINK-6179
URL: https://issues.apache.org/jira/browse/FLINK-6179
Project: Flink
Issue Type: Sub-task
Components: Distributed Coordination
Affects Versions: 1.3.0
Reporter: Till Rohrmann
Assignee: Till Rohrmann
Priority: Minor
The {{MainThreadValidatorUtil}} does not play well together with the
{{TestingSerialRpcService}} which executes all rpc call in the same thread. In
order to still support main thread validation in the {{RpcEndpoint}} methods, I
porpose to implement a {{SerialMainThreadValidatorUtil}} which not only sets
the main thread if the current thread is {{null}}, but also if current thread
is the entering thread. In order to make this properly work with releasing the
main thread field, we have to count how often we have entered the main thread
and only set the field to {{null}} iff the count equals 0.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
