Search Options

Results per page
Sort
Preferred Languages
Advance

Results 301 - 310 of 1,425 for Func (0.03 sec)

  1. cni/pkg/nodeagent/net_test.go

    	netServer.netnsRunner = func(fdable NetnsFd, toRun func() error) error {
    		return toRun()
    	}
    	netServer.Start(ctx)
    	return netTestFixture{
    		netServer:            netServer,
    		podNsMap:             podNsMap,
    		ztunnelServer:        ztunnelServer,
    		iptablesConfigurator: iptablesConfigurator,
    		nlDeps:               nlDeps,
    	}
    }
    
    func buildConvincingPod(v6IP bool) *corev1.Pod {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 25 16:13:38 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  2. cmd/callhome.go

    )
    
    var callhomeLeaderLockTimeout = newDynamicTimeout(30*time.Second, 10*time.Second)
    
    // initCallhome will start the callhome task in the background.
    func initCallhome(ctx context.Context, objAPI ObjectLayer) {
    	if !globalCallhomeConfig.Enabled() {
    		return
    	}
    
    	go func() {
    		r := rand.New(rand.NewSource(time.Now().UnixNano()))
    		// Leader node (that successfully acquires the lock inside runCallhome)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 17 16:53:34 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  3. internal/s3select/simdj/reader.go

    	decoded chan simdjson.Object
    
    	// err will only be returned after decoded has been closed.
    	err          *error
    	readCloser   io.ReadCloser
    	onReaderExit func()
    
    	exitReader chan struct{}
    	readerWg   sync.WaitGroup
    }
    
    // Read - reads single record.
    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    	v, ok := <-r.decoded
    	if !ok {
    		if r.err != nil && *r.err != nil {
    			return nil, errJSONParsingError(*r.err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  4. istioctl/pkg/tag/util.go

    		nsNames[i] = ns.Name
    	}
    	return nsNames, nil
    }
    
    // GetWebhookTagName extracts tag name from webhook object.
    func GetWebhookTagName(wh admitv1.MutatingWebhookConfiguration) string {
    	return wh.ObjectMeta.Labels[label.IoIstioTag.Name]
    }
    
    // GetWebhookRevision extracts tag target revision from webhook object.
    func GetWebhookRevision(wh admitv1.MutatingWebhookConfiguration) (string, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  5. internal/config/identity/plugin/config.go

    	currentMinute    serviceRTTMinuteStats
    }
    
    func (h *metrics) setConnSuccess(reqStartTime time.Time) {
    	h.Lock()
    	defer h.Unlock()
    	h.LastCheckSuccess = reqStartTime
    }
    
    func (h *metrics) setConnFailure(reqStartTime time.Time) {
    	h.Lock()
    	defer h.Unlock()
    	h.LastCheckFailure = reqStartTime
    }
    
    func (h *metrics) updateLastFullMinute(currReqMinute time.Time) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  6. tests/tracer_test.go

    )
    
    type Tracer struct {
    	Logger logger.Interface
    	Test   func(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error)
    }
    
    func (S Tracer) LogMode(level logger.LogLevel) logger.Interface {
    	return S.Logger.LogMode(level)
    }
    
    func (S Tracer) Info(ctx context.Context, s string, i ...interface{}) {
    	S.Logger.Info(ctx, s, i...)
    }
    
    func (S Tracer) Warn(ctx context.Context, s string, i ...interface{}) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Oct 18 09:28:06 UTC 2022
    - 830 bytes
    - Viewed (0)
  7. cmd/bucket-replication-metrics_gen.go

    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z ActiveWorkerStat) Msgsize() (s int) {
    	s = 1 + 5 + msgp.IntSize + 4 + msgp.Float32Size + 4 + msgp.IntSize
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *InQueueMetric) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  8. cmd/metrics-v2_gen.go

    func (z MetricName) Msgsize() (s int) {
    	s = msgp.StringPrefixSize + len(string(z))
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z MetricNamespace) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendString(o, string(z))
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  9. src/bytes/boundary_test.go

    		t.Fatalf("mprotect high failed %s\n", err)
    	}
    	return b[pagesize : 2*pagesize]
    }
    
    func TestEqualNearPageBoundary(t *testing.T) {
    	t.Parallel()
    	b := dangerousSlice(t)
    	for i := range b {
    		b[i] = 'A'
    	}
    	for i := 0; i <= len(b); i++ {
    		Equal(b[:i], b[len(b)-i:])
    		Equal(b[len(b)-i:], b[:i])
    	}
    }
    
    func TestIndexByteNearPageBoundary(t *testing.T) {
    	t.Parallel()
    	b := dangerousSlice(t)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Nov 30 20:05:58 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  10. src/cmd/addr2line/addr2line_test.go

    // GO_ADDR2LINETEST_IS_ADDR2LINE is set, and runs the tests otherwise.
    func TestMain(m *testing.M) {
    	if os.Getenv("GO_ADDR2LINETEST_IS_ADDR2LINE") != "" {
    		main()
    		os.Exit(0)
    	}
    
    	os.Setenv("GO_ADDR2LINETEST_IS_ADDR2LINE", "1") // Set for subprocesses to inherit.
    	os.Exit(m.Run())
    }
    
    func loadSyms(t *testing.T, dbgExePath string) map[string]string {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 06 13:23:48 UTC 2024
    - 3.2K bytes
    - Viewed (0)
Back to top