Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 106 for discarded (0.4 sec)

  1. internal/logger/target/kafka/kafka.go

    	if h.store != nil {
    		h.storeCtxCancel()
    	}
    
    	// Set logch to nil and close it.
    	// This will block all Send operations,
    	// and finish the existing ones.
    	// All future ones will be discarded.
    	h.logChMu.Lock()
    	xioutil.SafeClose(h.logCh)
    	h.logCh = nil
    	h.logChMu.Unlock()
    
    	if h.producer != nil {
    		h.producer.Close()
    		h.client.Close()
    	}
    
    	// Wait for messages to be sent...
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sun Jun 02 03:03:39 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  2. platforms/core-execution/build-cache-http/src/integTest/groovy/org/gradle/caching/http/internal/HttpBuildCacheServiceIntegrationTest.groovy

         * Theoretically, a service could accept the write and then redirect to another page that polls for the success of that write.
         */
        def "non method preserving redirects on write result in discarded write"() {
            given:
            httpBuildCacheServer.cacheDir.createDir("redirect")
            httpBuildCacheServer.addResponder { req, res ->
                if (req.method == "PUT") {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Apr 22 23:08:20 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  3. platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheValueSourceIntegrationTest.groovy

                    $exceptionHandlerImpl
                }
            """)
    
            when:
            configurationCacheFails()
    
            then:
            outputContains("Configuration cache entry discarded with 1 problem.")
            failure.assertHasFailures(expectedFailuresCount)
            problems.assertFailureHasProblems(failure) {
                totalProblemsCount == 1
                problemsWithStackTraceCount == 1
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:25 UTC 2024
    - 20.6K bytes
    - Viewed (0)
  4. platforms/core-configuration/dependency-management-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/dm/LocalFileDependencyBackedArtifactSetCodec.kt

            val variant = candidates.variants.first()
            return when (val spec = transforms[variant.attributes.asImmutable()]) {
                null -> {
                    // no mapping for extension, so it can be discarded
                    if (matchingOnArtifactFormat) {
                        ResolvedArtifactSet.EMPTY
                    } else {
                        variant.artifacts
                    }
                }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 04 18:56:44 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  5. src/cmd/compile/internal/types2/scope.go

    // objects of s to p, adding all children of s to the
    // children of p, and removing s from p's children.
    // The function f is called for each object obj in s which
    // has an object alt in p. s should be discarded after
    // having been squashed.
    func (s *Scope) Squash(err func(obj, alt Object)) {
    	p := s.parent
    	assert(p != nil)
    	for name, obj := range s.elems {
    		obj = resolve(name, obj)
    		obj.setParent(nil)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 07 20:08:23 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  6. src/go/types/scope.go

    // objects of s to p, adding all children of s to the
    // children of p, and removing s from p's children.
    // The function f is called for each object obj in s which
    // has an object alt in p. s should be discarded after
    // having been squashed.
    func (s *Scope) squash(err func(obj, alt Object)) {
    	p := s.parent
    	assert(p != nil)
    	for name, obj := range s.elems {
    		obj = resolve(name, obj)
    		obj.setParent(nil)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 07 20:08:23 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  7. src/cmd/vendor/golang.org/x/tools/internal/facts/facts.go

    //
    // It calls the getPackage function for the package path string of
    // each dependency (perhaps indirect) that it encounters in the
    // encoding. If the function returns nil, the fact is discarded.
    //
    // This function is preferred over [NewDecoder] when the client is
    // capable of efficient look-up of packages by package path.
    func NewDecoderFunc(pkg *types.Package, getPackage GetPackageFunc) *Decoder {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 03 02:38:00 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  8. platforms/documentation/docs/src/docs/userguide/authoring-builds/gradle-properties/service_injection.adoc

    The property getter method must be `public` or `protected`. The method can be `abstract` or, in cases where this isn't possible, can have a dummy method body.
    The method body is discarded.
    
    Here is an example that shows a task type that receives a two services via property getter methods:
    
    ====
    [source.multi-language-sample,java]
    .Download.java
    ----
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Apr 24 04:19:09 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  9. src/cmd/vendor/github.com/google/pprof/internal/elfexec/elfexec.go

    // additional pages after the segment end.
    // The function returns a slice of pointers to the headers in the input
    // slice, which are valid only while phdrs is not modified or discarded.
    func ProgramHeadersForMapping(phdrs []elf.ProgHeader, mapOff, mapSz uint64) []*elf.ProgHeader {
    	const (
    		// pageSize defines the virtual memory page size used by the loader. This
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 19:48:28 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  10. internal/logger/target/http/http.go

    	// Wait for messages to be sent...
    	h.wg.Wait()
    
    	// Set logch to nil and close it.
    	// This will block all Send operations,
    	// and finish the existing ones.
    	// All future ones will be discarded.
    	h.logChMu.Lock()
    	xioutil.SafeClose(h.logCh)
    	h.logCh = nil
    	h.logChMu.Unlock()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sun Jun 02 03:03:39 UTC 2024
    - 14.9K bytes
    - Viewed (0)
Back to top