added validation method to perform minimal check that message class implementation...
[vamsas.git] / src / uk / ac / vamsas / client / simpleclient / LockedFileOutputStream.java
1 /**\r
2  * \r
3  */\r
4 package uk.ac.vamsas.client.simpleclient;\r
5 \r
6 import java.io.File;\r
7 import java.io.FileDescriptor;\r
8 import java.io.FileNotFoundException;\r
9 import java.io.FileOutputStream;\r
10 import java.io.IOException;\r
11 import java.io.OutputStream;\r
12 import java.nio.channels.FileChannel;\r
13 \r
14 import org.apache.commons.logging.LogFactory;\r
15 \r
16 /**\r
17  * @author Jim\r
18  *\r
19  */\r
20 public class LockedFileOutputStream extends FileOutputStream {\r
21   private static org.apache.commons.logging.Log log = LogFactory.getLog(LockedFileOutputStream.class);\r
22   //FileOutputStream ostream=null;\r
23   boolean closed=true;\r
24   private void init() {\r
25     FileChannel ch = super.getChannel();\r
26     if (ch!=null) {\r
27       try { closed = !ch.isOpen();\r
28       } catch (Exception e) {\r
29         closed=true;\r
30         log.debug("Invalid LockedOutputStream marked closed.",e);\r
31       }\r
32     }\r
33   }\r
34   /**\r
35    * @param file\r
36    * @throws FileNotFoundException\r
37    */\r
38   public LockedFileOutputStream(File file) throws FileNotFoundException {\r
39     super(file); // super(file);\r
40     init();\r
41   }\r
42 \r
43   /**\r
44    * @param file\r
45    * @param append\r
46    * @throws FileNotFoundException\r
47    */\r
48   public LockedFileOutputStream(File file, boolean append)\r
49       throws FileNotFoundException {\r
50     super(file, append);\r
51     init();\r
52   }\r
53 \r
54   /**\r
55    * @param fdObj\r
56    */\r
57   public LockedFileOutputStream(FileDescriptor fdObj) {\r
58     super(fdObj);\r
59     init();\r
60     if (fdObj.valid())\r
61       closed=false;\r
62   }\r
63 \r
64   /**\r
65    * @param name\r
66    * @throws FileNotFoundException\r
67    */\r
68   public LockedFileOutputStream(String name) throws FileNotFoundException {\r
69     super(name);\r
70     init();\r
71   }\r
72 \r
73   /**\r
74    * @param name\r
75    * @param append\r
76    * @throws FileNotFoundException\r
77    */\r
78   public LockedFileOutputStream(String name, boolean append)\r
79       throws FileNotFoundException {\r
80     super(name, append);\r
81     init();\r
82   }\r
83   /**\r
84    * closes - actually just flushes the stream instead.\r
85    */\r
86   public void close() throws IOException {\r
87     if (!closed) {\r
88       super.flush();\r
89       super.getChannel().force(true);\r
90       log.debug("Marking Lockedoutputstream closed.");\r
91     } else\r
92       throw new IOException("Close on already closed FileOutputStream.");\r
93     closed=true;\r
94   }\r
95 \r
96 \r
97   /**\r
98    * @throws IOException\r
99    * @see java.io.OutputStream#flush()\r
100    */\r
101   public void flush() throws IOException {\r
102     if (!closed)\r
103       super.flush();\r
104     else\r
105       throw new IOException("flush on closed FileOutputStream");\r
106   }\r
107 \r
108   /**\r
109    * @return\r
110    * @see java.io.FileOutputStream#getChannel()\r
111    */\r
112   public FileChannel getChannel() {\r
113     if (!closed)\r
114       return super.getChannel();\r
115     else\r
116       return null;\r
117   }\r
118 \r
119 \r
120 \r
121   /**\r
122    * @param b\r
123    * @param off\r
124    * @param len\r
125    * @throws IOException\r
126    * @see java.io.FileOutputStream#write(byte[], int, int)\r
127    */\r
128   public void write(byte[] b, int off, int len) throws IOException {\r
129     if (!closed)\r
130       super.write(b, off, len);\r
131     else\r
132       throw new IOException("write on Closed FileOutputStream");\r
133   }\r
134 \r
135   /**\r
136    * @param b\r
137    * @throws IOException\r
138    * @see java.io.FileOutputStream#write(byte[])\r
139    */\r
140   public void write(byte[] b) throws IOException {\r
141     if (!closed)\r
142       super.write(b);\r
143     else\r
144       throw new IOException("write on Closed FileOutputStream");\r
145   }\r
146 \r
147   /**\r
148    * @param b\r
149    * @throws IOException\r
150    * @see java.io.FileOutputStream#write(int)\r
151    */\r
152   public void write(int b) throws IOException {\r
153     if (!closed)\r
154       super.write(b);\r
155     else\r
156       throw new IOException("write on Closed FileOutputStream");\r
157   }\r
158   \r
159 }\r