Examples of PipeIOException

Examples of uk.org.ogsadai.activity.io.PipeIOException

134
135
136
137
138
139
140
141
142
143
            }
            else
            {
                LOG.debug("Could not find serialiser for " +
                        block.getClass().getName());
                throw new PipeIOException(
                        new MissingSerialiserException(block));
            }
        }
    }
View Full Code Here

Examples of uk.org.ogsadai.activity.io.PipeIOException

94
95
96
97
98
99
100
101
102
103
104
105
            }
            tupleOutput.close();
        }
        catch (UnsupportedTupleTypeException e)
        {
            throw new PipeIOException(e);
        }
        catch (IOException e)
        {
            throw new PipeIOException(e);
        }
    }
View Full Code Here

Examples of uk.org.ogsadai.activity.io.PipeIOException

123
124
125
126
127
128
129
130
131
132
133
134
            // end of tuple stream
           
        }
        catch (IOException e)
        {
            throw new PipeIOException(e);
        }
        catch (UnsupportedTupleTypeException e)
        {
            throw new PipeIOException(e);
        }
    }
View Full Code Here

Examples of uk.org.ogsadai.activity.io.PipeIOException

111
112
113
114
115
116
117
118
            LOG.debug("Wrote binary data stream to file.");
            writer.write(file);
        }
        catch (IOException e)
        {
            throw new PipeIOException(e);
        }       
    }
View Full Code Here

Examples of uk.org.ogsadai.activity.io.PipeIOException

79
80
81
82
83
84
85
86
            data.writeUTF(mTransferManager.mapToGridFTP(mFile));
            output.close();
        }
        catch (IOException e)
        {
            throw new PipeIOException(e);
        }
    }
View Full Code Here

Examples of uk.org.ogsadai.activity.io.PipeIOException

133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
            LOG.debug("File transfer completed : " + outFilename);
        }
        catch (IOException e)
        {
            e.printStackTrace();
            throw new PipeIOException(e);
        }
        catch (InterruptedException e)
        {
            e.printStackTrace();
            throw new PipeIOException(e.getCause());
        }
        catch (ExecutionException e)
        {
            e.printStackTrace();
            throw new PipeIOException(e.getCause());
        }
    }
View Full Code Here

Examples of uk.org.ogsadai.activity.io.PipeIOException

90
91
92
93
94
95
96
97
98
99
100
*/
public Object peek() throws PipeIOException, PipeTerminatedException
{
     if (mRaiseIOException)
     {
         throw new PipeIOException();
     }
     else if (mRaiseTerminatedException)
     {
         throw new PipeTerminatedException("MockPipe");
     }
View Full Code Here

Examples of uk.org.ogsadai.activity.io.PipeIOException

112
113
114
115
116
117
118
119
120
121
122
*/
public Object read() throws PipeIOException, PipeTerminatedException
{
     if (mRaiseIOException)
     {
         throw new PipeIOException();
     }
     else if (mRaiseTerminatedException)
     {
         throw new PipeTerminatedException("MockPipe");
     }
View Full Code Here

Examples of uk.org.ogsadai.activity.io.PipeIOException

104
105
106
107
108
109
110
111
112
113
114
                mSize--;
                return object;
            }
            catch (DataCacheException e)
            {
                throw new PipeIOException(e);
            }
            catch (NoSuchElementException e)
            {
                // this shouldn't happen - size>0 indicates there are blocks
                // in the pipe
View Full Code Here

Examples of uk.org.ogsadai.activity.io.PipeIOException

168
169
170
171
172
173
174
175
176
177
178
179
180
                throw new PipeClosedException();
            }
        }
        catch (DataCacheException e)
        {
            throw new PipeIOException(e);
        }
        catch (BlockTypeNotSupported e)
        {
            // this would ideally be a user error but we can't throw such an error
            throw new PipeIOException(e);
        }
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.