Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 138 for RUnlock (0.03 sec)

  1. cmd/object_api_suite_test.go

    	globalCompressConfig.Enabled = true
    	globalCompressConfig.MimeTypes = mimeTypes
    	globalCompressConfig.Extensions = extensions
    	globalCompressConfig.AllowEncrypted = encrypt
    	globalCompressConfigMu.Unlock()
    	if encrypt {
    		globalAutoEncryption = encrypt
    		KMS, err := kms.ParseSecretKey("my-minio-key:5lF+0pJM0OWwlQrvK2S/I7W9mO4a6rJJI7wzj7v09cw=")
    		if err != nil {
    			t.Fatal(err)
    		}
    		GlobalKMS = KMS
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  2. cmd/metrics-v3-cache.go

    						v.ioStats[d] = getDriveIOStatMetrics(getDiffStats(ps, cs), duration)
    					}
    				}
    			}
    		}
    
    		prevDriveIOStats = currentStats
    		prevDriveIOStatsRefreshedAt = now
    		prevDriveIOStatsMu.Unlock()
    
    		return
    	}
    
    	return cachevalue.NewFromFunc(1*time.Minute,
    		cachevalue.Opts{ReturnLastGood: true},
    		loadDriveMetrics)
    }
    
    func newCPUMetricsCache() *cachevalue.Cache[madmin.CPUMetrics] {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 8K bytes
    - Viewed (0)
  3. cmd/naughty-disk_test.go

    }
    
    func (d *naughtyDisk) Close() (err error) {
    	if err = d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.Close()
    }
    
    func (d *naughtyDisk) calcError() (err error) {
    	d.mu.Lock()
    	defer d.mu.Unlock()
    	d.callNR++
    	if err, ok := d.errors[d.callNR]; ok {
    		return err
    	}
    	if d.defaultErr != nil {
    		return d.defaultErr
    	}
    	return nil
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 10.1K bytes
    - Viewed (0)
  4. docs/smb3-features/01-smb3-lease-design.md

                leases.put(newKey, newEntry);
                pathToLease.put(path, newKey);
                
                return newKey;
            } finally {
                lock.writeLock().unlock();
            }
        }
        
        public void updateLease(Smb2LeaseKey key, int grantedState) {
            LeaseEntry entry = leases.get(key);
            if (entry != null) {
                entry.updateState(grantedState);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 22K bytes
    - Viewed (0)
  5. cmd/prepare-storage.go

    	return func(endpoint Endpoint, err error, once bool) {
    		reqInfo := (&logger.ReqInfo{}).AppendTags("endpoint", endpoint.String())
    		ctx := logger.SetReqInfo(GlobalContext, reqInfo)
    		mutex.Lock()
    		defer mutex.Unlock()
    
    		m, ok := printOnce[endpoint]
    		if !ok {
    			m = make(map[string]int)
    			printOnce[endpoint] = m
    			if once {
    				m[err.Error()]++
    				peersLogAlwaysIf(ctx, err)
    				return
    			}
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (1)
  6. src/main/java/jcifs/SmbConstants.java

         */
        int DEFAULT_CONN_TIMEOUT = 35000;
    
        /**
         * No flags set in SMB header.
         */
        int FLAGS_NONE = 0x00;
        /**
         * Obsolete lock and read/write and unlock flag.
         */
        int FLAGS_LOCK_AND_READ_WRITE_AND_UNLOCK = 0x01;
        /**
         * Receive buffer has been posted flag.
         */
        int FLAGS_RECEIVE_BUFFER_POSTED = 0x02;
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 24 00:49:49 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  7. ci/official/containers/ml_build_arm64/builder.devtoolset/gcc9-fixups.patch

    +  {
         while (*ep != NULL)
           if (!strncmp (*ep, name, len) && (*ep)[len] == '=')
     	{
    @@ -332,6 +333,7 @@ unsetenv (const char *name)
     	}
           else
     	++ep;
    +  }
     
       UNLOCK;
     
    diff --git a/support/Makefile b/support/Makefile
    index a253698..2f4e2a9 100644
    --- a/support/Makefile
    +++ b/support/Makefile
    @@ -167,13 +167,6 @@ CFLAGS-support_paths.c = \
     		-DINSTDIR_PATH=\"$(prefix)\" \
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Mon Nov 11 19:25:56 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  8. src/test/java/jcifs/internal/smb2/lock/Smb2LockTest.java

            void testExclusiveLockFlag() {
                assertEquals(0x2, Smb2Lock.SMB2_LOCKFLAG_EXCLUSIVE_LOCK);
            }
    
            @Test
            @DisplayName("Should have correct unlock flag value")
            void testUnlockFlag() {
                assertEquals(0x4, Smb2Lock.SMB2_LOCKFLAG_UNLOCK);
            }
    
            @Test
            @DisplayName("Should have correct fail immediately flag value")
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb1/smb1/SmbConstants.java

        /** LM compatibility level */
        int LM_COMPATIBILITY = Config.getInt("jcifs.smb1.smb.lmCompatibility", 3);
    
        /** No flags set */
        int FLAGS_NONE = 0x00;
        /** Lock and read write and unlock flag */
        int FLAGS_LOCK_AND_READ_WRITE_AND_UNLOCK = 0x01;
        /** Receive buffer posted flag */
        int FLAGS_RECEIVE_BUFFER_POSTED = 0x02;
        /** Path names are caseless flag */
        int FLAGS_PATH_NAMES_CASELESS = 0x08;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  10. cmd/admin-handlers_test.go

    	if err != nil {
    		return nil, nil, err
    	}
    
    	// Make objLayer available to all internal services via globalObjectAPI.
    	globalObjLayerMutex.Lock()
    	globalObjectAPI = objLayer
    	globalObjLayerMutex.Unlock()
    	return objLayer, erasureDirs, nil
    }
    
    // cmdType - Represents different service subcomands like status, stop
    // and restart.
    type cmdType int
    
    const (
    	restartCmd cmdType = iota
    	stopCmd
    )
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (1)
Back to top