Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 715 for encodeTo (0.04 sec)

  1. internal/s3select/jstream/scratch.go

    	s.data = ndata
    }
    
    // append single byte to scratch buffer
    func (s *scratch) add(c byte) {
    	if s.fill+1 >= cap(s.data) {
    		s.grow()
    	}
    
    	s.data[s.fill] = c
    	s.fill++
    }
    
    // append encoded rune to scratch buffer
    func (s *scratch) addRune(r rune) int {
    	if s.fill+utf8.UTFMax >= cap(s.data) {
    		s.grow()
    	}
    
    	n := utf8.EncodeRune(s.data[s.fill:], r)
    	s.fill += n
    	return n
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 758 bytes
    - Viewed (0)
  2. cmd/listen-notification-handlers.go

    		tmpEvt := struct{ Records []event.Event }{[]event.Event{{}}}
    		for {
    			select {
    			case ev := <-localCh:
    				buf.Reset()
    				tmpEvt.Records[0] = ev
    				if err := enc.Encode(tmpEvt); err != nil {
    					bugLogIf(ctx, err, "event: Encode failed")
    					continue
    				}
    				mergeCh <- append(grid.GetByteBuffer()[:0], buf.Bytes()...)
    			case <-ctx.Done():
    				grid.PutByteBuffer(buf.Bytes())
    				return
    			}
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 6K bytes
    - Viewed (0)
  3. src/test/java/jcifs/smb1/smb1/AndXServerMessageBlockTest.java

        }
    
        @Test
        @DisplayName("encode without andx succeeds and signs when digest present")
        void testEncodeNoAndxWithSigning() throws Exception {
            DummyAndXBlock block = new DummyAndXBlock();
            TestSigningDigest digest = new TestSigningDigest();
            block.digest = digest;
    
            byte[] buf = new byte[256];
            int len = block.encode(buf, 0);
    
            assertTrue(len > 0);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  4. okhttp-tls/src/test/java/okhttp3/tls/HandshakeCertificatesTest.kt

            }
          }
        }
      }
    
      private fun assertPrivateKeysEquals(
        expected: PrivateKey,
        actual: PrivateKey,
      ) {
        assertThat(actual.encoded.toByteString()).isEqualTo(expected.encoded.toByteString())
      }
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  5. internal/s3select/simdj/record.go

    func (r *Record) Set(name string, value *sql.Value) (sql.Record, error) {
    	dst, err := r.CloneTo(nil)
    	if err != nil {
    		return nil, err
    	}
    	return dst.Set(name, value)
    }
    
    // WriteCSV - encodes to CSV data.
    func (r *Record) WriteCSV(writer io.Writer, opts sql.WriteCSVOpts) error {
    	csvRecord := make([]string, 0, 10)
    	var tmp simdjson.Iter
    	obj := r.object
    allElems:
    	for {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/fscc/FileRenameInformation2.java

            this.fileName = new String(nameBytes, StandardCharsets.UTF_16LE);
            return bufferIndex - start;
        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.Encodable#encode(byte[], int)
         */
        @Override
        public int encode(final byte[] dst, int dstIndex) {
            final int start = dstIndex;
            dst[dstIndex] = (byte) (this.replaceIfExists ? 1 : 0);
            dstIndex += 8; // 7 Reserved
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 3.5K bytes
    - Viewed (0)
  7. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt

    import java.net.ProtocolException
    import okio.Buffer
    import okio.BufferedSource
    import okio.ByteString
    import okio.ForwardingSource
    import okio.Source
    import okio.buffer
    
    /**
     * Streaming decoder of data encoded following Abstract Syntax Notation One (ASN.1). There are
     * multiple variants of ASN.1, including:
     *
     *  * DER: Distinguished Encoding Rules. This further constrains ASN.1 for deterministic encoding.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/fscc/FileBasicInfo.java

         */
        @Override
        public int size() {
            return 40;
        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.Encodable#encode(byte[], int)
         */
        @Override
        public int encode(final byte[] dst, int dstIndex) {
            final int start = dstIndex;
            SMBUtil.writeTime(this.createTime, dst, dstIndex);
            dstIndex += 8;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  9. internal/store/queuestore.go

    	enc := jsoniter.ConfigCompatibleWithStandardLibrary.NewEncoder(buf)
    
    	for i := range items {
    		if err = enc.Encode(items[i]); err != nil {
    			return err
    		}
    	}
    
    	path := filepath.Join(store.directory, key.String())
    	if key.Compress {
    		err = os.WriteFile(path, s2.Encode(nil, buf.Bytes()), os.FileMode(0o770))
    	} else {
    		err = os.WriteFile(path, buf.Bytes(), os.FileMode(0o770))
    	}
    
    	buf.Reset()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  10. internal/logger/logrotate.go

    			stdErrEnc.Encode(&log.Entry{
    				Level:   ErrorKind,
    				Message: msg,
    				Time:    time.Now().UTC(),
    				Trace:   &log.Trace{Message: msg},
    			})
    		}
    		if err := w.rotate(); err != nil {
    			msg := fmt.Sprintf("unable to rotate log file %v: %v", w.f.Name(), err)
    			stdErrEnc.Encode(&log.Entry{
    				Level:   ErrorKind,
    				Message: msg,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 5.8K bytes
    - Viewed (0)
Back to top