Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 2,167 for latch (0.02 sec)

  1. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

            return Outcome.FAILURE;
          }
        } catch (InvocationTargetException targetException) {
          Throwable actualException = targetException.getTargetException();
          if (actualException instanceof InterruptedException) {
            return Outcome.INTERRUPT;
          } else {
            throw new AssertionError("unexpected exception", targetException);
          }
        } catch (IllegalAccessException e) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:18:12 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  2. fess-crawler/src/test/java/org/codelibs/fess/crawler/filter/impl/UrlFilterImplTest.java

            final String sessionId = "id1";
            urlFilter.init(sessionId);
    
            assertTrue(urlFilter.match("http://example.com/"));
            assertTrue(urlFilter.match("http://example.com/a"));
            assertFalse(urlFilter.match("http://test.com/"));
            assertFalse(urlFilter.match("http://test.com/a"));
    
        }
    
        public void test_match_include_case2() {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  3. internal/event/target/redis.go

    	if typeAvailable != "none" {
    		expectedType := "hash"
    		if r.Format == event.AccessFormat {
    			expectedType = "list"
    		}
    
    		if typeAvailable != expectedType {
    			return fmt.Errorf("expected type %v does not match with available type %v", expectedType, typeAvailable)
    		}
    	}
    
    	return nil
    }
    
    // RedisTarget - Redis target.
    type RedisTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  4. internal/store/batch_test.go

    	batchLen := batch.Len()
    	if batchLen != int(limit) {
    		t.Fatalf("Expected batch.Len() %v; but got %v", limit, batchLen)
    	}
    
    	keys := store.List()
    	if len(keys) > 0 {
    		t.Fatalf("Expected empty store list but got len(list) %v", len(keys))
    	}
    	if err := batch.Add(testItem); err != nil {
    		t.Fatalf("unable to add to the batch; %v", err)
    	}
    	batchLen = batch.Len()
    	if batchLen != 1 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  5. CHANGELOG/CHANGELOG-1.17.md

    Renamed FeatureGate RequestManagement to APIPriorityAndFairness....
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Jan 28 10:44:33 UTC 2021
    - 346.2K bytes
    - Viewed (1)
  6. istioctl/pkg/writer/envoy/configdump/listener.go

    			})
    			for _, match := range matches {
    				if includeConfigType {
    					name := fmt.Sprintf("listener/%s", l.Name)
    					fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\n", name, strings.Join(addresses, ","), port, match.match, match.destination)
    				} else {
    					fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", strings.Join(addresses, ","), port, match.match, match.destination)
    				}
    			}
    		} else {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 29 12:37:14 UTC 2023
    - 18.1K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/app/web/admin/upgrade/AdminUpgradeAction.java

                    upgradeFromAll();
    
                    saveInfo(messages -> messages.addSuccessStartedDataUpdate(GLOBAL));
    
                    systemHelper.reloadConfiguration();
                } catch (final Exception e) {
                    logger.warn("Failed to upgrade data.", e);
                    saveError(messages -> messages.addErrorsFailedToUpgradeFrom(GLOBAL, VERSION_13_0, e.getLocalizedMessage()));
                }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 01:54:46 UTC 2024
    - 54K bytes
    - Viewed (0)
  8. callbacks/callbacks.go

    	deleteCallback.Match(enableTransaction).Register("gorm:begin_transaction", BeginTransaction)
    	deleteCallback.Register("gorm:before_delete", BeforeDelete)
    	deleteCallback.Register("gorm:delete_before_associations", DeleteBeforeAssociations)
    	deleteCallback.Register("gorm:delete", Delete(config))
    	deleteCallback.Register("gorm:after_delete", AfterDelete)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Oct 27 23:56:55 UTC 2021
    - 3.3K bytes
    - Viewed (0)
  9. common-protos/k8s.io/api/authorization/v1/generated.proto

      optional string verb = 2;
    }
    
    // NonResourceRule holds information that describes a rule for the non-resource
    message NonResourceRule {
      // Verb is a list of kubernetes non-resource API verbs, like: get, post, put, delete, patch, head, options.  "*" means all.
      repeated string verbs = 1;
    
      // NonResourceURLs is a set of partial urls that a user should have access to.  *s are allowed, but only as the full,
      // final step in the path.  "*" means all.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  10. android/guava-testlib/test/com/google/common/collect/testing/HelpersTest.java

        } catch (AssertionFailedError expected) {
        }
    
        try {
          assertContentsInOrder(list, "a", "c", "b");
          throw new Error();
        } catch (AssertionFailedError expected) {
        }
    
        try {
          assertContentsInOrder(list, "a", "B", "c");
          throw new Error();
        } catch (AssertionFailedError expected) {
        }
      }
    
      public void testAssertContains() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 5.1K bytes
    - Viewed (0)
Back to top