Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 27 of 27 for asReader (0.19 sec)

  1. pilot/pkg/leaderelection/leaderelection.go

    		ttl:   time.Second * 30,
    		cycle: atomic.NewInt32(0),
    		mu:    sync.RWMutex{},
    	}
    }
    
    func (l *LeaderElection) isLeader() bool {
    	l.mu.RLock()
    	defer l.mu.RUnlock()
    	if !l.enabled {
    		return true
    	}
    	if l.le == nil {
    		return false
    	}
    	return l.le.IsLeader()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 12 16:44:32 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  2. maven-compat/src/main/java/org/apache/maven/project/interpolation/AbstractStringBasedModelInterpolator.java

            serializedModel = interpolate(serializedModel, model, projectDir, config, debugEnabled);
    
            StringReader sReader = new StringReader(serializedModel);
    
            MavenStaxReader modelReader = new MavenStaxReader();
            try {
                model = new Model(modelReader.read(sReader));
            } catch (XMLStreamException e) {
                throw new ModelInterpolationException(
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Wed Sep 06 08:39:32 UTC 2023
    - 13.5K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    					if err := controlHandler(hdr, &wsReader); err != nil {
    						return nil, err
    					}
    					continue
    				}
    				if hdr.OpCode&want == 0 {
    					if err := wsReader.Discard(); err != nil {
    						return nil, err
    					}
    					continue
    				}
    				if int64(cap(dst)) < hdr.Length+1 {
    					dst = make([]byte, 0, hdr.Length+hdr.Length>>3)
    				}
    				return readAllInto(dst[:0], &wsReader)
    			}
    		}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  4. src/cmd/pack/pack.go

    				usage()
    			}
    			op = r
    		case 'v':
    			if verbose {
    				// Can be set only once.
    				usage()
    			}
    			verbose = true
    		default:
    			usage()
    		}
    	}
    }
    
    const (
    	arHeader = "!<arch>\n"
    )
    
    // An Archive represents an open archive file. It is always scanned sequentially
    // from start to end, without backing up.
    type Archive struct {
    	a        *archive.Archive
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 19:41:17 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  5. tensorflow/compiler/mlir/tensorflow/transforms/convert_control_to_data_outputs.cc

      for (auto class_iter = resource_equivalence_classes.begin();
           class_iter != resource_equivalence_classes.end(); ++class_iter) {
        // Only visit one element per class, the leader.
        if (!class_iter->isLeader()) continue;
    
        // Create chain source and sink identity islands for current equivalence
        // class.
        auto chain_arg = func.getArgument(chain_index++);
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Apr 25 16:01:03 UTC 2024
    - 28.7K bytes
    - Viewed (0)
  6. src/runtime/malloc.go

    				// Note: disabled when race detector is on, see comment near end of this function.
    				c.tiny = uintptr(x)
    				c.tinyoffset = size
    			}
    			size = maxTinySize
    		} else {
    			hasHeader := !noscan && !heapBitsInSpan(size)
    			if hasHeader {
    				size += mallocHeaderSize
    			}
    			var sizeclass uint8
    			if size <= smallSizeMax-8 {
    				sizeclass = size_to_class8[divRoundUp(size, smallSizeDiv)]
    			} else {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 59.6K bytes
    - Viewed (0)
  7. src/runtime/mbitmap.go

    			}
    		}
    	}
    	if !bad {
    		var addr uintptr
    		tp, addr = tp.next(x + span.elemsize)
    		if addr == 0 {
    			return
    		}
    		println("runtime: extra pointer:", hex(addr))
    	}
    	print("runtime: hasHeader=", header != nil, " typ.Size_=", typ.Size_, " hasGCProg=", typ.Kind_&abi.KindGCProg != 0, "\n")
    	print("runtime: x=", hex(x), " dataSize=", dataSize, " elemsize=", span.elemsize, "\n")
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 00:18:55 UTC 2024
    - 60K bytes
    - Viewed (0)
Back to top