Search Options

Results per page
Sort
Preferred Languages
Advance

Results 371 - 380 of 938 for Nil (0.02 sec)

  1. internal/grid/muxclient.go

    		return nil, err
    	}
    	if debugReqs {
    		fmt.Println(m.MuxID, m.parent.String(), "SEND")
    	}
    	// Wait for response or context.
    	select {
    	case v, ok := <-ch:
    		if !ok {
    			return nil, ErrDisconnected
    		}
    		if debugReqs && v.Err != nil {
    			v.Err = fmt.Errorf("%d %s RESP ERR: %w", m.MuxID, m.parent.String(), v.Err)
    		}
    		return v.Msg, v.Err
    	case <-ctx.Done():
    		if debugReqs {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  2. cmd/server-rlimit.go

    	sysMaxThreads, err := sys.GetMaxThreads()
    	if err == nil {
    		minioMaxThreads := (sysMaxThreads * 90) / 100
    		// Only set max threads if it is greater than the default one
    		if minioMaxThreads > 10000 {
    			debug.SetMaxThreads(minioMaxThreads)
    		}
    	}
    
    	var maxLimit uint64
    
    	// Set open files limit to maximum.
    	if _, maxLimit, err = sys.GetMaxOpenFileLimit(); err != nil {
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:09:36 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  3. cmd/metrics-v3-system-process.go

    	stat, err := p.Stat()
    	if err != nil {
    		metricsLogIf(ctx, err)
    	} else {
    		loadProcStatMetrics(ctx, stat, m)
    	}
    
    	io, err := p.IO()
    	if err != nil {
    		metricsLogIf(ctx, err)
    	} else {
    		loadProcIOMetrics(ctx, io, m)
    	}
    
    	l, err := p.Limits()
    	if err != nil {
    		metricsLogIf(ctx, err)
    	} else {
    		if l.OpenFiles > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 20 17:55:03 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  4. internal/http/transports.go

    		c, err := certs.NewManager(ctx, clientCert, clientKey, tls.LoadX509KeyPair)
    		if err != nil {
    			return nil, err
    		}
    		if c != nil {
    			c.UpdateReloadDuration(10 * time.Second)
    			c.ReloadOnSignal(syscall.SIGHUP) // allow reloads upon SIGHUP
    			transport.TLSClientConfig.GetClientCertificate = c.GetClientCertificate
    		}
    	}
    	return transport, nil
    }
    
    // NewRemoteTargetHTTPTransport returns a new http configuration
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  5. logger/sql_test.go

    	"fmt"
    	"regexp"
    	"strings"
    	"testing"
    
    	"github.com/jinzhu/now"
    	"gorm.io/gorm/logger"
    )
    
    type JSON json.RawMessage
    
    func (j JSON) Value() (driver.Value, error) {
    	if len(j) == 0 {
    		return nil, nil
    	}
    	return json.RawMessage(j).MarshalJSON()
    }
    
    type ExampleStruct struct {
    	Name string
    	Val  string
    }
    
    func (s ExampleStruct) Value() (driver.Value, error) {
    	return json.Marshal(s)
    }
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Mar 21 08:00:02 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  6. tests/prepared_stmt_test.go

    			tx.Rollback()
    		}
    	}()
    	if err := tx.Error; err != nil {
    		t.Errorf("Failed to start transaction, got error %v\n", err)
    	}
    
    	if err := tx.Where("name=?", "zzjin").Delete(&User{}).Error; err != nil {
    		tx.Rollback()
    		t.Errorf("Failed to run one transaction, got error %v\n", err)
    	}
    
    	if err := tx.Create(&User{Name: "zzjin"}).Error; err != nil {
    		tx.Rollback()
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  7. internal/bucket/replication/sourceselectioncriteria.go

    	if err := dec.DecodeElement(&ssc, &start); err != nil {
    		return err
    	}
    	if len(ssc.ReplicaModifications.Status) == 0 {
    		ssc.ReplicaModifications.Status = Enabled
    	}
    	*s = SourceSelectionCriteria(ssc)
    	return nil
    }
    
    // MarshalXML - encodes to XML data.
    func (s SourceSelectionCriteria) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    	if err := e.EncodeToken(start); err != nil {
    		return err
    	}
    	if s.IsValid() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  8. internal/config/batch/batch.go

    	}
    
    	kduration, err := time.ParseDuration(env.Get(EnvKeyRotationWorkersWait, kvs.GetWithDefault(KeyRotationWorkersWait, DefaultKVS)))
    	if err != nil {
    		return cfg, err
    	}
    	if kduration < 0 {
    		return cfg, config.ErrInvalidBatchKeyRotationWorkersWait(nil)
    	}
    
    	eduration, err := time.ParseDuration(env.Get(EnvKeyExpirationWorkersWait, kvs.GetWithDefault(ExpirationWorkersWait, DefaultKVS)))
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  9. clause/select_test.go

    		Result  string
    		Vars    []interface{}
    	}{
    		{
    			[]clause.Interface{clause.Select{}, clause.From{}},
    			"SELECT * FROM `users`", nil,
    		},
    		{
    			[]clause.Interface{clause.Select{
    				Columns: []clause.Column{clause.PrimaryColumn},
    			}, clause.From{}},
    			"SELECT `users`.`id` FROM `users`", nil,
    		},
    		{
    			[]clause.Interface{clause.Select{
    				Columns: []clause.Column{clause.PrimaryColumn},
    			}, clause.Select{
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Feb 18 01:06:43 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  10. internal/bucket/versioning/versioning_test.go

    		v, err = ParseConfig(strings.NewReader(tc.input))
    		if tc.err != err {
    			t.Fatalf("Test %d: expected %v but got %v", i+1, tc.err, err)
    		}
    		if err != nil {
    			if tc.err == nil {
    				t.Fatalf("Test %d: failed due to %v", i+1, err)
    			}
    		} else {
    			if err := v.Validate(); tc.err != err {
    				t.Fatalf("Test %d: validation failed due to %v", i+1, err)
    			}
    			if len(tc.excludedPrefixes) > 0 {
    				var mismatch bool
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun May 08 05:06:44 UTC 2022
    - 8.8K bytes
    - Viewed (0)
Back to top