Search Options

Results per page
Sort
Preferred Languages
Advance

Results 211 - 220 of 391 for ctx_ (0.02 sec)

  1. cmd/bucket-lifecycle.go

    				if err == nil {
    					auditLogLifecycle(es.ctx, oi, ILMFreeVersionDelete, nil, traceFn)
    				}
    				if ignoreNotFoundErr(err) != nil {
    					transitionLogIf(es.ctx, err)
    				}
    			default:
    				bugLogIf(es.ctx, fmt.Errorf("Invalid work type - %v", v))
    			}
    		}
    	}
    }
    
    func initBackgroundExpiry(ctx context.Context, objectAPI ObjectLayer) {
    	globalExpiryState = newExpiryState(ctx, objectAPI, globalILMConfig.getExpirationWorkers())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  2. tensorflow/c/eager/c_api_unified_experimental.cc

      return wrap(CreateTracingExecutionContext(fn_name, s));
    }
    
    TF_AbstractFunction* TF_FinalizeFunction(TF_ExecutionContext* ctx,
                                             TF_OutputList* outputs, TF_Status* s) {
      AbstractFunction* func;
      TracingContext* tracing_ctx = dyn_cast<TracingContext>(unwrap(ctx));
      if (!tracing_ctx) {
        tsl::Set_TF_Status_from_Status(
            s, tensorflow::errors::InvalidArgument(
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 9K bytes
    - Viewed (0)
  3. cmd/batch-expire.go

    func (r BatchJobExpire) Notify(ctx context.Context, body io.Reader) error {
    	if r.NotificationCfg.Endpoint == "" {
    		return nil
    	}
    
    	ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
    	defer cancel()
    
    	req, err := http.NewRequestWithContext(ctx, http.MethodPost, r.NotificationCfg.Endpoint, body)
    	if err != nil {
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  4. cmd/object-api-options_test.go

    // it is intended to be expanded when the function is worked on in the future.
    func TestGetAndValidateAttributesOpts(t *testing.T) {
    	globalBucketVersioningSys = &BucketVersioningSys{}
    	bucket := minioMetaBucket
    	ctx := context.Background()
    	testCases := []struct {
    		name            string
    		headers         http.Header
    		wantObjectAttrs map[string]struct{}
    	}{
    		{
    			name:            "empty header",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 21:13:59 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  5. cmd/metrics-v3-scanner.go

    		"Time elapsed (in seconds) since last scan activity.")
    )
    
    // loadClusterScannerMetrics - `MetricsLoaderFn` for cluster webhook
    // such as failed objects and directories scanned.
    func loadClusterScannerMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	m.Set(scannerBucketScansFinished, float64(globalScannerMetrics.lifetime(scannerMetricScanBucketDrive)))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 19:29:25 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  6. docs/site-replication/gen-oidc-sts-cred.go

    import (
    	"context"
    	"fmt"
    	"log"
    	"net/http"
    	"os"
    
    	cr "github.com/minio/minio-go/v7/pkg/credentials"
    	cmd "github.com/minio/minio/cmd"
    )
    
    func main() {
    	ctx := context.Background()
    
    	endpoint := os.Getenv("MINIO_ENDPOINT")
    	if endpoint == "" {
    		log.Fatalf("Please specify a MinIO server endpoint environment variable like:\n\n\texport MINIO_ENDPOINT=http://localhost:9000")
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 29 01:27:09 UTC 2022
    - 2.3K bytes
    - Viewed (0)
  7. tensorflow/c/eager/c_api_remote_test.cc

      TFE_Context* ctx = TFE_NewContext(opts, status);
      EXPECT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TFE_DeleteContextOptions(opts);
    
      TFE_ContextSetServerDef(ctx, 0, serialized.data(), serialized.size(), status);
      EXPECT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
    
      TFE_TensorHandle* h0_task0 = TestMatrixTensorHandle(ctx);
      TFE_TensorHandle* h1_task0 = TestMatrixTensorHandle(ctx);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Aug 12 00:14:22 UTC 2020
    - 5.4K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/SmbEnumerationUtil.java

    
        private static DcerpcHandle getHandle ( CIFSContext ctx, SmbResourceLocator loc, Address address, String ep )
                throws MalformedURLException, DcerpcException {
            return DcerpcHandle.getHandle(String.format("ncacn_np:%s[endpoint=%s,address=%s]", loc.getServer(), ep, address.getHostAddress()), ctx);
        }
    
    
        static FileEntry[] doDfsRootEnum ( CIFSContext ctx, SmbResourceLocator loc, Address address ) throws IOException {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sat Jul 20 08:41:19 UTC 2019
    - 12.5K bytes
    - Viewed (0)
  9. cmd/metacache-set.go

    }
    
    func (o *listPathOptions) setBucketMeta(ctx context.Context) {
    	lc, _ := globalLifecycleSys.Get(o.Bucket)
    	vc, _ := globalBucketVersioningSys.Get(o.Bucket)
    
    	// Check if bucket is object locked.
    	rcfg, _ := globalBucketObjectLockSys.Get(o.Bucket)
    	replCfg, _, _ := globalBucketMetadataSys.GetReplicationConfig(ctx, o.Bucket)
    	tgts, _ := globalBucketTargetSys.ListBucketTargets(ctx, o.Bucket)
    	o.Lifecycle = lc
    	o.Versioning = vc
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  10. cmd/server-main_test.go

    func TestNewObjectLayer(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    	// Tests for ErasureSD object layer.
    	nDisks := 1
    	disks, err := getRandomDisks(nDisks)
    	if err != nil {
    		t.Fatal("Failed to create drives for the backend")
    	}
    	defer removeRoots(disks)
    
    	obj, err := newObjectLayer(ctx, mustGetPoolEndpoints(0, disks...))
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Dec 07 09:33:56 UTC 2023
    - 3.1K bytes
    - Viewed (0)
Back to top