Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 378 for wsWrite (0.35 sec)

  1. platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/problems/JsonModelWriter.kt

            simpleString(name)
            write(':')
        }
    
        private
        fun simpleString(name: String) {
            write('"')
            write(name)
            write('"')
        }
    
        private
        val buffer = CharBuf.create(255)
    
        private
        fun jsonString(value: String) {
            if (value.isEmpty()) {
                write("\"\"")
            } else {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:25 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  2. platforms/core-runtime/base-services/src/main/java/org/gradle/util/internal/TextUtil.java

                            out.write('\\');
                            out.write('n');
                            break;
                        case '\t':
                            out.write('\\');
                            out.write('t');
                            break;
                        case '\f':
                            out.write('\\');
                            out.write('f');
                            break;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 29 06:47:40 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  3. src/vendor/golang.org/x/net/nettest/conntest.go

    	checkForTimeoutError(t, err)
    	if _, err := c1.Write(make([]byte, 1024)); err != nil {
    		t.Errorf("unexpected Write error: %v", err)
    	}
    }
    
    // testWriteTimeout tests that Write timeouts do not affect Read.
    func testWriteTimeout(t *testing.T, c1, c2 net.Conn) {
    	go chunkedCopy(c2, rand.New(rand.NewSource(0)))
    
    	c1.SetWriteDeadline(aLongTimeAgo)
    	_, err := c1.Write(make([]byte, 1024))
    	checkForTimeoutError(t, err)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  4. internal/grid/connection.go

    		c.blockMessages.Store(&block)
    		c.connMu.Unlock()
    	}
    }
    
    // wsWriter writes websocket messages.
    type wsWriter struct {
    	tmp [ws.MaxHeaderSize]byte
    }
    
    // writeMessage writes a message to w without allocations.
    func (ww *wsWriter) writeMessage(w io.Writer, s ws.State, op ws.OpCode, p []byte) error {
    	const fin = true
    	var frame ws.Frame
    	if s.ClientSide() {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  5. src/runtime/mbarrier.go

    // license that can be found in the LICENSE file.
    
    // Garbage collector: write barriers.
    //
    // For the concurrent garbage collector, the Go compiler implements
    // updates to pointer-valued fields that may be in heap objects by
    // emitting calls to write barriers. The main write barrier for
    // individual pointer writes is gcWriteBarrier and is implemented in
    // assembly. This file contains write barrier entry points for bulk
    // operations. See also mwbbuf.go.
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  6. platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/fingerprint/ConfigurationCacheFingerprintWriter.kt

                    write(ConfigurationCacheFingerprint.UndeclaredSystemProperty(key, value))
                }
            }
    
            fun envVariableRead(key: String, value: String?) {
                if (undeclaredEnvironmentVariables.add(key)) {
                    write(ConfigurationCacheFingerprint.UndeclaredEnvironmentVariable(key, value))
                }
            }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:30 UTC 2024
    - 32.8K bytes
    - Viewed (0)
  7. platforms/core-configuration/core-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/core/IsolatedCodecs.kt

            write(value.value)
        }
    
        override suspend fun ReadContext.decode(): IsolatedEnumValueSnapshot {
            val value = read() as Enum<*>
            return IsolatedEnumValueSnapshot(value)
        }
    }
    
    
    object IsolatedSetCodec : Codec<IsolatedSet> {
        override suspend fun WriteContext.encode(value: IsolatedSet) {
            write(value.elements)
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 23:09:56 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  8. platforms/core-configuration/core-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/core/jos/RecordingObjectOutputStream.kt

        override fun writeObjectOverride(obj: Any?) = record {
            write(obj)
        }
    
        override fun write(`val`: Int) = record {
            outputStream.write(`val`)
        }
    
        override fun write(buf: ByteArray) = record {
            outputStream.write(buf)
        }
    
        override fun write(buf: ByteArray, off: Int, len: Int) = record {
            outputStream.write(buf, off, len)
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 23:09:56 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  9. src/runtime/atomic_pointer.go

    // because while ptr does not escape, new does.
    // If new is marked as not escaping, the compiler will make incorrect
    // escape analysis decisions about the pointer value being stored.
    
    // atomicwb performs a write barrier before an atomic pointer write.
    // The caller should guard the call with "if writeBarrier.enabled".
    //
    // atomicwb should be an internal detail,
    // but widely used packages access it using linkname.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 4K bytes
    - Viewed (0)
  10. src/vendor/golang.org/x/crypto/sha3/sha3_s390x.go

    func (s *asmState) resetBuf() {
    	max := (cap(s.storage) / s.rate) * s.rate
    	s.buf = s.storage[:0:max]
    }
    
    // Write (via the embedded io.Writer interface) adds more data to the running hash.
    // It never returns an error.
    func (s *asmState) Write(b []byte) (int, error) {
    	if s.state != spongeAbsorbing {
    		panic("sha3: Write after Read")
    	}
    	length := len(b)
    	for len(b) > 0 {
    		if len(s.buf) == 0 && len(b) >= cap(s.buf) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 7.5K bytes
    - Viewed (0)
Back to top