Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for getFff (0.36 sec)

  1. src/test/java/org/codelibs/core/beans/impl/PropertyDescImplTest.java

             */
            public void setEee(final String eee) {
            }
    
            /**
             * @return int
             */
            public int getFff() {
                return fff_;
            }
    
            /**
             * @param fff
             */
            public void setFff(final int fff) {
                fff_ = fff;
            }
    
            /**
             * @return String
             */
            public String getJjj() {
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 11.1K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/podcgroupns.go

    	if err != nil {
    		return nil, err
    	}
    	if filter != nil && !filter.Contains(uid) {
    		return nil, nil
    	}
    
    	netns, err := proc.Open(netnsName)
    	if err != nil {
    		return nil, err
    	}
    	fd, err := GetFd(netns)
    	if err != nil {
    		netns.Close()
    		return nil, err
    	}
    	netnsObserved[inode] = struct{}{}
    	log.Debugf("found pod to netns: %s %d", uid, inode)
    
    	return &PodNetnsEntry{
    		uid:     uid,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 11K bytes
    - Viewed (0)
  3. cmd/notification.go

    	}
    	wg.Add(1)
    	go func(ch chan madmin.ReplicationMRF) error {
    		defer wg.Done()
    		if node != "all" && node != globalLocalNodeName {
    			return nil
    		}
    		mCh, err := globalReplicationPool.getMRF(ctx, bucket)
    		if err != nil {
    			return err
    		}
    		for e := range mCh {
    			select {
    			case <-ctx.Done():
    				return err
    			case mrfCh <- e:
    			}
    		}
    		return nil
    	}(mrfCh)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  4. cmd/peer-rest-server.go

    		return
    	}
    
    	vars := mux.Vars(r)
    	bucketName := vars[peerRESTBucket]
    	ctx := newContext(r, w, "GetReplicationMRF")
    	re, err := globalReplicationPool.getMRF(ctx, bucketName)
    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    	enc := gob.NewEncoder(w)
    
    	for m := range re {
    		if err := enc.Encode(m); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  5. cmd/bucket-replication.go

    		}
    	}()
    
    	return nil
    }
    
    func (p *ReplicationPool) initialized() bool {
    	return !(p == nil || p.objLayer == nil)
    }
    
    // getMRF returns MRF entries for this node.
    func (p *ReplicationPool) getMRF(ctx context.Context, bucket string) (ch <-chan madmin.ReplicationMRF, err error) {
    	mrfRec, err := p.loadMRF()
    	if err != nil {
    		return nil, err
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
Back to top