* @return the break reason
     */
    public int getBreakReason() {
        return breakReason;
    }

    /**
     * Gets the lease flags from the notification
     * @return the lease flags
     */
    public int getLeaseFlags() {
        return flags;
    }

    /**
     * Gets the access mask hint for optimizing lease handling
     * @return the access mask hint
     */

    }

    boolean allow;
    int flags;
    int access;
    SID sid;

    @Override
    public boolean isAllow() {
        return this.allow;
    }

    @Override
    public boolean isInherited() {
        return (this.flags & FLAGS_INHERITED) != 0;
    }

    @Override
    public int getFlags() {
        return this.flags;
    }

    @Override

            // Test with both flags
            setPrivateField(response, "shareFlags",
                    Smb2TreeConnectResponse.SMB2_SHAREFLAG_DFS | Smb2TreeConnectResponse.SMB2_SHAREFLAG_DFS_ROOT);
            assertTrue(response.isShareDfs(), "Should detect DFS from combined flags");

            // Test without DFS flags
            setPrivateField(response, "shareFlags", 0);

	"github.com/tinylib/msgp/msgp"
)

// DecodeMsg implements msgp.Decodable
func (z *Flags) DecodeMsg(dc *msgp.Reader) (err error) {
	{
		var zb0001 uint8
		zb0001, err = dc.ReadUint8()
		if err != nil {
			err = msgp.WrapError(err)
			return
		}
		(*z) = Flags(zb0001)
	}
	return
}

// EncodeMsg implements msgp.Encodable
func (z Flags) EncodeMsg(en *msgp.Writer) (err error) {
	err = en.WriteUint8(uint8(z))

		return false
	}
}

// BatchJobReplicateV1 v1 of batch job replication
type BatchJobReplicateV1 struct {
	APIVersion string                  `yaml:"apiVersion" json:"apiVersion"`
	Flags      BatchJobReplicateFlags  `yaml:"flags" json:"flags"`
	Target     BatchJobReplicateTarget `yaml:"target" json:"target"`
	Source     BatchJobReplicateSource `yaml:"source" json:"source"`

	clnt *miniogo.Core `msg:"-"`
}

  }

  data class Request(
    val network: Network?,
    val domain: String,
    val nsType: Int,
    val flags: Int,
    val callback: DnsResolver.Callback<List<InetAddress>>,
  )

  @Implementation
  fun query(
    network: Network?,
    domain: String,
    nsType: Int,
    flags: Int,
    executor: Executor,
    cancellationSignal: CancellationSignal?,
    callback: DnsResolver.Callback<List<InetAddress>>,

        Field flagsField = DcerpcMessage.class.getDeclaredField("flags");
        flagsField.setAccessible(true);
        int flagsValue = (int) flagsField.get(msrpcSamrConnect2);
        int expectedFlags = DcerpcConstants.DCERPC_FIRST_FRAG | DcerpcConstants.DCERPC_LAST_FRAG;
        assertEquals(expectedFlags, flagsValue, "The 'flags' field should be set to DCERPC_FIRST_FRAG | DCERPC_LAST_FRAG");
    }

    @Test

     */
    public boolean isInherited() {
        return (flags & FLAGS_INHERITED) != 0;
    }

    /**
     * Returns the flags for this ACE. The <code>isInherited()</code>
     * method checks the <code>FLAGS_INHERITED</code> bit in these flags.
     * @return the ACE flags
     */
    public int getFlags() {
        return flags;
    }

    /**

        Field flagsField = DcerpcMessage.class.getDeclaredField("flags");
        flagsField.setAccessible(true);
        int flagsValue = (int) flagsField.get(request);
        int expectedFlags = DcerpcConstants.DCERPC_FIRST_FRAG | DcerpcConstants.DCERPC_LAST_FRAG;
        assertEquals(expectedFlags, flagsValue, "The 'flags' field should be initialized to DCERPC_FIRST_FRAG | DCERPC_LAST_FRAG.");
    }

	}
	m.init = true
	m.singleResp = true
	msg := message{
		Op:         OpRequest,
		MuxID:      m.MuxID,
		Handler:    h,
		Flags:      m.BaseFlags | FlagEOF,
		Payload:    req,
		DeadlineMS: uint32(m.deadline.Milliseconds()),
	}
	if m.subroute != nil {
		msg.Flags |= FlagSubroute
	}
	ch := make(chan Response, 1)
	m.respMu.Lock()
	if m.closed {
		m.respMu.Unlock()
		return nil, ErrDisconnected
	}