Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/config.go

    	if err != nil {
    		return err
    	}
    
    	bootstrapTraceMsg("lookup the configuration")
    
    	// Override any values from ENVs.
    	lookupConfigs(srvCfg, objAPI)
    
    	// hold the mutex lock before a new config is assigned.
    	globalServerConfigMu.Lock()
    	globalServerConfig = srvCfg
    	globalServerConfigMu.Unlock()
    
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 23 10:07:06 UTC 2023
    - 6K bytes
    - Viewed (0)
  2. 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)
  3. docs/assets/css/app.css

        line-height: normal;
        font-weight: bold;
    }
    
    button.dl {
      font-weight: 300;
      font-size: 25px;
      line-height: 40px;
      padding: 3px 10px;
      display: inline-block;
      border-radius: 6px;
      color: #f0f0f0;
      margin: 5px 0;
      width: auto;
    }
    
    .logo {
      text-align: center;
      margin-top: 150px;
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Feb 08 07:57:03 UTC 2022
    - 1.1K bytes
    - Viewed (1)
  4. src/main/java/jcifs/smb1/smb1/WinError.java

     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     */
    
    package jcifs.smb1.smb1;
    
    public interface WinError {
    
        /* Don't bother to edit this. Everthing 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: Fri Mar 22 21:10:40 UTC 2019
    - 2.3K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  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. 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)
  10. 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)
Back to top