Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 59 for strnames (0.13 sec)

  1. analysis/analysis-api-standalone/tests/org/jetbrains/kotlin/analysis/api/standalone/fir/test/cases/session/builder/sessionBuilderTestUtils.kt

    import java.nio.file.Path
    import java.nio.file.Paths
    import java.time.LocalDateTime
    import java.time.ZoneOffset
    import kotlin.io.path.absolutePathString
    import kotlin.io.path.extension
    import kotlin.streams.asSequence
    
    internal fun testDataPath(path: String): Path {
        return Paths.get("analysis/analysis-api-standalone/testData/sessionBuilder").resolve(path)
    }
    
    fun KtCallExpression.assertIsCallOf(callableId: CallableId) {
    Registered: Wed Jun 12 09:53:16 UTC 2024
    - Last Modified: Wed Jun 05 16:16:39 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/doc.go

    // which is sent as the first byte of the message. The second byte is the channel
    // id. This CLOSE signal is handled by the websocket server by closing the stream,
    // allowing the other streams to complete transmission if necessary, and gracefully
    // shutdown the connection.
    //
    // Example client session:
    //
    //	CONNECT http://server.com with subprotocol "v5.channel.k8s.io"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 05 18:37:18 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  3. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/store/ResolutionResultsStoreFactory.java

                }
            };
        }
    
        //offset based implementation is only safe up to certain figure
        //because of the int max value
        //for large streams/files (huge builds), we need to roll the file
        //otherwise the stream.size() returns max integer and the offset is no longer correct
        private boolean isFull(DefaultBinaryStore store) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Oct 10 21:10:11 UTC 2023
    - 5K bytes
    - Viewed (0)
  4. platforms/ide/tooling-api/src/main/java/org/gradle/tooling/BuildController.java

         *
         * <p>The build action will fail if the client application did not register a listener to receive the streamed objects.</p>
         *
         * @since 8.6
         */
        @Incubating
        <T> void send(T value);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Dec 19 19:46:37 UTC 2023
    - 9.7K bytes
    - Viewed (0)
  5. platforms/jvm/testing-jvm/src/integTest/groovy/org/gradle/testing/AbstractTestOutputListenerIntegrationTest.groovy

            when:
            succeeds('test')
    
            then:
            outputContains('first: message from foo')
            outputContains('second: message from foo')
        }
    
        def "shows standard streams configured via closure"() {
            given:
            def test = file("src/test/java/SomeTest.java")
            test << """
                ${testFrameworkImports}
    
                public class SomeTest {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Sep 18 20:52:40 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  6. subprojects/core/src/main/java/org/gradle/api/internal/initialization/transform/utils/InstrumentationClasspathMerger.java

                .map(ClassPathTransformedArtifact::ofTransformedArtifact)
                // We sort based on the original classpath to we keep the original order,
                // we also rely on the fact that for ordered streams `sorted()` method has stable sort.
                .sorted((first, second) -> ordering.compare(first.originalIdentifier, second.originalIdentifier))
                .map(artifact -> artifact.file)
                .collect(Collectors.toList());
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Feb 29 19:11:55 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  7. tensorflow/compiler/jit/xla_tensor.cc

      return absl::OkStatus();
    }
    
    void XlaTensor::WaitForDefinitionEventOnStream(se::Stream* stream) {
      mutex_lock lock(mu_);
      if (!definition_event_) {
        return;
      }
    
      // The set of defined streams is expected to be very small indeed (usually
      // 1-2), so a simple linear scan should be fast enough.
      if (std::find(streams_defined_on_.begin(), streams_defined_on_.end(),
                    stream) != streams_defined_on_.end()) {
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Feb 22 08:47:20 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  8. tensorflow/compiler/mlir/tfrt/tests/tf_to_corert/basic.mlir

    // RUN: tf-tfrt-opt -pass-pipeline='builtin.module(func.func(tf-tensor-device-copy),tfrt-lower-tf-savedmodel{hoist-invariant-ops=true},tf-to-tfrt{tfrt-cost-threshold=1024 tfrt-merge-inter-dependent-streams=true})' %s | FileCheck %s --dump-input-filter=all
    
    // CHECK-NOT: tf_saved_model.semantics
    // CHECK: tfrt.cost_threshold = 1024
    // CHECK-SAME: tfrt.merge_inter_dependent_streams = true
    module attributes {tf_saved_model.semantics} {
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed May 08 00:18:59 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  9. platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/connection/ProviderOperationParameters.java

         * @since 7.6
         */
        Map<String, String> getSystemProperties(Map<String, String> defaultValue);
    
        /**
         * Handles a value streamed from the build action. Blocks until the value has been handled.
         *
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Dec 19 19:46:37 UTC 2023
    - 5K bytes
    - Viewed (0)
  10. platforms/core-runtime/serialization/src/test/groovy/org/gradle/internal/serialize/kryo/KryoBackedCodecTest.groovy

                    assert nested.readString() == "chunked"
                }
                assert decoder.readString() == "done"
            }
        }
    
        def "can encode and decode multiple byte streams"() {
            when:
            def bytes = encode { Encoder encoder ->
                encoder.encodeChunked { Encoder nested ->
                    nested.writeSmallInt(1)
                    nested.writeString("chunked")
                }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Apr 15 16:06:56 UTC 2024
    - 5.2K bytes
    - Viewed (0)
Back to top