Search Options

Results per page
Sort
Preferred Languages
Advance

Results 411 - 420 of 547 for sock (0.03 sec)

  1. cmd/erasure-decode.go

    					br.Close()
    				}
    				p.readers[i] = nil
    
    				// Since ReadAt returned error, trigger another read.
    				readTriggerCh <- true
    				return
    			}
    			newBufLK.Lock()
    			newBuf[bufIdx] = p.buf[bufIdx][:n]
    			newBufLK.Unlock()
    			// Since ReadAt returned success, there is no need to trigger another read.
    			readTriggerCh <- false
    		}(readerIndex)
    		readerIndex++
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

        }
    
        if (nextRouteToTry != null) {
          return true
        }
    
        if (failedConnection != null) {
          val retryRoute = retryRoute(failedConnection)
          if (retryRoute != null) {
            // Lock in the route because retryRoute() is racy and we don't want to call it twice.
            nextRouteToTry = retryRoute
            return true
          }
        }
    
        // If we have a routes left, use 'em.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 12K bytes
    - Viewed (0)
  3. guava/src/com/google/common/hash/BloomFilterStrategies.java

          return Longs.fromBytes(
              bytes[15], bytes[14], bytes[13], bytes[12], bytes[11], bytes[10], bytes[9], bytes[8]);
        }
      };
    
      /**
       * Models a lock-free array of bits.
       *
       * <p>We use this instead of java.util.BitSet because we need access to the array of longs and we
       * need compare-and-swap.
       */
      static final class LockFreeBitArray {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 10 19:45:10 UTC 2022
    - 10.7K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

              synchronized(this@DiskLruCache) {
                detach()
              }
            }
          }
        }
    
        /**
         * Commits this edit so it is visible to readers. This releases the edit lock so another edit
         * may be started on the same key.
         */
        @Throws(IOException::class)
        fun commit() {
          synchronized(this@DiskLruCache) {
            check(!done)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  5. cmd/object-api-errors.go

    	return "No bucket tags found for bucket: " + e.Bucket
    }
    
    // BucketObjectLockConfigNotFound - no bucket object lock config found
    type BucketObjectLockConfigNotFound GenericError
    
    func (e BucketObjectLockConfigNotFound) Error() string {
    	return "No bucket object lock configuration found for bucket: " + e.Bucket
    }
    
    // BucketQuotaConfigNotFound - no bucket quota config found.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 09 02:05:14 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  6. docs/en/docs/tutorial/security/simple-oauth2.md

      "email": "******@****.***",
      "full_name": "John Doe",
      "disabled": false,
      "hashed_password": "fakehashedsecret"
    }
    ```
    
    <img src="/img/tutorial/security/image06.png">
    
    If you click the lock icon and logout, and then try the same operation again, you will get an HTTP 401 error of:
    
    ```JSON
    {
      "detail": "Not authenticated"
    }
    ```
    
    ### Inactive user
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/util/MD4.java

    // This file is currently unlocked (change this line if you lock the file)
    //
    // $Log: MD4.java,v $
    // Revision 1.2  1998/01/05 03:41:19  iang
    // Added references only.
    //
    // Revision 1.1.1.1  1997/11/03 22:36:56  hopwood
    // + Imported to CVS (tagged as 'start').
    //
    // Revision 0.1.0.0  1997/07/14  R. Naffah
    // + original version
    //
    // $Endlog$
    /*
     * Copyright (c) 1997 Systemics Ltd
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 9.3K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt

    import okio.BufferedSink
    
    /** Writes HTTP/2 transport frames. */
    @Suppress("NAME_SHADOWING")
    class Http2Writer(
      private val sink: BufferedSink,
      private val client: Boolean,
    ) : Closeable {
      internal val lock: ReentrantLock = ReentrantLock()
    
      private val hpackBuffer: Buffer = Buffer()
      private var maxFrameSize: Int = INITIAL_MAX_FRAME_SIZE
      private var closed: Boolean = false
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  9. internal/event/target/amqp.go

    			return true
    		}
    
    		if nerr, ok := err.(*net.OpError); ok {
    			return (nerr.Err.Error() == "use of closed network connection")
    		}
    
    		return false
    	}
    
    	target.connMutex.Lock()
    	defer target.connMutex.Unlock()
    
    	if target.conn != nil {
    		ch, err = target.conn.Channel()
    		if err == nil {
    			if target.args.PublisherConfirms {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  10. cmd/handler-api.go

    		return
    	}
    
    	// A valid value is available return its 90%
    	available = (memStats.Available * 9) / 10
    	return
    }
    
    func (t *apiConfig) init(cfg api.Config, setDriveCounts []int, legacy bool) {
    	t.mu.Lock()
    	defer t.mu.Unlock()
    
    	clusterDeadline := cfg.ClusterDeadline
    	if clusterDeadline == 0 {
    		clusterDeadline = 10 * time.Second
    	}
    	t.clusterDeadline = clusterDeadline
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
Back to top