Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 861 - 870 of 1,033 for Close (0.04 seconds)

  1. tests/lru_test.go

    		t.Fatalf("values differs from expected")
    	}
    }
    
    // func TestExpirableMultipleClose(_ *testing.T) {
    //	lc :=lru.NewLRU[string, string](10, nil, 0)
    //	lc.Close()
    //	// should not panic
    //	lc.Close()
    // }
    
    func TestLRUWithPurge(t *testing.T) {
    	var evicted []string
    	lc := lru.NewLRU(10, func(key string, value string) { evicted = append(evicted, key, value) }, 150*time.Millisecond)
    
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Mon Sep 08 09:19:22 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  2. CHANGELOG/CHANGELOG-1.35.md

    - Added remote runtime and image `Close()` method to be able to close the connection. ([#133211](https://github.com/kubernetes/kubernetes/pull/133211), [@saschagrunert](https://github.com/saschagrunert)) [SIG Node]
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Mar 19 03:20:49 GMT 2026
    - 265.9K bytes
    - Click Count (0)
  3. cmd/common-main.go

    			if err != nil {
    				logger.FatalIf(err, "Unable to get free port for Console UI on the host")
    			}
    			// hold the port
    			l, err := net.Listen("TCP", fmt.Sprintf(":%s", p.String()))
    			if err == nil {
    				defer l.Close()
    			}
    			consoleAddr = net.JoinHostPort("", p.String())
    		}
    
    		if _, _, err := net.SplitHostPort(consoleAddr); err != nil {
    			logger.FatalIf(err, "Unable to start listening on console port")
    		}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 32.5K bytes
    - Click Count (3)
  4. guava-tests/test/com/google/common/io/CharSequenceReaderTest.java

        assertThrows(IllegalArgumentException.class, () -> reader.mark(-1));
      }
    
      public void testMethodsThrowWhenClosed() throws IOException {
        CharSequenceReader reader = new CharSequenceReader("");
        reader.close();
    
        assertThrows(IOException.class, reader::read);
    
        assertThrows(IOException.class, () -> reader.read(new char[10]));
    
        assertThrows(IOException.class, () -> reader.read(new char[10], 0, 10));
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 6.7K bytes
    - Click Count (0)
  5. src/test/java/jcifs/smb1/smb1/SmbSessionTest.java

            smbtStatic.when(() -> SmbTransport.getSmbTransport(addr, 445)).thenReturn(transport);
        }
    
        @AfterEach
        void tearDown() {
            if (smbtStatic != null) {
                smbtStatic.close();
            }
        }
    
        @Test
        void transportLazyInitialisation() {
            SmbSession session = new SmbSession(addr, 445, inet, 0, auth);
            // transport should still be null until first use
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 5.6K bytes
    - Click Count (0)
  6. internal/disk/stat_linux.go

    	}
    	return iostats, err
    }
    
    func readStat(fileName string) (stats []uint64, err error) {
    	file, err := os.Open(fileName)
    	if err != nil {
    		return nil, err
    	}
    	defer file.Close()
    
    	s, err := bufio.NewReader(file).ReadString('\n')
    	if err != nil && !errors.Is(err, io.EOF) {
    		return nil, err
    	}
    	statLine := strings.TrimSpace(s)
    	for _, token := range strings.Fields(statLine) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/CallKotlinTest.kt

        val proxySelector = RecordingProxySelector()
        proxySelector.proxies.add(Proxy(Proxy.Type.HTTP, TestUtil.UNREACHABLE_ADDRESS_IPV4))
        proxySelector.proxies.add(Proxy.NO_PROXY)
        server.close()
    
        client =
          client
            .newBuilder()
            .proxySelector(proxySelector)
            .readTimeout(Duration.ofMillis(100))
            .connectTimeout(Duration.ofMillis(100))
            .build()
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Jun 20 11:46:46 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  8. api/go1.3.txt

    pkg debug/macho, const TypeDylib Type
    pkg debug/macho, func NewFatFile(io.ReaderAt) (*FatFile, error)
    pkg debug/macho, func OpenFat(string) (*FatFile, error)
    pkg debug/macho, method (*FatFile) Close() error
    pkg debug/macho, method (FatArch) Close() error
    pkg debug/macho, method (FatArch) DWARF() (*dwarf.Data, error)
    pkg debug/macho, method (FatArch) ImportedLibraries() ([]string, error)
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Jun 02 02:45:00 GMT 2014
    - 117K bytes
    - Click Count (0)
  9. callbacks/delete.go

    				gorm.Scan(rows, db, mode)
    
    				if db.Statement.Result != nil {
    					db.Statement.Result.RowsAffected = db.RowsAffected
    				}
    				db.AddError(rows.Close())
    			}
    		}
    	}
    }
    
    func AfterDelete(db *gorm.DB) {
    	if db.Error == nil && db.Statement.Schema != nil && !db.Statement.SkipHooks && db.Statement.Schema.AfterDelete {
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sun May 25 07:40:40 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  10. src/main/java/jcifs/internal/smb1/com/SmbComWriteAndX.java

            if (cmd == SMB_COM_READ_ANDX) {
                return cfg.getBatchLimit("WriteAndX.ReadAndX");
            }
            if (cmd == SMB_COM_CLOSE) {
                return cfg.getBatchLimit("WriteAndX.Close");
            }
            return 0;
        }
    
        @Override
        protected int writeParameterWordsWireFormat(final byte[] dst, int dstIndex) {
            final int start = dstIndex;
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 6.1K bytes
    - Click Count (0)
Back to Top