Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 63 for Decoder (0.23 sec)

  1. pkg/kubelet/cm/devicemanager/manager_test.go

    				}
    				updated.Store(true)
    			}()
    			go func() {
    				defer wg.Done()
    				for !updated.Load() {
    					// When a data race occurs, golang will throw an error, and recover() cannot catch this error,
    					// Such as: `throw("Concurrent map iteration and map writing")`.
    					// When this test ends quietly, no data race error occurs.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 65K bytes
    - Viewed (0)
  2. src/net/netip/netip_test.go

    			ip:        Addr{},
    			wantPanic: true,
    		},
    		{
    			ip:        mustIP("::1"),
    			wantPanic: true,
    		},
    	}
    	as4 := func(ip Addr) (v [4]byte, gotPanic bool) {
    		defer func() {
    			if recover() != nil {
    				gotPanic = true
    				return
    			}
    		}()
    		v = ip.As4()
    		return
    	}
    	for i, tt := range tests {
    		got, gotPanic := as4(tt.ip)
    		if gotPanic != tt.wantPanic {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 17:10:01 UTC 2024
    - 54.3K bytes
    - Viewed (0)
  3. src/strings/strings_test.go

    			t.Errorf("Repeat(%v, %d) = %v; want %v", tt.in, tt.count, a, tt.out)
    			continue
    		}
    	}
    }
    
    func repeat(s string, count int) (err error) {
    	defer func() {
    		if r := recover(); r != nil {
    			switch v := r.(type) {
    			case error:
    				err = v
    			default:
    				err = fmt.Errorf("%s", v)
    			}
    		}
    	}()
    
    	Repeat(s, count)
    
    	return
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 03 12:58:37 UTC 2024
    - 53K bytes
    - Viewed (0)
  4. src/net/http/httputil/reverseproxy_test.go

    		t.Fatal(err)
    	}
    
    	rproxy := NewSingleHostReverseProxy(rpURL)
    
    	// Ensure that the handler panics when the body read encounters an
    	// io.ErrUnexpectedEOF
    	defer func() {
    		err := recover()
    		if err == nil {
    			t.Fatal("handler should have panicked")
    		}
    		if err != http.ErrAbortHandler {
    			t.Fatal("expected ErrAbortHandler, got", err)
    		}
    	}()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 54.6K bytes
    - Viewed (0)
  5. src/crypto/tls/common.go

    	//
    	// UnwrapSession will usually either decrypt a session state in the ticket
    	// (for example with [Config.EncryptTicket]), or use the ticket as a handle
    	// to recover a previously stored state. It must use [ParseSessionState] to
    	// deserialize the session state.
    	//
    	// If UnwrapSession returns an error, the connection is terminated. If it
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 59.1K bytes
    - Viewed (0)
  6. cluster/gce/windows/k8s-node-setup.psm1

      if (-not ${net_adapter}) {
        Throw ("Failed to find a suitable network adapter, check your network " +
               "settings.")
      }
    
      return $net_adapter
    }
    
    # Decodes the base64 $Data string and writes it as binary to $File. Does
    # nothing if $File already exists and $REDO_STEPS is not set.
    function Write_PkiData {
      param (
        [parameter(Mandatory=$true)] [string] $Data,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 21:13:22 UTC 2024
    - 88.3K bytes
    - Viewed (0)
  7. src/text/template/exec_test.go

    		"",
    		"2",
    		"a-b",
    	}
    	for _, name := range names {
    		testBadFuncName(name, t)
    	}
    }
    
    func testBadFuncName(name string, t *testing.T) {
    	t.Helper()
    	defer func() {
    		recover()
    	}()
    	New("X").Funcs(
    		FuncMap{
    			name: funcNameTestFunc,
    		},
    	)
    	// If we get here, the name did not cause a panic, which is how Funcs
    	// reports an error.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 22:23:55 UTC 2024
    - 60.1K bytes
    - Viewed (0)
  8. src/cmd/compile/internal/syntax/parser.go

    func (p *parser) trace(msg string) func() {
    	p.print(msg + " (")
    	const tab = ". "
    	p.indent = append(p.indent, tab...)
    	return func() {
    		p.indent = p.indent[:len(p.indent)-len(tab)]
    		if x := recover(); x != nil {
    			panic(x) // skip print_trace
    		}
    		p.print(")")
    	}
    }
    
    func (p *parser) print(msg string) {
    	fmt.Printf("%5d: %s%s\n", p.line, p.indent, msg)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 62.9K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.31.md

    - The kubelet is no longer able to recover from device manager state file older than 1.20. If the proper recommended upgrade flow is followed, there should be no issue. ([#123398](https://github.com/kubernetes/kubernetes/pull/123398), [@ffromani](https://github.com/ffromani)) [SIG Node and...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 20:34:14 UTC 2024
    - 60.3K bytes
    - Viewed (0)
  10. pkg/apis/core/v1/defaults_test.go

    	codec := legacyscheme.Codecs.LegacyCodec(corev1.SchemeGroupVersion)
    	data, err := runtime.Encode(codec, obj)
    	if err != nil {
    		t.Errorf("%v\n %#v", err, obj)
    		return nil
    	}
    	obj2, err := runtime.Decode(codec, data)
    	if err != nil {
    		t.Errorf("%v\nData: %s\nSource: %#v", err, string(data), obj)
    		return nil
    	}
    	obj3 := reflect.New(reflect.TypeOf(obj).Elem()).Interface().(runtime.Object)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 84.4K bytes
    - Viewed (0)
Back to top