- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 738 for STREAM (1.05 sec)
-
tensorflow/compiler/jit/xla_device.h
// performed by host_to_device/device_to_device stream or borrowing a stream // for each device to host transfer. const bool use_multiple_streams_; // If use_multiple_streams_, host to device transfers are performed using this // stream. std::shared_ptr<se::Stream> host_to_device_stream_ TF_GUARDED_BY(mu_);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 21 09:53:30 UTC 2024 - 13.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableSetMultimap.java
*/ @GwtIncompatible // java.io.ObjectOutputStream @J2ktIncompatible private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(valueComparator()); Serialization.writeMultimap(this, stream); } @CheckForNull Comparator<? super V> valueComparator() { return emptySet instanceof ImmutableSortedSet
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sun Jun 02 13:36:19 UTC 2024 - 23.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SearchLogHelper.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 20.8K bytes - Viewed (0) -
internal/grid/handlers.go
for req := range reqT { b, err := req.MarshalMsg(GetByteBufferCap(req.Msgsize())) if err != nil { gridLogOnceIf(ctx, err, err.Error()) } h.PutRequest(req) stream.Requests <- b } }() } else if stream.Requests != nil { xioutil.SafeClose(stream.Requests) } return &TypedStream[Req, Resp]{responses: stream, newResp: h.NewResponse, Requests: reqT}, nil
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.1K bytes - Viewed (0) -
platforms/software/resources/src/test/groovy/org/gradle/internal/resource/local/LocalFileStandInExternalResourceTest.groovy
} def "can copy file contents to a stream"() { def file = tmpDir.createFile("content") file.text = "1234" expect: def resource = new LocalFileStandInExternalResource(file, TestFiles.fileSystem()) def stream = new ByteArrayOutputStream() def result = resource.writeTo(stream) result.bytesRead == 4 stream.toString() == "1234" file.setText("abc")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 14K bytes - Viewed (0) -
guava/src/com/google/common/collect/ImmutableSetMultimap.java
*/ @GwtIncompatible // java.io.ObjectOutputStream @J2ktIncompatible private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(valueComparator()); Serialization.writeMultimap(this, stream); } @CheckForNull Comparator<? super V> valueComparator() { return emptySet instanceof ImmutableSortedSet
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 23.1K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_launch_util.cc
// separate stream from the main compute stream. We must ensure the // compute stream is synchronized with the host->device transfer // stream now otherwise we will create a race condition. auto* gpu_device_context = static_cast<GPUDeviceContext*>(ctx->op_device_context()); TF_RETURN_IF_ERROR(gpu_device_context->stream()->WaitFor(
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 16 00:36:08 UTC 2024 - 40.4K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/verification/writer/WriteDependencyVerificationFile.java
.flatMap(avm -> Stream.concat(avm.getTrustedPgpKeys().stream(), avm.getIgnoredPgpKeys().stream().map(IgnoredKey::getKeyId))) .forEach(keysToExport::add); exportKeyRingCollection( signatureVerificationService.getPublicKeyService(), existingKeyring, keysToExport, verifier.getConfiguration().getKeyringFormat() ); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 30.3K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/excludes/factories/Intersections.java
} @Override public ExcludeSpec doIntersect(ModuleSetExclude left, GroupSetExclude right, ExcludeFactory factory) { return factory.moduleIdSet(right.getGroups().stream().flatMap(group -> left.getModules().stream().map(module -> DefaultModuleIdentifier.newId(group, module))).collect(toSet())); } } @NonNullApi
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Feb 23 21:03:05 UTC 2024 - 21.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
* weight from the default (16) to a new value. * * @param streamId stream which has a priority change. * @param streamDependency the stream ID this stream is dependent on. * @param weight relative proportion of priority in `[1..256]`. * @param exclusive inserts this stream ID as the sole child of `streamDependency`. */ fun priority( streamId: Int,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 19.9K bytes - Viewed (0)