Repository: incubator-distributedlog Updated Branches: refs/heads/master e611ef9e8 -> 2a677d15a
DL-80: synchronized getLogRecordSetWriter() see jira's comments Author: xieliang <xieliang...@gmail.com> Reviewers: Sijie Guo <si...@apache.org> Closes #48 from xieliang/DL-80 Project: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/commit/2a677d15 Tree: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/tree/2a677d15 Diff: http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/diff/2a677d15 Branch: refs/heads/master Commit: 2a677d15aa8fd2284df125b1ee8be9e8ca8b8437 Parents: e611ef9 Author: xieliang <xieliang...@gmail.com> Authored: Fri Dec 2 19:45:02 2016 -0800 Committer: Sijie Guo <si...@apache.org> Committed: Fri Dec 2 19:45:02 2016 -0800 ---------------------------------------------------------------------- .../distributedlog/client/DistributedLogMultiStreamWriter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-distributedlog/blob/2a677d15/distributedlog-client/src/main/java/com/twitter/distributedlog/client/DistributedLogMultiStreamWriter.java ---------------------------------------------------------------------- diff --git a/distributedlog-client/src/main/java/com/twitter/distributedlog/client/DistributedLogMultiStreamWriter.java b/distributedlog-client/src/main/java/com/twitter/distributedlog/client/DistributedLogMultiStreamWriter.java index fa3dceb..eac8f9d 100644 --- a/distributedlog-client/src/main/java/com/twitter/distributedlog/client/DistributedLogMultiStreamWriter.java +++ b/distributedlog-client/src/main/java/com/twitter/distributedlog/client/DistributedLogMultiStreamWriter.java @@ -401,7 +401,7 @@ public class DistributedLogMultiStreamWriter implements Runnable { return streams.get(streamId); } - LogRecordSet.Writer getLogRecordSetWriter() { + synchronized LogRecordSet.Writer getLogRecordSetWriter() { return recordSetWriter; }
