Skip to content

Commit b092116

Browse files
committed
Removed the thrown exception if stream already closed.
1 parent d1884fa commit b092116

File tree

1 file changed

+8
-6
lines changed

1 file changed

+8
-6
lines changed

src/main/java/org/apache/hadoop/fs/glusterfs/GlusterFUSEInputStream.java

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -180,14 +180,16 @@ public void syncStreams (int bytes) throws IOException {
180180
}
181181

182182
public synchronized void close () throws IOException {
183-
if (closed)
184-
throw new IOException("Stream closed.");
185-
186183
super.close();
187-
if (fsInputStream != null)
188-
fsInputStream.close();
184+
185+
if (closed)
186+
return ;
187+
188+
if (fsInputStream != null){
189+
fsInputStream.close();
190+
}
191+
189192
fuseInputStream.close();
190-
191193
closed = true;
192194
}
193195

0 commit comments

Comments
 (0)