- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for domingo (0.21 sec)
-
cmd/notification.go
// rest of the `99*9` requests. // // This essentially splits the workload properly and also allows for network // utilization to be optimal, instead of blindly throttling the way we are // doing below. However the changes that are needed here are a bit involved, // further discussion advised. Remove this comment and remove the worker model // for this function in future. maxWorkers := runtime.GOMAXPROCS(0) / 2
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
"-j", "CONNMARK", "--set-xmark", inpodTproxyMark) // Handle healthcheck probes from the host node. In the host netns, before the packet enters the pod, we SNAT // the healthcheck packet to a fixed IP if the packet is coming from a node-local process with a socket. // // We do this so we can exempt this traffic from ztunnel capture/proxy - otherwise both kube-proxy (legit)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 19.6K bytes - Viewed (0) -
cni/pkg/install/install.go
} } func (in *Installer) installAll(ctx context.Context) (sets.String, error) { // Install binaries // Currently we _always_ do this, since the binaries do not live in a shared location // and we harm no one by doing so. copiedFiles, err := copyBinaries(in.cfg.CNIBinSourceDir, in.cfg.CNIBinTargetDirs) if err != nil { cniInstalls.With(resultLabel.Value(resultCopyBinariesFailure)).Increment()
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0) -
internal/s3select/select_test.go
input []byte requestXML []byte // override request XML wantResult string wantErr bool }{ { name: "select-all", input: testInput, query: ``, // Since we are doing offset, no headers are used. wantResult: `{"_1":"2","_2":"2017-01-02T03:04Z","_3":"-5","_4":" 0.765111","_5":""}`, requestXML: []byte(`<?xml version="1.0" encoding="UTF-8"?> <SelectObjectContentRequest>
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 76.2K bytes - Viewed (0) -
internal/lock/lock_windows.go
// simplicity it avoids the conversion entirely for relative // paths or paths containing .. elements. For now, // \\server\share paths are not converted to // \\?\UNC\server\share paths because the rules for doing so // are less well-specified. if len(path) >= 2 && path[:2] == `\\` { // Don't canonicalize UNC paths. return path } if !filepath.IsAbs(path) { // Relative path return path }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Oct 18 18:08:15 GMT 2023 - 7.9K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/test/install_cni.go
}, retry.Delay(time.Millisecond*10), retry.Timeout(time.Second*5)) checkTempFilesCleaned(tempCNIConfDir, t) } // RunInstallCNITest sets up temporary directories and runs the test. // // Doing a go test install_cni.go by itself will not execute the test as the // file doesn't have a _test.go suffix, and this func doesn't start with a Test // prefix. This func is only meant to be invoked programmatically. A separate
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
cmd/storage-rest-server.go
s.writeErrorResponse(w, err) return false } diskID := r.Form.Get(storageRESTDiskID) if diskID == "" { // Request sent empty disk-id, we allow the request // as the peer might be coming up and trying to read format.json // or create format.json return true } storedDiskID, err := s.getStorage().GetDiskID() if err != nil { s.writeErrorResponse(w, err) return false }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
// so they are only valid until the next bufio read. func readChunkLine(b *bufio.Reader) ([]byte, []byte, error) { buf, err := b.ReadSlice('\n') if err != nil { // We always know when EOF is coming. // If the caller asked for a line, there should be a line. if err == io.EOF { err = io.ErrUnexpectedEOF } else if err == bufio.ErrBufferFull { err = errLineTooLong } return nil, nil, err
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 18.2K bytes - Viewed (0) -
src/archive/tar/reader_test.go
err: ErrHeader, }, { // BSD tar v3.1.2 rejects a PAX path with NUL in the value, while // GNU tar v1.27.1 simply truncates at first NUL. // We emulate the behavior of BSD since it is strange doing NUL // truncations since PAX records are length-prefix strings instead // of NUL-terminated C-strings. file: "testdata/pax-nul-path.tar", err: ErrHeader, }, { file: "testdata/neg-size.tar",
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Nov 21 21:14:38 GMT 2022 - 47.1K bytes - Viewed (0)