GetStream - Code Search

platforms/core-runtime/io/src/main/java/org/gradle/internal/io/LinePerThreadBufferingOutputStream.java

        getStream().print(c);
    }

    @Override
    public void print(double d) {
        getStream().print(d);
    }

    @Override
    public void print(float f) {
        getStream().print(f);
    }

    @Override
    public void print(int i) {
        getStream().print(i);
    }

    @Override
    public void print(long l) {
        getStream().print(l);
    }

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Fri Apr 12 08:51:14 UTC 2024

- 6K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/core-configuration/model-core/src/test/groovy/org/gradle/model/internal/inspect/ManagedModelInitializerTest.groovy

    - An unmanaged property (i.e. annotated with @Unmanaged)""")
    }

    @Managed
    interface ManagedReadWriteWithInvalidProperty {
        FileInputStream getStream()

        void setStream(FileInputStream stream)
    }

    def "should fail with a reasonable exception when a type is not managed and not constructible"() {
        when:
        realizeNodeOfType(NonManaged)

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Thu Sep 28 09:51:04 UTC 2023

- 12.9K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/compiler/jit/kernels/xla_ops.cc

  VLOG(2) << "Executing Xla Computation.";
  Env* env = Env::Default();
  auto start_time = env->NowMicros();

  se::Stream* stream = GetStream(ctx);
  run_options.set_stream(GetStream(ctx));
  run_options.set_allocator(allocator);
  run_options.set_intra_op_thread_pool(&ctx->eigen_cpu_device());
  run_options.set_rng_seed(GetXLARandomSeed());

Registered: Sun Jun 16 05:45:23 UTC 2024

- Last Modified: Fri May 17 22:46:36 UTC 2024

- 41.4K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

        }
      }
    }
  }

  /**
   * Returns the number of [open streams][Http2Stream.isOpen] on this connection.
   */
  fun openStreamCount(): Int = this.withLock { streams.size }

  fun getStream(id: Int): Http2Stream? = this.withLock { streams[id] }

  internal fun removeStream(streamId: Int): Http2Stream? {
    this.withLock {
      val stream = streams.remove(streamId)

Registered: Sun Jun 16 04:42:17 UTC 2024

- Last Modified: Sat Apr 20 17:03:43 UTC 2024

- 32.6K bytes

- Viewed (0)

github.com/gradle/gradle

testing/performance/src/templates/native-dependents-resources/googleTest/libs/googleTest/1.7.0/include/gtest/internal/gtest-port.h

  ~GTestLog();

  ::std::ostream& GetStream() { return ::std::cerr; }

 private:
  const GTestLogSeverity severity_;

  GTEST_DISALLOW_COPY_AND_ASSIGN_(GTestLog);
};

#define GTEST_LOG_(severity) \
    ::testing::internal::GTestLog(::testing::internal::GTEST_##severity, \
                                  __FILE__, __LINE__).GetStream()

inline void LogToStderr() {}

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Thu Apr 04 07:21:38 UTC 2024

- 67.2K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/compiler/mlir/tensorflow/ir/tf_executor.cc

static constexpr int kDefaultParallelIterations = 10;

void EnterOp::print(OpAsmPrinter &p) {
  p << ' ';
  p.printOperands(getOperands());

  p << " frame \"";
  printEscapedString(getFrameName(), p.getStream());
  p << "\"";
  if (getParallelIterations() != kDefaultParallelIterations)
    p << " parallel_iterations " << getParallelIterations();
  if (getIsConstant()) p << " constant ";

Registered: Sun Jun 16 05:45:23 UTC 2024

- Last Modified: Thu Apr 25 16:01:03 UTC 2024

- 42.7K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/documentation/docs/src/snippets/native-binaries/google-test/groovy/libs/googleTest/1.7.0/include/gtest/internal/gtest-port.h

  ~GTestLog();

  ::std::ostream& GetStream() { return ::std::cerr; }

 private:
  const GTestLogSeverity severity_;

  GTEST_DISALLOW_COPY_AND_ASSIGN_(GTestLog);
};

#define GTEST_LOG_(severity) \
    ::testing::internal::GTestLog(::testing::internal::GTEST_##severity, \
                                  __FILE__, __LINE__).GetStream()

inline void LogToStderr() {}

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Mon Nov 27 17:53:42 UTC 2023

- 67.2K bytes

- Viewed (0)

github.com/minio/minio

internal/event/target/nats.go

			target.loggerOnce(context.Background(), err, target.ID().String())
		}
		return err
	}

	if target.natsConn != nil && args.JetStream.Enable {
		var jstream nats.JetStream
		jstream, err = target.natsConn.JetStream()
		if err != nil {
			if err.Error() != nats.ErrNoServers.Error() {
				target.loggerOnce(context.Background(), err, target.ID().String())
			}
			return err
		}

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Fri May 24 23:05:23 UTC 2024

- 12.8K bytes

- Viewed (0)

github.com/square/okhttp

okhttp-android/src/main/baseline-prof.txt

HSPLokhttp3/internal/http2/Http2Connection;->close$okhttp(Lokhttp3/internal/http2/ErrorCode;Lokhttp3/internal/http2/ErrorCode;Ljava/io/IOException;)V
HSPLokhttp3/internal/http2/Http2Connection;->getStream(I)Lokhttp3/internal/http2/Http2Stream;
HSPLokhttp3/internal/http2/Http2Connection;->pushedStream$okhttp(I)Z
HSPLokhttp3/internal/http2/Http2Connection;->removeStream$okhttp(I)Lokhttp3/internal/http2/Http2Stream;

Registered: Sun Jun 16 04:42:17 UTC 2024

- Last Modified: Mon Mar 21 11:22:00 UTC 2022

- 127.9K bytes

- Viewed (0)

github.com/minio/minio

internal/config/notify/help.go

			Description: "client cert key for NATS mTLS auth",
			Optional:    true,
			Type:        "string",
			Sensitive:   true,
		},
		config.HelpKV{
			Key:         target.NATSJetStream,
			Description: "enable JetStream support",
			Optional:    true,
			Type:        "on|off",
		},
		config.HelpKV{
			Key:         target.NATSQueueDir,
			Description: queueDirComment,
			Optional:    true,
			Type:        "path",

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Tue Mar 19 04:37:54 UTC 2024

- 18.8K bytes

- Viewed (0)

Search Options