Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 57 for getSources (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top