- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 47 for Meyers (0.18 sec)
-
cmd/site-replication.go
}) } if err != nil { return errSRServiceAccount(fmt.Errorf("unable to create service account on %s: %v", ourName, err)) } peers := make(map[string]madmin.PeerInfo, len(arg.Peers)) for dID, pi := range arg.Peers { if c.state.Peers != nil { if existingPeer, ok := c.state.Peers[dID]; ok { // retain existing ReplicateILMExpiry of peer if its already set // and incoming arg has it false. it could be default false
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 182.7K bytes - Viewed (1) -
cmd/notification.go
return } if pools, ok := objAPI.(*erasureServerPools); ok { pools.StopRebalance() } } // LoadRebalanceMeta notifies all peers to load rebalance.bin from object layer. // Note: Only peers participating in rebalance operation, namely the first node // in each pool will load rebalance.bin. func (sys *NotificationSys) LoadRebalanceMeta(ctx context.Context, startRebalance bool) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/logging.go
func peersLogIf(ctx context.Context, err error, errKind ...interface{}) { logger.LogIf(ctx, "peers", err, errKind...) } func peersLogAlwaysIf(ctx context.Context, err error, errKind ...interface{}) { logger.LogAlwaysIf(ctx, "peers", err, errKind...) } func peersLogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) { logger.LogOnceIf(ctx, "peers", err, id, errKind...) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 6.6K bytes - Viewed (0) -
cmd/endpoint.go
// The LOCAL host will be nil, but the indexes of all hosts should // remain consistent across the cluster. func (l EndpointServerPools) hostsSorted() []*xnet.Host { peers, localPeer := l.peers() sort.Strings(peers) hosts := make([]*xnet.Host, len(peers)) for i, hostStr := range peers { if hostStr == localPeer { continue } host, err := xnet.ParseHost(hostStr) if err != nil { internalLogIf(GlobalContext, err)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0) -
cmd/peer-s3-client.go
func newPeerS3Clients(endpoints EndpointServerPools) (peers []peerS3Client) { nodes := endpoints.GetNodes() peers = make([]peerS3Client, len(nodes)) for i, node := range nodes { if node.IsLocal { peers[i] = &localPeerS3Client{node: node} } else { peers[i] = newPeerS3Client(node) } peers[i].SetPools(node.Pools) } return peers } // Returns a peer S3 client.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
RELEASE.md
* Update `tf.keras` to the Keras 2.1.6 API. * Added [`tf.keras.layers.CuDNNGRU`](https://www.tensorflow.org/versions/r1.9/api_docs/python/tf/keras/layers/CuDNNGRU) and [`tf.keras.layers.CuDNNLSTM`](https://www.tensorflow.org/versions/r1.9/api_docs/python/tf/keras/layers/CuDNNLSTM) layers.
Plain Text - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Wed Apr 03 20:27:38 GMT 2024 - 727.4K bytes - Viewed (8) -
cmd/metacache-entries.go
} return other, other.isDir() == e.isDir() } eVers, eErr := e.xlmeta() oVers, oErr := other.xlmeta() if eErr != nil || oErr != nil { return nil, false } // check both fileInfo's have same number of versions, if not skip // the `other` entry. if len(eVers.versions) != len(oVers.versions) { eTime := eVers.latestModtime() oTime := oVers.latestModtime() if !eTime.Equal(oTime) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 23.2K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/references/KDocReferenceResolver.kt
* prefixed with a suitable extension receiver type (like in `Foo.bar`, or `foo.Foo.bar`). * * Relies on the fact that in such references only the last qualifier refers to the * actual extension callable, and the part before that refers to the receiver type (either fully * or partially qualified). * * For example, `foo.Foo.bar` may only refer to the extension callable `bar` with
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Fri Apr 19 11:06:47 GMT 2024 - 22.6K bytes - Viewed (0) -
cmd/peer-rest-client.go
_, err = loadSvcActRPC.Call(context.Background(), client.gridConn(), grid.NewMSSWith(map[string]string{ peerRESTUser: accessKey, })) return err } // LoadGroup - send load group command to peers. func (client *peerRESTClient) LoadGroup(group string) error { _, err := loadGroupRPC.Call(context.Background(), client.gridConn(), grid.NewMSSWith(map[string]string{ peerRESTGroup: group, })) return err }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/ReactorReader.java
.findFirst() .orElse(null); } /** * Determines whether the specified artifact refers to test classes. * * @param artifact The artifact to check, must not be {@code null}. * @return {@code true} if the artifact refers to test classes, {@code false} otherwise. */ private static boolean isTestArtifact(Artifact artifact) {
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 21.3K bytes - Viewed (0)