Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for bufChan (0.15 sec)

  1. src/crypto/tls/handshake_server_test.go

    		}
    
    		buf := make([]byte, 1024)
    		n, err := c.Read(buf)
    		if err != nil {
    			t.Errorf("Server read returned error: %s", err)
    			return
    		}
    		c.Close()
    		bufChan <- buf[:n]
    	}()
    
    	Server(s, testConfig).Handshake()
    	buf := <-bufChan
    
    	if len(buf) < 5+4 {
    		t.Fatalf("Server returned short message of length %d", len(buf))
    	}
    	// buf contains a TLS record, with a 5 byte record header and a 4 byte
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 03 14:56:25 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  2. pkg/kubelet/nodeshutdown/systemd/inhibit_linux.go

    	if err != nil {
    		return nil, err
    	}
    
    	busChan := make(chan *dbus.Signal, 1)
    	bus.SystemBus.Signal(busChan)
    
    	shutdownChan := make(chan bool, 1)
    
    	go func() {
    		for {
    			event, ok := <-busChan
    			if !ok {
    				close(shutdownChan)
    				return
    			}
    			if event == nil || len(event.Body) == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 04 06:56:50 UTC 2023
    - 6.2K bytes
    - Viewed (0)
Back to top