Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 371 - 380 of 733 for Buffers (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. compat/maven-model-builder/src/main/java/org/apache/maven/model/building/DefaultModelBuilder.java

                StringBuilder buffer = new StringBuilder(256);
                buffer.append("'parent.relativePath'");
                if (childModel != problems.getRootModel()) {
                    buffer.append(" of POM ").append(ModelProblemUtils.toSourceHint(childModel));
                }
                buffer.append(" points at ").append(groupId).append(':').append(artifactId);
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Sun Mar 30 23:08:08 GMT 2025
    - 55.3K bytes
    - Click Count (0)
  2. internal/http/response-recorder.go

    	ttfbBody   time.Duration
    
    	StartTime time.Time
    	// number of bytes written
    	bytesWritten int
    	// number of bytes of response headers written
    	headerBytesWritten int
    	// Internal recording buffer
    	headers bytes.Buffer
    	body    bytes.Buffer
    	// Indicate if headers are written in the log
    	headersLogged bool
    }
    
    // Hijack - hijacks the underlying connection
    func (lrw *ResponseRecorder) Hijack() (net.Conn, *bufio.ReadWriter, error) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 5.5K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt

    import okio.BufferedSink
    import okio.ByteString
    import okio.ByteString.Companion.encodeUtf8
    import okio.FileSystem
    import okio.Path
    import okio.Path.Companion.toPath
    import okio.buffer
    
    /**
     * Downloads the public suffix list from https://publicsuffix.org/list/public_suffix_list.dat and
     * transforms the file into an efficient format used by OkHttp.
     *
     *
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Aug 06 05:33:11 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/collect/EvictingQueue.java

     * attempting to add new elements onto the queue and it is full. This queue orders elements FIFO
     * (first-in-first-out). This data structure is logically equivalent to a circular buffer (i.e.,
     * cyclic buffer or ring buffer).
     *
     * <p>An evicting queue must be configured with a maximum size. Each time an element is added to a
     * full queue, the queue automatically removes its head element. This is different from conventional
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 13 17:34:21 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  5. guava/src/com/google/common/hash/SipHashFunction.java

        }
    
        @Override
        protected void process(ByteBuffer buffer) {
          b += CHUNK_SIZE;
          processM(buffer.getLong());
        }
    
        @Override
        protected void processRemaining(ByteBuffer buffer) {
          b += buffer.remaining();
          for (int i = 0; buffer.hasRemaining(); i += 8) {
            finalM ^= (buffer.get() & 0xFFL) << i;
          }
        }
    
        @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 13 17:34:21 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  6. src/main/java/jcifs/internal/smb1/com/SmbComWriteAndXResponse.java

            return 0;
        }
    
        @Override
        protected int readParameterWordsWireFormat(final byte[] buffer, final int bufferIndex) {
            this.count = SMBUtil.readInt2(buffer, bufferIndex) & 0xFFFFL;
            return 8;
        }
    
        @Override
        protected int readBytesWireFormat(final byte[] buffer, final int bufferIndex) {
            return 0;
        }
    
        @Override
        public String toString() {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  7. okhttp-testing-support/src/main/kotlin/okhttp3/FakeDns.kt

     * limitations under the License.
     */
    package okhttp3
    
    import assertk.assertThat
    import assertk.assertions.containsExactly
    import java.net.InetAddress
    import java.net.UnknownHostException
    import okio.Buffer
    
    class FakeDns : Dns {
      private val hostAddresses: MutableMap<String, List<InetAddress>> = mutableMapOf()
      private val requestedHosts: MutableList<String> = mutableListOf()
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 2.5K bytes
    - Click Count (0)
  8. src/main/java/jcifs/smb1/smb1/NtTransQuerySecurityDesc.java

            return 0;
        }
    
        @Override
        int readSetupWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
            return 0;
        }
    
        @Override
        int readParametersWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
            return 0;
        }
    
        @Override
        int readDataWireFormat(final byte[] buffer, final int bufferIndex, final int len) {
            return 0;
        }
    
        @Override
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 2.6K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/hash/HashTestUtils.java

            for (PrimitiveSink sink : sinks) {
              ByteBuffer buffer = ByteBuffer.wrap(value);
              Java8Compatibility.position(buffer, pos);
              Java8Compatibility.limit(buffer, limit);
              sink.putBytes(buffer);
              assertEquals(limit, buffer.limit());
              assertEquals(limit, buffer.position());
            }
          }
        },
        PUT_STRING() {
          @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 18:19:59 GMT 2025
    - 25.6K bytes
    - Click Count (0)
  10. lib/wasm/wasm_exec.js

    						const n = this.mem.getInt32(sp + 24, true);
    						fs.writeSync(fd, new Uint8Array(this._inst.exports.mem.buffer, p, n));
    					},
    
    					// func resetMemoryDataView()
    					"runtime.resetMemoryDataView": (sp) => {
    						sp >>>= 0;
    						this.mem = new DataView(this._inst.exports.mem.buffer);
    					},
    
    					// func nanotime1() int64
    					"runtime.nanotime1": (sp) => {
    						sp >>>= 0;
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Sun Dec 08 15:34:47 GMT 2024
    - 16.6K bytes
    - Click Count (0)
Back to Top