Search Options

Results per page
Sort
Preferred Languages
Advance

Results 541 - 550 of 1,365 for Read (0.03 sec)

  1. android/guava-tests/benchmark/com/google/common/io/CharStreamsCopyBenchmark.java

      enum CopyStrategy {
        OLD {
          @Override
          long copy(Readable from, Appendable to) throws IOException {
            CharBuffer buf = CharStreams.createBuffer();
            long total = 0;
            while (from.read(buf) != -1) {
              ((Buffer) buf).flip();
              to.append(buf);
              total += buf.remaining();
              ((Buffer) buf).clear();
            }
            return total;
          }
        },
        NEW {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/smb1/TestLocking.java

                            //                      System.out.print('l');
                        } else if (r < 1.0) {
                            final InputStream in = f.getInputStream();
                            while (in.read(buf) > 0) {
                                //                          System.out.print('r');
                            }
                            in.close();
                        }
                    } catch (final IOException ioe) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/smb1/trans/TransTransactNamedPipeResponse.java

    import jcifs.internal.SMBProtocolDecodingException;
    
    /**
     * Response for SMB1 TRANS_TRANSACT_NAMED_PIPE transaction.
     *
     * This response contains the data returned from the named pipe
     * after a transact operation (write then read) has been completed.
     */
    public class TransTransactNamedPipeResponse extends SmbComTransactionResponse {
    
        private final byte[] outputBuffer;
    
        /**
         * Constructs a response for a named pipe transaction.
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.9K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/curl/CurlRequest.java

                                return new GZIPInputStream(con.getInputStream());
                            } else {
                                return con.getInputStream();
                            }
                        } else if ("head".equalsIgnoreCase(con.getRequestMethod())) {
                            return new ByteArrayInputStream(new byte[0]);
                        } else {
                            if (GZIP.equals(con.getContentEncoding())) {
    Registered: Thu Sep 04 15:34:10 UTC 2025
    - Last Modified: Sat Jul 05 01:38:18 UTC 2025
    - 17.8K bytes
    - Viewed (0)
  5. okhttp-testing-support/src/main/kotlin/okhttp3/JsseDebugLogging.kt

          Encrypted,
          Setup,
          Unknown,
        }
    
        val type: Type
          get() =
            when {
              message == "adding as trusted certificates" -> Type.Setup
              message == "Raw read" || message == "Raw write" -> Type.Encrypted
              message == "Plaintext before ENCRYPTION" || message == "Plaintext after DECRYPTION" -> Type.Plaintext
              message.startsWith("System property ") -> Type.Setup
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  6. samples/guide/src/main/java/okhttp3/recipes/RewriteResponseCacheControl.java

              .build();
    
          OkHttpClient clientForCall;
          if (i == 2) {
            // Force this request's response to be written to the cache. This way, subsequent responses
            // can be read from the cache.
            System.out.println("Force cache: true");
            clientForCall = client.newBuilder()
                .addNetworkInterceptor(REWRITE_CACHE_CONTROL_INTERCEPTOR)
                .build();
          } else {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jan 12 03:31:36 UTC 2019
    - 2.6K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/netbios/SessionRequestPacket.java

            return dstIndex - start;
        }
    
        @Override
        int readTrailerWireFormat(final InputStream in, final byte[] buffer, int bufferIndex) throws IOException {
            final int start = bufferIndex;
            if (in.read(buffer, bufferIndex, length) != length) {
                throw new IOException("invalid session request wire format");
            }
            bufferIndex += calledName.readWireFormat(buffer, bufferIndex);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.4K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/lease/DirectoryLeaseState.java

        /**
         * Private constructor to prevent instantiation of this utility class
         */
        private DirectoryLeaseState() {
            // Utility class - prevent instantiation
        }
    
        /**
         * Directory Read and Handle caching (RH) - recommended for directory operations
         */
        public static final int DIRECTORY_READ_HANDLE = Smb2LeaseState.SMB2_LEASE_READ_CACHING | Smb2LeaseState.SMB2_LEASE_HANDLE_CACHING;
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 02:21:31 UTC 2025
    - 2.5K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/ResponseDataUtil.java

            } catch (final Exception e) {
                CloseableUtil.closeQuietly(fos); // for deleting file
                FileUtil.deleteInBackground(tempFile); // clean up
                throw new CrawlingAccessException("Could not read a response body: " + responseData.getUrl(), e);
            } finally {
                CloseableUtil.closeQuietly(fos);
            }
            return tempFile;
        }
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 2.4K bytes
    - Viewed (0)
  10. ci/official/containers/ml_build/setup.python.sh

    if [[ ! -f "/usr/local/include/$VERSION" ]]; then
      ln -sf /usr/include/$VERSION /usr/local/include/$VERSION
    fi
    
    # Install pip
    wget --retry-connrefused --waitretry=1 --read-timeout=20 --timeout=15 --tries=5 https://bootstrap.pypa.io/get-pip.py
    /usr/bin/$VERSION get-pip.py
    /usr/bin/$VERSION -m pip install --no-cache-dir --upgrade pip
    /usr/bin/$VERSION -m pip install -U setuptools
    
    
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Fri Aug 01 02:44:57 UTC 2025
    - 2.8K bytes
    - Viewed (0)
Back to top