Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 88 for closed (0.31 sec)

  1. cni/pkg/nodeagent/pod_cache.go

    }
    
    func closeNetns(netns NetnsCloser) {
    	netns.Close()
    }
    
    func (p *podNetnsCache) ReadCurrentPodSnapshot() map[string]WorkloadInfo {
    	p.mu.RLock()
    	defer p.mu.RUnlock()
    	// snapshot the cache to avoid long locking
    	return maps.Clone(p.currentPodCache)
    }
    
    // Remove and return the Netns for the given uid
    // No need to return NetnsCloser here it will be closed automatically on GC.
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 4.5K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/server_test.go

    		}
    	}
    }
    
    func (wg *WaitGroup) Add(i int32) {
    	select {
    	case <-wg.done:
    		panic("use of an already closed WaitGroup")
    	default:
    	}
    	atomic.AddInt32(&wg.count, i)
    }
    
    func (wg *WaitGroup) Done() {
    	i := atomic.AddInt32(&wg.count, -1)
    	if i == 0 {
    		close(wg.done)
    	}
    }
    
    func (wg *WaitGroup) C() <-chan struct{} {
    	return wg.done
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/pod_cache_test.go

    	netns2 := p.UpsertPodCacheWithNetns(string(pod.UID), wl2)
    	if netns2 != ns {
    		t.Fatalf("Expected the original Netns for the same uid, got %p and %p", netns2, ns)
    	}
    	if !ns2.closed.Load() {
    		t.Fatalf("Expected the second Netns to be closed")
    	}
    }
    
    func TestDoubleTake(t *testing.T) {
    	p := newPodNetnsCache(openNsTestOverride)
    
    	pod := &corev1.Pod{ObjectMeta: metav1.ObjectMeta{UID: "testUID"}}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/fakes_test.go

    	return &fakeNs{closed: &atomic.Bool{}, fd: fd, inode: inode}
    }
    
    // Fd returns the file descriptor
    func (f *fakeNs) Fd() uintptr {
    	return f.fd
    }
    
    func (f *fakeNs) Inode() uint64 {
    	return f.inode
    }
    
    // Close simulates closing the file descriptor and returns nil for no error
    func (f *fakeNs) Close() error {
    	f.closed.Store(true)
    	return nil
    }
    
    func fakeFs() fs.FS {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  5. cni/pkg/pluginlistener/listener_test.go

    	f := filepath.Join(t.TempDir(), "test")
    	l, err := NewListener(f)
    	if err != nil {
    		t.Fatalf("unexpected error %v", err)
    	}
    	defer l.Close()
    	conn, err := connect(f)
    	if err != nil {
    		t.Fatalf("failed to connect %v", err)
    	}
    	conn.Close()
    }
    
    func connect(socket string) (*grpc.ClientConn, error) {
    	var opts []grpc.DialOption
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 21:58:32 GMT 2024
    - 1.4K bytes
    - Viewed (0)
  6. licenses/github.com/cheggaaa/pb/v3/LICENSE

    CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE....
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Apr 22 05:37:52 GMT 2020
    - 1.4K bytes
    - Viewed (0)
  7. licenses/github.com/go-jose/go-jose/v4/json/LICENSE

    SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
    LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
    DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
    THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
    (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Apr 08 17:05:56 GMT 2024
    - 1.4K bytes
    - Viewed (0)
  8. licenses/github.com/grafana/regexp/LICENSE

    SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
    LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
    DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
    THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
    (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 26 02:16:11 GMT 2022
    - 1.4K bytes
    - Viewed (0)
  9. licenses/github.com/grpc-ecosystem/grpc-gateway/v2/LICENSE

    ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
    (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
    LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
    ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
    (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Aug 17 16:44:02 GMT 2023
    - 1.5K bytes
    - Viewed (0)
  10. licenses/github.com/klauspost/compress/snappy/LICENSE

    SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
    LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
    DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
    THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
    (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Nov 30 19:13:15 GMT 2021
    - 1.5K bytes
    - Viewed (0)
Back to top