func (m *muxServer) close() {
	m.cancel()
	m.recvMu.Lock()
	defer m.recvMu.Unlock()

	if m.inbound != nil {
		xioutil.SafeClose(m.inbound)
		m.inbound = nil
	}

	if m.outBlock != nil {
		xioutil.SafeClose(m.outBlock)
		m.outBlock = nil
	}

	if !m.checkSeq(seq) {
		return
	}
	if m.acked || m.outBlock == nil {
		return
	}
	available := cap(m.outBlock)
	for range available {
		m.outBlock <- struct{}{}
	}
	m.acked = true
}

func (m *muxClient) unblockSend(seq uint32) {
	if !m.checkSeq(seq) {
		return
	}
	select {
	case m.outBlock <- struct{}{}:
	default:

  /**
   * <a href="https://www.loc.gov/preservation/digital/formats/fdd/fdd000379.shtml">Microsoft
   * Outlook</a> items.
   *
   * @since 27.1
   */
  public static final MediaType MICROSOFT_OUTLOOK =
      createConstant(APPLICATION_TYPE, "vnd.ms-outlook");

  /**
   * <a

  /**
   * <a href="https://www.loc.gov/preservation/digital/formats/fdd/fdd000379.shtml">Microsoft
   * Outlook</a> items.
   *
   * @since 27.1
   */
  public static final MediaType MICROSOFT_OUTLOOK =
      createConstant(APPLICATION_TYPE, "vnd.ms-outlook");

  /**
   * <a

     * Lock object for synchronizing input operations
     */
    protected final Object inLock = new Object();
    /**
     * Lock object for synchronizing output operations
     */
    protected final Object outLock = new Object();

    /**
     * Map for tracking pending responses by their key
     */
    protected final Map<Long, Response> response_map = new ConcurrentHashMap<>(10);

				"application/vnd.ms-fontobject",
				"application/vnd.ms-htmlhelp",
				"application/vnd.ms-ims",
				"application/vnd.ms-lrm",
				"application/vnd.ms-outlook",
				"application/vnd.ms-outlook-pst",
				"application/vnd.ms-pki.seccat",
				"application/vnd.ms-pki.stl",
				"application/vnd.ms-playready.initiator+xml",
				"application/vnd.ms-powerpoint",

        final byte[] buffer = this.getContext().getBufferCache().getBuffer();
        try {
            // synchronize around encode and write so that the ordering for SMB1 signing can be maintained
            synchronized (this.outLock) {
                final int n = smb.encode(buffer, 4);
                Encdec.enc_uint32be(n & 0xFFFF, buffer, 0); /* 4 byte session message header */
                if (log.isTraceEnabled()) {
                    do {

    <glob pattern="*.lrm"/>
  </mime-type>

  <mime-type type="application/vnd.ms-outlook">
    <_comment>Microsoft Outlook Message</_comment>
    <glob pattern="*.msg" />
    <sub-class-of type="application/x-tika-msoffice"/>
  </mime-type>

  <mime-type type="application/vnd.ms-outlook-pst">
    <_comment>Outlook Personal Folders File Format</_comment>
    <magic priority="50">