Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 276 for buf1 (0.07 sec)

  1. cmd/admin-handlers-users_test.go

    		Status:     madmin.AccountEnabled,
    	}
    	buf, err := json.Marshal(reqBodyArg)
    	if err != nil {
    		c.Fatalf("unexpected json encode err: %v", err)
    	}
    	buf, err = madmin.EncryptData(secretKey, buf)
    	if err != nil {
    		c.Fatalf("unexpected encryption err: %v", err)
    	}
    
    	req.ContentLength = int64(len(buf))
    	sum := sha256.Sum256(buf)
    	req.Header.Set("X-Amz-Content-Sha256", hex.EncodeToString(sum[:]))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 47.3K bytes
    - Viewed (0)
  2. cmd/server_test.go

    	}
    	putContent := buffer.String()
    
    	buf := bytes.NewReader([]byte(putContent))
    
    	objectName := "test-big-object"
    	// create HTTP request for object upload.
    	request, err = newTestSignedRequest(http.MethodPut, getPutObjectURL(s.endPoint, bucketName, objectName),
    		int64(buf.Len()), buf, s.accessKey, s.secretKey, s.signer)
    	c.Assert(err, nil)
    
    	// execute the HTTP request.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 116.3K bytes
    - Viewed (0)
  3. cmd/admin-handlers.go

    		return
    	}
    	// Convert local entries to JSON
    	go func() {
    		var buf bytes.Buffer
    		enc := json.NewEncoder(&buf)
    		for {
    			select {
    			case <-ctx.Done():
    				return
    			case li := <-logCh:
    				if !li.SendLog(node, logKind) {
    					continue
    				}
    				buf.Reset()
    				if err := enc.Encode(li); err != nil {
    					continue
    				}
    				select {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  4. internal/bucket/object/lock/lock.go

    func ParseObjectLegalHold(reader io.Reader) (hold *ObjectLegalHold, err error) {
    	buf, err := io.ReadAll(io.LimitReader(reader, maxObjectLockConfigSize))
    	if err != nil {
    		return nil, err
    	}
    
    	hold = &ObjectLegalHold{}
    	if err = xml.NewDecoder(bytes.NewReader(buf)).Decode(hold); err != nil {
    		return nil, err
    	}
    
    	if !hold.Status.Valid() {
    		return nil, ErrMalformedXML
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 29 01:20:27 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/net/InetAddresses.java

        //   gap->num   => "num"     gap->gap   => ""
        StringBuilder buf = new StringBuilder(39);
        boolean lastWasNumber = false;
        for (int i = 0; i < hextets.length; i++) {
          boolean thisIsNumber = hextets[i] >= 0;
          if (thisIsNumber) {
            if (lastWasNumber) {
              buf.append(':');
            }
            buf.append(Integer.toHexString(hextets[i]));
          } else {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  6. guava/src/com/google/common/base/CharMatcher.java

        }
    
        int len = string.length();
        StringBuilder buf = new StringBuilder((len * 3 / 2) + 16);
    
        int oldpos = 0;
        do {
          buf.append(string, oldpos, pos);
          buf.append(replacement);
          oldpos = pos + 1;
          pos = indexIn(string, oldpos);
        } while (pos != -1);
    
        buf.append(string, oldpos, len);
        return buf.toString();
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 13:00:28 UTC 2024
    - 53.9K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/hash/BloomFilter.java

        return Collector.of(
            () -> BloomFilter.create(funnel, expectedInsertions, fpp),
            BloomFilter::put,
            (bf1, bf2) -> {
              bf1.putAll(bf2);
              return bf1;
            },
            Collector.Characteristics.UNORDERED,
            Collector.Characteristics.CONCURRENT);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 23 16:45:30 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  8. cmd/erasure-healing.go

    					continue
    				}
    				partPath := pathJoin(tmpID, dstDataDir, fmt.Sprintf("part.%d", partNumber))
    				if len(inlineBuffers) > 0 {
    					buf := grid.GetByteBufferCap(int(erasure.ShardFileSize(latestMeta.Size)) + 64)
    					inlineBuffers[i] = bytes.NewBuffer(buf[:0])
    					defer grid.PutByteBuffer(buf)
    
    					writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize())
    				} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

        assertThat(peer.takeFrame().type).isEqualTo(Http2.TYPE_DATA)
        assertThat(peer.frameCount()).isEqualTo(5)
      }
    
      @Test fun maxFrameSizeHonored() {
        val buff = ByteArray(peer.maxOutboundDataLength() + 1)
        buff.fill('*'.code.toByte())
    
        // Write the mocking script.
        peer.sendFrame().settings(Settings())
        peer.acceptFrame() // ACK
        peer.acceptFrame() // SYN_STREAM
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  10. guava/src/com/google/common/io/BaseEncoding.java

              checkPositionIndexes(off, off + len, buf.length);
    
              int i = off;
              for (; i < off + len; i++) {
                int b = read();
                if (b == -1) {
                  int read = i - off;
                  return read == 0 ? -1 : read;
                }
                buf[i] = (byte) b;
              }
              return i - off;
            }
    
            @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 41.8K bytes
    - Viewed (0)
Back to top