- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for _exit (0.14 sec)
-
src/cmd/addr2line/addr2line_test.go
// GO_ADDR2LINETEST_IS_ADDR2LINE is set, and runs the tests otherwise. func TestMain(m *testing.M) { if os.Getenv("GO_ADDR2LINETEST_IS_ADDR2LINE") != "" { main() os.Exit(0) } os.Setenv("GO_ADDR2LINETEST_IS_ADDR2LINE", "1") // Set for subprocesses to inherit. os.Exit(m.Run()) } // addr2linePath returns the path to the "addr2line" binary to run. func addr2linePath(t testing.TB) string { t.Helper() testenv.MustHaveExec(t)
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Feb 21 22:16:54 GMT 2024 - 3.8K bytes - Viewed (0) -
operator/cmd/mesh/manifest-diff.go
if err != nil { return err } if !equal { os.Exit(1) } return nil } equal, err = compareManifestsFromFiles(args, diffArgs.verbose, diffArgs.renameResources, diffArgs.selectResources, diffArgs.ignoreResources) if err != nil { return err } if !equal { os.Exit(1) } return nil }, } return cmd }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 5.8K bytes - Viewed (0) -
lib/time/mkzip.go
"archive/zip" "bytes" "flag" "fmt" "hash/crc32" "io/fs" "log" "os" "path/filepath" "strings" ) func usage() { fmt.Fprintf(os.Stderr, "usage: go run mkzip.go zoneinfo.zip\n") os.Exit(2) } func main() { log.SetPrefix("mkzip: ") log.SetFlags(0) flag.Usage = usage flag.Parse() args := flag.Args() if len(args) != 1 || !strings.HasSuffix(args[0], ".zip") { usage() }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Mar 04 17:32:07 GMT 2024 - 2.1K bytes - Viewed (0) -
internal/s3select/csv/reader.go
} select { case <-r.close: return case r.queue <- &q: } select { case <-r.close: return case r.input <- &q: } if nextErr != nil { // Exit on any error. return } next, nextErr = r.nextSplit(csvSplitSize, r.bufferPool.Get().([]byte)) } }() // Start parsers for i := 0; i < runtime.GOMAXPROCS(0); i++ { go func() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
cmd/batch-expire.go
ri.Complete = ri.ObjectsFailed == 0 ri.Failed = ri.ObjectsFailed > 0 globalBatchJobsMetrics.save(job.ID, ri) // Close the saverQuitCh - this also triggers saving in-memory state // immediately one last time before we exit this method. xioutil.SafeClose(saverQuitCh) // Notify expire jobs final status to the configured endpoint buf, _ := json.Marshal(ri) if err := r.Notify(context.Background(), bytes.NewReader(buf)); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cmd/admin-heal-ops.go
delete(ahs.healSeqMap, path) } } ahs.Unlock() periodicTimer.Reset(time.Minute * 5) case <-ctx.Done(): // server could be restarting - need // to exit immediately return } } } // getHealSequenceByToken - Retrieve a heal sequence by token. The second // argument returns if a heal sequence actually exists.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cmd/test-utils_test.go
globalConsoleSys = NewConsoleLogger(context.Background(), io.Discard) globalInternodeTransport = NewInternodeHTTPTransport(0)() initHelp() resetTestGlobals() globalIsCICD = true os.Exit(m.Run()) } // concurrency level for certain parallel tests. const testConcurrencyLevel = 10 const iso8601TimeFormat = "2006-01-02T15:04:05.000Z"
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/peer-rest-server.go
if traceOpts.TraceTypes().Contains(madmin.TraceBootstrap) { go globalBootstrapTracer.Publish(ctx, globalTrace) } // Wait for remote to cancel and SubscribeJSON to exit. wg.Wait() return nil } func (s *peerRESTServer) BackgroundHealStatusHandler(_ *grid.MSS) (*grid.JSON[madmin.BgHealState], *grid.RemoteErr) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
internal/grid/connection.go
return true }) c.inStream.Range(func(key uint64, value *muxServer) bool { value.close() return true }) c.inStream.Clear() c.outgoing.Clear() // Wait for existing to exit c.handleMsgWg.Wait() } func (c *Connection) updateState(s State) { c.connChange.L.Lock() defer c.connChange.L.Unlock() // We may have reads that aren't locked, so update atomically.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/bucket-replication.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1)