* License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */
package jcifs.util.transport;

/**
 * Base class for transport-layer messages in the jCIFS network communication.
 * Provides common functionality for message handling and processing.
 *
 * @author mbechler
 */
public interface Message {

    /**

# Full build with packaging
mvn clean package

# Run specific test class
mvn test -Dtest=CurlTest
mvn test -Dtest=CurlRequestTest
mvn test -Dtest=CurlResponseTest
mvn test -Dtest=CurlExceptionTest

# Run I/O layer tests
mvn test -Dtest=ContentCacheTest
mvn test -Dtest=ContentOutputStreamTest
mvn test -Dtest=IOIntegrationTest
```

### Code Quality
```bash
# Format code
mvn formatter:format

* `color` (not `colour`)
* `initialize` (not `initialise`)
* `behavior` (not `behaviour`)
* `analyze` (not `analyse`)
* `organization` (not `organisation`)
* `center` (not `centre`)
* `canceled` (not `cancelled`)
* `labeled` (not `labelled`)

### Rationale for American English

American English was chosen for the following reasons:

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */
package jcifs.util.transport;

import jcifs.CIFSException;

/**
 * Exception class for transport layer errors.
 * This exception is thrown when transport-related communication errors occur.
 */
public class TransportException extends CIFSException {

    /**
     *
     */

    e: IOException,
    call: RealCall,
    chain: Interceptor.Chain,
    userRequest: Request,
  ): Boolean {
    val requestSendStarted = e !is ConnectionShutdownException

    // The application layer has forbidden retries.
    if (!chain.retryOnConnectionFailure) return false

    // We can't send the request body again.
    if (requestSendStarted && requestIsOneShot(e, userRequest)) return false

		}
	}

	configData, err := xml.Marshal(encConfig)
	if err != nil {
		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
		return
	}

	// Store the bucket encryption configuration in the object layer
	updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, bucketSSEConfig, configData)
	if err != nil {
		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
		return
	}

	// Call site replication hook.

 *
 * This form is used to collect user input and parameters needed to initiate
 * crawling operations through the administrative interface wizard workflow.
 * It serves as a data transfer object between the web layer and the crawling
 * service components.
 */
public class StartCrawlingForm {

    /**
     * Default constructor.
     */
    public StartCrawlingForm() {
        // Default constructor
    }

     * behavior, this method accepts both the forward slash and the backward slash as separator.
     *
     * @param path The filesystem path, may be <code>null</code>.
     * @return The altered filesystem path or <code>null</code> if the input path was <code>null</code>.
     */
    private String chopLeadingFileSeparator(String path) {
        if (path != null) {

	var erasureDisks []string
	for range nDisks {
		// Do not attempt to create this path, the test validates
		// so that newErasureSets initializes non existing paths
		// and successfully returns initialized object layer.
		disk := filepath.Join(globalTestTmpDir, "minio-"+nextSuffix())
		erasureDisks = append(erasureDisks, disk)
		defer os.RemoveAll(disk)
	}

	endpoints := mustGetNewEndpoints(0, 16, erasureDisks...)

   * leaking resources callers must [close the response body][ResponseBody] or the response.
   *
   * Note that transport-layer success (receiving a HTTP response code, headers and body) does not
   * necessarily indicate application-layer success: `response` may still indicate an unhappy HTTP
   * response code like 404 or 500.
   *