- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for newConn (0.12 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/conn_test.go
return server, serverAddr } func TestRawConn(t *testing.T) { channels := []ChannelType{ReadWriteChannel, ReadWriteChannel, IgnoreChannel, ReadChannel, WriteChannel} conn := NewConn(NewDefaultChannelProtocols(channels)) s, addr := newServer(http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { conn.Open(w, req) })) defer s.Close()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 11.4K bytes - Viewed (0) -
src/net/smtp/smtp_test.go
var cmdbuf strings.Builder bcmdbuf := bufio.NewWriter(&cmdbuf) var fake faker fake.ReadWriter = bufio.NewReadWriter(bufio.NewReader(strings.NewReader(server)), bcmdbuf) c := &Client{Text: textproto.NewConn(fake), localName: "localhost"} if err := c.helo(); err != nil { t.Fatalf("HELO failed: %s", err) } if err := c.ehlo(); err == nil { t.Fatalf("Expected first EHLO to fail") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 28.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/conn.go
selectedProtocol string channels []*websocketChannel codec codecType ready chan struct{} ws *websocket.Conn timeout time.Duration } // NewConn creates a WebSocket connection that supports a set of channels. Channels begin each // web socket message with a single byte indicating the channel number (0-N). 255 is reserved for
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.5K bytes - Viewed (0) -
src/net/smtp/smtp.go
} // NewClient returns a new [Client] using an existing connection and host as a // server name to be used when authenticating. func NewClient(conn net.Conn, host string) (*Client, error) { text := textproto.NewConn(conn) _, _, err := text.ReadResponse(220) if err != nil { text.Close() return nil, err } c := &Client{Text: text, conn: conn, serverName: host, localName: "localhost"} _, c.tls = conn.(*tls.Conn)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 11.6K bytes - Viewed (0) -
src/net/http/fcgi/fcgi_test.go
continue } if !bytes.Equal(content, test.content) { t.Errorf("%s: read wrong content", test.desc) continue } buf.Reset() c := newConn(&nilCloser{buf}) w := newWriter(c, test.recType, test.reqId) if _, err := w.Write(test.content); err != nil { t.Errorf("%s: error writing record: %v", test.desc, err) continue }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 11 18:51:39 UTC 2023 - 10.6K bytes - Viewed (0) -
src/net/http/fcgi/child.go
conn *conn handler http.Handler requests map[uint16]*request // keyed by request ID } func newChild(rwc io.ReadWriteCloser, handler http.Handler) *child { return &child{ conn: newConn(rwc), handler: handler, requests: make(map[uint16]*request), } } func (c *child) serve() { defer c.conn.Close() defer c.cleanUp() var rec record for {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 10.3K bytes - Viewed (0) -
src/net/textproto/reader_test.go
// Send MIME header over net.Conn r, w := net.Pipe() go func() { // ReadMIMEHeader calls canonicalMIMEHeaderKey, which reads from commonHeader NewConn(r).ReadMIMEHeader() }() w.Write([]byte("A: 1\r\nB: 2\r\nC: 3\r\n\r\n")) // CanonicalMIMEHeaderKey calls commonHeaderOnce.Do(initCommonHeader) which initializes commonHeader CanonicalMIMEHeaderKey("a")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 05 18:31:56 UTC 2024 - 14.7K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/configurations/DefaultConfigurationContainerTest.groovy
) def addsNewConfigurationWhenConfiguringSelf() { when: configurationContainer.configure { newConf } then: configurationContainer.findByName('newConf') != null configurationContainer.newConf != null } def doesNotAddNewConfigurationWhenNotConfiguringSelf() { when: configurationContainer.getByName('unknown')
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 17:29:40 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/controller/deployment/progress_test.go
t.Error(err) } newCond := util.GetDeploymentCondition(test.d.Status, test.conditionType) switch { case newCond == nil: if test.d.Spec.ProgressDeadlineSeconds != nil && *test.d.Spec.ProgressDeadlineSeconds != math.MaxInt32 { t.Errorf("%s: expected deployment condition: %s", test.name, test.conditionType) } case newCond.Status != test.conditionStatus || newCond.Reason != test.conditionReason:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0) -
src/net/sendfile_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 12.1K bytes - Viewed (0)