- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 67 for out (0.21 sec)
-
docs/auditlog/auditlog-echo.go
if err != nil { log.Printf("Error reading request body: %v", err) w.WriteHeader(http.StatusBadRequest) return } log.Printf(">>> %s %s\n", r.Method, r.URL.Path) var out bytes.Buffer json.Indent(&out, body, "", " ") log.Printf("%s\n", out.String()) w.WriteHeader(http.StatusOK) } func main() { flag.Parse() http.HandleFunc("/", mainHandler) log.Printf("Listening on :%d\n", port)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 21:31:13 GMT 2024 - 1.5K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
} return debug, err } func setupConfigdumpZtunnelConfigWriter(debug []byte, out io.Writer) (*ztunnelDump.ConfigWriter, error) { cw := &ztunnelDump.ConfigWriter{Stdout: out, FullDump: debug} err := cw.Prime(debug) if err != nil { return nil, err } return cw, nil } func setupFileZtunnelConfigdumpWriter(filename string, out io.Writer) (*ztunnelDump.ConfigWriter, error) { data, err := readFile(filename)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0) -
.github/workflows/scorecard.yml
# - `publish_results` will always be set to `false`, regardless # of the value entered here. publish_results: true # Upload the results as artifacts (optional). Commenting out will disable uploads of run results in SARIF # format to the repository Actions tab. - name: "Upload artifact" uses: actions/upload-artifact@65462800fd760344b1a7b4382951275a0abb4808 # v4.3.3 with:
Others - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 29 23:37:56 GMT 2024 - 2.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
var readyTask: Task? = null var multipleReadyTasks = false // Decide what to run. This loop's goal wants to: // * Find out what this thread should do (either run a task or sleep) // * Find out if there's enough work to start another thread. eachQueue@ for (queue in readyQueues) { val candidate = queue.futureTasks[0]
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
pd.QueuedBuckets = append(pd.QueuedBuckets[:i], pd.QueuedBuckets[i+1:]...) // Clear tracker info. if pd.Bucket == bucket { pd.Bucket = "" // empty this out for next bucket pd.Prefix = "" // empty this out for the next bucket pd.Object = "" // empty this out for next object } return true } } return false } func (pd *PoolDecommissionInfo) isBucketDecommissioned(bucket string) bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cni/pkg/ipset/nldeps_linux.go
if err != nil { return fmt.Errorf("failed to flush ipset %s: %w", name, err) } return nil } // Alpine and some distros struggles with this - ipset CLI utilities support this, but // the kernel can be out of sync with the CLI utility, leading to errors like: // // ipset v7.10: Argument `comment' is supported in the kernel module of the set type hash:ip // starting from the revision 3 and you have installed revision 1 only.
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 3.9K bytes - Viewed (0) -
cmd/endpoint-ellipses.go
// prefers setCounts to be sorted for optimal behavior. if divisibleSize < setCounts[len(setCounts)-1] { return divisibleSize } // Figure out largest value of total_drives_in_erasure_set which results // in least number of total_drives/total_drives_erasure_set ratio. prevD := divisibleSize / setCounts[0] for _, cnt := range setCounts { if divisibleSize%cnt == 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 14.7K 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, }
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) -
cni/pkg/util/podutil.go
// Neither namespace nor pod has ambient mode enabled return false } if podHasSidecar(pod) { // Ztunnel and sidecar for a single pod is currently not supported; opt out. return false } // TODO: delete this block when there is a way for users to signal the intent to exclude // a pod from ambient that does not require the use of this annotation
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed May 01 18:04:40 GMT 2024 - 4.1K bytes - Viewed (0) -
cmd/bucket-targets.go
sys.hMutex.Unlock() } hcTimer.Reset(defaultHealthCheckDuration) case <-ctx.Done(): return } } } // periodically rebuild the healthCheck map from list of targets to clear // out stale endpoints func (sys *BucketTargetSys) reloadHealthCheckers(ctx context.Context) { m := make(map[string]epHealth) tgts := sys.ListTargets(ctx, "", "") sys.hMutex.Lock() for _, t := range tgts {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0)