Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 120 for isStale (0.18 sec)

  1. guava/src/com/google/common/hash/Striped64.java

            else if (a.cas(v = a.value, fn(v, x))) break;
            else if (n >= NCPU || cells != as) collide = false; // At max size or stale
            else if (!collide) collide = true;
            else if (busy == 0 && casBusy()) {
              try {
                if (cells == as) { // Expand table unless stale
                  Cell[] rs = new Cell[n << 1];
                  for (int i = 0; i < n; ++i) rs[i] = as[i];
                  cells = rs;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 17:55:55 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  2. docs/pt/docs/tutorial/security/first-steps.md

    ## Crie um `main.py`
    Copie o exemplo em um arquivo `main.py`:
    
    ```Python
    {!../../docs_src/security/tutorial001.py!}
    ```
    
    ## Execute-o
    
    /// info | "informação"
    
    
    
    ///
    
    	Primeiro, instale <a href="https://github.com/Kludex/python-multipart" class="external-link" target="_blank">`python-multipart`</a>.
    
    	Ex: `pip install python-multipart`.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  3. docs/features/calls.md

    ## Retrying Requests
    
    Sometimes connections fail: either a pooled connection was stale and disconnected, or the webserver itself couldn’t be reached. OkHttp will retry the request with a different route if one is available.
    
    ## [Calls](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-call/)
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  4. istioctl/pkg/describe/describe.go

    					if !exist {
    						dr, _ = configClient.NetworkingV1().DestinationRules(drNamespace).Get(context.Background(), drName, metav1.GetOptions{})
    						if dr == nil {
    							fmt.Fprintf(writer,
    								"WARNING: Proxy is stale; it references to non-existent destination rule %s.%s\n",
    								drName, drNamespace)
    						}
    						recordDestinationRules[newResourceID(drNamespace, drName)] = dr.DeepCopy()
    					}
    				}
    				if dr != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/CacheTest.kt

            .header("Cache-Control", "max-stale=180")
            .build()
        val response = client.newCall(request).execute()
        assertThat(response.body.string()).isEqualTo("A")
        assertThat(response.header("Warning")).isEqualTo(
          "110 HttpURLConnection \"Response is stale\"",
        )
      }
    
      @Test
      fun requestMaxStaleDirectiveWithNoValue() {
        // Add a stale response to the cache.
        server.enqueue(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 108.6K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/ztunnelserver.go

    	PodDeleted(ctx context.Context, uid string) error
    	PodAdded(ctx context.Context, pod *v1.Pod, netns Netns) error
    	Close() error
    }
    
    /*
    To clean up stale ztunnels
    
    	we may need to ztunnel to send its (uid, bootid / boot time) to us
    	so that we can remove stale entries when the ztunnel pod is deleted
    	or when the ztunnel pod is restarted in the same pod (remove old entries when the same uid connects again, but with different boot id?)
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  7. docs/pt/docs/deployment/docker.md

        Como esse arquivo **não muda com frequência**, o Docker irá detectá-lo e usar o **cache** para esse passo, habilitando o cache para o próximo passo também.
    
    4. Instale as dependências de pacote vindas do arquivo de requisitos.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Aug 12 21:47:53 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  8. cmd/bucket-metadata-sys.go

    	sys.Lock()
    	for _, bucket := range buckets {
    		sys.group.Forget(bucket)
    		delete(sys.metadataMap, bucket)
    		globalBucketMonitor.DeleteBucket(bucket)
    	}
    	sys.Unlock()
    }
    
    // RemoveStaleBuckets removes all stale buckets in memory that are not on disk.
    func (sys *BucketMetadataSys) RemoveStaleBuckets(diskBuckets set.StringSet) {
    	sys.Lock()
    	defer sys.Unlock()
    
    	for bucket := range sys.metadataMap {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  9. cmd/bucket-targets.go

    				sys.hMutex.Unlock()
    			}
    			hcTimer.Reset(defaultHealthCheckDuration)
    		case <-ctx.Done():
    			return
    		}
    	}
    }
    
    // periodically rebuild the healthCheck map from list of targets to clear
    // out stale endpoints
    func (sys *BucketTargetSys) reloadHealthCheckers(ctx context.Context) {
    	m := make(map[string]epHealth)
    	tgts := sys.ListTargets(ctx, "", "")
    	sys.hMutex.Lock()
    	for _, t := range tgts {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/server.go

    	var errs []error
    
    	// Remove the hostside ipset entry first, and unconditionally - if later failures happen, we never
    	// want to leave stale entries
    	if err := removePodFromHostNSIpset(pod, &s.hostsideProbeIPSet); err != nil {
    		log.Errorf("failed to remove pod %s from host ipset, error was: %v", pod.Name, err)
    		errs = append(errs, err)
    	}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
Back to top