Search Options

Results per page
Sort
Preferred Languages
Advance

Results 2061 - 2070 of 2,532 for created (0.17 sec)

  1. internal/deadlineconn/deadlineconn_test.go

    )
    
    // Test deadlineconn handles read timeout properly by reading two messages beyond deadline.
    func TestBuffConnReadTimeout(t *testing.T) {
    	l, err := net.Listen("tcp", "localhost:0")
    	if err != nil {
    		t.Fatalf("unable to create listener. %v", err)
    	}
    	defer l.Close()
    	serverAddr := l.Addr().String()
    
    	tcpListener, ok := l.(*net.TCPListener)
    	if !ok {
    		t.Fatalf("failed to assert to net.TCPListener")
    	}
    
    	var wg sync.WaitGroup
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Nov 05 18:09:21 UTC 2022
    - 3K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/base/FinalizablePhantomReference.java

     * after the garbage collector reclaims the referent. This is a simpler alternative to using a
     * {@link ReferenceQueue}.
     *
     * <p>Unlike a normal phantom reference, this reference will be cleared automatically.
     *
     * @author Bob Lee
     * @since 2.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    public abstract class FinalizablePhantomReference<T> extends PhantomReference<T>
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 23 15:09:35 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

    public abstract class AbstractListenableFutureTest extends TestCase {
    
      protected CountDownLatch latch;
      protected ListenableFuture<Boolean> future;
    
      @Override
      protected void setUp() throws Exception {
    
        // Create a latch and a future that waits on the latch.
        latch = new CountDownLatch(1);
        future = createListenableFuture(Boolean.TRUE, null, latch);
      }
    
      @Override
      protected void tearDown() throws Exception {
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 18:30:30 UTC 2023
    - 6K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/reflect/ImmutableTypeToInstanceMapTest.java

                      // but here we have to do some serious fudging
                      @Override
                      @SuppressWarnings({"unchecked", "rawtypes"})
                      public Map<TypeToken, Object> create(Object... elements) {
                        ImmutableTypeToInstanceMap.Builder<Object> builder =
                            ImmutableTypeToInstanceMap.builder();
                        for (Object object : elements) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 17:15:24 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java

        service.stopAsync().awaitTerminated();
        assertEquals("TestService [TERMINATED]", service.toString());
      }
    
      public void testTimeout() throws Exception {
        // Create a service whose executor will never run its commands
        Service service =
            new TestService() {
              @Override
              protected Executor executor() {
                return new Executor() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  6. src/main/java/jcifs/spnego/NegTokenInit.java

                ev.add(new DERTaggedObject(true, 0, new DERSequence(fields)));
                ByteArrayOutputStream collector = new ByteArrayOutputStream();
                ASN1OutputStream der = ASN1OutputStream.create(collector, ASN1Encoding.DER);
                DERTaggedObject derApplicationSpecific = new DERTaggedObject(false, BERTags.APPLICATION, 0, new DERSequence(ev));
                der.writeObject(derApplicationSpecific);
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Oct 01 12:01:17 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  7. internal/http/dial_linux.go

    			}
    
    			if opts.Interface != "" {
    				if h, _, err := net.SplitHostPort(address); err == nil {
    					address = h
    				}
    				// Create socket on specific vrf device.
    				// To catch all kinds of special cases this filters specifically for loopback networks.
    				if ip := net.ParseIP(address); ip != nil && !ip.IsLoopback() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  8. .teamcity/src/main/kotlin/projects/StageProject.kt

                    buildReportTab("Performance", "performance-test-results.zip!report/index.html")
                }
            }
    
            specificBuildTypes = stage.specificBuilds.map {
                it.create(model, stage)
            }
            specificBuildTypes.forEach(this::buildType)
    
            performanceTests = stage.performanceTests.map { createPerformanceTests(model, performanceTestBucketProvider, stage, it) } +
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Mon Oct 07 09:17:14 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  9. istioctl/pkg/proxystatus/proxystatus_test.go

    				IstioNamespace: "istio-system",
    			})
    			if !c.noIstiod {
    				client, err := ctx.CLIClientWithRevision(c.revision)
    				assert.NoError(t, err)
    				_, err = client.Kube().CoreV1().Pods("istio-system").Create(context.TODO(), &corev1.Pod{
    					ObjectMeta: metav1.ObjectMeta{
    						Name:      "istiod-test",
    						Namespace: "istio-system",
    						Labels: map[string]string{
    							"app":                 "istiod",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Mar 15 08:28:50 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  10. src/packaging/rpm/init.d/fess

            exit 1
        fi
    }
    
    start() {
        checkJava
        [ -x $exec ] || exit 5
    
        # Ensure that the PID_DIR exists (it is cleaned at OS startup time)
        if [ -n "$PID_DIR" ] && [ ! -e "$PID_DIR" ]; then
            mkdir -p "$PID_DIR" && chown "$FESS_USER":"$FESS_GROUP" "$PID_DIR"
        fi
        if [ -n "$pidfile" ] && [ ! -e "$pidfile" ]; then
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Jan 15 06:32:15 UTC 2023
    - 3.7K bytes
    - Viewed (0)
Back to top