Desmond - Code Search

src/main/webapp/WEB-INF/view/login/index.jsp

<link href="${fe:url('/css/admin/style.css')}" rel="stylesheet" type="text/css" />
<!--[if lt IE 9]>
<script src="${fe:url('/css/admin/html5shiv.min.js')}"></script>
<script src="${fe:url('/css/admin/respond.min.js')}"></script>
<![endif]-->
</head>
<body class="hold-transition login-page">
	<div class="login-box">
		<div class="login-logo">
			<la:link href="/">
				<img src="${fe:url('/images/logo-top.png')}"

Others

- Registered: Mon May 06 08:04:11 GMT 2024

- Last Modified: Fri Feb 17 12:13:41 GMT 2023

- 3K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/orig/view/profile/index.jsp

<link href="${fe:url('/css/admin/style.css')}" rel="stylesheet" type="text/css" />
<!--[if lt IE 9]>
<script src="${fe:url('/css/admin/html5shiv.min.js')}"></script>
<script src="${fe:url('/css/admin/respond.min.js')}"></script>
<![endif]-->
</head>
<body class="hold-transition login-page">
	<div class="login-box">
		<div class="login-logo">
			<la:link href="/">
				<img src="${fe:url('/images/logo-top.png')}"

Others

- Registered: Mon May 06 08:04:11 GMT 2024

- Last Modified: Fri Feb 17 12:13:41 GMT 2023

- 3.6K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

  }

  @Throws(IOException::class)
  override fun onReadMessage(bytes: ByteString) {
    listener.onMessage(this, bytes)
  }

  @Synchronized override fun onReadPing(payload: ByteString) {
    // Don't respond to pings after we've failed or sent the close frame.
    if (failed || enqueuedClose && messageAndCloseQueue.isEmpty()) return

    pongQueue.add(payload)
    runWriter()
    receivedPingCount++
  }

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Mon Apr 01 14:21:25 GMT 2024

- 22.1K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc

  EXPECT_EQ(cache.CacheSize(), 0);
}

TEST(RamFileBlockCacheTest, ParallelReads) {
  // This fetcher won't respond until either `callers` threads are calling it
  // concurrently (at which point it will respond with success to all callers),
  // or 10 seconds have elapsed (at which point it will respond with an error).
  const int callers = 4;
  BlockingCounter counter(callers);

C++

- Registered: Tue Apr 23 12:39:09 GMT 2024

- Last Modified: Fri Oct 15 03:16:57 GMT 2021

- 23.2K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

     * that once the Thread returns to the Executor that this Executor composes, the interruption
     * will still be present. If the composed Executor is an ExecutorService, it can respond to
     * shutdown() by returning tasks queued on that Thread after {@link #worker} drains the queue.
     */
    @SuppressWarnings("CatchingUnchecked") // sneaky checked exception
    private void workOnQueue() {

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Thu Feb 01 21:46:34 GMT 2024

- 10.6K bytes

- Viewed (0)

github.com/minio/minio

internal/dsync/dsync-server_test.go

	// and positive values indicating number of read locks
	lockMap map[string]int64

	// Refresh returns lock not found if set to true
	lockNotFound bool

	// Set to true if you want peers servers to do not respond
	responseDelay int64
}

func (l *lockServer) setRefreshReply(refreshed bool) {
	l.mutex.Lock()
	defer l.mutex.Unlock()
	l.lockNotFound = !refreshed
}

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Mon Jan 23 16:46:37 GMT 2023

- 8.3K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs/en/docs/advanced/websockets.md

<img src="/img/tutorial/websockets/image01.png">

You can type messages in the input box, and send them:

<img src="/img/tutorial/websockets/image02.png">

And your **FastAPI** application with WebSockets will respond back:

<img src="/img/tutorial/websockets/image03.png">

You can send (and receive) many messages:

<img src="/img/tutorial/websockets/image04.png">

And all of them will use the same WebSocket connection.

Plain Text

- Registered: Sun May 05 07:19:11 GMT 2024

- Last Modified: Thu May 02 22:37:31 GMT 2024

- 6.2K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/netbios/NbtAddress.java

 */ 

    public static final String MASTER_BROWSER_NAME = "\u0001\u0002__MSBROWSE__\u0002";

/**
 * A special generic name specified when connecting to a host for which
 * a name is not known. Not all servers respond to this name.
 */

    public static final String SMBSERVER_NAME = "*SMBSERVER     ";

/** 
 * A B node only broadcasts name queries. This is the default if a

Java

- Registered: Sun May 05 00:10:10 GMT 2024

- Last Modified: Fri Mar 22 20:39:42 GMT 2019

- 30.1K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs/en/docs/tutorial/security/first-steps.md

If it doesn't see an `Authorization` header, or the value doesn't have a `Bearer ` token, it will respond with a 401 status code error (`UNAUTHORIZED`) directly.

You don't even have to check if the token exists to return an error. You can be sure that if your function is executed, it will have a `str` in that token.

Plain Text

- Registered: Sun May 05 07:19:11 GMT 2024

- Last Modified: Wed Mar 13 19:02:19 GMT 2024

- 8.9K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

   *
   * To differentiate the two cases we ping the server when a stream times out. If the overall
   * connection is fine the ping will receive a pong; otherwise it won't.
   *
   * The deadline to respond to this ping attempts to limit the cost of being wrong. If it is too
   * long, streams created while we await the pong will reuse broken connections and inevitably

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Sat Apr 20 17:03:43 GMT 2024

- 32.6K bytes

- Viewed (0)

Search Options