You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@ignite.apache.org by "Ivan Fedotov (JIRA)" <ji...@apache.org> on 2018/03/30 12:30:00 UTC

[jira] [Created] (IGNITE-8084) Unlock write lock in DataStreamerImpl

Ivan Fedotov created IGNITE-8084:
------------------------------------

             Summary: Unlock write lock in DataStreamerImpl
                 Key: IGNITE-8084
                 URL: https://issues.apache.org/jira/browse/IGNITE-8084
             Project: Ignite
          Issue Type: Improvement
          Components: streaming
            Reporter: Ivan Fedotov
            Assignee: Ivan Fedotov
             Fix For: 2.5


In method DataStreamerImpl.CloseEx there is wrire lock without unlock [1]. I think this behavior is based on impossibility to call after closing other public method of DataStreamer, that use read lock.

It's not correctly that after closing streamer we don't unlock writeLock: I think that we can use *closed* flag to throw exception if streamer will be used after closing.

[1]https://github.com/apache/ignite/blob/master/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java#L1217



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)