- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 154 for readline (0.17 sec)
-
src/bufio/bufio.go
// of the line. The returned buffer is only valid until the next call to // ReadLine. ReadLine either returns a non-nil line or it returns an error, // never both. // // The text returned from ReadLine does not include the line end ("\r\n" or "\n"). // No indication or error is given if the input ends without a final line end. // Calling [Reader.UnreadByte] after ReadLine will always unread the last byte read
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) -
src/bufio/bufio_test.go
} // Test error after ReadSlice. _, _, err = r.ReadRune() // reset state if err != nil { t.Error("unexpected error on ReadRune (4):", err) } _, err = r.ReadSlice(0) if err != io.EOF { t.Error("unexpected error on ReadSlice (4):", err) } if r.UnreadRune() == nil { t.Error("expected error after ReadSlice (4)") } } func TestUnreadRuneAtEOF(t *testing.T) {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Feb 10 18:56:01 GMT 2023 - 51.5K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn.go
package deadlineconn import ( "net" "time" ) // DeadlineConn - is a generic stream-oriented network connection supporting buffered reader and read/write timeout. type DeadlineConn struct { net.Conn readDeadline time.Duration // sets the read deadline on a connection. writeDeadline time.Duration // sets the write deadline on a connection. } // Sets read deadline
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 2.3K bytes - Viewed (0) -
internal/config/api/api.go
) // API sub-system constants const ( apiRequestsMax = "requests_max" apiRequestsDeadline = "requests_deadline" apiClusterDeadline = "cluster_deadline" apiCorsAllowOrigin = "cors_allow_origin" apiRemoteTransportDeadline = "remote_transport_deadline" apiListQuorum = "list_quorum" apiReplicationPriority = "replication_priority"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 01:08:07 GMT 2024 - 11.1K bytes - Viewed (1) -
cmd/leak-detect_test.go
deadline := UTCNow().Add(leakDetectDeadline * time.Second) for { // get sack snapshot of relevant go routines. leaked := initialSnapShot.CompareCurrentSnapshot() // current stack snapshot matches the initial one, no leaks, return. if len(leaked) == 0 { return } // wait a test again will deadline. if UTCNow().Before(deadline) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.2K bytes - Viewed (0) -
internal/grid/connection.go
func (c *Connection) newMuxClient(ctx context.Context) (*muxClient, error) { client := newMuxClient(ctx, atomic.AddUint64(&c.NextID, 1), c) if dl, ok := ctx.Deadline(); ok { client.deadline = getDeadline(time.Until(dl)) if client.deadline == 0 { client.cancelFn(context.DeadlineExceeded) return nil, context.DeadlineExceeded } } for { // Handle the extremely unlikely scenario that we wrapped.
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) -
internal/config/certs.go
// decrypted using the ENV_VAR: MINIO_CERT_PASSWD. func LoadX509KeyPair(certFile, keyFile string) (tls.Certificate, error) { certPEMBlock, err := os.ReadFile(certFile) if err != nil { return tls.Certificate{}, ErrTLSReadError(nil).Msg("Unable to read the public key: %s", err) } keyPEMBlock, err := os.ReadFile(keyFile) if err != nil { return tls.Certificate{}, ErrTLSReadError(nil).Msg("Unable to read the private key: %s", err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 3.8K bytes - Viewed (0) -
cmd/metacache_gen.go
} switch msgp.UnsafeString(field) { case "end": z.ended, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "ended") return } case "st": z.started, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "started") return } case "lh": z.lastHandout, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "lastHandout") return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 08 18:26:08 GMT 2021 - 10K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
for _, o := range objects.Items { no := o.DeepCopy() out = append(out, object.NewK8sObject(no, nil, nil)) } } return out } // readFile reads a file and returns the contents. func readFile(path string) (string, error) { b, err := os.ReadFile(path) return string(b), err } // writeFile writes a file and returns an error if operation is unsuccessful. func writeFile(path string, data []byte) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
operator/cmd/mesh/profile-dump_test.go
if refreshGoldenFiles() { t.Logf("Refreshing golden file for %s", outPath) if err := os.WriteFile(outPath, []byte(got), 0o644); err != nil { t.Error(err) } } want, err := readFile(outPath) if err != nil { t.Fatal(err) } if !util.IsYAMLEqual(got, want) { t.Errorf("profile-dump command(%s): got:\n%s\n\nwant:\n%s\nDiff:\n%s\n", tt.desc, got, want, util.YAMLDiff(got, want)) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jan 20 11:44:25 GMT 2022 - 3.7K bytes - Viewed (0)