1 package org.apache.maven.surefire.api.util.internal;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import java.io.IOException;
23 import java.nio.Buffer;
24 import java.nio.ByteBuffer;
25 import java.nio.channels.ClosedChannelException;
26 import java.nio.channels.NonWritableChannelException;
27
28
29
30
31
32
33
34 abstract class AbstractNoninterruptibleWritableChannel implements WritableBufferedByteChannel
35 {
36 private volatile boolean open = true;
37
38 protected abstract void writeImpl( ByteBuffer src ) throws IOException;
39 protected abstract void closeImpl() throws IOException;
40 protected abstract void flushImpl() throws IOException;
41
42 @Override
43 public final int write( ByteBuffer src ) throws IOException
44 {
45 return write( src, true );
46 }
47
48 @Override
49 public final void writeBuffered( ByteBuffer src ) throws IOException
50 {
51 write( src, false );
52 }
53
54 int write( ByteBuffer src, boolean flush ) throws IOException
55 {
56 if ( !isOpen() )
57 {
58 throw new ClosedChannelException();
59 }
60
61 if ( !src.hasArray() || src.isReadOnly() )
62 {
63 throw new NonWritableChannelException();
64 }
65
66 if ( src.remaining() != src.capacity() )
67 {
68 ( (Buffer) src ).flip();
69 }
70
71 int countWrittenBytes = src.remaining();
72 writeImpl( src );
73 ( (Buffer) src ).position( ( (Buffer) src ).limit() );
74 if ( flush )
75 {
76 flushImpl();
77 }
78 return countWrittenBytes;
79 }
80
81 @Override
82 public final boolean isOpen()
83 {
84 return open;
85 }
86
87 @Override
88 public final void close() throws IOException
89 {
90 open = false;
91 closeImpl();
92 }
93 }