Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 321 - 330 of 459 for Closed (0.08 seconds)

  1. internal/s3select/select_benchmark_test.go

    			if err != nil {
    				b.Fatal(err)
    			}
    
    			if err = s3Select.Open(newBytesRSC(csvData)); err != nil {
    				b.Fatal(err)
    			}
    
    			s3Select.Evaluate(&nullResponseWriter{})
    			s3Select.Close()
    		}
    	})
    }
    
    func benchmarkSelectAll(b *testing.B, count int) {
    	benchmarkSelect(b, count, "select * from S3Object")
    }
    
    // BenchmarkSelectAll_100K - benchmark * function with 100k records.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5K bytes
    - Click Count (0)
  2. 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 Dec 28 09:35:17 GMT 2025
    - Last Modified: Mon Sep 08 09:19:22 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  3. docs/debugging/reorder-disks/main.go

    }
    
    func getMountMap() (map[string]string, error) {
    	result := make(map[string]string)
    
    	mountInfo, err := os.Open("/proc/self/mountinfo")
    	if err != nil {
    		return nil, err
    	}
    	defer mountInfo.Close()
    
    	scanner := bufio.NewScanner(mountInfo)
    	for scanner.Scan() {
    		s := strings.Split(scanner.Text(), " ")
    		if len(s) != 11 {
    			return nil, errors.New("unsupported /proc/self/mountinfo format")
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 5.4K bytes
    - Click Count (0)
  4. cmd/global-heal.go

    			bytes:   sz,
    			skipped: true,
    		}
    	}
    
    	// Collect updates to tracker from concurrent healEntry calls
    	results := make(chan healEntryResult, 1000)
    	quitting := make(chan struct{})
    	defer func() {
    		close(results)
    		<-quitting
    	}()
    
    	go func() {
    		for res := range results {
    			if res.entryDone {
    				tracker.setObject(res.name)
    				if time.Since(tracker.getLastUpdate()) > time.Minute {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  5. internal/grid/benchmark_test.go

    							fmt.Println(err.Error())
    						}
    						b.Fatal(err.Error())
    					}
    					got := 0
    					for range requests {
    						got++
    						st.Requests <- append(GetByteBuffer()[:0], payload...)
    					}
    					close(st.Requests)
    					err = st.Results(func(b []byte) error {
    						return nil
    					})
    					if err != nil {
    						if debugReqs {
    							fmt.Println(err.Error())
    						}
    						b.Fatal(err.Error())
    					}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.5K 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  7. .github/DISCUSSION_TEMPLATE/questions.yml

            And there's a high chance that you will find the solution along the way and you won't even have to submit it and wait for an answer. 😎
    
            As there are too many questions, I'll have to discard and close the incomplete ones. That will allow me (and others) to focus on helping people like you that follow the whole process and help us help you. 🤓
      - type: checkboxes
        id: checks
        attributes:
          label: First Check
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Thu Aug 03 15:59:41 GMT 2023
    - 5.8K bytes
    - Click Count (0)
  8. docs/de/docs/advanced/security/http-basic-auth.md

    `secrets.compare_digest()` benötigt `bytes` oder einen `str`, welcher nur ASCII-Zeichen (solche der englischen Sprache) enthalten darf, das bedeutet, dass es nicht mit Zeichen wie `á`, wie in `Sebastián`, funktionieren würde.
    
    Um dies zu lösen, konvertieren wir zunächst den `username` und das `password` in UTF-8-codierte `bytes`.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Sep 20 15:10:09 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  9. internal/config/identity/ldap/config.go

    	LDAP ldap.Config
    
    	stsExpiryDuration time.Duration // contains converted value
    }
    
    // Enabled returns if LDAP is enabled.
    func (l *Config) Enabled() bool {
    	return l.LDAP.Enabled
    }
    
    // Clone returns a cloned copy of LDAP config.
    func (l *Config) Clone() Config {
    	if l == nil {
    		return Config{}
    	}
    	cfg := Config{
    		LDAP:              l.LDAP.Clone(),
    		stsExpiryDuration: l.stsExpiryDuration,
    	}
    	return cfg
    }
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Sep 18 11:47:48 GMT 2025
    - 8.6K bytes
    - Click Count (0)
  10. impl/maven-core/src/test/remote-repo/org/codehaus/plexus/plexus-utils/1.1/plexus-utils-1.1.jar

    java.io.OutputStream, int) throws java.io.IOException; public static boolean contentEquals(java.io.InputStream, java.io.InputStream) throws java.io.IOException; public static void close(java.io.InputStream); public static void close(java.io.OutputStream); public static void close(java.io.Reader); public static void close(java.io.Writer); } org/codehaus/plexus/util/LineOrientedInterpol.class package org.codehaus.plexus.util; public synchronized class LineOrientedInterpol extends java.io.FilterReader...
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 164.6K bytes
    - Click Count (0)
Back to Top