Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 3A4BE200B54 for ; Thu, 28 Jul 2016 20:23:01 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 38DB2160A85; Thu, 28 Jul 2016 18:23:01 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id A6B79160A56 for ; Thu, 28 Jul 2016 20:23:00 +0200 (CEST) Received: (qmail 43717 invoked by uid 500); 28 Jul 2016 18:22:59 -0000 Mailing-List: contact dev-help@accumulo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@accumulo.apache.org Delivered-To: mailing list dev@accumulo.apache.org Received: (qmail 43706 invoked by uid 99); 28 Jul 2016 18:22:59 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 28 Jul 2016 18:22:59 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 742EAE0100; Thu, 28 Jul 2016 18:22:59 +0000 (UTC) From: ivakegg To: dev@accumulo.apache.org Reply-To: dev@accumulo.apache.org References: In-Reply-To: Subject: [GitHub] accumulo pull request #134: ACCUMULO-4391 Added synchronization around the a... Content-Type: text/plain Message-Id: <20160728182259.742EAE0100@git1-us-west.apache.org> Date: Thu, 28 Jul 2016 18:22:59 +0000 (UTC) archived-at: Thu, 28 Jul 2016 18:23:01 -0000 Github user ivakegg commented on a diff in the pull request: https://github.com/apache/accumulo/pull/134#discussion_r72674888 --- Diff: core/src/main/java/org/apache/accumulo/core/file/rfile/bcfile/BoundedRangeFileInputStream.java --- @@ -62,12 +62,15 @@ public BoundedRangeFileInputStream(FSDataInputStream in, long offset, long lengt @Override public int available() throws IOException { - int avail = in.available(); - if (pos + avail > end) { - avail = (int) (end - pos); - } + final FSDataInputStream inLocal = in; + synchronized (inLocal) { + int avail = inLocal.available(); --- End diff -- I am considering this, but others had commented to me that adhering to the API as close as possible was a good thing. However if we state clearly that this class does not, then avoid the synchronization altogether would be great. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastructure@apache.org or file a JIRA ticket with INFRA. ---