Search Options

Results per page
Sort
Preferred Languages
Advance

Results 841 - 850 of 920 for End (0.03 sec)

  1. cmd/bucket-lifecycle.go

    	defer t.lastDayMu.RUnlock()
    
    	res := make(DailyAllTierStats, len(t.lastDayStats))
    	for tier, st := range t.lastDayStats {
    		res[tier] = st.clone()
    	}
    	return res
    }
    
    // UpdateWorkers at the end of this function leaves n goroutines waiting for
    // transition tasks
    func (t *transitionState) UpdateWorkers(n int) {
    	t.mu.Lock()
    	defer t.mu.Unlock()
    	if t.objAPI == nil { // Init hasn't been called yet.
    		return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  2. api/go1.txt

    pkg go/ast, method (*BadStmt) Pos() token.Pos
    pkg go/ast, method (*BasicLit) End() token.Pos
    pkg go/ast, method (*BasicLit) Pos() token.Pos
    pkg go/ast, method (*BinaryExpr) End() token.Pos
    pkg go/ast, method (*BinaryExpr) Pos() token.Pos
    pkg go/ast, method (*BlockStmt) End() token.Pos
    pkg go/ast, method (*BlockStmt) Pos() token.Pos
    pkg go/ast, method (*BranchStmt) End() token.Pos
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
  3. cmd/sts-handlers.go

    	if r.TLS == nil {
    		writeSTSErrorResponse(ctx, w, ErrSTSInsecureConnection, errors.New("No TLS connection attempt"))
    		return
    	}
    
    	// A client may send a certificate chain such that we end up
    	// with multiple peer certificates. However, we can only accept
    	// a single client certificate. Otherwise, the certificate to
    	// policy mapping would be ambiguous.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 33.9K bytes
    - Viewed (0)
  4. cmd/api-response.go

    	for _, item := range s.Items {
    		if err := e.Encode(xmlKeyEntry{
    			XMLName: xxml.Name{Local: item.Key},
    			Value:   item.Value,
    		}); err != nil {
    			return err
    		}
    	}
    
    	return e.EncodeToken(start.End())
    }
    
    // ObjectInternalInfo contains some internal information about a given
    // object, it will printed in listing calls with enabled metadata.
    type ObjectInternalInfo struct {
    	K int // Data blocks
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 19:27:06 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  5. guava/src/com/google/common/collect/MapMakerInternalMap.java

       * the segment.
       */
      final transient int segmentMask;
    
      /**
       * Shift value for indexing within segments. Helps prevent entries that end up in the same segment
       * from also ending up in the same bucket.
       */
      final transient int segmentShift;
    
      /** The segments, each of which is a specialized hash table. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  6. cmd/erasure-object.go

    	for index := range metaArr {
    		if metaArr[index].IsValid() {
    			metaArr[index].ModTime = modTime
    			metaArr[index].VersionID = versionID
    			if !metaArr[index].InlineData() {
    				// If the data is not inlined, we may end up incorrectly
    				// inlining the data here, that leads to an inconsistent
    				// situation where some objects are were not inlined
    				// were now inlined, make sure to `nil` the Data such
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  7. internal/ringbuffer/ring_buffer_test.go

    		select {
    		case <-cc:
    			return
    		case <-c:
    			buf := make([]byte, 1<<20)
    			stacklen := runtime.Stack(buf, true)
    			fmt.Printf("=== Timeout, assuming deadlock ===\n*** goroutine dump...\n%s\n*** end\n", string(buf[:stacklen]))
    			os.Exit(2)
    		}
    	}()
    	return func() {
    		close(cc)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  8. internal/grid/grid_test.go

    		select {
    		case <-cc:
    			return
    		case <-c:
    			buf := make([]byte, 1<<20)
    			stacklen := runtime.Stack(buf, true)
    			fmt.Printf("=== Timeout, assuming deadlock ===\n*** goroutine dump...\n%s\n*** end\n", string(buf[:stacklen]))
    			os.Exit(2)
    		}
    	}()
    	return func() {
    		close(cc)
    	}
    }
    
    func assertNoActive(t *testing.T, c *Connection) {
    	t.Helper()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  9. src/cmd/api/main_test.go

    	// Diagnose common mistakes people make,
    	// since there is no apifmt to format these files.
    	// The missing final newline is important for the
    	// final release step of cat next/*.txt >go1.X.txt.
    	// If the files don't end in full lines, the concatenation goes awry.
    	if strings.Contains(s, "\r") {
    		log.Printf("%s: contains CRLFs", filename)
    		exitCode = 1
    	}
    	if filepath.Base(filename) == "go1.4.txt" {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 04 18:16:59 UTC 2024
    - 31.4K bytes
    - Viewed (0)
  10. cmd/erasure-healing.go

    		// but we noticed that ETag is the same for all objects, let's give it a shot
    		cannotHeal = false
    	}
    
    	if cannotHeal {
    		// Allow for dangling deletes, on versions that have DataDir missing etc.
    		// this would end up restoring the correct readable versions.
    		m, err := er.deleteIfDangling(ctx, bucket, object, partsMetadata, errs, dataErrsByPart, ObjectOptions{
    			VersionID: versionID,
    		})
    		errs = make([]error, len(errs))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
Back to top