Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1401 - 1410 of 1,613 for collections (0.1 sec)

  1. okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        )
    
        taskFaker.advanceUntil(540.ms)
        assertEvents(
          "plan 2 TCP connect canceled",
        )
    
        taskFaker.assertNoMoreTasks()
      }
    
      /**
       * This test puts several connections in flight that all fail at approximately the same time. It
       * confirms the fast fallback implements these invariants:
       *
       *  * if there's no TCP connect in flight, start one.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 24 04:40:49 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  2. internal/event/target/nsq.go

    		}
    		return eErr
    	}
    
    	if err := target.send(eventData); err != nil {
    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Close - closes underneath connections to NSQD server.
    func (target *NSQTarget) Close() (err error) {
    	close(target.quitCh)
    	if target.producer != nil {
    		// this blocks until complete:
    		target.producer.Stop()
    	}
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  3. manifests/addons/dashboards/lib/panels.libsonnet

          + timeSeries.standardOptions.withDecimals(0),
    
        seconds(title, targets, desc=''):
          self.base(title, targets, desc)
          + timeSeries.standardOptions.withUnit('s'),
    
        connections(title, targets, desc=''):
          self.base(title, targets, desc)
          + timeSeries.standardOptions.withUnit('cps'),
    
        dns(title, targets, desc=''):
          self.base(title, targets, desc)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jul 26 23:54:32 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/CertificatePinner.kt

    import okio.ByteString.Companion.toByteString
    
    /**
     * Constrains which certificates are trusted. Pinning certificates defends against attacks on
     * certificate authorities. It also prevents connections through man-in-the-middle certificate
     * authorities either known or unknown to the application's user.
     * This class currently pins a certificate's Subject Public Key Info as described on
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  5. cmd/bucket-lifecycle.go

    // there were no available workers.
    func (e *expiryStats) MissedTasks() int64 {
    	return e.missedExpiryTasks.Load()
    }
    
    // MissedFreeVersTasks returns the number of free version collection tasks that
    // were missed since there were no available workers.
    func (e *expiryStats) MissedFreeVersTasks() int64 {
    	return e.missedFreeVersTasks.Load()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  6. tensorflow/c/eager/parallel_device/parallel_device_lib_test.cc

      EXPECT_NE(TF_GetCode(status.get()), TF_CANCELLED);
      EXPECT_EQ(TF_GetCode(status.get()), TF_INVALID_ARGUMENT);
      EXPECT_THAT(TF_Message(status.get()), HasSubstr("assertion failed"));
    
      // Note that future collectives with the same context do not work at the
      // moment; once canceled, the collective executor requires the program to be
      // restarted / context to be reset.
    }
    
    TEST(PARALLEL_DEVICE_LIB, TestDifferentShapes) {
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 21 04:14:14 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  7. misc/cgo/gmp/gmp.go

    Translation of parameters and the return value follows the type
    translation above except that arrays passed as parameters translate
    explicitly in Go to pointers to arrays, as they do (implicitly) in C.
    
    Garbage collection is the big problem.  It is fine for the Go world to
    have pointers into the C world and to free those pointers when they
    are no longer needed.  To help, the Go code can define Go objects
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Apr 11 16:34:30 UTC 2022
    - 9.5K bytes
    - Viewed (0)
  8. cni/README.md

            - Pod has `istio-init` initContainer - this indicates a pod running its own injection setup.
    1. Return prevResult
    
    ## Troubleshooting
    
    ### Collecting Logs
    
    #### Using `istioctl`/helm
    
    - Set: `values.global.logging.level="cni:debug,ambient:debug"`
    - Inspect the pod logs of a `istio-cni` Daemonset pod on a specific node.
    
    #### From a specific node syslog
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jul 17 23:10:17 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  9. compat/maven-model-builder/pom.xml

                  <exclude>org.apache.maven.model.profile.ProfileSelector#getActiveProfilesV4(java.util.Collection,org.apache.maven.model.profile.ProfileActivationContext,org.apache.maven.model.building.ModelProblemCollector):METHOD_NEW_DEFAULT</exclude>
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.14.md

    * Add conntrack as a dependency of kubelet and kubeadm when building rpms and debs. Both require conntrack to handle cleanup of connections. ([#71540](https://github.com/kubernetes/kubernetes/pull/71540), [@mauilion](https://github.com/mauilion))
    * UDP connections now support graceful termination in IPVS mode ([#71515](https://github.com/kubernetes/kubernetes/pull/71515), [@lbernail](https://github.com/lbernail))
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Mon Jun 14 22:06:39 UTC 2021
    - 271.5K bytes
    - Viewed (0)
Back to top