- Sort Score
- Result 10 results
- Languages All
Results 1521 - 1530 of 1,715 for threw (0.03 sec)
-
internal/dsync/dsync_test.go
}() dm2nd.Lock(id, source) // fmt.Printf("2nd lock obtained after 1st lock is released\n") time.Sleep(testDrwMutexRefreshCallTimeout * 2) dm2nd.Unlock(context.Background()) } // Test three locks for same resource, one succeeds, one fails (after timeout) func TestThreeSimultaneousLocksForSameResource(t *testing.T) { dm1st := NewDRWMutex(ds, "aap") dm2nd := NewDRWMutex(ds, "aap") dm3rd := NewDRWMutex(ds, "aap")
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 19 14:35:19 UTC 2024 - 11.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
System.setProperty("fess.version", version); System.setProperty("fess.product.version", productVersion); } catch (final Exception e) { throw new FessSystemException("Failed to parse project.properties.", e); } } @PreDestroy public void destroy() { shutdownHookList.forEach(action -> { try {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Oct 17 12:10:08 UTC 2024 - 27.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
assertThat(state()).isEqualTo(Service.State.STOPPING); notifyStopped(); } @Override protected void doStop() { throw new AssertionError(); // Should not be called. } }; final ServiceManager manager = new ServiceManager(asList(a)); manager.startAsync(); manager.stopAsync();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 25.5K bytes - Viewed (0) -
architecture/ambient/ztunnel.md
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Jul 17 23:10:17 UTC 2024 - 16.8K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/HandshakeCertificates.kt
val immutableInsecureHosts = insecureHosts.toImmutableList() val heldCertificate = heldCertificate if (heldCertificate != null && heldCertificate.keyPair.private.format == null) { throw KeyStoreException("unable to support unencodable private key") } val keyManager = newKeyManager(null, heldCertificate, *(intermediates ?: emptyArray()))
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 8.5K bytes - Viewed (0) -
src/main/java/jcifs/smb/NtlmUtil.java
} /** * @param password * @return nt password hash */ public static byte[] getNTHash ( String password ) { if ( password == null ) { throw new NullPointerException("Password parameter is required"); } MessageDigest md4 = Crypto.getMD4(); md4.update(Strings.getUNIBytes(password)); return md4.digest(); }
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Tue Jul 07 12:07:20 UTC 2020 - 9.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/IndexingHelper.java
} } } } throw new SearchEngineClientException(response.buildFailureMessage()); } } if (logger.isInfoEnabled()) { if (docList.getContentSize() > 0) {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 16.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/dict/stemmeroverride/AdminDictStemmeroverrideAction.java
try { return createStemmerOverrideItem(this, form, hook); } catch (final ValidationErrorException e) { saveToken(); throw e; } } public static OptionalEntity<StemmerOverrideItem> createStemmerOverrideItem(final FessBaseAction action, final CreateForm form, final VaErrorHook hook) {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 18.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/elevateword/AdminElevatewordAction.java
suggestHelper.deleteAllElevateWord(false); suggestHelper.storeAllElevateWords(false); } catch (final Exception e) { throw new FessSystemException("Failed to import data.", e); } }); saveInfo(messages -> messages.addSuccessUploadElevateWord(GLOBAL)); return redirect(getClass()); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 18.7K bytes - Viewed (0) -
src/main/java/org/codelibs/core/xml/DomUtil.java
} try { return new ByteArrayInputStream(contents.getBytes(encoding)); } catch (final UnsupportedEncodingException ex) { throw new IORuntimeException(ex); } } /** * 属性の値をエンコードします。 * * @param s * 属性値 * @return エンコードされた属性値 */
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 10.5K bytes - Viewed (0)