/**
     * Expand/truncate file length
     * 
     * @param newLength
     *            new file length
     * @throws SmbException
     */
    void setLength ( long newLength ) throws SmbException;

        }
    }
    public void run() {
        int nameTrnId;
        NameServicePacket response;

        try {
            while( thread == Thread.currentThread() ) {
                in.setLength( RCV_BUF_SIZE );

                socket.setSoTimeout( closeTimeout );
                socket.receive( in );

                if( log.level > 3 )

        advance(l);
    }
    public void readOctetArray(byte[] b, int i, int l) {
        System.arraycopy(buf, index, b, i, l);
        advance(l);
    }


    public int getLength() {
        return deferred.length;
    }
    public void setLength(int length) {
        deferred.length = length;
    }
    public void advance(int n) {
        index += n;
        if ((index - start) > deferred.length) {

    /**
     * @param fbuf
     * @throws DcerpcException
     */
    private void setupReceivedFragment ( NdrBuffer fbuf ) throws DcerpcException {
        fbuf.reset();
        fbuf.setIndex(8);
        fbuf.setLength(fbuf.dec_ndr_short());

        if ( this.securityProvider != null ) {
            this.securityProvider.unwrap(fbuf);
        }
    }


    /**
     * @param msg
     * @param out

            this.responseTable.clear();
        }
    }


    @Override
    public void run () {
        try {
            while ( this.thread == Thread.currentThread() ) {
                this.in.setLength(this.transportContext.getConfig().getNetbiosRcvBufSize());

                this.socket.setSoTimeout(this.closeTimeout);
                this.socket.receive(this.in);

                      SmbFile t = new SmbFile(d1, makeRandomName()) ) {
                    try {
                        try ( SmbRandomAccessFile ra = f.openRandomAccess("rw") ) {
                            ra.setLength(length);
                        }

                        f.copyTo(t);
                        assertTrue(f.exists());
                        assertEquals(f.length(), t.length());

        return fp;
    }
    public void seek( long pos ) throws SmbException {
        fp = pos;
    }
    public long length() throws SmbException {
        return file.length();
    }
    public void setLength( long newLength ) throws SmbException {
        // ensure file is open
        if( file.isOpen() == false ) {
            file.open( openFlags, 0, SmbFile.ATTR_NORMAL, options );
        }

        try ( SmbFile f = createTestFile() ) {
            try {
                long newLength = 4096L;
                try ( SmbRandomAccessFile raf = new SmbRandomAccessFile(f, "rw") ) {
                    raf.setLength(newLength);
                }
                assertEquals(newLength, f.length());
            }
            finally {
                f.delete();
            }
        }
    }


    @Test

                off += n;
            }

            doReceiveFragment(stub, isDirect);
            buf.reset();
            buf.setIndex(8);
            buf.setLength(buf.dec_ndr_short());

            if (securityProvider != null)
                securityProvider.unwrap(buf);

            buf.setIndex(0);

            msg.decode_header(buf);

    public void readOctetArray ( byte[] b, int i, int l ) {
        System.arraycopy(this.buf, this.index, b, i, l);
        advance(l);
    }


    public int getLength () {
        return this.deferred.length;
    }


    public void setLength ( int length ) {
        this.deferred.length = length;
    }


    public void advance ( int n ) {
        this.index += n;