Search Options

Results per page
Sort
Preferred Languages
Advance

Results 341 - 350 of 1,179 for funcs (0.11 sec)

  1. cmd/mrf.go

    // the current heal status in one available disk
    func (m *mrfState) shutdown() {
    	atomic.StoreInt32(&m.closing, 1)
    	m.wg.Wait()
    	close(m.opCh)
    	atomic.StoreInt32(&m.closed, 1)
    
    	if len(m.opCh) > 0 {
    		healingLogEvent(context.Background(), "Saving MRF healing data (%d entries)", len(m.opCh))
    	}
    
    	newReader := func() io.ReadCloser {
    		r, w := io.Pipe()
    		go func() {
    			// Initialize MRF meta header.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. cmd/dynamic-timeouts_test.go

    		t.Errorf("Failure to decrease timeout appropriately")
    	}
    }
    
    func TestDynamicTimeoutConcurrent(t *testing.T) {
    	// Race test.
    	timeout := newDynamicTimeout(time.Second, time.Millisecond)
    	var wg sync.WaitGroup
    	for i := 0; i < runtime.GOMAXPROCS(0); i++ {
    		wg.Add(1)
    		rng := rand.New(rand.NewSource(int64(i)))
    		go func() {
    			defer wg.Done()
    			for i := 0; i < 100; i++ {
    				for j := 0; j < 100; j++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 14 10:08:40 UTC 2022
    - 5.4K bytes
    - Viewed (0)
  3. cmd/xl-storage-format-v2_string.go

    var _VersionType_index = [...]uint8{0, 18, 28, 38, 48, 63}
    
    func (i VersionType) String() string {
    	if i >= VersionType(len(_VersionType_index)-1) {
    		return "VersionType(" + strconv.FormatInt(int64(i), 10) + ")"
    	}
    	return _VersionType_name[_VersionType_index[i]:_VersionType_index[i+1]]
    }
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Dec 02 19:29:16 UTC 2021
    - 1.4K bytes
    - Viewed (0)
  4. internal/config/batch/batch.go

    // would wait before working on next object.
    func (opts Config) ExpirationWait() time.Duration {
    	configMu.RLock()
    	defer configMu.RUnlock()
    
    	return opts.ExpirationWorkersWait
    }
    
    // ReplicationWait returns the duration for which a batch replication worker
    // would wait before working on next object.
    func (opts Config) ReplicationWait() time.Duration {
    	configMu.RLock()
    	defer configMu.RUnlock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  5. internal/bucket/lifecycle/error.go

    // the string as a value that satisfies error of type tagging.Error
    func Errorf(format string, a ...interface{}) error {
    	return Error{err: fmt.Errorf(format, a...)}
    }
    
    // Unwrap the internal error.
    func (e Error) Unwrap() error { return e.err }
    
    // Error 'error' compatible method.
    func (e Error) Error() string {
    	if e.err == nil {
    		return "lifecycle: cause <nil>"
    	}
    	return e.err.Error()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.3K bytes
    - Viewed (0)
  6. internal/bucket/versioning/error.go

    // the string as a value that satisfies error of type tagging.Error
    func Errorf(format string, a ...interface{}) error {
    	return Error{err: fmt.Errorf(format, a...)}
    }
    
    // Unwrap the internal error.
    func (e Error) Unwrap() error { return e.err }
    
    // Error 'error' compatible method.
    func (e Error) Error() string {
    	if e.err == nil {
    		return "versioning: cause <nil>"
    	}
    	return e.err.Error()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.3K bytes
    - Viewed (0)
  7. tests/tests_test.go

    		db.Logger = db.Logger.LogMode(logger.Silent)
    	}
    
    	return
    }
    
    func RunMigrations() {
    	var err error
    	allModels := []interface{}{&User{}, &Account{}, &Pet{}, &Company{}, &Toy{}, &Language{}, &Coupon{}, &CouponProduct{}, &Order{}, &Parent{}, &Child{}, &Tools{}}
    	rand.Seed(time.Now().UnixNano())
    	rand.Shuffle(len(allModels), func(i, j int) { allModels[i], allModels[j] = allModels[j], allModels[i] })
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Sep 30 03:21:19 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  8. internal/event/config.go

    type FilterRule struct {
    	Name  string `xml:"Name"`
    	Value string `xml:"Value"`
    }
    
    func (filter FilterRule) isEmpty() bool {
    	return filter.Name == "" && filter.Value == ""
    }
    
    // MarshalXML implements a custom marshaller to support `omitempty` feature.
    func (filter FilterRule) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    	if filter.isEmpty() {
    		return nil
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 16 17:28:29 UTC 2021
    - 8.4K bytes
    - Viewed (0)
  9. cmd/signature-v2_test.go

    package cmd
    
    import (
    	"context"
    	"fmt"
    	"net/http"
    	"net/url"
    	"os"
    	"sort"
    	"testing"
    )
    
    // Tests for 'func TestResourceListSorting(t *testing.T)'.
    func TestResourceListSorting(t *testing.T) {
    	sortedResourceList := make([]string, len(resourceList))
    	copy(sortedResourceList, resourceList)
    	sort.Strings(sortedResourceList)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 14 10:08:40 UTC 2022
    - 8K bytes
    - Viewed (0)
  10. internal/event/rules_test.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package event
    
    import (
    	"reflect"
    	"testing"
    )
    
    func TestNewPattern(t *testing.T) {
    	testCases := []struct {
    		prefix         string
    		suffix         string
    		expectedResult string
    	}{
    		{"", "", ""},
    		{"*", "", "*"},
    		{"", "*", "*"},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 8.8K bytes
    - Viewed (0)
Back to top