reaper - Code Search

src/main/webapp/WEB-INF/orig/view/chat/chat.jsp

<link href="${fe:url('/css/chat.css')}" rel="stylesheet" type="text/css" />
</head>
<body>
	<jsp:include page="../header.jsp" />
	<main class="container">
		<div class="row">
			<div class="col-12 col-lg-10 offset-lg-1">
				<div class="card shadow-sm">
					<div class="card-header d-flex justify-content-between align-items-center">
						<div id="statusArea" class="status-lozenge status-ready" role="status" aria-live="polite">

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Sun Mar 15 06:21:57 GMT 2026

- 10.4K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/collect/DiscreteDomain.java

      }
    }
    return current;
  }

  /**
   * Returns the unique least value of type {@code C} that is greater than {@code value}, or {@code
   * null} if none exists. Inverse operation to {@link #previous}.
   *
   * @param value any value of type {@code C}
   * @return the least value greater than {@code value}, or {@code null} if {@code value} is {@code
   *     maxValue()}
   */

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Thu Feb 13 17:34:21 GMT 2025

- 10.4K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/util/ServerResponseValidatorTest.java

        });
    }

    @Test
    public void testValidSmbHeader() throws Exception {
        // SMB1 header
        validator.validateSmbHeader(0x424D53FF, 32, 0x72);

        // SMB2 header
        validator.validateSmbHeader(0x424D53FE, 64, 0x00);
    }

    @Test
    public void testInvalidProtocolId() throws Exception {

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Sat Aug 30 05:58:03 GMT 2025

- 14.2K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/collect/NullsLastOrdering.java

import com.google.common.annotations.J2ktIncompatible;
import java.io.Serializable;
import org.jspecify.annotations.NonNull;
import org.jspecify.annotations.Nullable;

/** An ordering that treats {@code null} as greater than all other values. */
@GwtCompatible
final class NullsLastOrdering<T extends @Nullable Object> extends Ordering<@Nullable T>
    implements Serializable {
  final Ordering<? super T> ordering;

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Wed Jun 04 13:03:16 GMT 2025

- 2.7K bytes

- Click Count (0)

github.com/google/guava

guava/src/com/google/common/collect/NullsLastOrdering.java

import com.google.common.annotations.J2ktIncompatible;
import java.io.Serializable;
import org.jspecify.annotations.NonNull;
import org.jspecify.annotations.Nullable;

/** An ordering that treats {@code null} as greater than all other values. */
@GwtCompatible
final class NullsLastOrdering<T extends @Nullable Object> extends Ordering<@Nullable T>
    implements Serializable {
  final Ordering<? super T> ordering;

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Wed Jun 04 13:03:16 GMT 2025

- 2.7K bytes

- Click Count (0)

github.com/minio/minio

internal/logger/logrotate.go

	if w.f != nil {
		if err := w.closeCurrentFile(); err != nil {
			return err
		}
	}

	return nil
}

var stdErrEnc = json.NewEncoder(os.Stderr)

func (w *Writer) listen() {
	for {
		var r io.Reader = w.pr
		if w.opts.MaximumFileSize > 0 {
			r = io.LimitReader(w.pr, w.opts.MaximumFileSize)
		}
		if _, err := io.Copy(w.f, r); err != nil {
			msg := fmt.Sprintf("unable to write to log file %v: %v", w.f.Name(), err)

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Sun Mar 30 00:56:02 GMT 2025

- 5.8K bytes

- Click Count (0)

github.com/square/okhttp

okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt

        .webSocketUpgrade(serverListener)
        .build(),
    )
    val response =
      client
        .newCall(
          request()
            .header("Connection", "Upgrade")
            .header("Upgrade", "websocket")
            .header("Sec-WebSocket-Key", "abc123")
            .build(),
        ).execute()
    response.body.close()
    networkLogs
      .assertLogEqual("--> GET $url http/1.1")

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Fri Nov 07 02:57:33 GMT 2025

- 39.4K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/ExchangeCodec.kt

  fun flushRequest()

  /** Flush the request to the underlying socket and signal no more bytes will be transmitted. */
  @Throws(IOException::class)
  fun finishRequest()

  /**
   * Parses bytes of a response header from an HTTP transport.
   *
   * @param expectContinue true to return null if this is an intermediate response with a "100"
   * response code. Otherwise this method never returns null.
   */
  @Throws(IOException::class)

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Tue Jul 29 21:11:09 GMT 2025

- 3.3K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs/zh/docs/advanced/response-cookies.md

如果你定义了 `response_model`，程序会自动根据`response_model`来过滤和转换你响应的对象。

**FastAPI** 会使用这个 *临时* 响应对象去装在这些cookies信息 (同样还有headers和状态码等信息), 最终会将这些信息和通过`response_model`转化过的数据合并到最终的响应里。

你也可以在依赖中定义`Response`参数，并设置cookie和header。

## 直接响应 `Response` { #return-a-response-directly }

你还可以在直接响应`Response`时直接创建cookies。

为此，你可以按照[直接返回 Response](response-directly.md)中的说明创建一个响应。

然后设置Cookies，并返回：

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Fri Mar 20 17:06:37 GMT 2026

- 2.1K bytes

- Click Count (0)

github.com/minio/minio

cmd/server-rlimit.go

	// Set the Go runtime max threads threshold to 90% of kernel setting.
	sysMaxThreads, err := sys.GetMaxThreads()
	if err == nil {
		minioMaxThreads := (sysMaxThreads * 90) / 100
		// Only set max threads if it is greater than the default one
		if minioMaxThreads > 10000 {
			debug.SetMaxThreads(minioMaxThreads)
		}
	}

	var maxLimit uint64

	// Set open files limit to maximum.

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Tue Jul 02 15:09:36 GMT 2024

- 2.8K bytes

- Click Count (0)

Search Options