Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 293 for resMap (0.63 sec)

  1. cmd/iam-store.go

    		}
    		resMap[user] = blankEntities
    	}
    
    	var r []madmin.UserPolicyEntities
    	cache.iamUserPolicyMap.Range(func(user string, mappedPolicy MappedPolicy) bool {
    		if userPredicate != nil && !userPredicate(user) {
    			return true
    		}
    
    		entitiesWithMemberOf, ok := resMap[user]
    		if !ok {
    			if len(userMap) > 0 {
    				return true
    			}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 87.1K bytes
    - Viewed (0)
  2. src/test/java/jcifs/smb/SmbWatchHandleImplTest.java

            List<FileNotifyInformation> info = new ArrayList<>();
            NotifyResponse resp = mock(NotifyResponse.class);
            when(resp.isReceived()).thenReturn(true);
            when(resp.getErrorCode()).thenReturn(0);
            when(resp.getNotifyInformation()).thenReturn(info);
            setupSmb2(resp, new byte[16]);
            SmbWatchHandleImpl sut = new SmbWatchHandleImpl(handle, 0x1234, true);
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  3. src/test/java/jcifs/smb/SmbFileHandleImplTest.java

            ArgumentCaptor<CommonServerMessageBlockRequest> reqCap = ArgumentCaptor.forClass(CommonServerMessageBlockRequest.class);
            ArgumentCaptor<SmbComBlankResponse> respCap = ArgumentCaptor.forClass(SmbComBlankResponse.class);
            verify(tree, times(1)).send(reqCap.capture(), respCap.capture(), eq(RequestParam.NO_RETRY));
            assertTrue(reqCap.getValue() instanceof SmbComClose, "Expected SmbComClose request");
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12.3K bytes
    - Viewed (0)
  4. docs/iam/access-manager-plugin.go

    		return
    	}
    
    	var out bytes.Buffer
    	json.Indent(&out, body, "", "  ")
    	fmt.Printf("Received JSON payload:\n%s\n", out.String())
    
    	reqMap := make(map[string]interface{})
    	err = json.Unmarshal(body, &reqMap)
    	if err != nil {
    		writeErrorResponse(w, err)
    		return
    	}
    
    	m := reqMap["input"].(map[string]interface{})
    	accountValue := m["account"].(string)
    	actionValue := m["action"].(string)
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Feb 08 17:15:20 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  5. src/test/java/jcifs/internal/smb2/ioctl/Smb2IoctlResponseTest.java

            Smb2IoctlResponse resp = new Smb2IoctlResponse(config);
    
            resp.decode(packet, 0);
            assertEquals(Smb2IoctlRequest.FSCTL_SRV_COPYCHUNK, resp.getCtlCode());
            assertEquals(0x1234, resp.getIoctlFlags());
            assertNotNull(resp.getFileId());
            assertEquals(16, resp.getFileId().length);
            assertEquals(12, resp.getOutputLength());
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  6. docs/en/docs/tutorial/cookie-params.md

    But even if you **fill the data** and click "Execute", because the docs UI works with **JavaScript**, the cookies won't be sent, and you will see an **error** message as if you didn't write any values.
    
    ///
    
    ## Recap { #recap }
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Sep 20 17:49:27 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  7. cmd/peer-rest-client.go

    	resp, err := getLocksRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	if err != nil || resp == nil {
    		return nil, err
    	}
    	return *resp, nil
    }
    
    // LocalStorageInfo - fetch server information for a remote node.
    func (client *peerRESTClient) LocalStorageInfo(ctx context.Context, metrics bool) (info StorageInfo, err error) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 26.1K bytes
    - Viewed (0)
  8. src/test/java/jcifs/internal/smb1/com/SmbComWriteResponseTest.java

        private SmbComWriteResponse resp;
        private Configuration cfgMock;
    
        @BeforeEach
        public void setUp() {
            // create a mock configuration that satisfies constructor requirements.
            cfgMock = mock(Configuration.class);
            resp = new SmbComWriteResponse(cfgMock);
        }
    
        @Test
        public void testInitialCountIsZero() {
            assertEquals(0, resp.getCount(), "Initial count should be zero");
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  9. src/test/java/jcifs/internal/smb2/session/Smb2SessionSetupResponseTest.java

            int decoded = resp.decode(buf, headerStart);
            assertTrue(decoded > 0, "Decode should return positive length");
    
            assertEquals(NtStatus.NT_STATUS_MORE_PROCESSING_REQUIRED, resp.getStatus());
            assertArrayEquals(blob, resp.getBlob(), "Security blob should match");
            assertEquals(sessionFlags, resp.getSessionFlags(), "Session flags should decode");
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.7K bytes
    - Viewed (0)
  10. internal/grid/handlers.go

    // If no deadline is set, a 1-minute deadline is added.
    func (h *SingleHandler[Req, Resp]) Call(ctx context.Context, c Requester, req Req) (resp Resp, err error) {
    	if c == nil {
    		if h.ignoreNilConn {
    			return resp, nil
    		}
    		return resp, ErrDisconnected
    	}
    	payload, err := req.MarshalMsg(GetByteBufferCap(req.Msgsize()))
    	if err != nil {
    		return resp, err
    	}
    	switch any(req).(type) {
    	case *MSS, *URLValues:
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 27.7K bytes
    - Viewed (0)
Back to top