Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1521 - 1530 of 1,715 for threw (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. architecture/ambient/ztunnel.md

    ## Traffic routing
    
    Based on the three [redirection](#redirection) paths, the ztunnel has three primary types of traffic it handles.
    
    ### Outbound
    
    Requests leaving a pod go through the "outbound" code path on port 15001.
    This is where most of Ztunnel's logic lives.
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jul 17 23:10:17 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top