- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 89 for Hencke (0.22 sec)
-
cmd/listen-notification-handlers.go
return } } rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()}) setEventStreamHeaders(w) // Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers. // Use buffered channel to take care of burst sends or slow w.Write() mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames()))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
internal/pubsub/pubsub.go
maxSubscribers int32 // not atomics: subs []*Sub[T] sync.RWMutex } // Publish message to the subscribers. // Note that publish is always non-blocking send so that we don't block on slow receivers. // Hence receivers should use buffered channel so as not to miss the published events. func (ps *PubSub[T, M]) Publish(item T) { ps.RLock() defer ps.RUnlock() for _, sub := range ps.subs {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Viewed (0) -
cmd/bitrot-streaming.go
// sequent of operations: // 1) pipe.Write() // 2) pipe.Close() // Now pipe.Close() can return before the data is read on the other end of the pipe and written to the disk // Hence an immediate Read() on the file can return incorrect data. if b.canClose != nil { b.canClose.Wait() } return err } // newStreamingBitrotWriterBuffer returns streaming bitrot writer implementation.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 5.8K bytes - Viewed (0) -
tensorflow/c/eager/gradients.h
// maintains the map from `op_id` to a `OpTapeEntry` which stores the `op_type`, // inputs and outputs and the gradient function These data structures combined // allow us to trace the data dependencies between operations and hence compute // gradients. // // `ZerosLike` is not expected to be called and returns a nullptr. The creation // of default zeros grads is handled by the `DefaultGradientFunction` registered // for each op.
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Mon Sep 26 10:27:05 GMT 2022 - 6.9K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/Project.java
} /** * Returns the project artifacts as immutable list. Elements are the project POM artifact and the artifact * produced by this project build, if applicable. Hence, the returned list may have one or two elements * (never less than 1, never more than 2), depending on project packaging. * <p>
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Mon Feb 05 09:42:51 GMT 2024 - 7.4K bytes - Viewed (0) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/components/KtFe10CallResolver.kt
if (targetDescriptor.isSynthesizedPropertyFromJavaAccessors()) { // FE1.0 represents synthesized properties as an extension property of the Java class. Hence we use the extension receiver as // the dispatch receiver and always pass null for extension receiver (because in Java there is no way to specify an extension // receiver)
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Thu Mar 14 06:10:31 GMT 2024 - 36.4K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/plugin/internal/DefaultPluginValidationManager.java
@Singleton @Named public final class DefaultPluginValidationManager extends AbstractEventSpy implements PluginValidationManager { /** * The collection of "G:A" combinations that do NOT belong to Maven Core, hence, should be excluded from * "expected in provided scope" type of checks. */ static final Collection<String> EXPECTED_PROVIDED_SCOPE_EXCLUSIONS_GA = Collections.unmodifiableCollection(Arrays.asList(
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Sun Nov 19 21:11:13 GMT 2023 - 17.4K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/Session.java
* Note: Project properties contains properties injected from profiles, if applicable. Their precedence is * {@code profile > project}, hence active profile property may override project property. * <p> * The caller of this method should decide whether there is a project in scope (hence, a project instance * needs to be passed) or not. * * @param project {@link Project} or {@code null}.
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Fri Mar 01 17:18:13 GMT 2024 - 30K bytes - Viewed (0) -
guava/src/com/google/common/base/Splitter.java
* containing {@code ["a", "b", "c,d"]}. When omitting empty strings, the omitted strings do not * count. Hence, {@code Splitter.on(',').limit(3).omitEmptyStrings().split("a,,,b,,,c,d")} returns * an iterable containing {@code ["a", "b", "c,d"]}. When trim is requested, all entries are * trimmed, including the last. Hence {@code Splitter.on(',').limit(3).trimResults().split(" a , b * , c , d ")} results in {@code ["a", "b", "c , d"]}. *
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 24.4K bytes - Viewed (0) -
cmd/signature-v4-utils.go
case "content-length": // Signature-V4 spec excludes Content-Length from signed headers list for signature calculation. // But some clients deviate from this rule. Hence we consider Content-Length for signature // calculation to be compatible with such clients. extractedSignedHeaders.Set(header, strconv.FormatInt(r.ContentLength, 10)) default: return nil, ErrUnsignedHeaders }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Jan 31 18:56:45 GMT 2024 - 9K bytes - Viewed (0)