Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 151 - 160 of 210 for unpipe (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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 for
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 13.6K bytes
    - Click Count (0)
  4. 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 for
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 13.6K bytes
    - Click Count (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top