val responseBuilder =
        Response
          .Builder()
          .protocol(statusLine.protocol)
          .code(statusLine.code)
          .message(statusLine.message)
          .headers(headersReader.readHeaders())

      return when {
        expectContinue && statusLine.code == HTTP_CONTINUE -> {
          null
        }

    they could leak passwords and other authentication credentials to insecure
    logs.

 *  **WebSocket API now uses `RequestBody` and `ResponseBody` for messages.**
    This is a backwards-incompatible API change.

 *  **The DNS service is now pluggable.** In some situations this may be useful
    to manually prioritize specific IP addresses.

package jcifs.smb1.dcerpc.ndr;

import java.io.UnsupportedEncodingException;
import java.util.HashMap;

import jcifs.smb1.util.Encdec;

/**
 * NDR (Network Data Representation) buffer for encoding and decoding DCE/RPC messages.
 * This class provides methods for reading and writing primitive types and strings
 * in NDR format for DCE/RPC communication.
 */
public class NdrBuffer {
    int referent;
    HashMap referents;

  private static final String E44 = "4-4";
  private static final int NODE_COUNT = 20;
  private static final int EDGE_COUNT = 20;
  // TODO(user): Consider adding both error messages from here and {@link AbstractNetworkTest}
  // in one class (may be a utility class for error messages).
  private static final String ERROR_PARALLEL_EDGE = "connected by a different edge";
  private static final String ERROR_NEGATIVE_COUNT = "is non-negative";

    public String ldapMemberofAttribute;

    /**
     * Notification message displayed on the login page.
     * This message is shown to users on the authentication page.
     */
    @Size(max = 3000)
    public String notificationLogin;

    /**
     * Notification message displayed on the search top page.
     * This message is shown to users on the main search page.
     */
    @Size(max = 3000)

            throw new SmbException("Message size too small: " + size);
        }

        int maxSize = isSmb1 ? MAX_SMB1_MESSAGE_SIZE : MAX_SMB_MESSAGE_SIZE;
        if (size > maxSize) {
            failedValidations.incrementAndGet();
            log.warn("Message size exceeds maximum: {} > {}", size, maxSize);
            throw new SmbException("Message size exceeds maximum: " + size + " > " + maxSize);
        }

package jcifs.dcerpc.ndr;

import java.util.HashMap;
import java.util.Map;

import jcifs.util.Encdec;
import jcifs.util.Strings;

/**
 * NDR (Network Data Representation) buffer for encoding and decoding DCE/RPC messages.
 * This class provides methods for reading and writing primitive types and strings
 * in NDR format for DCE/RPC communication.
 */
public class NdrBuffer {

    private int referent;

    static {
        DEFAULT_BATCH_LIMITS.put("TreeConnectAndX.QueryInformation", 0);
    }

    private final Map<String, Integer> batchLimits = new HashMap<>();

    /** Local process ID for SMB messages */
    protected int localPid = -1;
    /** Local timezone for time calculations */
    protected TimeZone localTimeZone;
    /** Secure random generator for cryptographic operations */
    protected SecureRandom random;

				VersionID: req.VersionID,
				Objects:   objects,
			},
		},
	}

	if trace != nil {
		entry.Trace = &log.Trace{
			Message:   message,
			Source:    trace,
			Variables: tags,
		}
	} else {
		entry.Message = message
	}

	if anonFlag {
		entry.API.Args.Bucket = HashString(entry.API.Args.Bucket)
		entry.API.Args.Object = HashString(entry.API.Args.Object)

		}
		return nil, context.Cause(ctx)
	}
}

// send the message. msg.Seq and msg.MuxID will be set
func (m *muxClient) send(msg message) error {
	m.respMu.Lock()
	defer m.respMu.Unlock()
	if m.closed {
		return errors.New("mux client closed")
	}
	return m.sendLocked(msg)
}

// sendLocked the message. msg.Seq and msg.MuxID will be set.
// m.respMu must be held.