Search Options

Results per page
Sort
Preferred Languages
Advance

Results 721 - 730 of 780 for upstream (0.17 sec)

  1. guava/src/com/google/common/collect/ImmutableCollection.java

        // We serialize by default to ImmutableList, the simplest thing that works.
        return new ImmutableList.SerializedForm(toArray());
      }
    
      @J2ktIncompatible // serialization
      private void readObject(ObjectInputStream stream) throws InvalidObjectException {
        throw new InvalidObjectException("Use SerializedForm");
      }
    
      /**
       * Abstract base class for builders of {@link ImmutableCollection} types.
       *
       * @since 10.0
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 18.7K bytes
    - Viewed (0)
  2. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultWagonManager.java

                for (String extension : checksums.keySet()) {
                    // TODO shouldn't need a file intermediary - improve wagon to take a stream
                    File temp = File.createTempFile("maven-artifact", null);
                    temp.deleteOnExit();
                    byte[] bytes = sums.get(extension).getBytes(StandardCharsets.UTF_8);
                    Files.write(
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Sat Apr 05 11:52:05 UTC 2025
    - 29.9K bytes
    - Viewed (0)
  3. cmd/s3-zip-handlers.go

    	}
    
    	if isTruncated {
    		listObjectsInfo.IsTruncated = true
    		listObjectsInfo.NextContinuationToken = nextToken
    	}
    
    	return listObjectsInfo, nil
    }
    
    // getFilesFromZIPObject reads a partial stream of a zip file to build the zipindex.Files index
    func getFilesListFromZIPObject(ctx context.Context, objectAPI ObjectLayer, bucket, object string, opts ObjectOptions) (zipindex.Files, ObjectInfo, error) {
    	size := 1 << 20
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  4. src/test/java/jcifs/smb/SmbRandomAccessFileTest.java

            ArgumentCaptor<Integer> lenCap = ArgumentCaptor.forClass(Integer.class);
            verify(raf, atLeast(2)).write(any(byte[].class), anyInt(), lenCap.capture());
            assertTrue(lenCap.getAllValues().stream().allMatch(len -> len == 1));
        }
    
        @Test
        @DisplayName("write(short/char/int/long/float/double): correct byte lengths")
        void write_multiByteVariants_lengths() throws Exception {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

        assertThat(URLConnection.getDefaultRequestProperty("X-setDefaultRequestProperty")).isNull()
      }
    
      /**
       * Reads `count` characters from the stream. If the stream is exhausted before `count`
       * characters can be read, the remaining characters are returned and the stream is closed.
       */
      private fun readAscii(
        inputStream: InputStream,
        count: Int,
      ): String {
        val result = StringBuilder()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 133.2K bytes
    - Viewed (0)
  6. cmd/bucket-handlers.go

    		// https://en.wikipedia.org/wiki/Copy_protection so the incoming stream
    		// is always going to be in-memory as we cannot re-read from what we
    		// wrote to disk - since that amounts to "copying" from a "copy"
    		// instead of "copying" from source, we need the stream to be seekable
    		// to ensure that we can make fan-out calls concurrently.
    		buf := bytebufferpool.Get()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/smb1/ServerMessageBlock.java

         * actually purer. However, in the case of smb we know the
         * wordCount and byteCount. And since every subclass of
         * ServerMessageBlock would have to perform the same read
         * operation on the input stream, we might as will pull that
         * common functionality into the superclass and read wordCount
         * and byteCount worth of data.
         *
         * We will still use the readXxxWireFormat return values to
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  8. cmd/handler-utils.go

    			return nil, err
    		}
    	}
    
    	// Set content-type to default value if it is not set.
    	if _, ok := metadata[strings.ToLower(xhttp.ContentType)]; !ok {
    		metadata[strings.ToLower(xhttp.ContentType)] = "binary/octet-stream"
    	}
    
    	// https://github.com/google/security-research/security/advisories/GHSA-76wf-9vgp-pj7w
    	for k := range metadata {
    		if equals(k, xhttp.AmzMetaUnencryptedContentLength, xhttp.AmzMetaUnencryptedContentMD5) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.3K bytes
    - Viewed (1)
  9. fess-crawler-lasta/src/main/resources/crawler/extractor.xml

    				"application/news-groupinfo",
    				"application/news-transmission",
    				"application/nss",
    				"application/ocsp-request",
    				"application/ocsp-response",
    				"application/octet-stream",
    				"application/oda",
    				"application/oebps-package+xml",
    				"application/ogg",
    				"application/kate",
    				"application/onenote",
    				"application/parityfec",
    				"application/patch-ops-error+xml",
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Aug 01 21:40:30 UTC 2020
    - 49K bytes
    - Viewed (0)
  10. src/archive/tar/reader_test.go

    	}
    
    	data1, data2, pax, sparse := ss[0], ss[1], ss[2], ss[3]
    	data2 += strings.Repeat("\x00", 10*512)
    	trash := strings.Repeat("garbage ", 64) // Exactly 512 bytes
    
    	vectors := []struct {
    		input string // Input stream
    		cnt   int    // Expected number of headers read
    		err   error  // Expected error outcome
    	}{
    		{"", 0, io.EOF}, // Empty file is a "valid" tar file
    		{data1[:511], 0, io.ErrUnexpectedEOF},
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Thu Oct 03 15:48:09 UTC 2024
    - 46.9K bytes
    - Viewed (0)
Back to top