Thread t = this.thread;
        if ( t != null && Thread.currentThread() != t ) {
            this.thread = null;
            try {
                log.debug("Interrupting transport thread");
                t.interrupt();
                log.debug("Joining transport thread");
                t.join(timeout);
                log.debug("Joined transport thread");
            }
            catch ( InterruptedException e ) {

                try {
                    synchronized ( lock ) {
                        lock.wait(1000);
                    }

                    Thread.sleep(100);
                    t.interrupt();
                }
                catch ( InterruptedException e ) {
                    e.printStackTrace();
                }
            }
        });

        try {

        joinThread(q1x);
        interruptThreadSafely(q20);
        joinThread(q20);
    }


    private static void interruptThreadSafely ( QueryThread thread ) {
        try {
            thread.interrupt();
        }
        catch ( SecurityException e ) {
            e.printStackTrace();
        }
    }


    private static void joinThread ( Thread thread ) {
        try {

            }
            finally {
                w.write(null, -1, null);
                w.interrupt();
                try {
                    w.join();
                }
                catch ( InterruptedException e ) {
                    log.warn("Interrupted while joining copy thread", e);
                }
            }
        }
        catch ( CIFSException e ) {

                        }
                        break;
                    }
                    catch ( InterruptedException e ) {
                        InterruptedIOException ie = new InterruptedIOException("Interrupted while acquiring credits");
                        ie.initCause(e);
                        throw ie;
                    }
                }
                else {

                    // immediately
                    Thread.sleep(500 + RAND.nextInt(1000));
                }
            }
            catch ( InterruptedException e ) {
                log.debug("interrupted sleep in send", e);
            }

            if ( request != null ) {
                log.debug("Restting request");
                request.reset();
            }
            if ( rpath != null ) {