- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for froward (0.21 sec)
-
cmd/metacache-walk.go
var scanDir func(path string) error scanDir = func(current string) error { // Skip forward, if requested... sb := bytebufferpool.Get() defer func() { sb.Reset() bytebufferpool.Put(sb) }() forward := "" if len(opts.ForwardTo) > 0 && strings.HasPrefix(opts.ForwardTo, current) { forward = strings.TrimPrefix(opts.ForwardTo, current) // Trim further directories and trailing slash.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/generic-handlers.go
if err != nil { h.ServeHTTP(w, r) return } remote, self := globalSiteReplicationSys.getPeerForUpload(deplID) if self { h.ServeHTTP(w, r) return } // forward request to peer handling this upload if globalBucketTargetSys.isOffline(remote.EndpointURL) { defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0) -
misc/ios/go_ios_exec.go
lldb.Stdin = strings.NewReader(lldbDriver) lldb.Stdout = os.Stdout var out bytes.Buffer lldb.Stderr = io.MultiWriter(&out, os.Stderr) err := lldb.Start() if err == nil { // Forward SIGQUIT to the lldb driver which in turn will forward // to the running program. sigs := make(chan os.Signal, 1) signal.Notify(sigs, syscall.SIGQUIT) proc := lldb.Process go func() { for sig := range sigs {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 23.4K bytes - Viewed (0) -
cmd/metacache-set.go
// The last entry can be used as a marker to resume the listing. func (r *metacacheReader) filter(o listPathOptions) (entries metaCacheEntriesSorted, err error) { // Forward to prefix, if any err = r.forwardTo(o.Prefix) if err != nil { return entries, err } if o.Marker != "" { err = r.forwardTo(o.Marker) if err != nil { return entries, err } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
misc/go_android_exec/main.go
return 0, err } } } } deviceBin := fmt.Sprintf("%s/%s", deviceGotmp, binName) if err := adb("push", os.Args[1], deviceBin); err != nil { return 0, err } // Forward SIGQUIT from the go command to show backtraces from // the binary instead of from this wrapper. quit := make(chan os.Signal, 1) signal.Notify(quit, syscall.SIGQUIT) go func() { for range quit {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Aug 21 17:46:57 GMT 2023 - 15.3K bytes - Viewed (0) -
src/archive/zip/writer.go
// The file contents will be compressed using the [Deflate] method. // The name must be a relative path: it must not start with a drive // letter (e.g. C:) or leading slash, and only forward slashes are // allowed. To create a directory instead of a file, add a trailing // slash to the name. // The file's contents must be written to the [io.Writer] before the next
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Apr 04 14:28:57 GMT 2024 - 19.3K bytes - Viewed (0) -
misc/cgo/gmp/gmp.go
// Mul sets z = x * y and returns z. func (z *Int) Mul(x, y *Int) *Int { x.doinit() y.doinit() z.doinit() C.mpz_mul(&z.i[0], &x.i[0], &y.i[0]) return z } // Div sets z = x / y, rounding toward zero, and returns z. func (z *Int) Div(x, y *Int) *Int { x.doinit() y.doinit() z.doinit() C.mpz_tdiv_q(&z.i[0], &x.i[0], &y.i[0]) return z } // Mod sets z = x % y and returns z.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 9.5K bytes - Viewed (0) -
src/bufio/bufio.go
sw, tryStringWriter = b.wr.(io.StringWriter) } if b.Buffered() == 0 && tryStringWriter { // Large write, empty buffer, and the underlying writer supports // WriteString: forward the write to the underlying StringWriter. // This avoids an extra copy. n, b.err = sw.WriteString(s) } else { n = copy(b.buf[b.n:], s) b.n += n b.Flush() } nn += n s = s[n:]
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Oct 12 14:39:08 GMT 2023 - 21.8K bytes - Viewed (0) -
istioctl/pkg/metrics/metrics.go
} if err = fw.Start(); err != nil { return fmt.Errorf("failure running port forward process: %v", err) } // Close the forwarder either when we exit or when an this processes is interrupted. defer fw.Close() dashboard.ClosePortForwarderOnInterrupt(fw) log.Debugf("port-forward to prometheus pod ready") promAPI, err := prometheusAPI(fmt.Sprintf("http://%s", fw.Address()))
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 8.4K bytes - Viewed (0) -
src/cmd/api/testdata/src/pkg/p1/p1.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package p1 import ( ptwo "p2" ) const ( ConstChase2 = constChase // forward declaration to unexported ident constChase = AIsLowerA // forward declaration to exported ident // Deprecated: use B. A = 1 a = 11 A64 int64 = 1 AIsLowerA = a // previously declared ) const (
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Dec 02 16:29:41 GMT 2022 - 3.3K bytes - Viewed (0)