Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 391 for ctx_ (0.02 sec)

  1. src/cmd/asm/internal/asm/asm.go

    	}
    
    	prog := &obj.Prog{
    		Ctxt: p.ctxt,
    		As:   obj.AFUNCDATA,
    		Pos:  p.pos(),
    		From: valueAddr,
    		To:   nameAddr,
    	}
    	p.append(prog, "", true)
    }
    
    // asmJump assembles a jump instruction.
    // JMP	R1
    // JMP	exit
    // JMP	3(PC)
    func (p *Parser) asmJump(op obj.As, cond string, a []obj.Addr) {
    	var target *obj.Addr
    	prog := &obj.Prog{
    		Ctxt: p.ctxt,
    		Pos:  p.pos(),
    		As:   op,
    	}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 21 14:11:44 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  2. cmd/erasure-healing_test.go

    		_, err = objLayer.HealObject(ctx, bucket, object, "", hopts)
    		if err != nil {
    			t.Fatal(err)
    		}
    
    		fileInfos, errs = readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true)
    		if countErrs(errs, nil) != len(fileInfos) {
    			t.Fatal("Expected all xl.meta healed, but partial heal detected")
    		}
    
    		fileInfos, errs = readAllFileInfo(ctx, erasureDisks, "", minioMetaBucket, cfgFile, "", false, true)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  3. cmd/bucket-object-lock.go

    		return mode, retainDate, legalHold, ErrNone
    	}
    
    	opts, err := getOpts(ctx, rq, bucket, object)
    	if err != nil {
    		return mode, retainDate, legalHold, toAPIErrorCode(ctx, err)
    	}
    
    	replica := rq.Header.Get(xhttp.AmzBucketReplicationStatus) == replication.Replica.String()
    
    	if opts.VersionID != "" && !replica {
    		if objInfo, err := getObjectInfoFn(ctx, bucket, object, opts); err == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  4. tests/tracer_test.go

    }
    
    func (S Tracer) Error(ctx context.Context, s string, i ...interface{}) {
    	S.Logger.Error(ctx, s, i...)
    }
    
    func (S Tracer) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error) {
    	S.Logger.Trace(ctx, begin, fc, err)
    	S.Test(ctx, begin, fc, err)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Oct 18 09:28:06 UTC 2022
    - 830 bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-decom.go

    	})
    	return err
    }
    
    func (z *erasureServerPools) decommissionPool(ctx context.Context, idx int, pool *erasureSets, bi decomBucketInfo) error {
    	ctx = logger.SetReqInfo(ctx, &logger.ReqInfo{})
    
    	const envDecomWorkers = "_MINIO_DECOMMISSION_WORKERS"
    	workerSize, err := env.GetInt(envDecomWorkers, len(pool.sets))
    	if err != nil {
    		decomLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets)))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  6. tests/connpool_test.go

    func (c *wrapperConnPool) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error) {
    	c.got = append(c.got, query)
    	return c.db.PrepareContext(ctx, query)
    }
    
    func (c *wrapperConnPool) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error) {
    	c.got = append(c.got, query)
    	return c.db.ExecContext(ctx, query, args...)
    }
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Feb 06 02:54:40 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  7. tensorflow/c/eager/c_api_debug_test.cc

      TFE_DeleteContext(ctx);
      TF_DeleteStatus(status);
    }
    
    TEST(CApiDebug, 2DCPU) {
      TF_Status* status = TF_NewStatus();
      TFE_ContextOptions* opts = TFE_NewContextOptions();
      TFE_Context* ctx = TFE_NewContext(opts, status);
      CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TFE_DeleteContextOptions(opts);
    
      TFE_TensorHandle* h = TestMatrixTensorHandle3X2(ctx);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Apr 06 22:10:09 UTC 2020
    - 2.3K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/helper/LanguageHelperTest.java

            assertEquals("aaa;ctx._source.title_ja=ctx._source.title;ctx._source.content_ja=ctx._source.content",
                    languageHelper.createScript(doc, "aaa").getIdOrCode());
        }
    
        public void test_getReindexScriptSource() {
            assertEquals(
                    "if(ctx._source.lang!=null){ctx._source['title_'+ctx._source.lang]=ctx._source.title;ctx._source['content_'+ctx._source.lang]=ctx._source.content}",
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  9. cmd/erasure-sets.go

    	return s.getHashedSet(object).TransitionObject(ctx, bucket, object, opts)
    }
    
    // RestoreTransitionedObject - restore transitioned object content locally on this cluster.
    func (s *erasureSets) RestoreTransitionedObject(ctx context.Context, bucket, object string, opts ObjectOptions) error {
    	return s.getHashedSet(object).RestoreTransitionedObject(ctx, bucket, object, opts)
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (0)
  10. cmd/site-replication.go

    		if err != nil {
    			return err
    		}
    
    		c.healBucket(ctx, objAPI, bucket, info)
    
    		if bi.Deleted.IsZero() || (!bi.Created.IsZero() && bi.Deleted.Before(bi.Created)) {
    			c.healVersioningMetadata(ctx, objAPI, bucket, info)
    			c.healOLockConfigMetadata(ctx, objAPI, bucket, info)
    			c.healSSEMetadata(ctx, objAPI, bucket, info)
    			c.healBucketReplicationConfig(ctx, objAPI, bucket, info, &opts)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
Back to top