- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 2,325 for strtab (0.13 sec)
-
tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem.cc
if (TF_GetCode(status) != TF_OK) return -1; auto stream = gcs_file->gcs_client.ReadObject( bucket, object, gcs::ReadRange(offset, offset + buffer_size)); TF_SetStatusFromGCSStatus(stream.status(), status); if ((TF_GetCode(status) != TF_OK) && (TF_GetCode(status) != TF_OUT_OF_RANGE)) { return -1; } int64_t read; auto content_length = stream.headers().find("content-length");
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 23 06:55:53 UTC 2023 - 46.9K bytes - Viewed (0) -
tensorflow/c/kernels.cc
status->status = absl::FailedPreconditionError( "Accessing device stream is not supported for a CPU device."); return nullptr; } else if (!cc_ctx->op_device_context()->IsPluggableDevice()) { status->status = absl::FailedPreconditionError( "Accessing device stream is only supported for pluggable devices."); return nullptr; } else { // Is a PluggableDevice
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue May 28 22:53:47 UTC 2024 - 36K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt
val task = serviceStreamTask(stream) results.add(task) task.run() } /** Returns a task that processes both request and response from [stream]. */ private fun serviceStreamTask(stream: Stream): FutureTask<Void> { return FutureTask<Void> { stream.requestBody.use { stream.responseBody.use { while (true) { val action = actions.poll() ?: break
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.2K bytes - Viewed (0) -
platforms/core-runtime/io/src/main/java/org/gradle/internal/io/LinePerThreadBufferingOutputStream.java
public void println(boolean x) { PrintStream stream = getStream(); synchronized (this) { stream.print(x); stream.print(lineSeparator); } } @Override public void println(char x) { PrintStream stream = getStream(); synchronized (this) { stream.print(x); stream.print(lineSeparator); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:14 UTC 2024 - 6K bytes - Viewed (0) -
src/main/java/org/codelibs/core/stream/StreamUtil.java
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/direction/FessProp.java
} return list.stream().map(p -> { final String key = p.getFirst(); if (StringUtil.isEmpty(key) || userBean .map(user -> stream(user.getRoles()).get(stream -> stream.anyMatch(s -> (ROLE_VALUE_PREFIX + s).equals(key))) || stream(user.getGroups()).get(stream -> stream.anyMatch(s -> (GROUP_VALUE_PREFIX + s).equals(key))))
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 85K bytes - Viewed (0) -
guava/src/com/google/common/collect/Serialization.java
Map<K, V> map, ObjectOutputStream stream) throws IOException { stream.writeInt(map.size()); for (Map.Entry<K, V> entry : map.entrySet()) { stream.writeObject(entry.getKey()); stream.writeObject(entry.getValue()); } } /** * Populates a map by reading an input stream, as part of deserialization. See {@link #writeMap} * for the data format. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Mar 06 16:06:58 UTC 2023 - 8.5K bytes - Viewed (0) -
platforms/core-runtime/daemon-services/src/test/groovy/org/gradle/internal/daemon/clientinput/StdInStreamTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 5.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/PopularWordHelper.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 5.6K bytes - Viewed (0) -
tensorflow/c/experimental/stream_executor/stream_executor_test.cc
TF_ASSERT_OK(stream->WaitFor(event.get())); ASSERT_TRUE(wait_called); } TEST_F(StreamExecutorTest, MemcpyToHost) { se_.create_stream = [](const SP_Device* const device, SP_Stream* stream, TF_Status* const status) -> void { *stream = new SP_Stream_st(14); }; se_.destroy_stream = [](const SP_Device* const device, SP_Stream stream) -> void { delete stream; };
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon May 20 19:54:04 UTC 2024 - 26.5K bytes - Viewed (0)