Search Options

Results per page
Sort
Preferred Languages
Advance

Results 391 - 400 of 1,667 for byte1 (0.04 sec)

  1. src/main/java/jcifs/pac/ASN1Util.java

         *
         * BC no longer seems to allow that out of the box
         *
         * @param expectTag
         * @param in
         * @return coded bytes of the tagged object
         * @throws IOException
         */
        public static byte[] readUnparsedTagged(int expectTag, int limit, ASN1InputStream in) throws IOException {
            int ftag = in.read();
            int tag = readTagNumber(in, ftag);
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Oct 02 12:02:06 UTC 2023
    - 6.5K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt

       *
       *  * 16 bytes: either `OkHttp cache v1\n` if the persisted file is complete. This is another
       *    sequence of bytes if the file is incomplete and should not be used.
       *  * 8 bytes: *n*: upstream data size
       *  * 8 bytes: *m*: metadata size
       *  * *n* bytes: upstream data
       *  * *m* bytes: metadata
       *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt

      }
    
      @Test fun clientSimpleBinary() {
        val bytes = binaryData(256)
        data.write("827E0100".decodeHex()).write(bytes)
        clientReader.processNextFrame()
        callback.assertBinaryMessage(bytes)
      }
    
      @Test fun clientTwoFrameBinary() {
        val bytes = binaryData(200)
        data.write("0264".decodeHex()).write(bytes, 0, 100)
        data.write("8064".decodeHex()).write(bytes, 100, 100)
        clientReader.processNextFrame()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 14.4K bytes
    - Viewed (1)
  4. internal/s3select/select.go

    		if err != nil {
    			return err
    		}
    		if buf.Bytes()[buf.Len()-1] == '\n' {
    			buf.Truncate(buf.Len() - 1)
    		}
    		buf.WriteString(s3Select.Output.CSVArgs.RecordDelimiter)
    
    		return nil
    	case jsonFormat:
    		err := record.WriteJSON(buf)
    		if err != nil {
    			return err
    		}
    		// Trim trailing newline from non-simd output
    		if buf.Bytes()[buf.Len()-1] == '\n' {
    			buf.Truncate(buf.Len() - 1)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  5. internal/crypto/sse-c.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package crypto
    
    import (
    	"bytes"
    	"context"
    	"crypto/md5"
    	"encoding/base64"
    	"net/http"
    
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    )
    
    type ssec struct{}
    
    var (
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  6. internal/config/subnet/subnet.go

    )
    
    // Upload given file content (payload) to specified URL
    func (c Config) Upload(reqURL string, filename string, payload []byte) (string, error) {
    	if !c.Registered() {
    		return "", errors.New("Deployment is not registered with SUBNET. Please register the deployment via 'mc license register ALIAS'")
    	}
    
    	var body bytes.Buffer
    	writer := multipart.NewWriter(&body)
    	part, e := writer.CreateFormFile("file", filename)
    	if e != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 27 16:35:36 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  7. cmd/admin-handlers-users_test.go

    	_, err := client.PutObject(ctx, bucket, "some-object", bytes.NewBuffer([]byte("stuff")), 5, minio.PutObjectOptions{})
    	if err != nil {
    		c.Fatalf("upload did not succeed got %#v", err)
    	}
    }
    
    func (c *check) mustNotUpload(ctx context.Context, client *minio.Client, bucket string) {
    	c.Helper()
    	_, err := client.PutObject(ctx, bucket, "some-object", bytes.NewBuffer([]byte("stuff")), 5, minio.PutObjectOptions{})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 47.3K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/SMBSigningDigest.java

         * Performs MAC signing of the SMB. This is done as follows.
         * The signature field of the SMB is overwritten with the sequence number;
         * The MD5 digest of the MAC signing key + the entire SMB is taken;
         * The first 8 bytes of this are placed in the signature field.
         *
         * @param data
         *            The data.
         * @param offset
         *            The starting offset at which the SMB header begins.
         * @param length
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Aug 05 09:45:59 UTC 2018
    - 2.2K bytes
    - Viewed (0)
  9. docs/sts/client-grants.go

    	}
    
    	u, err := url.Parse(stsEndpoint)
    	if err != nil {
    		log.Fatal(err)
    	}
    
    	clnt, err := minio.New(u.Host, opts)
    	if err != nil {
    		log.Fatal(err)
    	}
    
    	d := bytes.NewReader([]byte("Hello, World"))
    	n, err := clnt.PutObject(context.Background(), "my-bucketname", "my-objectname", d, d.Size(), minio.PutObjectOptions{})
    	if err != nil {
    		log.Fatalln(err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 3.3K bytes
    - Viewed (0)
  10. istioctl/pkg/multicluster/remote_secret.go

    			},
    			Labels: map[string]string{
    				multicluster.MultiClusterSecretLabel: "true",
    			},
    		},
    		Data: map[string][]byte{
    			key: data.Bytes(),
    		},
    	}
    	return out, nil
    }
    
    func createBaseKubeconfig(caData []byte, clusterName, server string) *api.Config {
    	return &api.Config{
    		Clusters: map[string]*api.Cluster{
    			clusterName: {
    				CertificateAuthorityData: caData,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 23.3K bytes
    - Viewed (0)
Back to top