- Sort Score
- Num 10 results
- Language All
Results 151 - 160 of 210 for unpipe (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/metacache-set.go
return nil } readers := make([]*metacacheReader, len(disks)) defer func() { for _, r := range readers { r.Close() } }() for i := range disks { r, w := io.Pipe() // Make sure we close the pipe so blocked writes doesn't stay around. defer r.CloseWithError(context.Canceled) readers[i] = newMetacacheReader(r) d := disks[i] // Send request to each disk. go func() {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 30.7K bytes - Click Count (0) -
docs/site-replication/run-replication-with-checksum-header.sh
# Download AWS CLI echo -n "Download and install AWS CLI" rm -rf /usr/local/aws-cli || sudo rm -rf /usr/local/aws-cli curl "https://awscli.amazonaws.com/awscli-exe-linux-x86_64.zip" -o "awscliv2.zip" unzip -qq awscliv2.zip ./aws/install || sudo ./aws/install echo "done" # Add credentials to ~/.aws/credentials if ! [ -d ~/.aws ]; then mkdir -p ~/.aws fi cat >~/.aws/credentials <<EOF [enterprise]
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Jan 20 14:49:07 GMT 2025 - 11.5K bytes - Click Count (0) -
android/guava/src/com/google/common/graph/Graph.java
* Returns true if there is an edge that directly connects {@code endpoints} (in the order, if * any, specified by {@code endpoints}). This is equivalent to {@code * edges().contains(endpoints)}. * * <p>Unlike the other {@code EndpointPair}-accepting methods, this method does not throw if the * endpoints are unordered and the graph is directed; it simply returns {@code false}. This is forCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 13.6K bytes - Click Count (0) -
guava/src/com/google/common/graph/Graph.java
* Returns true if there is an edge that directly connects {@code endpoints} (in the order, if * any, specified by {@code endpoints}). This is equivalent to {@code * edges().contains(endpoints)}. * * <p>Unlike the other {@code EndpointPair}-accepting methods, this method does not throw if the * endpoints are unordered and the graph is directed; it simply returns {@code false}. This is forCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 13.6K bytes - Click Count (0) -
src/builtin/builtin.go
// details. func cap(v Type) int // The make built-in function allocates and initializes an object of type // slice, map, or chan (only). Like new, the first argument is a type, not a // value. Unlike new, make's return type is the same as the type of its // argument, not a pointer to it. The specification of the result depends on // the type: // // - Slice: The size specifies the length. The capacity of the slice is
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Dec 30 23:59:23 GMT 2024 - 12.8K bytes - Click Count (0) -
src/main/java/jcifs/smb1/smb1/SmbTransport.java
final int errorCode = Encdec.dec_uint32le(BUF, 9) & 0xFFFFFFFF; if (resp.command == ServerMessageBlock.SMB_COM_READ_ANDX && (errorCode == 0 || errorCode == 0x80000005)) { // overflow indicator normal for pipe final SmbComReadAndXResponse r = (SmbComReadAndXResponse) resp; int off = HEADER_LENGTH; /* WordCount thru dataOffset always 27 */ readn(in, BUF, 4 + off, 27);
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 31.8K bytes - Click Count (0) -
src/main/java/jcifs/smb1/smb1/SmbFile.java
* represents is a share. */ public static final int TYPE_SHARE = 0x08; /** * Returned by {@link #getType()} if the resource this {@code SmbFile} * represents is a named pipe. */ public static final int TYPE_NAMED_PIPE = 0x10; /** * Returned by {@link #getType()} if the resource this {@code SmbFile} * represents is a printer. */Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 112.2K bytes - Click Count (0) -
android/guava/src/com/google/common/io/CharSource.java
import java.util.Iterator; import java.util.List; import java.util.function.Consumer; import java.util.stream.Stream; import org.jspecify.annotations.Nullable; /** * A readable source of characters, such as a text file. Unlike a {@link Reader}, a {@code * CharSource} is not an open, stateful stream of characters that can be read and closed. Instead, * it is an immutable <i>supplier</i> of {@code Reader} instances. *Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 08 18:35:13 GMT 2025 - 25.7K bytes - Click Count (0) -
guava/src/com/google/common/collect/LinkedListMultimap.java
* multimap.put(key1, foo); * multimap.put(key2, bar); * multimap.put(key1, baz); * } * * ... the iteration order for {@link #keys()} is {@code [key1, key2, key1]}, and similarly for * {@link #entries()}. Unlike {@link LinkedHashMultimap}, the iteration order is kept consistent * between keys, entries and values. For example, calling: * * {@snippet : * multimap.remove(key1, foo); * } *
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 18:35:44 GMT 2025 - 27K bytes - Click Count (0) -
guava/src/com/google/common/io/CharSource.java
import java.util.Iterator; import java.util.List; import java.util.function.Consumer; import java.util.stream.Stream; import org.jspecify.annotations.Nullable; /** * A readable source of characters, such as a text file. Unlike a {@link Reader}, a {@code * CharSource} is not an open, stateful stream of characters that can be read and closed. Instead, * it is an immutable <i>supplier</i> of {@code Reader} instances. *Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 08 18:35:13 GMT 2025 - 25.3K bytes - Click Count (0)