- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,995 for IsStream (0.15 sec)
-
tensorflow/c/experimental/stream_executor/stream_executor.cc
&HostCallbackTrampoline, ctx); } void DeallocateStream(Stream* stream) override { static_cast<CStream*>(stream)->Destroy(); } absl::Status BlockHostForEvent(Stream* stream, Event* event) { OwnedTFStatus c_status(TF_NewStatus()); SP_Event event_handle = static_cast<CEvent*>(event)->Handle(); stream_executor_->block_host_for_event(&device_, event_handle,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jun 14 07:39:19 UTC 2024 - 27.1K bytes - Viewed (0) -
internal/s3select/json/preader.go
continue } dst, ok := r.kvDstPool.Get().([]jstream.KVS) if !ok { dst = make([]jstream.KVS, 0, 1000) } d := jstream.NewDecoder(bytes.NewBuffer(in.input), 0).ObjectAsKVS() stream := d.Stream() all := dst[:0] for mv := range stream { var kvs jstream.KVS if mv.ValueType == jstream.Object { // This is a JSON object type (that preserves key
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Mar 05 04:57:35 UTC 2023 - 6.4K bytes - Viewed (0) -
testing/performance/src/templates/native-dependents-resources/googleTest/libs/googleTest/1.7.0/include/gtest/gtest-message.h
namespace testing { // The Message class works like an ostream repeater. // // Typical usage: // // 1. You stream a bunch of values to a Message object. // It will remember the text in a stringstream. // 2. Then you stream the Message object to an ostream. // This causes the text in the Message to be streamed // to the ostream. // // For example; // // testing::Message foo;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 9K bytes - Viewed (0) -
platforms/documentation/docs/src/snippets/native-binaries/google-test/groovy/libs/googleTest/1.7.0/include/gtest/gtest-message.h
namespace testing { // The Message class works like an ostream repeater. // // Typical usage: // // 1. You stream a bunch of values to a Message object. // It will remember the text in a stringstream. // 2. Then you stream the Message object to an ostream. // This causes the text in the Message to be streamed // to the ostream. // // For example; // // testing::Message foo;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java
@Execute @Secured({ ROLE, ROLE + VIEW }) public ActionResponse download(final String id) { if (stream(fessConfig.getIndexBackupAllTargets()).get(stream -> stream.anyMatch(s -> s.equals(id)))) { if ("system.properties".equals(id)) { return asStream(id).contentTypeOctetStream().stream(out -> { try (final ByteArrayOutputStream baos = new ByteArrayOutputStream()) {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 25.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/wsstream/legacy.go
// Deprecated: This WebSockets package under apiserver is no longer in use. // Please use the apimachinery version of the package at: // // k8s.io/apimachinery/pkg/util/httpstream/wsstream package wsstream import apimachinerywsstream "k8s.io/apimachinery/pkg/util/httpstream/wsstream" // Aliases for all exported symbols previously in "conn.go" const ( ChannelWebSocketProtocol = apimachinerywsstream.ChannelWebSocketProtocol
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 07 18:21:43 UTC 2023 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/responsewriters/writers.go
out, flush, contentType, err := stream.InputStream(req.Context(), gv.String(), req.Header.Get("Accept")) if err != nil { ErrorNegotiated(err, s, gv, w, req) return } if out == nil { // No output provided - return StatusNoContent w.WriteHeader(http.StatusNoContent) return } defer out.Close() if wsstream.IsWebSocketRequest(req) { r := wsstream.NewReader(out, true, wsstream.NewDefaultReaderProtocols())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 07 18:21:43 UTC 2023 - 10.6K bytes - Viewed (0) -
tensorflow/c/experimental/stream_executor/stream_executor_internal.h
SP_Event event_handle_; }; class CStream : public StreamCommon { public: CStream(SP_Device* device, SP_StreamExecutor* stream_executor, StreamExecutor* executor) : StreamCommon(executor), device_(device), stream_executor_(stream_executor), stream_handle_(nullptr) {} ~CStream() override { parent()->BlockHostUntilDone(this).IgnoreError();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jun 14 07:39:19 UTC 2024 - 8K bytes - Viewed (0) -
internal/s3select/json/reader.go
} return nil, io.EOF } var kvs jstream.KVS if v.ValueType == jstream.Object { // This is a JSON object type (that preserves key // order) kvs = v.Value.(jstream.KVS) } else { // To be AWS S3 compatible Select for JSON needs to // output non-object JSON as single column value // i.e. a map with `_1` as key and value as the // non-object. kvs = jstream.KVS{jstream.KV{Key: "_1", Value: v.Value}} }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 24 03:58:53 UTC 2022 - 3K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/internal/mlir_pass_instrumentation_test.cc
void runBeforePass(Pass* pass, Operation* op) override { StringStream stream; op->print(stream, mlir::OpPrintingFlags().useLocalScope()); ops_seen_by_pass_[pass] = stream.ss.str(); } void runAfterPass(Pass* pass, Operation* op) override { StringStream stream; op->print(stream, mlir::OpPrintingFlags().useLocalScope()); if (!absl::StrContains(stream.ss.str(), kTestInstrumentationSearch) &&
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Sep 19 22:54:26 UTC 2023 - 3.9K bytes - Viewed (0)