Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 207 for Shardz (0.11 sec)

  1. cmd/notification.go

    	// To avoid these problems we must split the work at scale. With 1000 node
    	// setup becoming a reality we must try to shard the work properly such as
    	// pick 10 nodes that precisely can send those 100 requests the first node
    	// in the 10 node shard would coordinate between other 9 shards to get the
    	// rest of the `99*9` requests.
    	//
    	// This essentially splits the workload properly and also allows for network
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 44.9K bytes
    - Viewed (0)
  2. platforms/core-configuration/model-core/src/main/java/org/gradle/api/internal/provider/DefaultProperty.java

            // TODO(mlopatkin) while calling getProvider is not going to cause StackOverflowError by itself, the returned provider is typically used in some recursive call.
            //  Without the safety net of the EvaluationContext, it can cause hard-to-debug exceptions.
            try (EvaluationContext.ScopeContext context = openScope()) {
                return getSupplier(context);
            }
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 29 05:33:15 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/endpointslice.go

    		v1beta1.LabelServiceName: name,
    	}).AsSelectorPreValidated().Add(*endpointSliceRequirement)
    }
    
    func (esc *endpointSliceController) pushEDS(hostnames []host.Name, namespace string) {
    	shard := model.ShardKeyFromRegistry(esc.c)
    	// Even though we just read from the cache, we need the full lock to ensure pushEDS
    	// runs sequentially when `EnableK8SServiceSelectWorkloadEntries` is enabled. Otherwise,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  4. src/internal/coverage/cfile/emit.go

    		" fnID:", fnID, " numCtrs:", nCtrs)
    	println("list of hard-coded runtime package IDs needs revising.")
    	println("[see the comment on the 'rtPkgs' var in ")
    	println(" <goroot>/src/internal/coverage/pkid.go]")
    	println("registered list:")
    	for k, b := range metaList {
    		print("slot: ", k, " path='", b.PkgPath, "' ")
    		if b.PkgID != -1 {
    			print(" hard-coded id: ", b.PkgID)
    		}
    		println("")
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 09:57:47 UTC 2024
    - 18.9K bytes
    - Viewed (0)
  5. tensorflow/compiler/mlir/lite/transforms/split_merged_operands.cc

    // been converted to constants, all the assign ops are gone, etc.). However,
    // TFLite has these variable tensors semantics. So the variable mapping from TF
    // to TFLite is actually broken here, we sort of hard-code the variable tensors
    // based on the actual ops using them, such as unidirectional_sequence_lstm.
    //
    // MLIRConverter also benefits from lots of typical compiler optimization like
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Apr 24 20:30:06 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  6. docs/en/data/people.yml

      url: https://github.com/alejsdev
    - login: hard-coders
      count: 10
      avatarUrl: https://avatars.githubusercontent.com/u/9651103?u=95db33927bbff1ed1c07efddeb97ac2ff33068ed&v=4
      url: https://github.com/hard-coders
    - login: KaniKim
      count: 10
      avatarUrl: https://avatars.githubusercontent.com/u/19832624?u=40f8f7f3f36d5f2365ba2ad0b40693e60958ce70&v=4
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Mon Jun 03 01:09:53 UTC 2024
    - 55.4K bytes
    - Viewed (0)
  7. pkg/registry/core/service/strategy.go

    		if a[i] != b[i] {
    			return false
    		}
    	}
    	return true
    }
    
    // This is an unusual case.  Service has a number of inter-related fields and
    // in order to avoid breaking clients we try really hard to infer what users
    // mean when they change them.
    //
    // Services are effectively a discriminated union, where `type` is the
    // discriminator. Some fields just don't make sense with some types, so we
    // clear them.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 13:09:36 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  8. src/sync/pool.go

    // the result of calling p.New.
    func (p *Pool) Get() any {
    	if race.Enabled {
    		race.Disable()
    	}
    	l, pid := p.pin()
    	x := l.private
    	l.private = nil
    	if x == nil {
    		// Try to pop the head of the local shard. We prefer
    		// the head over the tail for temporal locality of
    		// reuse.
    		x, _ = l.shared.popHead()
    		if x == nil {
    			x = p.getSlow(pid)
    		}
    	}
    	runtime_procUnpin()
    	if race.Enabled {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  9. src/net/dnsclient.go

    // trailing dot to match pure Go reverse resolver and all other lookup
    // routines.
    // See golang.org/issue/12189.
    // But we don't want to add dots for local names from /etc/hosts.
    // It's hard to tell so we settle on the heuristic that names without dots
    // (like "localhost" or "myhost") do not get trailing dots, but any other
    // names do.
    func absDomainName(s string) string {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:53 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  10. src/runtime/mstats.go

    	}
    }
    
    // unsafeRead aggregates the delta for this shard into out.
    //
    // Unsafe because it does so without any synchronization. The
    // world must be stopped.
    func (m *consistentHeapStats) unsafeRead(out *heapStatsDelta) {
    	assertWorldStopped()
    
    	for i := range m.stats {
    		out.merge(&m.stats[i])
    	}
    }
    
    // unsafeClear clears the shard.
    //
    // Unsafe because the world must be stopped and values should
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 08 21:03:13 UTC 2024
    - 34.2K bytes
    - Viewed (0)
Back to top