Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 41 for writeHeaders (0.06 seconds)

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HpackTest.kt

      @Test
      fun staticTableIndexedHeaders() {
        hpackWriter!!.writeHeaders(headerEntries(":method", "GET"))
        assertBytes(0x82)
        assertThat(hpackWriter!!.headerCount).isEqualTo(0)
        hpackWriter!!.writeHeaders(headerEntries(":method", "POST"))
        assertBytes(0x83)
        assertThat(hpackWriter!!.headerCount).isEqualTo(0)
        hpackWriter!!.writeHeaders(headerEntries(":path", "/"))
        assertBytes(0x84)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 38.6K bytes
    - Click Count (0)
  2. cmd/object-handlers-common.go

    			// If the object ETag matches with the specified ETag.
    			writeHeaders()
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrPreconditionFailed), r.URL)
    			return true
    		}
    	}
    
    	etagMatch := opts.PreserveETag != "" && isETagEqual(objInfo.ETag, opts.PreserveETag)
    	vidMatch := opts.VersionID != "" && opts.VersionID == objInfo.VersionID
    	if etagMatch && vidMatch {
    		writeHeaders()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Jul 23 12:36:06 GMT 2025
    - 15.2K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/api/engine/SearchEngineApiManager.java

                try (ServletOutputStream out = response.getOutputStream(); InputStream in = curlResponse.getContentAsStream()) {
                    response.setStatus(curlResponse.getHttpStatusCode());
                    writeHeaders(response);
                    final String responseContentType = curlResponse.getHeaderValue("Content-Type");
                    if (StringUtil.isBlank(responseContentType)) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:40 GMT 2026
    - 13.4K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/api/BaseApiManager.java

            } else {
                enc = encoding;
            }
            buf.append(enc);
            final HttpServletResponse response = LaResponseUtil.getResponse();
            response.setContentType(buf.toString());
            writeHeaders(response);
            try (PrintWriter out = new PrintWriter(new OutputStreamWriter(response.getOutputStream(), enc))) {
                out.print(text);
            } catch (final IOException e) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  5. internal/http/response-recorder.go

    	return blobBody
    }
    
    // WriteHeader - writes http status code
    func (lrw *ResponseRecorder) WriteHeader(code int) {
    	if !lrw.headersLogged {
    		lrw.ttfbHeader = time.Now().UTC().Sub(lrw.StartTime)
    		lrw.StatusCode = code
    		lrw.writeHeaders(&lrw.headers, code, lrw.Header())
    		lrw.headersLogged = true
    		lrw.ResponseWriter.WriteHeader(code)
    	}
    }
    
    // Flush - Calls the underlying Flush.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 5.5K bytes
    - Click Count (0)
  6. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

        socket.sleepWhileOpen(response.trailersDelayNanos)
        if ("chunked".equals(response.headers["Transfer-Encoding"], ignoreCase = true)) {
          writeHeaders(socket.sink, response.trailers)
        }
      }
    
      @Throws(IOException::class)
      private fun writeHeaders(
        sink: BufferedSink,
        headers: Headers,
      ) {
        for ((name, value) in headers) {
          sink.writeUtf8(name)
          sink.writeUtf8(": ")
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 40.3K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

       * @param flushHeaders true to force flush the response headers. This should be true unless the
       *     response body exists and will be written immediately.
       */
      @Throws(IOException::class)
      fun writeHeaders(
        responseHeaders: List<Header>,
        outFinished: Boolean,
        flushHeaders: Boolean,
      ) {
        assertLockNotHeld()
    
        var flushHeaders = flushHeaders
        withLock {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jul 07 18:57:05 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/api/chat/ChatApiManager.java

                if (!used.contains(vq)) {
                    groupedQueries.add(vq);
                }
            }
            return groupedQueries.toArray(new String[0]);
        }
    
        @Override
        protected void writeHeaders(final HttpServletResponse response) {
            ComponentUtil.getFessConfig().getApiJsonResponseHeaderList().forEach(e -> response.setHeader(e.getFirst(), e.getSecond()));
        }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 06:06:55 GMT 2026
    - 25.8K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Hpack.kt

           *
           * http://tools.ietf.org/html/draft-ietf-httpbis-header-compression-12#section-6.2.3
           */
          @Throws(IOException::class)
          fun writeHeaders(headerBlock: List<Header>) {
            if (emitDynamicTableSizeUpdate) {
              if (smallestHeaderTableSizeSetting < maxDynamicTableByteCount) {
                // Multiple dynamic table size updates!
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 23.2K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

          }
        }
    
        if (flushHeaders) {
          writer.flush()
        }
    
        return stream
      }
    
      @Throws(IOException::class)
      internal fun writeHeaders(
        streamId: Int,
        outFinished: Boolean,
        alternating: List<Header>,
      ) {
        writer.headers(outFinished, streamId, alternating)
      }
    
      /**
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 31.9K bytes
    - Click Count (0)
Back to Top