- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 357 for gallery (0.2 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
fun metadata(): ByteString = metadata /** * Returns a new source that returns the same bytes as upstream. Returns null if this relay has * been closed and no further sources are possible. In that case callers should retry after * building a new relay with [.read]. */ fun newSource(): Source? { synchronized(this@Relay) { if (file == null) return null sourceCount++ }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
func handleNamespace(istioNamespace string) string { if istioNamespace == "" { istioNamespace = constants.IstioSystemNamespace } return istioNamespace } // TODO(nmittler): Remove this once Pilot migrates to galley schema. func convertObjectFromUnstructured(schema resource.Schema, un *unstructured.Unstructured, domain string) (*config.Config, error) { data, err := fromSchemaAndJSONMap(schema, un.Object["spec"]) if err != nil {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Jan 22 17:58:52 GMT 2024 - 15K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Interceptor.kt
* * Other exception types cancel the current call: * * * For synchronous calls made with [Call.execute], the exception is propagated to the caller. * * * For asynchronous calls made with [Call.enqueue], an [IOException] is propagated to the caller * indicating that the call was canceled. The interceptor's exception is delivered to the current
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/posix/copy_file_portable.cc
std::unique_ptr<char[]> buffer(new char[kPosixCopyFileBufferSize]); off_t offset = 0; int bytes_transferred = 0; int rc = 1; // When `sendfile` returns 0 we stop copying and let callers handle this. while (offset < size && rc > 0) { size_t chunk = size - offset; if (chunk > kPosixCopyFileBufferSize) chunk = kPosixCopyFileBufferSize; rc = read(src_fd, buffer.get(), chunk);
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Fri Nov 22 21:23:55 GMT 2019 - 1.9K bytes - Viewed (0) -
internal/grid/stream.go
"errors" ) // A Stream is a two-way stream. // All responses *must* be read by the caller. // If the call is canceled through the context, // the appropriate error will be returned. type Stream struct { // responses from the remote server. // Channel will be closed after error or when remote closes. // All responses *must* be read by the caller until either an error is returned or the channel is closed.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0) -
guava/src/com/google/common/base/Verify.java
} } /* * For a discussion of the signature of verifyNotNull, see the discussion above * Preconditions.checkNotNull. * * (verifyNotNull has many fewer "problem" callers, so we could try to be stricter. On the other * hand, verifyNotNull arguably has more reason to accept nullable arguments in the first * place....) */ /**
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Mon May 17 14:07:47 GMT 2021 - 18.5K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Preconditions.java
boolean expression, /* * TODO(cpovirk): Consider removing @CheckForNull here, as we've done with the other methods' * errorMessageTemplate parameters: It is unlikely that callers intend for their string * template to be null (though we do handle that case gracefully at runtime). I've left this * one as it is because one of our users has defined a wrapper API around Preconditions,
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Apr 11 11:52:14 GMT 2024 - 52.9K bytes - Viewed (0) -
internal/http/close.go
// convenient wrapper to drain any remaining data on response body. // // Subsequently this allows golang http RoundTripper // to reuse the same connection for future requests. func DrainBody(respBody io.ReadCloser) { // Callers should close resp.Body when done reading from it. // If resp.Body is not closed, the Client's underlying RoundTripper // (typically Transport) may not be able to reuse a persistent TCP
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 1.7K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/posix/posix_filesystem_helper.h
#include <dirent.h> #include <sys/stat.h> namespace tf_posix_filesystem { // Copies up to `size` of `src` to `dst`, creating destination if needed. // // Callers should pass size of `src` in `size` and the permissions of `src` in // `mode`. The later is only used if `dst` needs to be created. int TransferFileContents(const char* src, const char* dst, mode_t mode,
C - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Fri Nov 22 21:23:55 GMT 2019 - 1.5K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/posix/copy_file_linux.cc
int CopyFileContents(int dst_fd, int src_fd, off_t size) { off_t offset = 0; int bytes_transferred = 0; int rc = 1; // When `sendfile` returns 0 we stop copying and let callers handle this. while (offset < size && rc > 0) { // Use uint64 for safe compare SSIZE_MAX uint64_t chunk = size - offset; if (chunk > SSIZE_MAX) chunk = SSIZE_MAX;
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Fri Nov 22 21:23:55 GMT 2019 - 1.5K bytes - Viewed (0)