- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 149 for channel2 (0.06 sec)
-
ci/devinfra/docker/windows/Dockerfile
[Environment]::SetEnvironmentVariable('PATH', $env:PATH, 'Machine'); ENV CLOUDSDK_CORE_DISABLE_PROMPTS 1 RUN (New-Object Net.WebClient).DownloadFile('https://dl.google.com/dl/cloudsdk/channels/rapid/google-cloud-sdk.zip', 'C:\Temp\google-cloud-sdk.zip'); \ Expand-Archive -Path 'C:\Temp\google-cloud-sdk.zip' -DestinationPath $env:ProgramFiles -Verbose:$false
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Fri Jan 17 16:35:57 UTC 2025 - 8.4K bytes - Viewed (0) -
cmd/data-usage.go
backgroundHealInfoPath = bucketMetaPrefix + SlashSeparator + ".background-heal.json" dataUsageCacheName = ".usage-cache.bin" ) // storeDataUsageInBackend will store all objects sent on the dui channel until closed. func storeDataUsageInBackend(ctx context.Context, objAPI ObjectLayer, dui <-chan DataUsageInfo) { attempts := 1 for dataUsageInfo := range dui { json := jsoniter.ConfigCompatibleWithStandardLibrary
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu May 09 00:51:34 UTC 2024 - 5.6K bytes - Viewed (0) -
CODE_OF_CONDUCT.md
interaction with the people involved, including unsolicited interaction with those enforcing the Code of Conduct, for a specified period. This includes avoiding interactions in community spaces and external channels like social media. Violating these terms may lead to a temporary or permanent ban. ### 3. Temporary Ban **Community Impact**: A serious violation of community standards, including sustained inappropriate behavior.
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Thu Oct 17 06:18:13 UTC 2024 - 5K bytes - Viewed (0) -
docs/de/docs/deployment/manually.md
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sat Nov 09 16:39:20 UTC 2024 - 5.3K bytes - Viewed (0) -
cmd/metacache-server-pool.go
entries.listID = o.ID } } if !truncated { return entries, io.EOF } return entries, nil } // listMerged will list across all sets and return a merged results stream. // The result channel is closed when no more results are expected. func (z *erasureServerPools) listMerged(ctx context.Context, o listPathOptions, results chan<- metaCacheEntry) error { var mu sync.Mutex var wg sync.WaitGroup var errs []error
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon May 26 07:06:43 UTC 2025 - 12.9K bytes - Viewed (0) -
docs/fr/docs/deployment/manually.md
ASGI compatible avec HTTP/2 et Trio entre autres fonctionnalités. * <a href="https://github.com/django/daphne" class="external-link" target="_blank">Daphne</a> : le serveur ASGI conçu pour Django Channels. ## Machine serveur et programme serveur Il y a un petit détail sur les noms à garder à l'esprit. 💡
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sat Nov 09 16:39:20 UTC 2024 - 5.3K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/plugin/Log.java
import org.apache.maven.api.annotations.Experimental; import org.apache.maven.api.annotations.Provider; /** * This interface supplies the API for providing feedback to the user from the {@code Mojo}, * using standard Maven channels. * There should be no big surprises here, although you may notice that the methods accept * <code>java.lang.CharSequence</code> rather than <code>java.lang.String</code>. This is provided mainly as a
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Sat Sep 28 09:03:24 UTC 2024 - 5.4K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
setEventStreamHeaders(w) // Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers. // Use buffered channel to take care of burst sends or slow w.Write() mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames())) localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 6K bytes - Viewed (0) -
cmd/admin-heal-ops.go
h.mutex.Lock() h.endTime = UTCNow() h.currentStatus.Summary = healFinishedStatus h.mutex.Unlock() // drain traverse channel so the traversal // go-routine does not leak. go func() { // Eventually the traversal go-routine closes // the channel and returns, so this go-routine // itself will not leak. <-h.traverseAndHealDoneCh }() } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 25.4K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaConnection.java
*/ package jcifs.internal.smb2.rdma.tcp; import java.io.IOException; import java.net.InetSocketAddress; import java.net.Socket; import java.net.SocketTimeoutException; import java.nio.ByteBuffer; import java.nio.channels.SocketChannel; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import jcifs.internal.smb2.rdma.RdmaConnection; import jcifs.internal.smb2.rdma.RdmaMemoryRegion;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 8.8K bytes - Viewed (0)