Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 52 for GetSink (0.17 sec)

  1. pkg/proxy/util/nfacct/handler.go

    */
    
    package nfacct
    
    import (
    	"github.com/vishvananda/netlink/nl"
    	"github.com/vishvananda/netns"
    	"golang.org/x/sys/unix"
    )
    
    // handler is an injectable interface for creating netlink request.
    type handler interface {
    	newRequest(cmd int, flags uint16) request
    }
    
    // request is an injectable interface representing a netlink request.
    type request interface {
    	Serialize() []byte
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 06:47:50 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  2. cni/pkg/ipset/nldeps_linux.go

    		family = unix.AF_INET6
    	} else {
    		family = unix.AF_INET
    	}
    	err := netlink.IpsetCreate(name, "hash:ip", netlink.IpsetCreateOptions{Comments: true, Replace: true, Family: family})
    	if ipsetErr, ok := err.(nl.IPSetError); ok && ipsetErr == nl.IPSET_ERR_EXIST {
    		return nil
    	}
    
    	return err
    }
    
    func (m *realDeps) destroySet(name string) error {
    	err := netlink.IpsetDestroy(name)
    	return err
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 30 18:07:05 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  3. tools/istio-iptables/pkg/capture/run_linux.go

    			if cfg.EnableIPv6 {
    				families = append(families, unix.AF_INET6)
    			}
    			for _, family := range families {
    				r := netlink.NewRule()
    				r.Family = family
    				r.Table = tproxyTable
    				r.Mark = tproxyMark
    				if err := netlink.RuleAdd(r); err != nil {
    					return fmt.Errorf("failed to configure netlink rule: %v", err)
    				}
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 22:24:38 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  4. src/syscall/netlink_linux.go

    // license that can be found in the LICENSE file.
    
    // Netlink sockets and messages
    
    package syscall
    
    import (
    	"sync"
    	"unsafe"
    )
    
    // Round the length of a netlink message up to align it properly.
    func nlmAlignOf(msglen int) int {
    	return (msglen + NLMSG_ALIGNTO - 1) & ^(NLMSG_ALIGNTO - 1)
    }
    
    // Round the length of a netlink route attribute up to align it
    // properly.
    func rtaAlignOf(attrlen int) int {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 20:01:34 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  5. pkg/proxy/util/nfacct/nfacct_linux.go

    	var attrsProcessed int
    
    	// length and type of netlink attribute.
    	var length, attrType uint16
    
    	// now we are just left with the attributes(struct nlattr) after skipping netlink generic
    	// message; we iterate over all the attributes one by one to construct our Counter object.
    	for reader.Len() > 0 {
    		// netlink attributes are in LTV(length, type and value) format.
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 06:47:50 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/CompactLinkedHashMap.java

      }
    
      private void setSuccessor(int entry, int succ) {
        long succMask = (~0L) >>> 32;
        setLink(entry, (link(entry) & ~succMask) | ((succ + 1) & succMask));
      }
    
      private void setPredecessor(int entry, int pred) {
        long predMask = ~0L << 32;
        setLink(entry, (link(entry) & ~predMask) | ((long) (pred + 1) << 32));
      }
    
      private void setSucceeds(int pred, int succ) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  7. platforms/native/platform-native/src/main/java/org/gradle/nativeplatform/internal/DefaultSharedLibraryBinarySpec.java

            return getFileCollectionFactory().create(new SharedLibraryRuntimeOutputs());
        }
    
        @Override
        protected ObjectFilesToBinary getCreateOrLink() {
            return tasks.getLink();
        }
    
        @Override
        public SharedLibraryBinarySpec.TasksCollection getTasks() {
            return tasks;
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Nov 16 20:20:03 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  8. platforms/native/platform-native/src/main/java/org/gradle/nativeplatform/internal/DefaultNativeExecutableBinarySpec.java

        }
    
        @Override
        public File getPrimaryOutput() {
            return getExecutableFile();
        }
    
        @Override
        protected ObjectFilesToBinary getCreateOrLink() {
            return tasks.getLink();
        }
    
        @Override
        public NativeExecutableBinarySpec.TasksCollection getTasks() {
            return tasks;
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Nov 16 20:20:03 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  9. platforms/native/testing-native/src/main/java/org/gradle/nativeplatform/test/internal/DefaultNativeTestSuiteBinarySpec.java

        }
    
        @Override
        public File getPrimaryOutput() {
            return getExecutableFile();
        }
    
        @Override
        protected ObjectFilesToBinary getCreateOrLink() {
            return tasks.getLink();
        }
    
        @Override
        public NativeTestSuiteBinarySpec.TasksCollection getTasks() {
            return tasks;
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Nov 16 20:20:03 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  10. guava/src/com/google/common/collect/CompactLinkedHashMap.java

      }
    
      private void setSuccessor(int entry, int succ) {
        long succMask = (~0L) >>> 32;
        setLink(entry, (link(entry) & ~succMask) | ((succ + 1) & succMask));
      }
    
      private void setPredecessor(int entry, int pred) {
        long predMask = ~0L << 32;
        setLink(entry, (link(entry) & ~predMask) | ((long) (pred + 1) << 32));
      }
    
      private void setSucceeds(int pred, int succ) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 10.2K bytes
    - Viewed (0)
Back to top