- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 610 for Chan (0.15 sec)
-
cmd/iam-object-store.go
// items have the pathPrefix removed from their names. func listIAMConfigItems(ctx context.Context, objAPI ObjectLayer, pathPrefix string) <-chan itemOrErr { ch := make(chan itemOrErr) go func() { defer xioutil.SafeClose(ch) // Allocate new results channel to receive ObjectInfo. objInfoCh := make(chan ObjectInfo) if err := objAPI.Walk(ctx, minioMetaBucket, pathPrefix, objInfoCh, WalkOptions{}); err != nil { select {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 19.9K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
udsSockDir := t.TempDir() udsSock := filepath.Join(udsSockDir, "cni.sock") logger := NewUDSLogger() pluginLog.SetOutputLevel(log.DebugLevel) // this will be configured by global.logging.level stop := make(chan struct{}) defer close(stop) assert.NoError(t, logger.StartUDSLogServer(udsSock, stop)) // Configure log to tee to UDS server stdout := os.Stdout r, w, _ := os.Pipe() os.Stdout = w
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
cmd/object-api-interface.go
type ObjectLayer interface { // Locking operations on object. NewNSLock(bucket string, objects ...string) RWLocker // Storage operations. Shutdown(context.Context) error NSScanner(ctx context.Context, updates chan<- DataUsageInfo, wantCycle uint32, scanMode madmin.HealScanMode) error BackendInfo() madmin.BackendInfo StorageInfo(ctx context.Context, metrics bool) StorageInfo LocalStorageInfo(ctx context.Context, metrics bool) StorageInfo
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 16.9K bytes - Viewed (0) -
doc/go1.17_spec.html
<-chan <-chan int // same as <-chan (<-chan int) chan (<-chan int) </pre> <p> A new, initialized channel value can be made using the built-in function <a href="#Making_slices_maps_and_channels"><code>make</code></a>, which takes the channel type and an optional <i>capacity</i> as arguments: </p> <pre> make(chan int, 100) </pre> <p>
HTML - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Apr 11 20:22:45 GMT 2024 - 211.6K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/google/SortedMapGenerators.java
import java.util.Map.Entry; import java.util.SortedMap; /** * Generators of sorted maps and derived collections. * * @author Kevin Bourrillion * @author Jesse Wilson * @author Jared Levy * @author Hayward Chan * @author Chris Povirk * @author Louis Wasserman */ @GwtCompatible @ElementTypesAreNonnullByDefault public class SortedMapGenerators {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Feb 26 19:46:10 GMT 2024 - 4.6K bytes - Viewed (0) -
cmd/peer-rest-server.go
out <- grid.NewBytesWithCopyOf(buf.Bytes()) } } } // TraceHandler sends http trace messages back to peer rest client func (s *peerRESTServer) TraceHandler(ctx context.Context, payload []byte, _ <-chan []byte, out chan<- []byte) *grid.RemoteErr { var traceOpts madmin.ServiceTraceOpts err := json.Unmarshal(payload, &traceOpts) if err != nil { return grid.NewRemoteErr(err) } var wg sync.WaitGroup
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/google/ListGenerators.java
import com.google.common.primitives.Chars; import java.util.Arrays; import java.util.Collections; import java.util.List; /** * Common generators of different types of lists. * * @author Hayward Chan */ @GwtCompatible @ElementTypesAreNonnullByDefault public final class ListGenerators { private ListGenerators() {} public static class ImmutableListOfGenerator extends TestStringListGenerator {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Feb 21 16:49:06 GMT 2024 - 5K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/google/SortedMapGenerators.java
import java.util.Map.Entry; import java.util.SortedMap; /** * Generators of sorted maps and derived collections. * * @author Kevin Bourrillion * @author Jesse Wilson * @author Jared Levy * @author Hayward Chan * @author Chris Povirk * @author Louis Wasserman */ @GwtCompatible @ElementTypesAreNonnullByDefault public class SortedMapGenerators {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Feb 26 19:46:10 GMT 2024 - 4.6K bytes - Viewed (0) -
internal/grid/debug.go
hosts, listeners, err := getHosts(n) if err != nil { return nil, err } dialer := &net.Dialer{ Timeout: 5 * time.Second, } var res TestGrid res.Hosts = hosts ready := make(chan struct{}) ctx, cancel := context.WithCancel(context.Background()) res.cancel = cancel for i, host := range hosts { manager, err := NewManager(ctx, ManagerOptions{ Dialer: dialer.DialContext, Local: host,
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 08 18:15:27 GMT 2024 - 4.2K bytes - Viewed (0) -
cmd/data-scanner.go
// // Compaction happens when either: // // 1) The folder (and subfolders) contains less than dataScannerCompactLeastObject objects. // 2) The folder itself contains more than dataScannerCompactAtFolders folders. // 3) The folder only contains objects and no subfolders. // // A bucket root will never be compacted. // // Furthermore if a has more than dataScannerCompactAtChildren recursive children (uncompacted folders)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 47.4K bytes - Viewed (0)