Examples of NoCloseOutputStream

io.apigee.trireme.core.internal.NoCloseOutputStream
This is just a output stream that filters another, but ignores the close. We use it when spawning child processes that share output.
nexj.core.util.NoCloseOutputStream
OutputStream decorator that disables the close method.
org.apache.sshd.common.util.NoCloseOutputStream
TODO Add javadoc @author Apache MINA SSHD Project
org.freehep.util.io.NoCloseOutputStream
The NoCloseOutputStream ignores the close so that one can keep writing to the underlying stream. @author Mark Donszelmann @version $Id: NoCloseOutputStream.java 8584 2006-08-10 23:06:37Z duns $
org.pentaho.reporting.engine.classic.core.util.NoCloseOutputStream
A Wrapper stream that does never calls close on its parent. This implementation is needed when creating ZipOutputStream, as the final ZipDirectory is written when close is called on the ZipOutputSteam. @author Thomas Morgner

Examples of io.apigee.trireme.core.internal.NoCloseOutputStream

                int fd = getStdioFD(opts);
                OutputStream out;
                switch (fd) {
                case 1:
                    log.debug("Using standard output for script output");
                    out = new NoCloseOutputStream(parent.runner.getStdout());
                    break;
                case 2:
                    log.debug("Using standard error for script output");
                    out = new NoCloseOutputStream(parent.runner.getStderr());
                    break;
                default:
                    throw new AssertionError("Child process only supported on fds 1 and 2");
                }
                switch (arg) {

View Full Code Here

Examples of nexj.core.util.NoCloseOutputStream

         ((TextMarshaller)msh).setVersion(3);
      }


      if (m_bCompressed)
      {
         ostream = new GZIPOutputStream(new NoCloseOutputStream(ostream));
      }


      Writer writer = IOUtil.openBufferedWriter(ostream, XMLUtil.ENCODING);


      msh.serialize(obj, writer);

View Full Code Here

Examples of org.apache.sshd.common.util.NoCloseOutputStream

                }
                w.append("\n");
                w.close();
                channel.setIn(new ByteArrayInputStream(baos.toByteArray()));
            }
            channel.setOut(new NoCloseOutputStream(System.out));
            channel.setErr(new NoCloseOutputStream(System.err));
            channel.open().await();
            channel.waitFor(ClientChannel.CLOSED, 0);
            session.close(false);
        } finally {
            client.stop();

View Full Code Here

Examples of org.apache.sshd.common.util.NoCloseOutputStream

            }
            w.append("\n");
            w.close();
            channel.setIn(new ByteArrayInputStream(baos.toByteArray()));
        }
        channel.setOut(new NoCloseOutputStream(System.out));
        channel.setErr(new NoCloseOutputStream(System.err));
        channel.open().await();
        channel.waitFor(ClientChannel.CLOSED, 0);
        session.close(false);
        client.stop();
    }

View Full Code Here

Examples of org.apache.sshd.common.util.NoCloseOutputStream

        SshClient client = SshClient.setUpDefaultClient();
        client.start();
        ClientSession session = client.connect("localhost", port).await().getSession();
        session.authPassword("smx", "smx").await().isSuccess();
        ChannelExec channel = session.createExecChannel("test");
        channel.setOut(new NoCloseOutputStream(System.out));
        channel.setErr(new NoCloseOutputStream(System.err));
        channel.open().await();
        Thread.sleep(100);
        try {
            for (int i = 0; i < 100; i++) {
                channel.getInvertedIn().write("a".getBytes());

View Full Code Here

Examples of org.apache.sshd.common.util.NoCloseOutputStream

                }
                w.append("\n");
                w.close();
                channel.setIn(new ByteArrayInputStream(baos.toByteArray()));
            }
            channel.setOut(new NoCloseOutputStream(System.out));
            channel.setErr(new NoCloseOutputStream(System.err));
            channel.open().await();
            channel.waitFor(ClientChannel.CLOSED, 0);
            session.close(false);
        } finally {
            client.stop();

View Full Code Here

Examples of org.apache.sshd.common.util.NoCloseOutputStream

        SshClient client = SshClient.setUpDefaultClient();
        client.start();
        ClientSession session = client.connect("localhost", port).await().getSession();
        session.authPassword("smx", "smx").await().isSuccess();
        ChannelExec channel = session.createExecChannel("test");
        channel.setOut(new NoCloseOutputStream(System.out));
        channel.setErr(new NoCloseOutputStream(System.err));
        channel.open().await();
        Thread.sleep(100);
        try {
            for (int i = 0; i < 100; i++) {
                channel.getInvertedIn().write("a".getBytes());

View Full Code Here

Examples of org.apache.sshd.common.util.NoCloseOutputStream

            }
            w.append("\n");
            w.close();
            channel.setIn(new ByteArrayInputStream(baos.toByteArray()));
        }
        channel.setOut(new NoCloseOutputStream(System.out));
        channel.setErr(new NoCloseOutputStream(System.err));
        channel.open().await();
        channel.waitFor(ClientChannel.CLOSED, 0);
        session.close(false);
        client.stop();
    }

View Full Code Here

Examples of org.apache.sshd.common.util.NoCloseOutputStream

                }
                w.append("\n");
                w.close();
                channel.setIn(new ByteArrayInputStream(baos.toByteArray()));
            }
            channel.setOut(new NoCloseOutputStream(System.out));
            channel.setErr(new NoCloseOutputStream(System.err));
            channel.open().await();
            channel.waitFor(ClientChannel.CLOSED, 0);
            session.close(false);
        } finally {
            client.stop();

View Full Code Here

Examples of org.apache.sshd.common.util.NoCloseOutputStream

                    Object ctype = session.get("LC_CTYPE");
                    if (ctype != null) {
                        ((ChannelShell) channel).setEnv("LC_CTYPE", ctype.toString());
                    }
                }
                channel.setOut(new NoCloseOutputStream(System.out));
                channel.setErr(new NoCloseOutputStream(System.err));
                channel.open();
                channel.waitFor(ClientChannel.CLOSED, 0);
            } finally {
                session.put( Console.IGNORE_INTERRUPTS, oldIgnoreInterrupts );
                sshSession.close(false);

View Full Code Here

0 1 2 3 4

TOP

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.