Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 75 for Ln (0.02 sec)

  1. src/net/sendfile_test.go

    		t.Error("internal.poll.SendFile called with unexpected FD")
    	}
    }
    
    func TestSendfile(t *testing.T) {
    	ln := newLocalListener(t, "tcp")
    	defer ln.Close()
    
    	errc := make(chan error, 1)
    	go func(ln Listener) {
    		// Wait for a connection.
    		conn, err := ln.Accept()
    		if err != nil {
    			errc <- err
    			close(errc)
    			return
    		}
    
    		go func() {
    			defer close(errc)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 18:12:56 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  2. src/net/tcpsock_test.go

    		t.Skipf("not supported on %s", runtime.GOOS)
    	}
    
    	ln, err := Listen("tcp", "127.0.0.1:0")
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer ln.Close()
    	var server Conn
    	errc := make(chan error, 1)
    	go func() {
    		var err error
    		server, err = ln.Accept()
    		errc <- err
    	}()
    	client, err := Dial("tcp", ln.Addr().String())
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer client.Close()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 17.7K bytes
    - Viewed (0)
  3. src/net/timeout_test.go

    	case "plan9":
    		t.Skipf("not supported on %s", runtime.GOOS)
    	}
    
    	ln := newLocalListener(t, "tcp")
    	defer ln.Close()
    
    	if err := ln.(*TCPListener).SetDeadline(noDeadline); err != nil {
    		t.Error(err)
    	}
    	if err := ln.(*TCPListener).SetDeadline(time.Now().Add(10 * time.Millisecond)); err != nil {
    		t.Error(err)
    	}
    	c, err := ln.Accept()
    	if err == nil {
    		c.Close()
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 24 18:06:55 UTC 2024
    - 30K bytes
    - Viewed (0)
  4. src/net/net_test.go

    				t.Skipf("network %s is not testable on the current platform", network)
    			}
    			t.Parallel()
    
    			ln := newLocalListener(t, network)
    			switch network {
    			case "unix", "unixpacket":
    				defer os.Remove(ln.Addr().String())
    			}
    			defer ln.Close()
    
    			c, err := Dial(ln.Addr().Network(), ln.Addr().String())
    			if err != nil {
    				t.Fatal(err)
    			}
    			switch network {
    			case "unix", "unixpacket":
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jan 22 21:04:44 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  5. src/net/listen_test.go

    		}
    	}()
    
    	if ln, err := Listen("tcp", ""); err == nil {
    		ln.Close()
    	}
    	if ln, err := ListenPacket("udp", ""); err == nil {
    		ln.Close()
    	}
    	if ln, err := ListenTCP("tcp", nil); err == nil {
    		ln.Close()
    	}
    	if ln, err := ListenUDP("udp", nil); err == nil {
    		ln.Close()
    	}
    	if ln, err := ListenIP("ip:icmp", nil); err == nil {
    		ln.Close()
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 20.5K bytes
    - Viewed (0)
  6. src/net/mockserver_test.go

    		},
    		port: port,
    	}, nil
    }
    
    func (ls *localServer) transponder(ln Listener, ch chan<- error) {
    	defer close(ch)
    
    	switch ln := ln.(type) {
    	case *TCPListener:
    		ln.SetDeadline(time.Now().Add(someTimeout))
    	case *UnixListener:
    		ln.SetDeadline(time.Now().Add(someTimeout))
    	}
    	c, err := ln.Accept()
    	if err != nil {
    		if perr := parseAcceptError(err); perr != nil {
    			ch <- perr
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. src/net/dial_test.go

    	})
    
    	handler := func(ls *localServer, ln Listener) {
    		for {
    			c, err := ln.Accept()
    			if err != nil {
    				return
    			}
    			c.Close()
    		}
    	}
    	ln := newLocalListener(t, "tcp", &ListenConfig{
    		KeepAlive: -1, // prevent calling hook from accepting
    	})
    	ls := (&streamListener{Listener: ln}).newLocalServer()
    	defer ls.teardown()
    	if err := ls.buildup(handler); err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 30.3K bytes
    - Viewed (0)
  8. src/cmd/compile/internal/ssa/likelyadjust.go

    		}
    	}
    	ln.initializedChildren = true
    }
    
    // calculateDepths uses the children field of loops
    // to determine the nesting depth (outer=1) of each
    // loop.  This is helpful for finding exit edges.
    func (ln *loopnest) calculateDepths() {
    	if ln.initializedDepth {
    		return
    	}
    	ln.assembleChildren()
    	for _, l := range ln.loops {
    		if l.outer == nil {
    			l.setDepth(1)
    		}
    	}
    	ln.initializedDepth = true
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Oct 31 21:41:20 UTC 2022
    - 15.4K bytes
    - Viewed (0)
  9. src/net/error_test.go

    			t.Error(perr)
    		}
    	} else {
    		c.Close()
    		t.Error("should fail")
    	}
    	ln, err := FileListener(f)
    	if err != nil {
    		if ln != nil {
    			t.Errorf("FileListener returned non-nil interface %T(%v) with err != nil", ln, ln)
    		}
    		if perr := parseCommonError(err); perr != nil {
    			t.Error(perr)
    		}
    	} else {
    		ln.Close()
    		t.Error("should fail")
    	}
    	pc, err := FilePacketConn(f)
    	if err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 20.3K bytes
    - Viewed (0)
  10. pilot/pkg/networking/grpcgen/lds.go

    		}
    
    		for _, name := range allNames {
    			ln, ok := filter[name]
    			if !ok {
    				ln = listenerName{RequestedNames: sets.New[string]()}
    			}
    			ln.RequestedNames.Insert(requestedName)
    
    			// only build the portmap if we aren't filtering this name yet, or if the existing filter is non-empty
    			if hasPort && (!ok || len(ln.Ports) != 0) {
    				if ln.Ports == nil {
    					ln.Ports = map[string]struct{}{}
    				}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 14.6K bytes
    - Viewed (0)
Back to top