- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 425 for doneSz (0.04 sec)
-
docs/bucket/replication/setup_2site_existing_replication.sh
catch() { if [ $# -ne 0 ]; then echo "error on line $1" for site in sitea siteb; do echo "$site server logs =========" cat "/tmp/${site}_1.log" echo "===========================" cat "/tmp/${site}_2.log" done fi echo "Cleaning up instances of MinIO" pkill minio pkill -9 minio rm -rf /tmp/multisitea rm -rf /tmp/multisiteb rm -rf /tmp/data if [ $# -ne 0 ]; then exit $# fi } catchRegistered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Sep 06 09:42:21 UTC 2024 - 5.6K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/collect/SortedCopyBenchmark.java
List<Integer> list = new ArrayList<>(set); inputOrder.arrange(list); input = ImmutableList.copyOf(list); } @Benchmark int collections(int reps) { int dummy = 0; // Yes, this could be done more elegantly if (mutable) { for (int i = 0; i < reps; i++) { List<Integer> copy = new ArrayList<>(input); sort(copy); dummy += copy.get(0); } } else {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 3.5K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/AbstractNonStreamingHashFunction.java
import java.nio.ByteOrder; import java.nio.charset.Charset; import java.util.Arrays; /** * Skeleton implementation of {@link HashFunction}, appropriate for non-streaming algorithms. All * the hash computation done using {@linkplain #newHasher()} are delegated to the {@linkplain * #hashBytes(byte[], int, int)} method. * * @author Dimitris Andreou */ @ImmutableRegistered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 3.8K bytes - Viewed (0) -
ci/official/containers/ml_build/setup.python.sh
pushd /usr/include/x86_64-linux-gnu for f in $(ls | grep python); do # set up symlink for devtoolset-9 rm -f /dt9/usr/include/x86_64-linux-gnu/$f ln -s /usr/include/x86_64-linux-gnu/$f /dt9/usr/include/x86_64-linux-gnu/$f done popd # Python 3.10 include headers fix: # sysconfig.get_path('include') incorrectly points to /usr/local/include/python # map /usr/include/python3.10 to /usr/local/include/python3.10
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Fri Aug 01 02:44:57 UTC 2025 - 2.8K bytes - Viewed (0) -
docs/en/docs/async.md
There's no waiting 🕙 anywhere, just a lot of work to be done, on multiple places of the house. You could have turns as in the burgers example, first the living room, then the kitchen, but as you are not waiting 🕙 for anything, just cleaning and cleaning, the turns wouldn't affect anything. It would take the same amount of time to finish with or without turns (concurrency) and you would have done the same amount of work.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:56:21 UTC 2025 - 24K bytes - Viewed (0) -
cmd/metacache-server-pool.go
listCtx, cancelList := context.WithCancel(ctx) filteredResults := o.gatherResults(listCtx, filterCh) var wg sync.WaitGroup wg.Add(1) var listErr error go func(o listPathOptions) { defer wg.Done() if o.Lifecycle == nil { // No filtering ahead, ask drives to stop // listing exactly at a specific limit. o.StopDiskAtLimit = true } listErr = z.listMerged(listCtx, o, filterCh)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon May 26 07:06:43 UTC 2025 - 12.9K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
var mu sync.Mutex for onlineServers < len(clnts)/2 { var wg sync.WaitGroup wg.Add(len(clnts)) onlineServers = 0 for _, clnt := range clnts { go func(clnt *bootstrapRESTClient) { defer wg.Done() if clnt.gridConn.State() != grid.StateConnected { mu.Lock() offlineEndpoints = append(offlineEndpoints, fmt.Errorf("%s is unreachable: %w", clnt, grid.ErrDisconnected)) mu.Unlock() return
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Oct 01 22:13:18 UTC 2024 - 8.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
* mutated by the call thread only. If is accessed by background connect threads. */ private val tcpConnectsInFlight = CopyOnWriteArrayList<Plan>() /** * Results are posted here as they occur. The find job is done when either one plan completes * successfully or all plans fail. */ private val connectResults = taskRunner.backend.decorate(LinkedBlockingDeque<ConnectResult>()) override fun find(): RealConnection {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 5.8K bytes - Viewed (0) -
ci/official/containers/ml_build_arm64/setup.python.sh
for f in $(ls | grep python); do # set up symlink for devtoolset-10 rm -f /dt10/usr/include/aarch64-linux-gnu/$f ln -s /usr/include/aarch64-linux-gnu/$f /dt10/usr/include/aarch64-linux-gnu/$f done popd # Python 3.10 include headers fix: # sysconfig.get_path('include') incorrectly points to /usr/local/include/python # map /usr/include/python3.10 to /usr/local/include/python3.10
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Fri Aug 01 19:14:43 UTC 2025 - 3.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt
* returns null. * * This will typically return null until [ResponseBody.source] has buffered the last byte of the * response body. Call `body.source().request(1024 * 1024)` to block until either that's done, or * 1 MiB of response data is loaded into memory. (You could use any size here, though large values * risk exhausting memory.) * * This returns an empty value if the trailers are available, but have no data.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 28 14:39:28 UTC 2025 - 18.1K bytes - Viewed (0)