Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 2,166 for contexto (0.15 sec)

  1. internal/logger/logonce.go

    // on how it is used.
    func LogOnceIf(ctx context.Context, subsystem string, err error, id string, errKind ...interface{}) {
    	if logIgnoreError(err) {
    		return
    	}
    	logOnce.logOnceIf(ctx, subsystem, err, id, errKind...)
    }
    
    // LogOnceConsoleIf - similar to LogOnceIf but exclusively only logs to console target.
    func LogOnceConsoleIf(ctx context.Context, subsystem string, err error, id string, errKind ...interface{}) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  2. internal/logger/reqinfo.go

    	}
    	return
    }
    
    // SetReqInfo sets ReqInfo in the context.
    func SetReqInfo(ctx context.Context, req *ReqInfo) context.Context {
    	if ctx == nil {
    		LogIf(context.Background(), "", fmt.Errorf("context is nil"))
    		return nil
    	}
    	return context.WithValue(ctx, contextLogKey, req)
    }
    
    // GetReqInfo returns ReqInfo if set.
    func GetReqInfo(ctx context.Context) *ReqInfo {
    	if ctx != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/ConfiguredGoalSupport.java

                return ERROR;
            }
            return doExecute(context);
        }
    
        protected boolean validateConfiguration(DefaultEncryptInvoker.LocalContext context) {
            SecDispatcher.ValidationResponse response = secDispatcher.validateConfiguration();
            if (!response.isValid() || context.invokerRequest.options().verbose().orElse(false)) {
                dumpResponse(context, "", response);
            }
            return response.isValid();
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. callbacks/associations.go

    							fv, _ := ref.PrimaryKey.ValueOf(db.Statement.Context, obj)
    							db.AddError(ref.ForeignKey.Set(db.Statement.Context, joinValue, fv))
    						} else if ref.PrimaryValue != "" {
    							db.AddError(ref.ForeignKey.Set(db.Statement.Context, joinValue, ref.PrimaryValue))
    						} else {
    							fv, _ := ref.PrimaryKey.ValueOf(db.Statement.Context, elem)
    							db.AddError(ref.ForeignKey.Set(db.Statement.Context, joinValue, fv))
    						}
    					}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Apr 11 03:06:13 UTC 2023
    - 14.3K bytes
    - Viewed (0)
  5. internal/logger/logger.go

    // the execution of the server.
    func LogAlwaysIf(ctx context.Context, subsystem string, err error, errKind ...interface{}) {
    	if err == nil {
    		return
    	}
    	logIf(ctx, subsystem, err, errKind...)
    }
    
    // LogIf prints a detailed error message during
    // the execution of the server, if it is not an
    // ignored error.
    func LogIf(ctx context.Context, subsystem string, err error, errKind ...interface{}) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 09:43:48 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  6. cmd/admin-handlers-users_test.go

    	}
    }
    
    func (c *check) mustGetIAMUserInfo(ctx context.Context, admClnt *madmin.AdminClient, accessKey string) madmin.UserInfo {
    	c.Helper()
    	ui, err := admClnt.GetUserInfo(ctx, accessKey)
    	if err != nil {
    		c.Fatalf("should be able to get user info: %v", err)
    	}
    	return ui
    }
    
    func (c *check) mustNotCreateIAMUser(ctx context.Context, admClnt *madmin.AdminClient) {
    	c.Helper()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 47.3K bytes
    - Viewed (0)
  7. cmd/ftp-server-driver.go

    }
    
    // ListDir implements ftpDriver
    func (driver *ftpDriver) ListDir(ctx *ftp.Context, objPath string, callback func(os.FileInfo) error) (err error) {
    	stopFn := globalFtpMetrics.log(ctx, objPath)
    	defer stopFn(0, err)
    
    	clnt, err := driver.getMinIOClient(ctx)
    	if err != nil {
    		return err
    	}
    
    	cctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	bucket, prefix := path2BucketObject(objPath)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14K bytes
    - Viewed (0)
  8. internal/logger/targets.go

    //
    //	e.g. Send the log to a http server
    type Target interface {
    	String() string
    	Endpoint() string
    	Stats() types.TargetStats
    	Init(ctx context.Context) error
    	IsOnline(ctx context.Context) bool
    	Cancel()
    	Send(ctx context.Context, entry interface{}) error
    	Type() types.TargetType
    }
    
    type targetsList struct {
    	list []Target
    	mu   sync.RWMutex
    }
    
    func newTargetsList() *targetsList {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 03 15:44:50 UTC 2024
    - 6K bytes
    - Viewed (0)
  9. tensorflow/c/eager/parallel_device/parallel_device_lib_test.cc

      }
      std::unique_ptr<TFE_Op, decltype(&TFE_DeleteOp)> read_op(
          TFE_NewOp(context.get(), "ReadVariableOp", status.get()), TFE_DeleteOp);
      ASSERT_TRUE(TF_GetCode(status.get()) == TF_OK) << TF_Message(status.get());
      TFE_OpSetAttrType(read_op.get(), "dtype", TF_FLOAT);
      parallel_device.Execute(context.get(), handle_inputs, "ReadVariableOp",
                              TFE_OpGetAttrs(read_op.get()),
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 21 04:14:14 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  10. cmd/object_api_suite_test.go

    }
    
    // Tests validate PutObject without prefix.
    func testPutObject(obj ObjectLayer, instanceType string, t TestErrHandler) {
    	content := []byte("testcontent")
    	length := int64(len(content))
    	readerEOF := newTestReaderEOF(content)
    	readerNoEOF := newTestReaderNoEOF(content)
    	err := obj.MakeBucket(context.Background(), "bucket", MakeBucketOptions{})
    	if err != nil {
    		t.Fatalf("%s: <ERROR> %s", instanceType, err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
Back to top