Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 1,387 for funcs (0.07 sec)

  1. cni/pkg/nodeagent/netns_linux.go

    )
    
    type NetnsWrapper struct {
    	innerNetns netns.NetNS
    	inode      uint64
    }
    
    func (n *NetnsWrapper) Inode() uint64 {
    	return n.inode
    }
    
    func (n *NetnsWrapper) Close() error {
    	return n.innerNetns.Close()
    }
    
    func (n *NetnsWrapper) Fd() uintptr {
    	return n.innerNetns.Fd()
    }
    
    func inodeForFd(n NetnsFd) (uint64, error) {
    	stats := &unix.Stat_t{}
    	err := unix.Fstat(int(n.Fd()), stats)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jan 31 10:05:36 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  2. cmd/metacache_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgmetacache(b *testing.B) {
    	v := metacache{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgmetacache(b *testing.B) {
    	v := metacache{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.3K bytes
    - Viewed (0)
  3. src/bytes/buffer_test.go

    type negativeReader struct{}
    
    func (r *negativeReader) Read([]byte) (int, error) { return -1, nil }
    
    func init() {
    	testBytes = make([]byte, N)
    	for i := 0; i < N; i++ {
    		testBytes[i] = 'a' + byte(i%26)
    	}
    	testString = string(testBytes)
    }
    
    // Verify that contents of buf match the string s.
    func check(t *testing.T, testname string, buf *Buffer, s string) {
    	bytes := buf.Bytes()
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Sep 03 20:55:15 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/compare/sds/util.go

    }
    
    // Name sets the name field on a secretItemBuilder
    func (s *secretItemBuilder) Name(name string) SecretItemBuilder {
    	s.name = name
    	return s
    }
    
    // Data sets the data field on a secretItemBuilder
    func (s *secretItemBuilder) Data(data string) SecretItemBuilder {
    	s.data = data
    	return s
    }
    
    // Source sets the source field on a secretItemBuilder
    func (s *secretItemBuilder) Source(source string) SecretItemBuilder {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 28 19:52:53 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  5. cni/pkg/plugin/cnieventclient_test.go

    		},
    		Gateway: fakeGW,
    	}
    )
    
    func TestPushCNIAddEventSucceed(t *testing.T) {
    	// Fake out a test HTTP server and use that instead of a real HTTP server over gRPC to validate  req/resp flows
    	testServer := httptest.NewServer(http.HandlerFunc(func(res http.ResponseWriter, req *http.Request) {
    		res.WriteHeader(http.StatusOK)
    		res.Write([]byte("server happy"))
    	}))
    	defer func() { testServer.Close() }()
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  6. cni/pkg/util/pluginutil.go

    func (w *Watcher) Wait(ctx context.Context) error {
    	select {
    	case <-w.Events:
    		return nil
    	case err := <-w.Errors:
    		return err
    	case <-ctx.Done():
    		return ctx.Err()
    	}
    }
    
    func (w *Watcher) Close() {
    	_ = w.watcher.Close()
    }
    
    // Creates a file watcher that watches for any changes to the directory
    func CreateFileWatcher(paths ...string) (*Watcher, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  7. internal/hash/errors.go

    	ExpectedSHA256   string
    	CalculatedSHA256 string
    }
    
    func (e SHA256Mismatch) Error() string {
    	return "Bad sha256: Expected " + e.ExpectedSHA256 + " does not match calculated " + e.CalculatedSHA256
    }
    
    // BadDigest - Content-MD5 you specified did not match what we received.
    type BadDigest struct {
    	ExpectedMD5   string
    	CalculatedMD5 string
    }
    
    func (e BadDigest) Error() string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon May 15 21:08:54 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  8. src/cmd/asm/internal/lex/stack.go

    		tok = s.Next()
    	}
    	return tok
    }
    
    func (s *Stack) Text() string {
    	return s.tr[len(s.tr)-1].Text()
    }
    
    func (s *Stack) File() string {
    	return s.Base().Filename()
    }
    
    func (s *Stack) Base() *src.PosBase {
    	return s.tr[len(s.tr)-1].Base()
    }
    
    func (s *Stack) SetBase(base *src.PosBase) {
    	s.tr[len(s.tr)-1].SetBase(base)
    }
    
    func (s *Stack) Line() int {
    	return s.tr[len(s.tr)-1].Line()
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Jan 09 22:33:23 UTC 2017
    - 1.2K bytes
    - Viewed (0)
  9. cmd/peer-s3-client.go

    }
    
    type localPeerS3Client struct {
    	node  Node
    	pools []int
    }
    
    func (l *localPeerS3Client) GetHost() string {
    	return l.node.Host
    }
    
    func (l *localPeerS3Client) SetPools(p []int) {
    	l.pools = make([]int, len(p))
    	copy(l.pools, p)
    }
    
    func (l localPeerS3Client) GetPools() []int {
    	return l.pools
    }
    
    func (l localPeerS3Client) ListBuckets(ctx context.Context, opts BucketOptions) ([]BucketInfo, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  10. cmd/namespace-lock.go

    	ctx    context.Context
    	cancel context.CancelFunc
    }
    
    // Context returns lock context
    func (l LockContext) Context() context.Context {
    	return l.ctx
    }
    
    // Cancel function calls cancel() function
    func (l LockContext) Cancel() {
    	if l.cancel != nil {
    		l.cancel()
    	}
    }
    
    // newNSLock - return a new name space lock map.
    func newNSLock(isDistErasure bool) *nsLockMap {
    	nsMutex := nsLockMap{
    		isDistErasure: isDistErasure,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
Back to top