Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for leaks (0.22 sec)

  1. cmd/leak-detect_test.go

    	"sort"
    	"strings"
    	"time"
    )
    
    const (
    	// deadline (in seconds) up to which the go routine leak detection has to be retried.
    	leakDetectDeadline = 5
    	// pause time (in milliseconds) between each snapshot at the end of the go routine leak detection.
    	leakDetectPauseTimeMs = 50
    )
    
    // LeakDetect - type with  methods for go routine leak detection.
    type LeakDetect struct {
    	relevantRoutines map[string]bool
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.2K bytes
    - Viewed (0)
  2. cmd/object-handlers.go

    			Bucket:    objInfo.Bucket,
    			Object:    objInfo.Name,
    			VersionID: objInfo.VersionID,
    			Status:    http.StatusText(http.StatusOK),
    		})
    	}
    
    	// Do not send checksums in events to avoid leaks.
    	hash.TransferChecksumHeader(w, r)
    	writeSuccessResponseHeadersOnly(w)
    
    	// Remove the transitioned object whose object version is being overwritten.
    	if !globalTierConfigMgr.Empty() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  3. cmd/tier-journal.go

    		return err
    	}
    
    	b, err := je.MarshalMsg(nil)
    	if err != nil {
    		return err
    	}
    
    	jd.Lock()
    	defer jd.Unlock()
    	_, err = jd.file.Write(b)
    	if err != nil {
    		// Do not leak fd here, close the file properly.
    		Fdatasync(jd.file)
    		_ = jd.file.Close()
    
    		jd.file = nil // reset to allow subsequent reopen when file/disk is available.
    	}
    	return err
    }
    
    Go
    - Registered: Sun Feb 25 19:28:16 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.4K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    			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
    				// that xl.meta is written as expected.
    				metaArr[index].Data = nil
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  5. internal/bpool/bpool.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package bpool
    
    import "github.com/klauspost/reedsolomon"
    
    // BytePoolCap implements a leaky pool of []byte in the form of a bounded channel.
    type BytePoolCap struct {
    	c    chan []byte
    	w    int
    	wcap int
    }
    
    // NewBytePoolCap creates a new BytePool bounded to the given maxSize, with new
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 2.6K bytes
    - Viewed (0)
  6. cmd/admin-heal-ops.go

    		h.currentStatus.Summary = healFinishedStatus
    		h.mutex.Unlock()
    
    		// drain traverse channel so the traversal
    		// go-routine does not leak.
    		go func() {
    			// Eventually the traversal go-routine closes
    			// the channel and returns, so this go-routine
    			// itself will not leak.
    			<-h.traverseAndHealDoneCh
    		}()
    	}
    }
    
    func (h *healSequence) queueHealTask(source healSource, healType madmin.HealItemType) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  7. cmd/admin-handlers.go

    		//nolint:gocritic
    		if err != nil {
    			ldap.Status = string(madmin.ItemOffline)
    		} else if ldapConn == nil {
    			ldap.Status = "Not Configured"
    		} else {
    			// Close ldap connection to avoid leaks.
    			ldapConn.Close()
    			ldap.Status = string(madmin.ItemOnline)
    		}
    	}
    
    	log, audit := fetchLoggerInfo(ctx)
    
    	// Get the notification target info
    	notifyTarget := fetchLambdaInfo()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  8. CREDITS

    network, you should also make sure that it provides a way for users to
    get its source.  For example, if your program is a web application, its
    interface could display a "Source" link that leads users to an archive
    of the code.  There are many ways you could offer source, and different
    solutions will be better for different programs; see section 13 for the
    specific requirements.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:31:35 GMT 2024
    - 1.6M bytes
    - Viewed (0)
Back to top