- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 42 for keystream (0.41 sec)
-
src/crypto/rc4/rc4_test.go
} } func TestGolden(t *testing.T) { for gi, g := range golden { data := make([]byte, len(g.keystream)) for i := range data { data[i] = byte(i) } expect := make([]byte, len(g.keystream)) for i := range expect { expect[i] = byte(i) ^ g.keystream[i] } for size := 1; size <= len(g.keystream); size++ { c, err := NewCipher(g.key) if err != nil { t.Fatalf("#%d: NewCipher: %v", gi, err)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 21 19:49:06 UTC 2018 - 4.3K bytes - Viewed (0) -
src/vendor/golang.org/x/crypto/chacha20/chacha_generic.go
if s.len != 0 { keyStream := s.buf[bufSize-s.len:] if len(src) < len(keyStream) { keyStream = keyStream[:len(src)] } _ = src[len(keyStream)-1] // bounds check elimination hint for i, b := range keyStream { dst[i] = src[i] ^ b } s.len -= len(keyStream) dst, src = dst[len(keyStream):], src[len(keyStream):] } if len(src) == 0 { return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 26 00:11:50 UTC 2022 - 13.9K bytes - Viewed (0) -
src/crypto/cipher/cfb.go
} for len(src) > 0 { if x.outUsed == len(x.out) { x.b.Encrypt(x.out, x.next) x.outUsed = 0 } if x.decrypt { // We can precompute a larger segment of the // keystream on decryption. This will allow // larger batches for xor, and we should be // able to match CTR/OFB performance. copy(x.next[x.outUsed:], src) } n := subtle.XORBytes(dst, src, x.out[x.outUsed:])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 17:09:47 UTC 2023 - 2K bytes - Viewed (0) -
src/vendor/golang.org/x/crypto/chacha20/chacha_s390x.s
//go:build gc && !purego #include "go_asm.h" #include "textflag.h" // This is an implementation of the ChaCha20 encryption algorithm as // specified in RFC 7539. It uses vector instructions to compute // 4 keystream blocks in parallel (256 bytes) which are then XORed // with the bytes in the input slice. GLOBL ·constants<>(SB), RODATA|NOPTR, $32 // BSWAP: swap bytes in each 4-byte element DATA ·constants<>+0x00(SB)/4, $0x03020100
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 5.3K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/test/groovy/org/gradle/model/internal/inspect/ManagedModelInitializerTest.groovy
- An unmanaged property (i.e. annotated with @Unmanaged)""") } @Managed interface ManagedReadWriteWithInvalidProperty { FileInputStream getStream() void setStream(FileInputStream stream) } def "should fail with a reasonable exception when a type is not managed and not constructible"() { when: realizeNodeOfType(NonManaged)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 09:51:04 UTC 2023 - 12.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
check(!client) { "Client cannot push requests." } return newStream(associatedStreamId, requestHeaders, out) } /** * Returns a new locally-initiated stream. * * @param out true to create an output stream that we can use to send data to the remote peer. * Corresponds to `FLAG_FIN`. */ @Throws(IOException::class) fun newStream( requestHeaders: List<Header>, out: Boolean,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
platforms/core-runtime/io/src/main/java/org/gradle/internal/io/LinePerThreadBufferingOutputStream.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:14 UTC 2024 - 6K bytes - Viewed (0) -
internal/event/target/nats.go
target.loggerOnce(context.Background(), err, target.ID().String()) } return err } if target.natsConn != nil && args.JetStream.Enable { var jstream nats.JetStream jstream, err = target.natsConn.JetStream() if err != nil { if err.Error() != nats.ErrNoServers.Error() { target.loggerOnce(context.Background(), err, target.ID().String()) } return err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 12.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.acceptFrame() // DATA STREAM 3 peer.play() // Play it back. val connection = connect(peer) val stream1 = connection.newStream(headerEntries("a", "android"), true) val stream2 = connection.newStream(headerEntries("b", "banana"), true) connection.writePingAndAwaitPong() // Ensure the GO_AWAY that resets stream2 has been received. val sink1 = stream1.getSink().buffer()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/problems/DefaultProblemDiagnosticsFactoryTest.groovy
diagnostics5.exception == null diagnostics5.stack.empty } def "each stream has an independent stack trace limit"() { def stream1 = factory.newStream() def stream2 = factory.newStream() given: stream1.forCurrentCaller() expect: !stream1.forCurrentCaller().stack.empty !stream2.forCurrentCaller().stack.empty
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 23 17:15:42 UTC 2024 - 5.3K bytes - Viewed (0)