package jcifs.util.transport;


/**
 * 
 *
 */
public interface Request extends Message {

    /**
     * @return number of credits this request requires
     */
    int getCreditCost ();


    /**
     * @param credits
     */
    void setRequestCredits ( int credits );


    /**
     * @return whether this is a cancel request
     */
    boolean isCancel ();


    /**

 */
package jcifs.internal;


import jcifs.CIFSContext;


/**
 * @author mbechler
 * @param <T>
 *            response type
 *
 */
public interface Request <T extends CommonServerMessageBlockResponse> extends CommonServerMessageBlockRequest {

    /**
     * 
     * @param tc
     * @return the initialized response
     * @internal
     */

package jcifs.smb1.util.transport;

public interface Request {

    /**
     * @param request
     * @param response
     * @param params
     * @param timeout
     * @param firstKey
     * @return
     * @throws IOException
     */
    private <T extends Response> long prepareRequests ( Request request, T response, Set<RequestParam> params, long timeout ) throws IOException {
        Response curResp = response;
        Request curReq = request;
        long firstKey = 0;

    protected abstract void makeKey( Request request ) throws IOException;
    protected abstract Request peekKey() throws IOException;
    protected abstract void doSend( Request request ) throws IOException;
    protected abstract void doRecv( Response response ) throws IOException;
    protected abstract void doSkip() throws IOException;

    public synchronized void sendrecv( Request request,
                    Response response,

    /**
     * Calls the static {@link #authenticate(HttpServletRequest,
     * HttpServletResponse, byte[])} method to perform NTLM authentication
     * for the specified servlet request.
     *
     * @param req The request being serviced.
     * @param resp The response.
     * @param challenge The domain controller challenge.
     * @throws IOException If an IO error occurs.

        request.isBroadcast = request.addr == null;

        if( request.isBroadcast ) {
            request.addr = baddr;
            n = RETRY_COUNT;
        } else {
            request.isBroadcast = false;
            n = 1;
        }

        do {
            try {
                send( request, response, RETRY_TIMEOUT );
            } catch( IOException ioe ) {

import jcifs.CIFSContext;
import jcifs.Configuration;
import jcifs.internal.Request;
import jcifs.internal.smb1.SMB1SigningDigest;
import jcifs.internal.smb1.ServerMessageBlock;
import jcifs.internal.util.SMBUtil;


/**
 * 
 *
 */
public class SmbComClose extends ServerMessageBlock implements Request<SmbComBlankResponse> {

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

                default:
                    throw new SmbException( "Invalid operation for " + service + " service" + request );
            }
        }
        request.tid = tid;
        if( inDfs && !service.equals("IPC") && request.path != null && request.path.length() > 0 ) {
            /* When DFS is in action all request paths are
             * full UNC paths minus the first backslash like
             *   \server\share\path\to\file

        request.isBroadcast = request.addr == null || isBroadcastAddress(request.addr);

        if ( request.isBroadcast ) {
            if ( request.addr == null ) {
                request.addr = this.baddr;
            }
            n = config.getNetbiosRetryCount();
        }
        else {
            n = 1;
        }

        do {
            try {