- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 95 for panic (0.2 sec)
-
cni/pkg/nodeagent/ztunnelserver_test.go
ztun, err := newZtunnelServer(addr, pods) if err != nil { panic(err) } go ztun.Run(ctx) // now as a client connect confirm we and get snapshot resolvedAddr, err := net.ResolveUnixAddr("unixpacket", addr) if err != nil { panic(err) } ztunClient, err := net.DialUnix("unixpacket", nil, resolvedAddr) if err != nil { panic(err) } // send hello sendHello(ztunClient)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
internal/event/targetlist_test.go
panic(err) } targetListCase3 := NewTargetList(context.Background()) if err := targetListCase3.Add(&ExampleTarget{TargetID{"3", "testcase"}, false, false}); err != nil { panic(err) } if err := targetListCase3.Add(&ExampleTarget{TargetID{"1", "webhook"}, false, false}); err != nil { panic(err) } testCases := []struct {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Dec 05 10:16:33 GMT 2023 - 6.1K bytes - Viewed (0) -
src/bytes/buffer.go
// another n bytes. After Grow(n), at least n bytes can be written to the // buffer without another allocation. // If n is negative, Grow will panic. // If the buffer can't grow it will panic with [ErrTooLarge]. func (b *Buffer) Grow(n int) { if n < 0 { panic("bytes.Buffer.Grow: negative count") } m := b.grow(n) b.buf = b.buf[:m] } // Write appends the contents of p to the buffer, growing the buffer as
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 17:10:31 GMT 2023 - 15.7K bytes - Viewed (0) -
cmd/metrics-v3-types.go
panic("labels must be a list of ordered key-value pairs") } validLabels := desc.getLabelSet() labelMap := make(map[string]string, len(labels)/2) for i := 0; i < len(labels); i += 2 { if _, ok := validLabels[labels[i]]; !ok { panic(fmt.Sprintf("invalid label: %s (metric: %s)", labels[i], name)) } labelMap[labels[i]] = labels[i+1] } if len(labels)/2 != len(validLabels) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 14.6K bytes - Viewed (0) -
src/bufio/bufio.go
if b.r > 0 { copy(b.buf, b.buf[b.r:b.w]) b.w -= b.r b.r = 0 } if b.w >= len(b.buf) { panic("bufio: tried to fill full buffer") } // Read new data: try a limited number of times. for i := maxConsecutiveEmptyReads; i > 0; i-- { n, err := b.rd.Read(b.buf[b.w:]) if n < 0 { panic(errNegativeRead) } b.w += n if err != nil { b.err = err return } if n > 0 {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Oct 12 14:39:08 GMT 2023 - 21.8K bytes - Viewed (0) -
src/cmd/api/main_test.go
} func (w *Walker) emitf(format string, args ...any) { f := strings.Join(w.scope, ", ") + ", " + fmt.Sprintf(format, args...) if strings.Contains(f, "\n") { panic("feature contains newlines: " + f) } if _, dup := w.features[f]; dup { panic("duplicate feature inserted: " + f) } w.features[f] = true if verbose { log.Printf("feature: %s", f) } }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Apr 09 20:48:51 GMT 2024 - 31.4K bytes - Viewed (0) -
src/bufio/scan_test.go
func TestDontLoopForever(t *testing.T) { s := NewScanner(strings.NewReader("abc")) s.Split(loopAtEOFSplit) // Expect a panic defer func() { err := recover() if err == nil { t.Fatal("should have panicked") } if msg, ok := err.(string); !ok || !strings.Contains(msg, "empty tokens") { panic(err) } }() for count := 0; s.Scan(); count++ { if count > 1000 { t.Fatal("looping") } }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Sep 22 16:22:42 GMT 2023 - 14.3K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
t.Fatalf("unlock of unlocked RWMutex did not panic") } }() mu := NewDRWMutex(ds, "test") mu.Unlock(context.Background()) } // Borrowed from rwmutex_test.go func TestUnlockPanic2(t *testing.T) { mu := NewDRWMutex(ds, "test-unlock-panic-2") defer func() { if recover() == nil { t.Fatalf("unlock of unlocked RWMutex did not panic") }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 9.7K bytes - Viewed (0) -
internal/lsync/lrwmutex_test.go
ctx := context.Background() lrwm := NewLRWMutex() if !lrwm.GetRLock(ctx, "", "object1", time.Second) { panic("Failed to acquire read lock") } // fmt.Println("1st read lock acquired, waiting...") if !lrwm.GetRLock(ctx, "", "object1", time.Second) { panic("Failed to acquire read lock") } // fmt.Println("2nd read lock acquired, waiting...") go func() { time.Sleep(2 * time.Second)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 7.9K bytes - Viewed (0) -
internal/event/config_test.go
</QueueConfiguration>`) queue3 := &Queue{} if err := xml.Unmarshal(data, queue3); err != nil { panic(err) } targetList1 := NewTargetList(context.Background()) targetList2 := NewTargetList(context.Background()) if err := targetList2.Add(&ExampleTarget{TargetID{"1", "webhook"}, false, false}); err != nil { panic(err) } testCases := []struct { queue *Queue region string
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Dec 05 10:16:33 GMT 2023 - 29K bytes - Viewed (0)