Search Options

Results per page
Sort
Preferred Languages
Advance

Results 341 - 350 of 453 for ctx_ (0.03 sec)

  1. cni/test/install_cni.go

    // via context cancellation
    func startInstallServer(ctx context.Context, serverConfig *config.Config, t *testing.T) {
    	readyFlag := &atomic.Value{}
    	installer := install.NewInstaller(&serverConfig.InstallConfig, readyFlag)
    
    	t.Logf("CNI installer created, watching...")
    	// installer.Run() will block indefinitely, and attempt to permanently "keep"
    	// the CNI binary installed.
    	if err := installer.Run(ctx); err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  2. cmd/kms-handlers_test.go

    		if err != nil {
    			t.Fatal(err)
    		}
    		_, err = globalIAMSys.SetPolicy(ctx, testKMSPolicyName, *policyData)
    		if err != nil {
    			t.Fatal(err)
    		}
    		_, err = globalIAMSys.PolicyDBSet(ctx, accessKey, testKMSPolicyName, regUser, false)
    		if err != nil {
    			t.Fatal(err)
    		}
    	} else {
    		err = globalIAMSys.DeletePolicy(ctx, testKMSPolicyName, false)
    		if err != nil {
    			t.Fatal(err)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/fakes_test.go

    	deletedPods atomic.Int32
    	addedPods   atomic.Int32
    	addError    error
    	delError    error
    }
    
    func (f *fakeZtunnel) Run(ctx context.Context) {
    }
    
    func (f *fakeZtunnel) PodDeleted(ctx context.Context, uid string) error {
    	f.deletedPods.Add(1)
    	return f.delError
    }
    
    func (f *fakeZtunnel) PodAdded(ctx context.Context, pod *corev1.Pod, netns Netns) error {
    	f.addedPods.Add(1)
    	return f.addError
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 23:33:46 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  4. internal/config/notify/parse.go

    	xnet "github.com/minio/pkg/v3/net"
    )
    
    const (
    	formatNamespace = "namespace"
    )
    
    const (
    	logSubsys = "notify"
    )
    
    func logOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) {
    	logger.LogOnceIf(ctx, logSubsys, err, id, errKind...)
    }
    
    // ErrTargetsOffline - Indicates single/multiple target failures.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  5. cmd/metrics-v2.go

    		metricsGroupOpts: opts,
    	}
    	mg.RegisterRead(func(ctx context.Context) (metrics []MetricV2) {
    		objLayer := newObjectLayerFn()
    		if objLayer == nil {
    			return
    		}
    
    		metrics = make([]MetricV2, 0, 50)
    		dataUsageInfo, err := loadDataUsageFromBackend(ctx, objLayer)
    		if err != nil {
    			metricsLogIf(ctx, err)
    			return
    		}
    
    		// data usage has not captured any data yet.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  6. internal/http/check_port_linux.go

    					_ = syscall.SetsockoptString(int(fdPtr), syscall.SOL_SOCKET, syscall.SO_BINDTODEVICE, opts.Interface)
    				}
    			})
    			return nil
    		},
    	}
    
    	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    	defer cancel()
    
    	l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port))
    	if err != nil {
    		return err
    	}
    
    	// As we are able to listen on this network, the port is not in use.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 03 21:12:25 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  7. tensorflow/c/c_api_experimental.h

    TF_CAPI_EXPORT extern void TFE_AbortCollectiveOps(TFE_Context* ctx,
                                                      TF_Status* status);
    
    // Checks the health of collective ops peers. Explicit health check is needed in
    // multi worker collective ops to detect failures in the cluster.  If a peer is
    // down, collective ops may hang.
    TF_CAPI_EXPORT extern void TFE_CollectiveOpsCheckPeerHealth(
        TFE_Context* ctx, const char* task, int64_t timeout_in_ms,
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Apr 27 21:07:00 UTC 2023
    - 15.1K bytes
    - Viewed (0)
  8. cmd/sts-errors.go

    import (
    	"context"
    	"encoding/xml"
    	"net/http"
    
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    )
    
    // writeSTSErrorResponse writes error headers
    func writeSTSErrorResponse(ctx context.Context, w http.ResponseWriter, errCode STSErrorCode, err error) {
    	stsErr := stsErrCodes.ToSTSErr(errCode)
    
    	// Generate error response.
    	stsErrorResponse := STSErrorResponse{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  9. tests/test_security_oauth2_optional.py

                        "loc": ["body", "grant_type"],
                        "msg": "String should match pattern 'password'",
                        "input": "incorrect",
                        "ctx": {"pattern": "password"},
                    }
                ]
            }
        ) | IsDict(
            # TODO: remove when deprecating Pydantic v1
            {
                "detail": [
                    {
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  10. cmd/data-usage-cache.go

    // save the content of the cache to minioMetaBackgroundOpsBucket with the provided name.
    // Note that no locking is done when saving.
    func (d *dataUsageCache) save(ctx context.Context, store objectIO, name string) error {
    	select {
    	case <-ctx.Done():
    		return ctx.Err()
    	case maxConcurrentScannerSaves <- struct{}{}:
    	}
    
    	buf := bytebufferpool.Get()
    	defer func() {
    		<-maxConcurrentScannerSaves
    		buf.Reset()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
Back to top