- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 47 for nw (0.04 sec)
-
internal/ioutil/ioutil.go
} // buf is not aligned, hence use writeUnaligned() // for the remainder un, err = w.Write(buf[len(buf)-remain:]) nw += int64(un) } if nw > 0 { written += nw } if err != nil { return written, err } if nw != int64(len(buf)) { return written, io.ErrShortWrite } if totalSize > 0 && written == totalSize {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 10.2K bytes - Viewed (0) -
pilot/pkg/model/network.go
} return SortGateways(out) } func (gws *NetworkGateways) GatewaysForNetwork(nw network.ID) []NetworkGateway { gws.mu.RLock() defer gws.mu.RUnlock() if gws.byNetwork == nil { return nil } return gws.byNetwork[nw] } func (gws *NetworkGateways) GatewaysForNetworkAndCluster(nw network.ID, c cluster.ID) []NetworkGateway { gws.mu.RLock() defer gws.mu.RUnlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 16.9K bytes - Viewed (0) -
src/internal/coverage/encodecounter/encode.go
sz := len(ws.BytesWritten()) zeros := []byte{0, 0, 0, 0} rem := uint32(sz) % 4 if rem != 0 { pad := zeros[:(4 - rem)] if nw, err := ws.Write(pad); err != nil { return err } else if nw != len(pad) { return fmt.Errorf("error: short write") } } return nil } func (cfw *CoverageDataWriter) patchSegmentHeader(ws *slicewriter.WriteSeeker) error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 7.8K bytes - Viewed (0) -
pkg/proxy/util/nodeport_addresses.go
func (npa *NodePortAddresses) GetNodeIPs(nw NetworkInterfacer) ([]net.IP, error) { addrs, err := nw.InterfaceAddrs() if err != nil { return nil, fmt.Errorf("error listing all interfaceAddrs from host, error: %v", err) } // Use a map to dedup matches addresses := make(map[string]net.IP) for _, cidr := range npa.cidrs { for _, addr := range addrs { var ip net.IP
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 3.6K bytes - Viewed (0) -
src/io/pipe.go
return 0, p.writeCloseError() default: p.wrMu.Lock() defer p.wrMu.Unlock() } for once := true; once || len(b) > 0; once = false { select { case p.wrCh <- b: nw := <-p.rdCh b = b[nw:] n += nw case <-p.done: return n, p.writeCloseError() } } return n, nil } func (p *pipe) closeWrite(err error) error { if err == nil { err = EOF } p.werr.Store(err)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 18 19:34:35 UTC 2023 - 5.1K bytes - Viewed (0) -
src/net/pipe.go
} p.wrMu.Lock() // Ensure entirety of b is written together defer p.wrMu.Unlock() for once := true; once || len(b) > 0; once = false { select { case p.wrTx <- b: nw := <-p.wrRx b = b[nw:] n += nw case <-p.localDone: return n, io.ErrClosedPipe case <-p.remoteDone: return n, io.ErrClosedPipe case <-p.writeDeadline.wait(): return n, os.ErrDeadlineExceeded } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/hbone/util.go
} nr, err := src.Read(buf) log.Debugf("read %v/%v", nr, err) if nr > 0 { // before dealing with the read error nw, ew := dst.Write(buf[0:nr]) log.Debugf("write %v/%v", nw, ew) if f, ok := dst.(http.Flusher); ok { f.Flush() } if nr != nw { // Should not happen ew = io.ErrShortWrite } if ew != nil { return } } if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 3.4K bytes - Viewed (0) -
src/internal/coverage/encodemeta/encode.go
} return off + (int64(len(b.funcs)) * 4) } func (b *CoverageMetaDataBuilder) emitFunc(w io.WriteSeeker, off int64, f funcDesc) (int64, error) { ew := len(f.encoded) if nw, err := w.Write(f.encoded); err != nil { return 0, err } else if ew != nw { return 0, fmt.Errorf("short write emitting coverage meta-data") } return off + int64(ew), nil } func (b *CoverageMetaDataBuilder) reportWriteError(err error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 29 17:16:10 UTC 2024 - 5.5K bytes - Viewed (0) -
src/encoding/base64/base64.go
d.err = io.ErrUnexpectedEOF } return 0, d.err } // Decode chunk into p, or d.out and then p if p is too small. nr := d.nbuf / 4 * 4 nw := d.nbuf / 4 * 3 if nw > len(p) { nw, d.err = d.enc.Decode(d.outbuf[:], d.buf[:nr]) d.out = d.outbuf[:nw] n = copy(p, d.out) d.out = d.out[n:] } else { n, d.err = d.enc.Decode(p, d.buf[:nr]) } d.nbuf -= nr copy(d.buf[:d.nbuf], d.buf[nr:])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 19:04:28 UTC 2023 - 17.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/net/interface_test.go
t.Errorf("case[%v]: expected %v, got %v .err : %v", tc.tcase, tc.expected, ip, err) } } } func TestAddrs(t *testing.T) { var nw networkInterfacer = validNetworkInterface{} intf := net.Interface{Index: 0, MTU: 0, Name: "eth3", HardwareAddr: nil, Flags: 0} addrs, err := nw.Addrs(&intf) if err != nil { t.Errorf("expected no error got : %v", err) } if len(addrs) != 2 { t.Errorf("expected addrs: 2 got null")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 10 07:29:34 UTC 2023 - 33.2K bytes - Viewed (0)