Search Options

Results per page
Sort
Preferred Languages
Advance

Results 301 - 310 of 682 for wlock (0.03 sec)

  1. internal/once/singleton.go

    package once
    
    // Singleton contains a pointer to T that must be set once.
    // Until the value is set all Get() calls will block.
    type Singleton[T any] struct {
    	v   *T
    	set chan struct{}
    }
    
    // NewSingleton creates a new unset singleton.
    func NewSingleton[T any]() *Singleton[T] {
    	return &Singleton[T]{set: make(chan struct{}), v: nil}
    }
    
    // Get will return the singleton value.
    func (s *Singleton[T]) Get() *T {
    	<-s.set
    	return s.v
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 952 bytes
    - Viewed (0)
  2. internal/config/identity/openid/provider/keycloak.go

    	if err != nil {
    		return err
    	}
    	defer resp.Body.Close()
    
    	var accessToken Token
    	if err = json.NewDecoder(resp.Body).Decode(&accessToken); err != nil {
    		return err
    	}
    
    	k.Lock()
    	k.accessToken = accessToken
    	k.Unlock()
    	return nil
    }
    
    // LookupUser lookup user by their userid.
    func (k *KeycloakProvider) LookupUser(userid string) (User, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jul 14 18:12:07 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/Queues.java

       * Queue<E> queue = Queues.synchronizedQueue(MinMaxPriorityQueue.<E>create());
       * ...
       * queue.add(element);  // Needn't be in synchronized block
       * ...
       * synchronized (queue) {  // Must synchronize on queue!
       *   Iterator<E> i = queue.iterator(); // Must be in synchronized block
       *   while (i.hasNext()) {
       *     foo(i.next());
       *   }
       * }
       * }</pre>
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  4. internal/rest/client.go

    func (c *Client) LastConn() time.Time {
    	return time.Unix(0, atomic.LoadInt64(&c.lastConn))
    }
    
    // LastError returns previous error
    func (c *Client) LastError() error {
    	c.RLock()
    	defer c.RUnlock()
    	return fmt.Errorf("[%s] %w", c.lastErrTime.Format(time.RFC3339), c.lastErr)
    }
    
    // computes the exponential backoff duration according to
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  5. cmd/erasure-metadata-utils_test.go

    	shuffledDisks := shuffleDisks(disks, distribution)
    	// From the "distribution" above you can notice that:
    	// 1st data block is in the 9th disk (i.e distribution index 8)
    	// 2nd data block is in the 8th disk (i.e distribution index 7) and so on.
    	if shuffledDisks[0] != disks[8] ||
    		shuffledDisks[1] != disks[7] ||
    		shuffledDisks[2] != disks[9] ||
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  6. common-protos/k8s.io/api/networking/v1alpha1/generated.proto

      // This field is immutable.
      // +required
      optional int32 perNodeHostBits = 2;
    
      // ipv4 defines an IPv4 IP block in CIDR notation(e.g. "10.0.0.0/8").
      // At least one of ipv4 and ipv6 must be specified.
      // This field is immutable.
      // +optional
      optional string ipv4 = 3;
    
      // ipv6 defines an IPv6 IP block in CIDR notation(e.g. "2001:db8::/64").
      // At least one of ipv4 and ipv6 must be specified.
      // This field is immutable.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 6K bytes
    - Viewed (0)
  7. mockwebserver/src/main/kotlin/mockwebserver3/internal/ThrottledSink.kt

    /*
     * Copyright (c) 2022 Block, Inc.
     *
     * Licensed under the Apache License, Version 2.0 (the "License");
     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  8. cmd/xl-storage_noatime_supported.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"os"
    	"syscall"
    )
    
    var (
    	// Disallow updating access times
    	// Add non-block to avoid syscall to attempt to set epoll on files.
    	readMode = os.O_RDONLY | 0x40000 | syscall.O_NONBLOCK // O_NOATIME
    
    	// Write with data sync only used only for `xl.meta` writes
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 16:36:24 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  9. okhttp-android/src/test/kotlin/okhttp3/android/AndroidAsyncDnsTest.kt

    /*
     * Copyright (C) 2024 Block, Inc.
     *
     * Licensed under the Apache License, Version 2.0 (the "License");
     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 22 20:07:09 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb/WinError.java

     */
    
    package jcifs.smb;
    
    
    @SuppressWarnings ( "javadoc" )
    public interface WinError {
    
        /*
         * Don't bother to edit this. Everything within the interface
         * block is automatically generated from the ntstatus package.
         */
    
        public static final int ERROR_SUCCESS = 0;
        public static final int ERROR_ACCESS_DENIED = 5;
        public static final int ERROR_REQ_NOT_ACCEP = 71;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 2.4K bytes
    - Viewed (0)
Back to top