synchronized (this) {
            try {
                state = 1;
                final DcerpcMessage bind = new DcerpcBind(binding, this);
                sendrecv(bind);
            } catch (final IOException ioe) {
                state = 0;
                throw ioe;
            }
        }
    }

    /**
     * Sends a DCERPC message and receives the response

> Notice the requirement of common SLA here original cluster had 1024 drives with 16 drives per erasure set with default parity of '4', second pool is expected to have a minimum of 8 drives per erasure set to match the original cluster SLA (parity count) of '4'. '12' drives stripe per erasure set in the second pool satisfies the original pool's parity count.

                    treq.setFileInformation(new FileEndOfFileInformation(0));
                    th.send(treq, RequestParam.NO_RETRY);
                }
            }
        } catch (final CIFSException e) {
            throw SmbException.wrap(e);
        }
    }

    SmbFileOutputStream(final SmbFile file, final SmbTreeHandleImpl th, final SmbFileHandleImpl handle, final int openFlags,

     *
     * @return whether to ignore exceptions that occur during file copy
     */
    boolean isIgnoreCopyToException();

    /**
     * Gets the batch limit for a specific SMB command
     *
     * @param cmd the SMB command name
     * @return the batch limit for the given command
     */
    int getBatchLimit(String cmd);

    /**
     *

	if len(reference.Erasure.Sets) != len(format.Erasure.Sets) {
		return fmt.Errorf("Expected number of sets %d, got %d", len(reference.Erasure.Sets), len(format.Erasure.Sets))
	}

	// Make sure that the sets match.
	for i := range reference.Erasure.Sets {
		if len(reference.Erasure.Sets[i]) != len(format.Erasure.Sets[i]) {
			return fmt.Errorf("Each set should be of same size, expected %d got %d",

    }

    public void test_init() {
        DocumentHelper documentHelper = new DocumentHelper();

        try {
            documentHelper.init();
        } catch (Exception e) {
            fail("init() should not throw an exception: " + e.getMessage());
        }
    }

    public void test_getTitle() {
        DocumentHelper documentHelper = new DocumentHelper();

 * Are always invoked once, even if the HTTP response is served from the cache.
 * Observe the application's original intent. Unconcerned with OkHttp-injected headers like `If-None-Match`.
 * Permitted to short-circuit and not call `Chain.proceed()`.
 * Permitted to retry and make multiple calls to `Chain.proceed()`.
 * Can adjust Call timeouts using withConnectTimeout, withReadTimeout, withWriteTimeout.

                     * have a real NetBIOS name
                     */
                    this.calledName = null;
                    return getHostName();
                }
            } catch (final UnknownHostException uhe) {
                this.calledName = null;
            }
        } else {
            this.calledName = null;
        }

        return this.calledName;
    }

	globalInternodeInterface     string
	globalInternodeInterfaceOnce sync.Once

	// Set last client perf extra time (get lock, and validate)
	globalLastClientPerfExtraTime int64

	// Captures all batch jobs metrics globally
	globalBatchJobsMetrics batchJobMetrics

	// Indicates if server was started as `--address ":0"`
	globalDynamicAPIPort bool

	// Add new variable global values here.
)

        assertEquals("", DocumentUtil.encodeUrl(""));
        try {
            DocumentUtil.encodeUrl(null);
            fail("Should throw NullPointerException");
        } catch (NullPointerException e) {
            // Expected
        }
    }

    public void test_encodeUrl_unicode() {
        assertEquals("%3F", DocumentUtil.encodeUrl("あ"));