Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 261 - 270 of 857 for wlock (0.05 seconds)

  1. internal/kms/secret-key.go

    	}
    	iv, nonce := random[:16], random[16:]
    
    	prf := hmac.New(sha256.New, s.key)
    	prf.Write(iv)
    	key := prf.Sum(make([]byte, 0, prf.Size()))
    
    	block, err := aes.NewCipher(key)
    	if err != nil {
    		return DEK{}, err
    	}
    	aead, err := cipher.NewGCM(block)
    	if err != nil {
    		return DEK{}, err
    	}
    
    	plaintext, err := sioutil.Random(32)
    	if err != nil {
    		return DEK{}, err
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Apr 21 16:23:51 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  2. cmd/iam.go

    	bootstrapTraceMsg("IAM initialization started")
    	globalServerConfigMu.RLock()
    	s := globalServerConfig
    	globalServerConfigMu.RUnlock()
    
    	sys.Lock()
    	sys.iamRefreshInterval = iamRefreshInterval
    	sys.Unlock()
    
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	var (
    		openidInit bool
    		ldapInit   bool
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 76.5K bytes
    - Click Count (0)
  3. internal/logger/logger.go

    			API:       "SYSTEM",
    			RequestID: fmt.Sprintf("%X", time.Now().UTC().UnixNano()),
    		}
    	}
    	req.RLock()
    	defer req.RUnlock()
    
    	API := "SYSTEM"
    	switch {
    	case req.API != "":
    		API = req.API
    	case subsystem != "":
    		API += "." + subsystem
    	}
    
    	// Copy tags. We hold read lock already.
    	tags := make(map[string]any, len(req.tags))
    	for _, entry := range req.tags {
    		tags[entry.Key] = entry.Val
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  4. cmd/globals.go

    	globalAuthPluginMutex.Lock()
    	defer globalAuthPluginMutex.Unlock()
    	return globalAuthNPlugin
    }
    
    func newGlobalAuthZPluginFn() *polplugin.AuthZPlugin {
    	globalAuthPluginMutex.Lock()
    	defer globalAuthPluginMutex.Unlock()
    	return globalAuthZPlugin
    }
    
    func setGlobalAuthNPlugin(authn *idplugin.AuthNPlugin) {
    	globalAuthPluginMutex.Lock()
    	globalAuthNPlugin = authn
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Sep 03 18:23:41 GMT 2024
    - 16.2K bytes
    - Click Count (1)
  5. internal/ioutil/ioutil.go

    	"github.com/minio/minio/internal/bpool"
    	"github.com/minio/minio/internal/disk"
    )
    
    // Block sizes constant.
    const (
    	SmallBlock  = 32 * humanize.KiByte  // Default r/w block size for smaller objects.
    	MediumBlock = 128 * humanize.KiByte // Default r/w block size for medium sized objects.
    	LargeBlock  = 1 * humanize.MiByte   // Default r/w block size for normal objects.
    )
    
    // AlignedBytePool is a pool of fixed size aligned blocks
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/base/Suppliers.java

          in.defaultReadObject();
          lock = new Object();
        }
    
        @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = 0;
      }
    
      private static final class NonSerializableMemoizingSupplier<T extends @Nullable Object>
          implements Supplier<T> {
        private final Object lock = new Object();
    
        private volatile @Nullable Supplier<T> delegate;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 31 21:24:28 GMT 2026
    - 16.1K bytes
    - Click Count (0)
  7. src/archive/tar/writer.go

    					sa.IsExtended()[0] = 1
    				}
    				return sp
    			}
    			sp2 := formatSPD(spd, blk.GNU().Sparse())
    			for len(sp2) > 0 {
    				var spHdr block
    				sp2 = formatSPD(sp2, spHdr.Sparse())
    				spb = append(spb, spHdr[:]...)
    			}
    
    			// Update size fields in the header block.
    			realSize := hdr.Size
    			hdr.Size = 0 // Encoded size; does not account for encoded sparse map
    			for _, s := range spd {
    				hdr.Size += s.Length
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Feb 03 16:38:43 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  8. doc/go_spec.html

    	    and ends at the end of the innermost containing block.</li>
    
    	<li>The scope of a type identifier declared inside a function
    	    begins at the identifier in the TypeSpec
    	    and ends at the end of the innermost containing block.</li>
    </ol>
    
    <p>
    An identifier declared in a block may be redeclared in an inner block.
    While the identifier of the inner declaration is in scope, it denotes
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Wed Apr 01 23:39:18 GMT 2026
    - 287.8K bytes
    - Click Count (1)
  9. android/guava/src/com/google/common/util/concurrent/LazyLogger.java

    import java.util.logging.Logger;
    import org.jspecify.annotations.Nullable;
    
    /** A holder for a {@link Logger} that is initialized only when requested. */
    @GwtCompatible
    final class LazyLogger {
      private final Object lock = new Object();
    
      private final String loggerName;
      private volatile @Nullable Logger logger;
    
      LazyLogger(Class<?> ownerOfLogger) {
        this.loggerName = ownerOfLogger.getName();
      }
    
      Logger get() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 1.9K bytes
    - Click Count (0)
  10. src/main/java/jcifs/smb1/smb1/TransCallNamedPipeResponse.java

            if (pipe.pipeIn != null) {
                final TransactNamedPipeInputStream in = (TransactNamedPipeInputStream) pipe.pipeIn;
                synchronized (in.lock) {
                    in.receive(buffer, bufferIndex, len);
                    in.lock.notify();
                }
            }
            return len;
        }
    
        @Override
        public String toString() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 2.1K bytes
    - Click Count (0)
Back to Top