Search Options

Results per page
Sort
Preferred Languages
Advance

Results 811 - 820 of 1,020 for err (0.01 sec)

  1. cmd/bucket-replication-stats.go

    		}
    	case replication.Completed:
    		if ri.OpType.IsDataReplication() {
    			rs.set(ri.Arn, ri.Size, ri.Duration, status, ri.OpType, ri.endpoint, ri.secure, ri.Err)
    		}
    	case replication.Failed:
    		if ri.OpType.IsDataReplication() && prevStatus == replication.Pending {
    			rs.set(ri.Arn, ri.Size, ri.Duration, status, ri.OpType, ri.endpoint, ri.secure, ri.Err)
    		}
    	case replication.Replica:
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  2. istioctl/pkg/util/formatting/formatter.go

    	}
    	return strings.Join(logOutput, "\n")
    }
    
    func printJSON(ms diag.Messages) (string, error) {
    	jsonOutput, err := json.MarshalIndent(ms, "", "\t")
    	return string(jsonOutput), err
    }
    
    func printYAML(ms diag.Messages) (string, error) {
    	yamlOutput, err := yaml.Marshal(ms)
    	return string(yamlOutput), err
    }
    
    // Formatting options for Message
    var (
    	colorPrefixes = map[diag.Level]string{
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Tue Jul 11 02:41:45 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  3. internal/http/listener.go

    func (listener *httpListener) Accept() (conn net.Conn, err error) {
    	select {
    	case result, ok := <-listener.acceptCh:
    		if ok {
    			return result.conn, result.err
    		}
    	case <-listener.ctx.Done():
    	}
    	return nil, syscall.EINVAL
    }
    
    // Close - closes underneath all TCP listeners.
    func (listener *httpListener) Close() (err error) {
    	listener.ctxCanceler()
    
    	for i := range listener.listeners {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  4. src/cmd/asm/internal/lex/lex_test.go

    		err := firstError(input)
    		if err == nil {
    			t.Errorf("%s: got no error", test.error)
    			continue
    		}
    		if !strings.Contains(err.Error(), test.error) {
    			t.Errorf("got error %q expected %q", err.Error(), test.error)
    		}
    	}
    }
    
    // firstError returns the first error value triggered by the input.
    func firstError(input *Input) (err error) {
    	panicOnError = true
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Aug 29 07:48:38 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  5. src/cmd/asm/internal/asm/expr_test.go

    func TestBadExpr(t *testing.T) {
    	for i, test := range badExprTests {
    		err := runBadTest(i, test, t)
    		if err == nil {
    			if test.error != "" {
    				t.Errorf("#%d: %q: expected error %q; got none", i, test.input, test.error)
    			}
    			continue
    		}
    		if !strings.Contains(err.Error(), test.error) {
    			t.Errorf("#%d: expected error %q; got %q", i, test.error, err)
    			continue
    		}
    	}
    }
    
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Aug 29 07:48:38 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  6. internal/amztime/iso8601_time.go

    }
    
    // ISO8601Parse parses ISO8601 date string
    func ISO8601Parse(iso8601 string) (t time.Time, err error) {
    	for _, layout := range []string{
    		iso8601TimeFormat,
    		iso8601TimeFormatLong,
    		time.RFC3339,
    	} {
    		t, err = time.Parse(layout, iso8601)
    		if err == nil {
    			return t, nil
    		}
    	}
    
    	return t, err
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jan 16 23:38:33 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/netns_linux_test.go

    // limitations under the License.
    
    package nodeagent
    
    import "testing"
    
    func TestOpenNetns(t *testing.T) {
    	ns, err := OpenNetns("/proc/self/ns/net")
    	if err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	// the inode for netns is proc dynamic, so it needs to be higher than
    	// #define PROC_DYNAMIC_FIRST 0xF0000000U
    
    	if ns.Inode() < 0xF0000000 {
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 976 bytes
    - Viewed (0)
  8. internal/http/dial_linux.go

    	return func(ctx context.Context, network, addr string) (net.Conn, error) {
    		dialer := &net.Dialer{
    			Timeout: dialTimeout,
    			Control: setTCPParametersFn(opts),
    		}
    		conn, err := dialer.DialContext(ctx, network, addr)
    		if err != nil {
    			return nil, err
    		}
    		if opts.DriveOPTimeout != nil {
    			// Read deadlines are sufficient for now as per various
    			// scenarios of hung node detection, we may add Write deadlines
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5K bytes
    - Viewed (3)
  9. cmd/version_test.go

    package cmd
    
    import (
    	"testing"
    	"time"
    )
    
    func TestVersion(t *testing.T) {
    	Version = "2017-05-07T06:37:49Z"
    	_, err := time.Parse(time.RFC3339, Version)
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 956 bytes
    - Viewed (0)
  10. internal/s3select/parquet/args.go

    	// Make subtype to avoid recursive UnmarshalXML().
    	type subReaderArgs ReaderArgs
    	parsedArgs := subReaderArgs{}
    	if err := d.DecodeElement(&parsedArgs, &start); err != nil {
    		return err
    	}
    
    	args.unmarshaled = true
    	return nil
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.4K bytes
    - Viewed (0)
Back to top