Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 159 for Hancic (0.21 sec)

  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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  2. 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
    }
    
    // EncodeData encodes the given data and returns the erasure-coded data.
    // It returns an error if the erasure coding failed.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 02:11:45 GMT 2024
    - 8.6K bytes
    - Viewed (0)
  3. operator/cmd/mesh/manifest-generate_test.go

    		d, err := os.MkdirTemp("", "data-snapshot-*")
    		if err != nil {
    			panic(fmt.Errorf("failed to make temp dir: %v", err))
    		}
    		f, err := os.Open("testdata/manifest-generate/data-snapshot.tar.gz")
    		if err != nil {
    			panic(fmt.Errorf("failed to read data snapshot: %v", err))
    		}
    		if err := extract(f, d); err != nil {
    			panic(fmt.Errorf("failed to extract data snapshot: %v", err))
    		}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 18 18:16:49 GMT 2024
    - 43.5K bytes
    - Viewed (0)
  4. internal/s3select/select.go

    }
    
    func (s3Select *S3Select) outputRecord() sql.Record {
    	switch s3Select.Output.format {
    	case csvFormat:
    		return csv.NewRecord()
    	case jsonFormat:
    		return json.NewRecord(sql.SelectFmtJSON)
    	}
    
    	panic(fmt.Errorf("unknown output format '%v'", s3Select.Output.format))
    }
    
    func (s3Select *S3Select) getProgress() (bytesScanned, bytesProcessed int64) {
    	if s3Select.progressReader != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 21K bytes
    - Viewed (0)
  5. 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
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Aug 15 23:04:20 GMT 2023
    - 8K bytes
    - Viewed (0)
  6. finisher_api.go

    				// Make sure to rollback when panic, Block error or Commit error
    				if panicked || err != nil {
    					db.RollbackTo(fmt.Sprintf("sp%p", fc))
    				}
    			}()
    		}
    		err = fc(db.Session(&Session{NewDB: db.clone == 1}))
    	} else {
    		tx := db.Begin(opts...)
    		if tx.Error != nil {
    			return tx.Error
    		}
    
    		defer func() {
    			// Make sure to rollback when panic, Block error or Commit error
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Fri Jan 12 08:42:21 GMT 2024
    - 22.7K bytes
    - Viewed (0)
  7. CHANGELOG/CHANGELOG-1.12.md

    - kubectl: fixes a panic displaying pods with nominatedNodeName set ([#66406](https://github.com/kubernetes/kubernetes/pull/66406), [@liggitt](https://github.com/liggitt))
    - prevents infinite CLI wait on delete when item is recreated ([#66136](https://github.com/kubernetes/kubernetes/pull/66136), [@deads2k](https://github.com/deads2k))
    Plain Text
    - Registered: Fri May 03 09:05:14 GMT 2024
    - Last Modified: Thu Feb 06 06:04:15 GMT 2020
    - 293.8K bytes
    - Viewed (1)
  8. src/archive/tar/format.go

    		copy(b.toSTAR().trailer(), trailerSTAR)
    	case format.has(FormatUSTAR | FormatPAX):
    		copy(b.toUSTAR().magic(), magicUSTAR)
    		copy(b.toUSTAR().version(), versionUSTAR)
    	default:
    		panic("invalid format")
    	}
    
    	// Update checksum.
    	// This field is special in that it is terminated by a NULL then space.
    	var f formatter
    	field := b.toV7().chksum()
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 11.3K bytes
    - Viewed (0)
  9. internal/s3select/sql/value_test.go

    	},
    	func() *Value {
    		return FromFloat(math.Pi)
    	},
    	func() *Value {
    		return FromInt(0x1337)
    	},
    	func() *Value {
    		t, err := time.Parse(time.RFC3339, "2006-01-02T15:04:05Z")
    		if err != nil {
    			panic(err)
    		}
    		return FromTimestamp(t)
    	},
    	func() *Value {
    		return FromString("string contents")
    	},
    }
    
    // altValueBuilders contains one constructor for each value type.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 06 16:56:10 GMT 2023
    - 12.5K bytes
    - Viewed (0)
  10. src/cmd/api/api_test.go

    			t.Fatalf("stdPackages contains unexpected package %s", pkg)
    		}
    	}
    }
    
    func TestIssue64958(t *testing.T) {
    	defer func() {
    		if x := recover(); x != nil {
    			t.Errorf("expected no panic; recovered %v", x)
    		}
    	}()
    
    	testenv.MustHaveGoBuild(t)
    
    	for _, context := range contexts {
    		w := NewWalker(context, "testdata/src/issue64958")
    		pkg, err := w.importFrom("p", "", 0)
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Thu Jan 04 17:31:12 GMT 2024
    - 7.1K bytes
    - Viewed (0)
Back to top