// checkMetacacheState should be used if data is not updating.
// Should only be called if a failure occurred.
func (o listPathOptions) checkMetacacheState(ctx context.Context, rpc *peerRESTClient) error {
	// We operate on a copy...
	o.Create = false
	c, err := rpc.GetMetacacheListing(ctx, o)
	if err != nil {
		return err
	}
	cache := *c

	if cache.status == scanStateNone || cache.fileNotFound {
		return errFileNotFound

import jcifs.smb1.dcerpc.ndr.NdrException;
import jcifs.smb1.dcerpc.ndr.NdrObject;

/**
 * Server Service RPC interface implementation for remote server administration (SMB1).
 */
public class srvsvc {

    /**
     * Private constructor to prevent instantiation.
     */
    private srvsvc() {
    }

    /**
     * Gets the RPC interface syntax string.
     * @return the interface UUID and version
     */

class samrTest {

    @Mock
    private NdrBuffer mockNdrBuffer;

    @Mock
    private NdrBuffer mockDeferredBuffer;

    @Mock
    private rpc.policy_handle mockPolicyHandle;

    @Mock
    private rpc.sid_t mockSidT;

    @Mock
    private rpc.unicode_string mockUnicodeString;

    @Mock
    private lsarpc.LsarSidArray mockLsarSidArray;

    @BeforeEach
    void setUp() {

	"cmd/internal/obj/wasm"
	"cmd/internal/obj/x86"
	"fmt"
	"strings"
)

// Pseudo-registers whose names are the constant name without the leading R.
const (
	RFP = -(iota + 1)
	RSB
	RSP
	RPC
)

// Arch wraps the link architecture object with more architecture-specific information.
type Arch struct {
	*obj.LinkArch
	// Map of instruction names to enumeration.
	Instructions map[string]obj.As

							b.Fatal("No connection")
						}
						// Send the payload.
						t := time.Now()
						resp, err := rpc.Call(ctx, conn, &req)
						latency += time.Since(t).Nanoseconds()
						if err != nil {
							if debugReqs {
								fmt.Println(err.Error())
							}
							b.Fatal(err.Error())
						}
						rpc.PutResponse(resp)
						n++
					}
					atomic.AddInt64(&ops, int64(n))
					atomic.AddInt64(&lat, latency)

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */

package jcifs.smb1.dcerpc;

/**
 * DCE/RPC protocol constants for SMB1 compatibility
 */
public interface DcerpcConstants {

    /**
     * NDR syntax UUID for DCE/RPC protocol
     */
    UUID DCERPC_UUID_SYNTAX_NDR = new UUID("8a885d04-1ceb-11c9-9fe8-08002b104860");

    /**

import jcifs.dcerpc.msrpc.lsarpc;
import jcifs.dcerpc.msrpc.netdfs;
import jcifs.dcerpc.msrpc.samr;
import jcifs.dcerpc.msrpc.srvsvc;

/**
 * DCE/RPC binding information for connecting to remote endpoints.
 * This class encapsulates the details needed to establish a DCE/RPC connection.
 */
public class DcerpcBinding {

    private static final Map<String, String> INTERFACES = new HashMap<>();

    static {

import jcifs.CIFSException;
import jcifs.SmbPipeResource;
import jcifs.smb.SmbNamedPipe;
import jcifs.smb.SmbPipeHandleInternal;
import jcifs.util.Encdec;

/**
 * DCE/RPC handle implementation for named pipe communications.
 * This class provides DCE/RPC communication over SMB named pipes.
 */
public class DcerpcPipeHandle extends DcerpcHandle {

    /* This 0x20000 bit is going to get chopped! */

    //                    "[\\PIPE\\netdfs]", auth);
    //        try {
    //            rpc = new MsrpcDfsRootEnum(domainName);
    //            handle.sendrecv(rpc);
    //            if (rpc.retval != 0)
    //                throw new SmbException(rpc.retval, true);
    //            return rpc.getEntries();
    //        } finally {
    //            try {
    //                handle.close();

    // Output parameters for WitnessRegister
    private byte[] contextHandle;

    /**
     * Creates a new WitnessRegister RPC message.
     */
    public WitnessRegisterMessage() {
        super(WITNESS_REGISTER);
        this.contextHandle = new byte[20]; // Standard DCE/RPC context handle size
    }

    /**
     * Sets the witness protocol version.
     *
     * @param version the witness protocol version