Search Options

Results per page
Sort
Preferred Languages
Advance

Results 741 - 750 of 1,105 for errC (0.02 sec)

  1. callbacks/update.go

    				if rows, err := db.Statement.ConnPool.QueryContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...); db.AddError(err) == nil {
    					dest := db.Statement.Dest
    					db.Statement.Dest = db.Statement.ReflectValue.Addr().Interface()
    					gorm.Scan(rows, db, mode)
    					db.Statement.Dest = dest
    					db.AddError(rows.Close())
    				}
    			} else {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Mar 18 05:44:55 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  2. cmd/veeam-sos-api.go

    	gr, err := veeamSOSAPIGetObject(ctx, bucket, object, nil, opts)
    	if gr != nil {
    		gr.Close()
    		return gr.ObjInfo, nil
    	}
    	return ObjectInfo{}, err
    }
    
    func veeamSOSAPIGetObject(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, opts ObjectOptions) (gr *GetObjectReader, err error) {
    	var buf []byte
    	switch object {
    	case systemXMLObject:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  3. internal/bucket/replication/replication.go

    // ParseConfig parses ReplicationConfiguration from xml
    func ParseConfig(reader io.Reader) (*Config, error) {
    	config := Config{}
    	if err := xml.NewDecoder(io.LimitReader(reader, maxReplicationConfigSize)).Decode(&config); err != nil {
    		return nil, err
    	}
    	// By default, set replica modification to enabled if unset.
    	for i := range config.Rules {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 28 17:44:56 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  4. cmd/metrics-v2.go

    	if err := registry.Register(prometheus.NewProcessCollector(prometheus.ProcessCollectorOpts{
    		Namespace:    minioNamespace,
    		ReportErrors: true,
    	})); err != nil {
    		logger.CriticalIf(GlobalContext, err)
    	}
    	if err := registry.Register(prometheus.NewGoCollector()); err != nil {
    		logger.CriticalIf(GlobalContext, err)
    	}
    	gatherers := prometheus.Gatherers{
    		registry,
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  5. internal/http/server.go

    		// shutdown in progress
    		return http.ErrServerClosed
    	}
    
    	// Close underneath HTTP listener.
    	srv.listenerMutex.Lock()
    	err := srv.listener.Close()
    	srv.listenerMutex.Unlock()
    	if err != nil {
    		return err
    	}
    
    	// Wait for opened connection to be closed up to Shutdown timeout.
    	return nil
    }
    
    // UseIdleTimeout configure idle connection timeout
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  6. internal/once/init.go

    		return l.do(f)
    	}
    	return nil
    }
    
    func (l *Init) do(f func() error) error {
    	l.m.Lock()
    	defer l.m.Unlock()
    	if atomic.LoadUint32(&l.done) == 0 {
    		if err := f(); err != nil {
    			return err
    		}
    		// Mark as done only when f() is successful
    		atomic.StoreUint32(&l.done, 1)
    	}
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 09 04:20:31 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  7. istioctl/cmd/root_test.go

    	parent.AddCommand(child)
    
    	// verify both parent flags and the child flag are visible by default
    	parent.SetArgs([]string{"child", "--help"})
    	if err := parent.Execute(); err != nil {
    		t.Fatal(err)
    	}
    	got := out.String()
    	out.Reset()
    	checkHelpForFlag(t, got, parentFlag0, true)
    	checkHelpForFlag(t, got, parentFlag1, true)
    	checkHelpForFlag(t, got, parentFlag2, true)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 15 17:59:55 UTC 2021
    - 2.4K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/fakes_test.go

    func (f *fakeNs) Close() error {
    	f.closed.Store(true)
    	return nil
    }
    
    func fakeFs() fs.FS {
    	subFs, err := fs.Sub(fakeProc, "testdata")
    	if err != nil {
    		panic(err)
    	}
    	subFs, err = fs.Sub(subFs, "cgroupns")
    	if err != nil {
    		panic(err)
    	}
    	return &fakeFsWithFakeFds{ReadDirFS: subFs.(fs.ReadDirFS)}
    }
    
    type fakeFsWithFakeFds struct {
    	fs.ReadDirFS
    }
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 23:33:46 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  9. internal/config/subnet/subnet.go

    	client := &http.Client{
    		Timeout:   10 * time.Second,
    		Transport: c.transport,
    	}
    
    	resp, err := client.Do(r)
    	if err != nil {
    		return "", err
    	}
    	defer xhttp.DrainBody(resp.Body)
    
    	respBytes, err := io.ReadAll(io.LimitReader(resp.Body, respBodyLimit))
    	if err != nil {
    		return "", err
    	}
    	respStr := string(respBytes)
    
    	if resp.StatusCode == http.StatusOK {
    		return respStr, nil
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 27 16:35:36 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  10. internal/bucket/object/lock/lock_test.go

    		},
    	}
    	for _, tt := range tests {
    		d, err := xml.MarshalIndent(&tt.value, "", "\t")
    		if err != nil {
    			t.Fatal(err)
    		}
    		var dr DefaultRetention
    		err = xml.Unmarshal(d, &dr)
    		//nolint:gocritic
    		if tt.expectedErr == nil {
    			if err != nil {
    				t.Fatalf("error: expected = <nil>, got = %v", err)
    			}
    		} else if err == nil {
    			t.Fatalf("error: expected = %v, got = <nil>", tt.expectedErr)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 29 01:20:27 UTC 2024
    - 17.1K bytes
    - Viewed (0)
Back to top