Examples of java.io.InterruptedIOException

java.io.InterruptedIOException
This IO exception is thrown when a program reading or writing to a stream is interrupted. This is also thrown when a socket timeout occurs before the request has completed.

   * is interrupted and <code>paintMode</code> is equal to <code>PaintMode.EXPORT</code>.  
   */
  private void checkCurrentThreadIsntInterrupted(PaintMode paintMode) throws InterruptedIOException {
    if (paintMode == PaintMode.EXPORT
        && Thread.interrupted()) {
      throw new InterruptedIOException("Current thread interrupted");
    }
  }

View Full Code Here

    
    public abstract BufferedImage renderImageAt(Camera frameCamera, boolean last) throws IOException;
    
    protected void checkLaunchingThreadIsntInterrupted() throws InterruptedIOException {
      if (this.launchingThread.isInterrupted()) {
        throw new InterruptedIOException("Lauching thread interrupted");
      }
    }

View Full Code Here

      throw ex2;
    } catch (InterruptedException ex) {
      if (dataSink != null) {
        dataSink.stop();
      }
      throw new InterruptedIOException("Video creation interrupted");
    } finally {
      if (dataSink != null) {
        dataSink.close();
        dataSink.removeDataSinkListener(dataSinkListener);
      }

View Full Code Here

        if (root instanceof TransportException) {
            ioe = (TransportException)root;
            root = ((TransportException)ioe).getRootCause();
        }
        if (root instanceof InterruptedException) {
            ioe = new InterruptedIOException(root.getMessage());
            ioe.initCause(root);
        }
        return ioe;
    }

View Full Code Here

                return n;
            }
            try {
                awaitReadable(channel);
            } catch (InterruptedException ex) {
                throw new InterruptedIOException(ex.getMessage());
            }
        } while (true);
    }

View Full Code Here

                return n;
            }
            try {
                awaitWritable(channel);
            } catch (InterruptedException ex) {
                throw new InterruptedIOException(ex.getMessage());
            }
        } while (true);
    }

View Full Code Here

  IOException exception(int result)
     throws IOException
  {
    switch (result) {
    case INTERRUPT_EXN:
      return new InterruptedIOException("interrupted i/o");


    case DISCONNECT_EXN:
      return new ClientDisconnectException("connection reset by peer");


    case TIMEOUT_EXN:

View Full Code Here

              " of " + numRegs + " regions are online; retries exhausted.");
          }
          try { // Sleep
            Thread.sleep(getPauseTime(tries));
          } catch (InterruptedException e) {
            throw new InterruptedIOException("Interrupted when opening" +
              " regions; " + actualRegCount.get() + " of " + numRegs +
              " regions processed so far");
          }
          if (actualRegCount.get() > prevRegCount) { // Making progress
            prevRegCount = actualRegCount.get();
            tries = -1;
          }
        } else {
          doneWithMetaScan = true;
          tries = -1;
        }
      } else if (isTableEnabled(desc.getName())) {
        return;
      } else {
        try { // Sleep
          Thread.sleep(getPauseTime(tries));
        } catch (InterruptedException e) {
          throw new InterruptedIOException("Interrupted when waiting" +
            " for table to be enabled; meta scan was done");
        }
      }
    }
    throw new TableNotEnabledException(

View Full Code Here

  throws IOException {
    if (store.getHRegion().areWritesEnabled()) return;
    // Else cleanup.
    writer.close();
    store.getFileSystem().delete(writer.getPath(), false);
    throw new InterruptedIOException( "Aborting compaction of store " + store +
      " in region " + store.getHRegion() + " because user requested stop.");
  }

View Full Code Here

        HRegionInfo regionInfo = future.get();
        regionInfos.add(regionInfo);
      }
    } catch (InterruptedException e) {
      LOG.error("Caught " + e + " during region creation");
      throw new InterruptedIOException(e.getMessage());
    } catch (ExecutionException e) {
      throw new IOException(e);
    } finally {
      regionOpenAndInitThreadPool.shutdownNow();
    }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of java.io.InterruptedIOException

com.addthis.meshy.service.stream.SourceInputStream

com.asakusafw.runtime.stage.output.BridgeOutputFormat$BridgeOutputCommitter

com.asakusafw.runtime.stage.temporary.TemporaryFileOutput

com.asakusafw.testdriver.directio.DirectIoTestHelper

com.asakusafw.testdriver.file.FileInputFormatDriver

com.asakusafw.testdriver.file.FileOutputFormatDriver

com.etsy.net.UnixDomainSocket$UnixDomainSocketInputStream

com.facebook.presto.jdbc.internal.airlift.http.client.jetty.JettyHttpClient$BodyGeneratorContentProvider$BodyGeneratorOutputStream

com.proofpoint.http.client.jetty.JettyHttpClient$BodyGeneratorContentProvider$BodyGeneratorOutputStream

com.sshtools.j2ssh.connection.ChannelInputStream

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.