Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 163 for panic (0.11 seconds)

  1. cmd/main.go

    			// Infinite blocking op
    			<-make(chan struct{})
    		}
    
    		// Override the logger os.Exit()
    		logger.ExitFunc = freeze
    
    		defer func() {
    			if err := recover(); err != nil {
    				fmt.Println("panic:", err)
    				fmt.Println("")
    				fmt.Println(string(debug.Stack()))
    			}
    			freeze(-1)
    		}()
    	}
    
    	// Run the app - exit on error.
    	if err := newApp(appName).Run(args); err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Jul 30 22:59:48 GMT 2024
    - 6.5K bytes
    - Click Count (0)
  2. cmd/generic-handlers.go

    		if globalLocalNodeName != "" {
    			w.Header().Set(xhttp.AmzRequestHostID, globalLocalNodeNameHex)
    		}
    		h.ServeHTTP(w, r)
    	})
    }
    
    // criticalErrorHandler handles panics and fatal errors by
    // `panic(logger.ErrCritical)` as done by `logger.CriticalIf`.
    //
    // It should be always the first / highest HTTP handler.
    func setCriticalErrorHandler(h http.Handler) http.Handler {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.7K bytes
    - Click Count (1)
  3. src/bytes/example_test.go

    	n, err := b.Read(rdbuf)
    	if err != nil {
    		panic(err)
    	}
    	fmt.Println(n)
    	fmt.Println(b.String())
    	fmt.Println(string(rdbuf))
    	// Output:
    	// 1
    	// bcde
    	// a
    }
    
    func ExampleBuffer_ReadByte() {
    	var b bytes.Buffer
    	b.Grow(64)
    	b.Write([]byte("abcde"))
    	c, err := b.ReadByte()
    	if err != nil {
    		panic(err)
    	}
    	fmt.Println(c)
    	fmt.Println(b.String())
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon May 12 16:07:54 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  4. docs/distributed/DESIGN.md

                    if atTotal > choose && pool.Available > 0 {
                            return pool.Index
                    }
            }
            // Should not happen, but print values just in case.
            panic(fmt.Errorf("reached end of serverPools (total: %v, atTotal: %v, choose: %v)", total, atTotal, choose))
    }
    ```
    
    ## Other usages
    
    ### Advanced use cases with multiple ellipses
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Feb 26 09:25:50 GMT 2025
    - 8K bytes
    - Click Count (2)
  5. 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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 23.1K bytes
    - Click Count (0)
  6. internal/etag/etag_test.go

    		}
    		if !Equal(etag, test.Plaintext) {
    			t.Fatalf("Test %d: got '%v' - want '%v'", i, etag, test.Plaintext)
    		}
    	}
    }
    
    func must(s string) ETag {
    	t, err := Parse(s)
    	if err != nil {
    		panic(err)
    	}
    	return t
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  7. src/cmd/api/api_test.go

    	if *flagCheck {
    		// slow, not worth repeating in -check
    		t.Skip("skipping with -check set")
    	}
    	testenv.MustHaveGoBuild(t)
    
    	defer func() {
    		if x := recover(); x != nil {
    			t.Errorf("expected no panic; recovered %v", x)
    		}
    	}()
    	for _, context := range contexts {
    		w := NewWalker(context, "testdata/src/issue64958")
    		pkg, err := w.importFrom("p", "", 0)
    		if err != nil {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Mar 02 13:20:41 GMT 2026
    - 7.6K bytes
    - Click Count (0)
  8. cmd/erasure-coding.go

    		once.Do(func() {
    			e, err := reedsolomon.New(dataBlocks, parityBlocks, reedsolomon.WithAutoGoroutines(int(e.ShardSize())))
    			if err != nil {
    				// Error conditions should be checked above.
    				panic(err)
    			}
    			enc = e
    		})
    		return enc
    	}
    	return e, err
    }
    
    // EncodeData encodes the given data and returns the erasure-coded data.
    // It returns an error if the erasure coding failed.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  9. cmd/erasure-encode_test.go

    		}
    		_, err := erasure.Encode(context.Background(), bytes.NewReader(content), writers, buffer, erasure.dataBlocks+1)
    		closeBitrotWriters(writers)
    		if err != nil {
    			panic(err)
    		}
    	}
    }
    
    func BenchmarkErasureEncodeQuick(b *testing.B) {
    	const size = 12 * 1024 * 1024
    	b.Run(" 00|00 ", func(b *testing.B) { benchmarkErasureEncode(2, 2, 0, 0, size, b) })
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  10. internal/grid/handlers.go

    	peerPrefixS3    = "peerS3"
    	healPrefix      = "heal"
    )
    
    func init() {
    	// Static check if we exceed 255 handler ids.
    	// Extend the type to uint16 when hit.
    	if uint32(handlerLast) > 255 {
    		panic(fmt.Sprintf("out of handler IDs. %d > %d", handlerLast, 255))
    	}
    }
    
    func (h HandlerID) valid() bool {
    	return h != handlerInvalid && h < handlerLast
    }
    
    func (h HandlerID) isTestHandler() bool {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 27.7K bytes
    - Click Count (0)
Back to Top