Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 470 for wlock (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/erasure-sets.go

    	sets []*erasureObjects
    
    	// Reference format.
    	format *formatErasureV3
    
    	// erasureDisks mutex to lock erasureDisks.
    	erasureDisksMu sync.RWMutex
    
    	// Re-ordered list of disks per set.
    	erasureDisks [][]StorageAPI
    
    	// Distributed locker clients.
    	erasureLockers setsDsyncLockers
    
    	// Distributed lock owner (constant per running instance).
    	erasureLockOwner string
    
    	// List of endpoints provided on the command line.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37K bytes
    - Click Count (1)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

        if (existingRouteSelection != null && existingRouteSelection.hasNext()) {
          return planConnectToRoute(existingRouteSelection.next())
        }
    
        // Decide which proxy to use, if any. This may block in ProxySelector.select().
        var newRouteSelector = routeSelector
        if (newRouteSelector == null) {
          newRouteSelector =
            RouteSelector(
              address = address,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 12K bytes
    - Click Count (0)
  3. internal/grid/grid_test.go

    	// Wait for the server to send the first response.
    	<-serverSent
    
    	// Read back from the stream and block.
    	nowBlocking := make(chan struct{})
    	stopBlocking := make(chan struct{})
    	defer close(stopBlocking)
    	go func() {
    		st.Results(func(b []byte) error {
    			close(nowBlocking)
    			// Block until test is done.
    			<-stopBlocking
    			return nil
    		})
    	}()
    
    	<-nowBlocking
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.1K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt

      } catch (_: IOException) {
        false // Couldn't read; socket is closed.
      }
    
    internal inline fun threadName(
      name: String,
      block: () -> Unit,
    ) {
      val currentThread = Thread.currentThread()
      val oldName = currentThread.name
      currentThread.name = name
      try {
        block()
      } finally {
        currentThread.name = oldName
      }
    }
    
    /** Returns the Content-Length as reported by the response headers. */
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 10.2K bytes
    - Click Count (1)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

        address: Address,
        call: RealCall,
        routes: List<Route>?,
        requireMultiplexed: Boolean,
      ): RealConnection? {
        for (connection in connections) {
          // In the first synchronized block, acquire the connection if it can satisfy this call.
          val acquired =
            connection.withLock {
              when {
                requireMultiplexed && !connection.isMultiplexed -> false
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  6. cmd/bucket-stats.go

    	qs.QStats = r.qCache.getBucketStats(bucket)
    	qs.TgtXferStats = make(map[string]map[RMetricName]XferStats)
    	qs.MRFStats = ReplicationMRFStats{
    		LastFailedCount: atomic.LoadUint64(&r.mrfStats.LastFailedCount),
    	}
    
    	r.RLock()
    	defer r.RUnlock()
    
    	brs, ok := r.Cache[bucket]
    	if !ok {
    		return qs
    	}
    	for arn := range brs.Stats {
    		qs.TgtXferStats[arn] = make(map[RMetricName]XferStats)
    	}
    	count := 0
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  7. cmd/storage-rest-server.go

    					write([]byte(err.Error()))
    				} else {
    					write([]byte{0})
    				}
    				xioutil.SafeClose(doneCh)
    				return
    			case block := <-blockCh:
    				var tmp [5]byte
    				tmp[0] = 2
    				binary.LittleEndian.PutUint32(tmp[1:], uint32(len(block)))
    				write(tmp[:])
    				write(block)
    				if canWrite {
    					xhttp.Flush(w)
    				}
    			}
    		}
    	}()
    	return &h
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 45.7K bytes
    - Click Count (0)
  8. src/main/java/jcifs/internal/smb2/ServerMessageBlock2.java

        private ServerMessageBlock2 next;
    
        /**
         * Constructor for SMB2 message block with configuration.
         *
         * @param config the configuration object
         */
        protected ServerMessageBlock2(final Configuration config) {
            this.config = config;
        }
    
        /**
         * Constructor for SMB2 message block with configuration and command.
         *
         * @param config the configuration object
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 24K bytes
    - Click Count (0)
  9. cmd/test-utils_test.go

    }
    
    // sets globalObjectAPI to `nil`.
    func resetGlobalObjectAPI() {
    	globalObjLayerMutex.Lock()
    	globalObjectAPI = nil
    	globalObjLayerMutex.Unlock()
    }
    
    // reset the value of the Global server config.
    // set it to `nil`.
    func resetGlobalConfig() {
    	// hold the mutex lock before a new config is assigned.
    	globalServerConfigMu.Lock()
    	// Save the loaded config globally.
    	globalServerConfig = nil
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 77K bytes
    - Click Count (0)
  10. src/main/java/jcifs/smb1/util/Base64.java

            length -= remainder;
            int block;
            int i = 0;
            while (i < length) {
                block = (bytes[i++] & 0xff) << 16 | (bytes[i++] & 0xff) << 8 | bytes[i++] & 0xff;
                buffer.append(ALPHABET.charAt(block >>> 18));
                buffer.append(ALPHABET.charAt(block >>> 12 & 0x3f));
                buffer.append(ALPHABET.charAt(block >>> 6 & 0x3f));
                buffer.append(ALPHABET.charAt(block & 0x3f));
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 4.1K bytes
    - Click Count (0)
Back to Top