flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Till Rohrmann (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-6179) Create SerialMainThreadValidatorUtil to support TestingSerialRpcService
Date Fri, 24 Mar 2017 09:37:41 GMT
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

View raw message