Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for IsItab (0.13 sec)

  1. src/net/internal/socktest/switch.go

    // calls.
    type Switch struct {
    	once sync.Once
    
    	fmu   sync.RWMutex
    	fltab map[FilterType]Filter
    
    	smu   sync.RWMutex
    	sotab Sockets
    	stats stats
    }
    
    func (sw *Switch) init() {
    	sw.fltab = make(map[FilterType]Filter)
    	sw.sotab = make(Sockets)
    	sw.stats = make(stats)
    }
    
    // Stats returns a list of per-cookie socket statistics.
    func (sw *Switch) Stats() []Stat {
    	var st []Stat
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  2. src/internal/coverage/encodecounter/encode.go

    func (cfw *CoverageDataWriter) AppendSegment(args map[string]string, visitor CounterVisitor) error {
    	cfw.stab = &stringtab.Writer{}
    	cfw.stab.InitWriter()
    	cfw.stab.Lookup("")
    
    	var err error
    	for k, v := range args {
    		cfw.stab.Lookup(k)
    		cfw.stab.Lookup(v)
    	}
    
    	ws := &slicewriter.WriteSeeker{}
    	if err = cfw.writeSegmentPreamble(args, ws); err != nil {
    		return err
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  3. src/internal/coverage/encodemeta/encode.go

    		return nil, fmt.Errorf("invalid empty package path")
    	}
    	x := &CoverageMetaDataBuilder{
    		tmp: make([]byte, 0, 256),
    		h:   md5.New(),
    	}
    	x.stab.InitWriter()
    	x.stab.Lookup("")
    	x.pkgpath = x.stab.Lookup(pkgpath)
    	x.pkgname = x.stab.Lookup(pkgname)
    	x.modpath = x.stab.Lookup(modulepath)
    	io.WriteString(x.h, pkgpath)
    	io.WriteString(x.h, pkgname)
    	io.WriteString(x.h, modulepath)
    	return x, nil
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Feb 29 17:16:10 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  4. src/net/internal/socktest/sys_unix.go

    	if err = af.apply(so); err != nil {
    		return err
    	}
    
    	sw.smu.Lock()
    	defer sw.smu.Unlock()
    	if so.Err != nil {
    		sw.stats.getLocked(so.Cookie).CloseFailed++
    		return so.Err
    	}
    	delete(sw.sotab, s)
    	sw.stats.getLocked(so.Cookie).Closed++
    	return nil
    }
    
    // Connect wraps syscall.Connect.
    func (sw *Switch) Connect(s int, sa syscall.Sockaddr) (err error) {
    	so := sw.sockso(s)
    	if so == nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 4K bytes
    - Viewed (0)
  5. src/net/internal/socktest/sys_windows.go

    	if err = af.apply(so); err != nil {
    		return err
    	}
    
    	sw.smu.Lock()
    	defer sw.smu.Unlock()
    	if so.Err != nil {
    		sw.stats.getLocked(so.Cookie).CloseFailed++
    		return so.Err
    	}
    	delete(sw.sotab, s)
    	sw.stats.getLocked(so.Cookie).Closed++
    	return nil
    }
    
    // Connect wraps [syscall.Connect].
    func (sw *Switch) Connect(s syscall.Handle, sa syscall.Sockaddr) (err error) {
    	so := sw.sockso(s)
    	if so == nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 4.3K bytes
    - Viewed (0)
Back to top