}

    public void setDoInput(boolean doInput) {
        connection.setDoInput(doInput);
        this.doInput = doInput;
    }

    public boolean getDoInput() {
        return connection.getDoInput();
    }

    public void setDoOutput(boolean doOutput) {
        connection.setDoOutput(doOutput);
        this.doOutput = doOutput;
    }

    public boolean getDoOutput() {

     * this transport.
     */

    protected abstract boolean doDisconnect ( boolean hard, boolean inUse ) throws IOException;


    /**
     * Connect the transport
     * 
     * @param timeout
     * @return whether the transport was connected
     * @throws TransportException
     */
    public synchronized boolean connect ( long timeout ) throws TransportException {
        int st = this.state;

 */

package jcifs.smb1.dcerpc;

public class UnicodeString extends rpc.unicode_string {

    boolean zterm;

    public UnicodeString(boolean zterm) {
        this.zterm = zterm;
    }
    public UnicodeString(rpc.unicode_string rus, boolean zterm) {
        this.length = rus.length;
        this.maximum_length = rus.maximum_length;
        this.buffer = rus.buffer;

        return getNegotiatedMpxCount();
    }


    /**
     * {@inheritDoc}
     *
     * @see jcifs.internal.SmbNegotiationResponse#canReuse(jcifs.CIFSContext, boolean)
     */
    @Override
    public boolean canReuse ( CIFSContext tc, boolean forceSigning ) {
        return this.getConfig().equals(tc.getConfig());
    }


    /**
     * @return the dialectIndex
     */

    private static final Logger log = LoggerFactory.getLogger(SmbPipeHandleImpl.class);

    private final SmbNamedPipe pipe;
    private final boolean transact;
    private final boolean call;

    private final int openFlags;
    private final int access;
    private volatile boolean open = true;

    private SmbFileHandleImpl handle;
    private SmbPipeOutputStream output;
    private SmbPipeInputStream input;

     *            context to use
     * @return whether the given address is a group address
     *
     * @throws UnknownHostException
     *             if the host cannot be resolved to find out.
     */
    boolean isGroupAddress ( CIFSContext tc ) throws UnknownHostException;


    /**
     * Checks the node type of this address.
     * 
     * @param tc
     *            context to use

 * 
 */
public class SmbComNegotiate extends ServerMessageBlock implements SmbNegotiationRequest {

    private final boolean signingEnforced;
    private String[] dialects;


    /**
     * 
     * @param config
     * @param signingEnforced
     */
    public SmbComNegotiate ( Configuration config, boolean signingEnforced ) {
        super(config, SMB_COM_NEGOTIATE);
        this.signingEnforced = signingEnforced;

                }
            } catch( Exception ex ) {
                String msg = ex.getMessage();
                boolean timeout = msg != null && msg.equals( "Read timed out" );
                /* If just a timeout, try to disconnect gracefully
                 */
                boolean hard = timeout == false;

                if (!timeout && log.level >= 3)
                    ex.printStackTrace( log );

/**
 * This <code>OutputStream</code> can write bytes to a file on an SMB file server.
 */

public class SmbFileOutputStream extends OutputStream {

    private SmbFile file;
    private boolean append, useNTSmbs;
    private int openFlags, access, writeSize;
    private long fp;
    private byte[] tmp = new byte[1];
    private SmbComWriteAndX reqx;
    private SmbComWriteAndXResponse rspx;

 */

public class SmbFileOutputStream extends OutputStream {

    private static final Logger log = LoggerFactory.getLogger(SmbFileOutputStream.class);

    private SmbFile file;
    private boolean append, useNTSmbs;
    private int openFlags, access, writeSize, writeSizeFile;
    private long fp;
    private byte[] tmp = new byte[1];
    private SmbComWriteAndX reqx;
    private SmbComWriteAndXResponse rspx;