- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 57 for getSources (0.08 sec)
-
cmd/namespace-lock.go
opsID string } // Lock - block until write lock is taken or timeout has occurred. func (di *distLockInstance) GetLock(ctx context.Context, timeout *dynamicTimeout) (LockContext, error) { lockSource := getSource(2) start := UTCNow() newCtx, cancel := context.WithCancel(ctx) if !di.rwMutex.GetLock(newCtx, cancel, di.opsID, lockSource, dsync.Options{ Timeout: timeout.Timeout(),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 9.2K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/ModelBuilderRequest.java
*/ REQUEST_DOMINANT, } @Nonnull Session getSession(); @Nonnull ModelSource getSource(); @Nonnull RequestType getRequestType(); boolean isLocationTracking(); boolean isRecursive(); /** * Defines external profiles that may be activated for the given model.
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Wed Oct 09 11:07:31 UTC 2024 - 13.3K bytes - Viewed (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/io/DefaultModelReader.java
Object value = (options != null) ? options.get(IS_STRICT) : null; return value == null || Boolean.parseBoolean(value.toString()); } private InputSource getSource(Map<String, ?> options) { Object value = (options != null) ? options.get(INPUT_SOURCE) : null; return (InputSource) value; } private Path getRootDirectory(Map<String, ?> options) {
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 5.8K bytes - Viewed (0) -
guava-testlib/test/com/google/common/collect/testing/features/FeatureUtilTest.java
assertThrows( ConflictingRequirementsException.class, () -> buildTesterRequirements(Tester.class)); assertThat(e.getConflicts()).containsExactly(FOO); assertThat(e.getSource()).isEqualTo(Tester.class.getAnnotation(Require.class)); } public void testBuildTesterRequirements_classClassConflict_inherited() { @Require(FOO) abstract class BaseTester {} @Require(absent = FOO)
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 05 22:05:05 UTC 2024 - 11.5K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/profiles/DefaultProfileManager.java
Profile existing = profilesById.get(profileId); if (existing != null) { logger.warn("Overriding profile: '" + profileId + "' (source: " + existing.getSource() + ") with new instance from source: " + profile.getSource()); } profilesById.put(profile.getId(), profile); Activation activation = profile.getActivation();
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 6.7K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/features/ConflictingRequirementsException.java
super(message); this.conflicts = conflicts; this.source = source; } public Set<Feature<?>> getConflicts() { return conflicts; } public Object getSource() { return source; } @Override public String getMessage() { return super.getMessage() + " (source: " + source + ")"; } private static final long serialVersionUID = 0;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 1.4K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/RealStream.kt
import okio.buffer /** Adapt OkHttp's internal [Http2Stream] type to the public [Stream] type. */ internal class RealStream( private val http2Stream: Http2Stream, ) : Stream { override val requestBody = http2Stream.getSource().buffer() override val responseBody = http2Stream.getSink().buffer() override fun cancel() { http2Stream.closeLater(ErrorCode.CANCEL) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Dec 31 18:24:52 UTC 2022 - 1.1K bytes - Viewed (0) -
compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/AbstractMojoExecutionException.java
*/ public AbstractMojoExecutionException(Throwable cause) { super(cause); } public String getLongMessage() { return longMessage; } public Object getSource() { return source; }
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 1.8K bytes - Viewed (0) -
internal/logger/console.go
} else { message = fmt.Sprint(args...) } logJSON, err := json.Marshal(&log.Entry{ Level: FatalKind, Message: message, Time: time.Now().UTC(), Trace: &log.Trace{Message: message, Source: []string{getSource(6)}}, }) if err != nil { panic(err) } fmt.Fprintln(Output, string(logJSON)) ExitFunc(1) } func (f fatalMsg) quiet(msg string, args ...interface{}) { f.pretty(msg, args...) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 7.5K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/aether/ReverseTreeRepositoryListener.java
indent += " "; InputLocation location = plugin.getLocation(""); if (location != null && location.getSource() != null) { trackingData.add(indent + location.getSource().getModelId() + " (implicit)"); indent += " "; } } else if (collectStepTrace != null) {
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 9.8K bytes - Viewed (0)