- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 73 for opxrrr (0.19 sec)
-
src/crypto/tls/handshake_server_test.go
c, s := localPipe(t) go func() { Client(c, testConfig).sendAlert(alertUnknownCA) c.Close() }() err := Server(s, testConfig).Handshake() s.Close() var opErr *net.OpError if !errors.As(err, &opErr) || opErr.Err != error(alertUnknownCA) { t.Errorf("Got error: %s; expected: %s", err, error(alertUnknownCA)) } } func TestClose(t *testing.T) { c, s := localPipe(t) go c.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 64.7K bytes - Viewed (0) -
src/net/rpc/client.go
if err == nil && resp.Status == connected { return NewClient(conn), nil } if err == nil { err = errors.New("unexpected HTTP response: " + resp.Status) } conn.Close() return nil, &net.OpError{ Op: "dial-http", Net: network + " " + address, Addr: nil, Err: err, } } // Dial connects to an RPC server at the specified network address.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 9K bytes - Viewed (0) -
internal/event/target/amqp.go
var err error var conn *amqp091.Connection var ch *amqp091.Channel isAMQPClosedErr := func(err error) bool { if err == amqp091.ErrClosed { return true } if nerr, ok := err.(*net.OpError); ok { return (nerr.Err.Error() == "use of closed network connection") } return false } target.connMutex.Lock() defer target.connMutex.Unlock() if target.conn != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 10K bytes - Viewed (0) -
src/log/syslog/syslog_test.go
ct := 0 for { var n int var err error c.SetReadDeadline(time.Now().Add(100 * time.Millisecond)) n, _, err = c.ReadFrom(buf[:]) rcvd += string(buf[:n]) if err != nil { if oe, ok := err.(*net.OpError); ok { if ct < 3 && oe.Temporary() { ct++ continue } } break } } c.Close() done <- rcvd } var crashy = false func testableNetwork(network string) bool {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 12 16:09:24 UTC 2023 - 9.6K bytes - Viewed (0) -
src/crypto/tls/conn.go
} if c.vers == VersionTLS13 { return c.in.setErrorLocked(&net.OpError{Op: "remote error", Err: alert(data[1])}) } switch data[0] { case alertLevelWarning: // Drop the record on the floor and retry. return c.retryReadRecord(expectChangeCipherSpec) case alertLevelError: return c.in.setErrorLocked(&net.OpError{Op: "remote error", Err: alert(data[1])}) default:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 51.8K bytes - Viewed (0) -
src/net/dial_test.go
} } t.Fatalf("dial error after %d ticks (%d before cancel sent): %v", ticks, cancelTick-ticks, err) } if oe, ok := err.(*OpError); !ok || oe.Err != errCanceled { t.Fatalf("dial error = %v (%T); want OpError with Err == errCanceled", err, err) } return // success. } } } func TestCancelAfterDial(t *testing.T) { if testing.Short() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 30.3K bytes - Viewed (0) -
src/net/dnsclient_unix.go
if err != nil { dnsErr := newDNSError(err, name, server) // Set IsTemporary for socket-level errors. Note that this flag // may also be used to indicate a SERVFAIL response. if _, ok := err.(*OpError); ok { dnsErr.IsTemporary = true } lastErr = dnsErr continue } if err := checkHeader(&p, h); err != nil { if err == errNoSuchHost {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 24.5K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/stdlib/manifest.go
{"MX", Type, 0}, {"MX.Host", Field, 0}, {"MX.Pref", Field, 0}, {"NS", Type, 1}, {"NS.Host", Field, 1}, {"OpError", Type, 0}, {"OpError.Addr", Field, 0}, {"OpError.Err", Field, 0}, {"OpError.Net", Field, 0}, {"OpError.Op", Field, 0}, {"OpError.Source", Field, 5}, {"PacketConn", Type, 0}, {"ParseCIDR", Func, 0}, {"ParseError", Type, 0}, {"ParseError.Text", Field, 0},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 534.2K bytes - Viewed (0) -
api/go1.5.txt
pkg mime/quotedprintable, type Reader struct pkg mime/quotedprintable, type Writer struct pkg mime/quotedprintable, type Writer struct, Binary bool pkg net, type Dialer struct, FallbackDelay time.Duration pkg net, type OpError struct, Source Addr pkg net/http, type Request struct, Cancel <-chan struct pkg net/http/fcgi, var ErrConnClosed error pkg net/http/fcgi, var ErrRequestAborted error
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jul 30 21:14:09 UTC 2015 - 46.6K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/prove.go
return isNonNegative(v.Args[0]) || isNonNegative(v.Args[1]) case OpMod64, OpMod32, OpMod16, OpMod8, OpDiv64, OpDiv32, OpDiv16, OpDiv8, OpOr64, OpOr32, OpOr16, OpOr8, OpXor64, OpXor32, OpXor16, OpXor8: return isNonNegative(v.Args[0]) && isNonNegative(v.Args[1]) // We could handle OpPhi here, but the improvements from doing // so are very minor, and it is neither simple nor cheap. } return false
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 17:30:21 UTC 2024 - 48.9K bytes - Viewed (0)