- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 74 for Hancic (0.15 sec)
-
istioctl/pkg/writer/envoy/configdump/listener.go
cidr := r.AddressPrefix pl := r.PrefixLen.GetValue() if pl != 32 && pl != 128 { cidr += fmt.Sprintf("/%d", pl) } m[cidr] = rm.OnMatch } } default: panic("unhandled") } } outputs := []string{} for k, v := range m { switch v := v.GetOnMatch().(type) { case *matcher.Matcher_OnMatch_Action: if v.Action.GetName() == name {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0) -
cmd/erasure-decode_test.go
} if _, err = erasure.Decode(context.Background(), bytes.NewBuffer(content[:0]), bitrotReaders, 0, size, size, nil); err != nil { panic(err) } closeBitrotReaders(bitrotReaders) } } func BenchmarkErasureDecodeQuick(b *testing.B) { const size = 12 * 1024 * 1024
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 21.1K bytes - Viewed (1) -
cmd/test-utils_test.go
if method == "" { method = http.MethodPost } req, err := http.NewRequest(method, urlStr, nil) if err != nil { return nil, err } if body == nil { // this is added to avoid panic during io.ReadAll(req.Body). // th stack trace can be found here https://github.com/minio/minio/pull/2074 . // This is very similar to https://github.com/golang/go/issues/7527.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/object-api-utils.go
// NewGetObjectReader creates a new GetObjectReader. The cleanUpFns // are called on Close() in FIFO order as passed in ObjReadFn(). NOTE: It is // assumed that clean up functions do not panic (otherwise, they may // not all run!). func NewGetObjectReader(rs *HTTPRangeSpec, oi ObjectInfo, opts ObjectOptions) ( fn ObjReaderFn, off, length int64, err error, ) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
internal/logger/target/testlogger/testlogger.go
// Call the returned function to disable logging. func (t *testLogger) SetErrorTB(tb testing.TB) func() { return t.setTB(tb, errorMessage) } // SetFatalTB will set the logger to output to tb.Panic. // Call the returned function to disable logging. func (t *testLogger) SetFatalTB(tb testing.TB) func() { return t.setTB(tb, fatalMessage) } func (t *testLogger) setTB(tb testing.TB, action int32) func() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 4K bytes - Viewed (0) -
src/cmd/asm/internal/lex/lex_test.go
func firstError(input *Input) (err error) { panicOnError = true defer func() { panicOnError = false switch e := recover(); e := e.(type) { case nil: case error: err = e default: panic(e) } }() for { tok := input.Next() if tok == scanner.EOF { return } }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Aug 29 07:48:38 GMT 2023 - 5.8K bytes - Viewed (0) -
internal/event/targetlist.go
return t } func (list *TargetList) startSendWorkers(workerCount int) { if workerCount == 0 { workerCount = runtime.GOMAXPROCS(0) } wk, err := workers.New(workerCount) if err != nil { panic(err) } for i := 0; i < workerCount; i++ { wk.Take() go func() { defer wk.Give() for { select { case av := <-list.queue: list.sendSync(av.ev, av.targetSet)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
cmd/format-erasure.go
drives += len(set) } return drives } func (f *formatErasureV3) Clone() *formatErasureV3 { b, err := json.Marshal(f) if err != nil { panic(err) } var dst formatErasureV3 if err = json.Unmarshal(b, &dst); err != nil { panic(err) } return &dst } // Returns formatErasure.Erasure.Version func newFormatErasureV3(numSets int, setLen int) *formatErasureV3 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0) -
internal/grid/manager.go
defer func() { if debugPrint { fmt.Printf("grid: Handler returning from: %v %v\n", req.Method, req.URL) } if r := recover(); r != nil { debug.PrintStack() err := fmt.Errorf("grid: panic: %v\n", r) gridLogIf(context.Background(), err, err.Error()) w.WriteHeader(http.StatusInternalServerError) } }() if debugPrint { fmt.Printf("grid: Got a %s request for: %v\n", req.Method, req.URL)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
internal/grid/grid_test.go
errFatal(handler.Register(manager, func(ctx context.Context, pp *testRequest, in <-chan *testRequest, out chan<- *testResponse) *RemoteErr { n := 0 for i := range in { if n > payloads { panic("too many requests") } // t.Log("Got request:", *i) out <- &testResponse{ OrgNum: i.Num + pp.Num, OrgString: pp.String + i.String, Embedded: *i, } n++ }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0)