Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 612 for Clock (0.03 sec)

  1. cmd/iam-etcd-store.go

    		iamCache:     newIamCache(),
    		client:       client,
    		usersSysType: usersSysType,
    	}
    }
    
    func (ies *IAMEtcdStore) rlock() *iamCache {
    	ies.RLock()
    	return ies.iamCache
    }
    
    func (ies *IAMEtcdStore) runlock() {
    	ies.RUnlock()
    }
    
    func (ies *IAMEtcdStore) lock() *iamCache {
    	ies.Lock()
    	return ies.iamCache
    }
    
    func (ies *IAMEtcdStore) unlock() {
    	ies.Unlock()
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (0)
  2. 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
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  3. 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
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  4. 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
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 24K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

        address: Address,
        connectionUser: ConnectionUser,
        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
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  6. src/test/java/jcifs/smb1/smb1/AndXServerMessageBlockTest.java

            DummyAndXBlock block = new DummyAndXBlock(next);
    
            assertNotNull(block);
            assertSame(next, block.andx, "andx should reference provided SMB");
        }
    
        @Test
        @DisplayName("getBatchLimit defaults to 0")
        void testGetBatchLimitDefault() {
            DummyAndXBlock block = new DummyAndXBlock();
            assertEquals(0, block.getBatchLimit((byte) 0x25));
        }
    
        @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  7. cmd/erasure-utils.go

    	var totalWritten int64
    
    	// Write all data blocks to dst.
    	for _, block := range enBlocks[:dataBlocks] {
    		// Skip blocks until we have reached our offset.
    		if offset >= int64(len(block)) {
    			// Decrement offset.
    			offset -= int64(len(block))
    			continue
    		}
    
    		// Skip until offset.
    		block = block[offset:]
    
    		// Reset the offset for next iteration to read everything
    		// from subsequent blocks.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool.go

    	defer func() {
    		if unlockOnDefer {
    			nsUnlocker()
    		}
    	}()
    
    	// Acquire lock
    	if !opts.NoLock {
    		lock := z.NewNSLock(bucket, object)
    		lkctx, err := lock.GetRLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return nil, err
    		}
    		ctx = lkctx.Context()
    		nsUnlocker = func() { lock.RUnlock(lkctx) }
    		unlockOnDefer = true
    	}
    
    	checkPrecondFn := opts.CheckPrecondFn
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  9. 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));
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

          while (true) {
            var tryAgain = false
            var readBytesDelivered = -1L
            var errorExceptionToDeliver: IOException? = null
    
            // 1. Decide what to do in a synchronized block.
    
            withLock {
              val doReadTimeout = doReadTimeout()
              if (doReadTimeout) {
                readTimeout.enter()
              }
              try {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 18:57:05 UTC 2025
    - 22.4K bytes
    - Viewed (0)
Back to top