Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for afterFilter (0.37 sec)

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

    // error.
    // It can return a non-nil [AfterFilter] for filtering after the
    // execution of the system call.
    type Filter func(*Status) (AfterFilter, error)
    
    func (f Filter) apply(st *Status) (AfterFilter, error) {
    	if f == nil {
    		return nil, nil
    	}
    	return f(st)
    }
    
    // An AfterFilter represents a socket system call filter after an
    // execution of a system call.
    //
    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/net/internal/socktest/main_test.go

    				socketFunc(family, syscall.SOCK_STREAM, syscall.IPPROTO_TCP)
    			}
    		}()
    	}
    	wg.Wait()
    }
    
    func TestSocket(t *testing.T) {
    	for _, f := range []socktest.Filter{
    		func(st *socktest.Status) (socktest.AfterFilter, error) { return nil, nil },
    		nil,
    	} {
    		sw.Set(socktest.FilterSocket, f)
    		for _, family := range []int{syscall.AF_INET, syscall.AF_INET6} {
    			socketFunc(family, syscall.SOCK_STREAM, syscall.IPPROTO_TCP)
    		}
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jul 20 18:36:30 UTC 2023
    - 1.1K bytes
    - Viewed (0)
  3. src/net/main_posix_test.go

    func enableSocketConnect() {
    	sw.Set(socktest.FilterConnect, nil)
    }
    
    func disableSocketConnect(network string) {
    	net, _, _ := strings.Cut(network, ":")
    	sw.Set(socktest.FilterConnect, func(so *socktest.Status) (socktest.AfterFilter, error) {
    		switch net {
    		case "tcp4":
    			if so.Cookie.Family() == syscall.AF_INET && so.Cookie.Type() == syscall.SOCK_STREAM {
    				return nil, syscall.EHOSTUNREACH
    			}
    		case "udp4":
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  4. src/net/error_test.go

    		return nil, &DNSError{Err: "dial error test", Name: "name", Server: "server", IsTimeout: true}
    	}
    	sw.Set(socktest.FilterConnect, func(so *socktest.Status) (socktest.AfterFilter, error) {
    		return nil, errOpNotSupported
    	})
    	defer sw.Set(socktest.FilterConnect, nil)
    
    	d := Dialer{Timeout: someTimeout}
    	for i, tt := range dialErrorTests {
    		i, tt := i, tt
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 20.3K bytes
    - Viewed (0)
  5. src/net/net_test.go

    	syserr := make(chan error)
    	go func() {
    		defer close(syserr)
    		for _, err := range abortedConnRequestErrors {
    			syserr <- err
    		}
    	}()
    	sw.Set(socktest.FilterAccept, func(so *socktest.Status) (socktest.AfterFilter, error) {
    		if err, ok := <-syserr; ok {
    			return nil, err
    		}
    		return nil, nil
    	})
    	defer sw.Set(socktest.FilterAccept, nil)
    
    	operr := make(chan error, 1)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jan 22 21:04:44 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  6. platforms/software/dependency-management/src/main/resources/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/verification/report/uikit.min.js

    var h=(n=s,r=a,G([],l).sort(function(t,e){return ht(t,n).localeCompare(ht(e,n),void 0,{numeric:!0})*("asc"===r||-1)}));U(h,l)||h.forEach(function(t){return we(c.target,t)})}}t?this.animate(e).then(function(){return Kt(c.$el,"afterFilter",[c])}):(e(),Kt(this.$el,"afterFilter",[this]))},updateState:function(){var t=this;xi.write(function(){return t.setState(t.getState(),!1)})}}};function Mr(t,e){return Ni(ht(t,e),["filter"])}function zr(t,e,i){var n=Mr(t,e),r=n.filter,o=n.group,s=n.sort,a=n.order;return...
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Oct 10 21:10:11 UTC 2023
    - 130.5K bytes
    - Viewed (0)
Back to top