- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for thread_name (1.01 sec)
-
src/test/java/org/codelibs/fess/it/CrawlTestBase.java
final List<Map<String, Object>> resList = new ArrayList<>(); for (Map<String, Object> elem : logList) { logger.info("config_id: {}, thread_name: {}", configId, elem.get("thread_name")); if (elem.containsKey("thread_name") && elem.get("thread_name").toString().startsWith("Crawler-" + configId.replace('-', '_'))) { resList.add(elem); } } return resList; }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.9K bytes - Viewed (0) -
src/internal/trace/traceviewer/emitter.go
} e.threadMeta(format.ProcsSection, id, name, priority) } e.c.Flush() } func (e *Emitter) threadMeta(sectionID, tid uint64, name string, priority int) { e.Event(&format.Event{ Name: "thread_name", Phase: "M", PID: sectionID, TID: tid, Arg: &format.NameArg{Name: name}, }) e.Event(&format.Event{ Name: "thread_sort_index", Phase: "M", PID: sectionID, TID: tid,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 21:29:58 UTC 2023 - 20.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/cbean/ca/bs/BsFailureUrlCA.java
public void setThreadName_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda) { setThreadName_Terms("threadName", opLambda, null); } public void setThreadName_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda, OperatorCall<BsFailureUrlCA> aggsLambda) { setThreadName_Terms("threadName", opLambda, aggsLambda); }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 46.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/bsentity/dbmeta/FailureUrlDbm.java
null, false, false, false, "Long", 0, 0, null, null, false, null, null, null, null, null, false); protected final ColumnInfo _columnThreadName = cci("threadName", "threadName", null, null, String.class, "threadName", null, false, false, false, "keyword", 0, 0, null, null, false, null, null, null, null, null, false);
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 10.2K bytes - Viewed (0) -
src/main/webapp/WEB-INF/view/admin/failureurl/admin_failureurl_details.jsp
<tr> <th><la:message key="labels.failure_url_thread_name"/></th> <td>${f:h(threadName)}<la:hidden property="threadName"/></td> </tr> <tr> <th><la:message key="labels.failure_url_error_name"/></th>
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 13 07:47:04 UTC 2020 - 10.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TestThread.java
private final SynchronousQueue<Response> responseQueue = new SynchronousQueue<>(); private @Nullable Throwable uncaughtThrowable = null; public TestThread(L lockLikeObject, String threadName) { super(threadName); this.lockLikeObject = checkNotNull(lockLikeObject); start(); } // Thread.stop() is okay because all threads started by a test are dying at the end of the test,
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
private final SynchronousQueue<Response> responseQueue = new SynchronousQueue<>(); private @Nullable Throwable uncaughtThrowable = null; public TestThread(L lockLikeObject, String threadName) { super(threadName); this.lockLikeObject = checkNotNull(lockLikeObject); start(); } // Thread.stop() is okay because all threads started by a test are dying at the end of the test,
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
return; } short current = getSystemCpuPercent(); if (current < percent) { return; } final String threadName = Thread.currentThread().getName(); try { waitingThreadNames.add(threadName); while (current >= percent) { if (logger.isInfoEnabled()) {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Sun May 26 05:52:29 UTC 2024 - 26.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
import okhttp3.internal.http.CallServerInterceptor import okhttp3.internal.http.RealInterceptorChain import okhttp3.internal.http.RetryAndFollowUpInterceptor import okhttp3.internal.platform.Platform import okhttp3.internal.threadName import okio.AsyncTimeout import okio.Timeout /** * Bridge between OkHttp's application and network layers. This class exposes high-level application * layer primitives: connections, requests, responses, and streams.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt
} } catch (_: SocketTimeoutException) { true // Read timed out; socket is good. } catch (_: IOException) { false // Couldn't read; socket is closed. } } internal inline fun threadName( name: String, block: () -> Unit, ) { val currentThread = Thread.currentThread() val oldName = currentThread.name currentThread.name = name try { block() } finally {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon May 13 13:42:37 UTC 2024 - 10.7K bytes - Viewed (0)