Search Options

Results per page
Sort
Preferred Languages
Advance

Results 921 - 930 of 956 for Socket (0.19 sec)

  1. guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

          ArrayList<LockGraphNode> acquiredLockList = requireNonNull(acquiredLocks.get());
          LockGraphNode node = lock.getLockGraphNode();
          // Iterate in reverse because locks are usually locked/unlocked in a
          // LIFO order.
          for (int i = acquiredLockList.size() - 1; i >= 0; i--) {
            if (acquiredLockList.get(i) == node) {
              acquiredLockList.remove(i);
              break;
            }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 35.9K bytes
    - Viewed (0)
  2. docs/en/docs/release-notes.md

    * ✏ Fix minor typos in `docs/en/docs/async.md`. PR [#5125](https://github.com/tiangolo/fastapi/pull/5125) by [@Ksenofanex](https://github.com/Ksenofanex).
    * 📝 Add external link to docs: "Fastapi, Docker(Docker compose) and Postgres". PR [#5033](https://github.com/tiangolo/fastapi/pull/5033) by [@krishnardt](https://github.com/krishnardt).
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Nov 01 11:25:57 UTC 2024
    - 460.3K bytes
    - Viewed (0)
  3. compat/maven-model-builder/src/test/resources/dag.txt

    	quarkus/extensions/panache/panache-common/runtime/pom.xml
    	quarkus/extensions/panache/panache-hibernate-common/runtime/pom.xml
    quarkus/extensions/container-image/container-image-docker/deployment/pom.xml
    	quarkus/extensions/container-image/container-image-docker/runtime/pom.xml
    	quarkus/extensions/container-image/deployment/pom.xml
    quarkus/extensions/spring-cloud-config-client/runtime/pom.xml
    	quarkus/extensions/arc/runtime/pom.xml
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 224K bytes
    - Viewed (0)
  4. docs/metrics/prometheus/grafana/replication/minio-replication-node.json

              "expr": "sum by (server) (minio_node_replication_last_minute_queued_count{job=\"$scrape_jobs\"})",
              "interval": "1m",
              "intervalFactor": 2,
              "legendFormat": "{{bucket}}",
              "refId": "A"
            }
          ],
          "title": "Last Minute Queued Objects",
          "type": "timeseries"
        },
        {
          "datasource": {
            "type": "prometheus",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 13 22:26:54 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java

    import org.opensearch.search.SearchHit;
    import org.opensearch.search.SearchHits;
    import org.opensearch.search.aggregations.AggregationBuilders;
    import org.opensearch.search.aggregations.bucket.filter.FilterAggregationBuilder;
    import org.opensearch.search.aggregations.bucket.terms.TermsAggregationBuilder;
    import org.opensearch.search.collapse.CollapseBuilder;
    import org.opensearch.search.fetch.subphase.highlight.HighlightBuilder;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Oct 20 02:08:03 UTC 2024
    - 86.1K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

        for (int i = 0; i < originalCount; i++) {
          Object key = new Object();
          Object value = new Object();
          int hash = map.hash(key);
          // chain all entries together as we only have a single bucket
          entry = map.newEntry(key, hash, entry);
          ValueReference<Object, Object> valueRef = map.newValueReference(entry, value, 1);
          entry.setValueReference(valueRef);
        }
        segment.table.set(0, entry);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 110.6K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/cache/LocalCacheTest.java

        for (int i = 0; i < originalCount; i++) {
          Object key = new Object();
          Object value = new Object();
          int hash = map.hash(key);
          // chain all entries together as we only have a single bucket
          entry = map.newEntry(key, hash, entry);
          ValueReference<Object, Object> valueRef = map.newValueReference(entry, value, 1);
          entry.setValueReference(valueRef);
        }
        segment.table.set(0, entry);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 112.3K bytes
    - Viewed (0)
  8. guava/src/com/google/common/io/ByteStreams.java

       * <ol>
       *   <li>Use sendfile(2) or equivalent. Requires that both the input channel and the output
       *       channel have their own file descriptors. Generally this only happens when both channels
       *       are files or sockets. This performs zero copies - the bytes never enter userspace.
       *   <li>Use mmap(2) or equivalent. Requires that either the input channel or the output channel
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 29.7K bytes
    - Viewed (0)
  9. cmd/iam-object-store.go

    			}
    			policyDocs[index] = policyDoc
    			return nil
    		}, index)
    	}
    
    	err := errors.Join(g.Wait()...)
    	return policyDocs, err
    }
    
    // Assumes cache is locked by caller.
    func (iamOS *IAMObjectStore) loadAllFromObjStore(ctx context.Context, cache *iamCache, firstTime bool) error {
    	bootstrapTraceMsgFirstTime := func(s string) {
    		if firstTime {
    			bootstrapTraceMsg(s)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  10. istioctl/pkg/describe/describe.go

    	}
    
    	if hIP := ingress.pods[0].Status.HostIP; hIP != "" {
    		return hIP
    	}
    
    	// The scope of this function is to get the IP from Kubernetes, we do not
    	// ask Docker or minikube for an IP.
    	// See https://istio.io/docs/tasks/traffic-management/ingress/ingress-control/#determining-the-ingress-ip-and-ports
    	return "unknown"
    }
    
    func printIngressInfo(
    	writer io.Writer,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
Back to top