Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 371 - 380 of 827 for sock (0.05 seconds)

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

  1. cmd/perf-tests.go

    	activeConnections uint64
    	sync.RWMutex
    }
    
    func (n *netPerfRX) Connect() {
    	n.Lock()
    	defer n.Unlock()
    	n.activeConnections++
    	atomic.StoreUint64(&n.RX, 0)
    	n.lastToConnect = time.Now()
    }
    
    func (n *netPerfRX) Disconnect() {
    	n.Lock()
    	defer n.Unlock()
    	n.activeConnections--
    	if n.firstToDisconnect.IsZero() {
    		n.RXSample = atomic.LoadUint64(&n.RX)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  2. cmd/erasure-server-pool-decom.go

    		return err
    	}
    
    	// if no update is needed return right away.
    	if !update {
    		z.poolMetaMutex.Lock()
    		z.poolMeta = meta
    		z.poolMetaMutex.Unlock()
    	} else {
    		newMeta := newPoolMeta(z, meta)
    		if err = newMeta.save(ctx, z.serverPools); err != nil {
    			return err
    		}
    		z.poolMetaMutex.Lock()
    		z.poolMeta = newMeta
    		z.poolMetaMutex.Unlock()
    	}
    
    	pools := meta.returnResumablePools()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
  3. src/test/java/jcifs/internal/smb1/com/SmbComFindClose2Test.java

    import static org.junit.jupiter.api.Assertions.assertTrue;
    
    import org.junit.jupiter.api.BeforeEach;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.extension.ExtendWith;
    import org.mockito.Mock;
    import org.mockito.junit.jupiter.MockitoExtension;
    
    import jcifs.Configuration;
    
    /**
     * Unit tests for {@link SmbComFindClose2}.
     * The class is intentionally tiny – the tests mainly verify that the
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 3.1K bytes
    - Click Count (0)
  4. src/test/java/jcifs/internal/smb2/rdma/RdmaBufferManagerTest.java

    import org.junit.jupiter.api.BeforeEach;
    import org.junit.jupiter.api.Test;
    import org.mockito.Mock;
    import org.mockito.MockitoAnnotations;
    
    import jcifs.internal.smb2.rdma.tcp.TcpMemoryRegion;
    
    /**
     * Unit tests for RDMA buffer manager
     */
    public class RdmaBufferManagerTest {
    
        @Mock
        private RdmaProvider mockProvider;
    
        private RdmaBufferManager bufferManager;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  5. src/test/java/jcifs/internal/smb1/com/SmbComSeekResponseTest.java

    import org.mockito.Mock;
    import org.mockito.junit.jupiter.MockitoExtension;
    
    import jcifs.Configuration;
    import jcifs.internal.SMBProtocolDecodingException;
    
    /**
     * Unit tests for {@link SmbComSeekResponse}.
     */
    @ExtendWith(MockitoExtension.class)
    @DisplayName("SmbComSeekResponse tests")
    class SmbComSeekResponseTest {
    
        @Mock
        private Configuration mockConfig;
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  6. src/test/java/jcifs/BufferCacheTest.java

    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Test;
    import org.mockito.Mock;
    
    /**
     * Comprehensive test suite for BufferCache interface.
     * Tests the contract and behavior of BufferCache implementations.
     */
    @DisplayName("BufferCache Interface Tests")
    class BufferCacheTest extends BaseTest {
    
        @Mock
        private BufferCache mockBufferCache;
    
        private TestBufferCacheImpl testCache;
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  7. .github/workflows/translate.yml

            with:
              python-version-file: ".python-version"
          - name: Setup uv
            uses: astral-sh/setup-uv@v7
            with:
              cache-dependency-glob: |
                pyproject.toml
                uv.lock
          - name: Install Dependencies
            run: uv sync --locked --no-dev --group github-actions --group translations
          - name: Export Language Codes
            id: show-langs
            run: |
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Mar 18 15:36:56 GMT 2026
    - 4K bytes
    - Click Count (0)
  8. cmd/grid.go

    var globalGrid atomic.Pointer[grid.Manager]
    
    // globalLockGrid is the global lock grid manager.
    var globalLockGrid atomic.Pointer[grid.Manager]
    
    // globalGridStart is a channel that will block startup of grid connections until closed.
    var globalGridStart = make(chan struct{})
    
    // globalLockGridStart is a channel that will block startup of lock grid connections until closed.
    var globalLockGridStart = make(chan struct{})
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 3.7K bytes
    - Click Count (0)
  9. ci/official/requirements_updater/README.md

    together with their corresponding hashes are specified in
    `requirements_lock_<python version>.txt` files (e.g.
    `requirements_lock_3_12.txt` for `Python 3.12`).
    
    To update the lock files, make sure
    `ci/official/requirements_updater/requirements.in` contains the desired direct
    dependencies list and then execute the following command (which will call
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Sat Jun 29 00:19:18 GMT 2024
    - 3K bytes
    - Click Count (0)
  10. cmd/config-current.go

    // found, otherwise use default parameters
    func newSrvConfig(objAPI ObjectLayer) error {
    	// Initialize server config.
    	srvCfg := newServerConfig()
    
    	// hold the mutex lock before a new config is assigned.
    	globalServerConfigMu.Lock()
    	globalServerConfig = srvCfg
    	globalServerConfigMu.Unlock()
    
    	// Save config into file.
    	return saveServerConfig(GlobalContext, objAPI, srvCfg)
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 28.5K bytes
    - Click Count (0)
Back to Top