- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 444 for dialed (0.2 sec)
-
cmd/erasure-healing_test.go
if err != nil { t.Fatalf("Failed to heal object - %v", err) } part1Replaced, err := firstDisk.ReadAll(context.Background(), bucket, pathJoin(object, fi.DataDir, "part.1")) if err != nil { t.Fatalf("Failed to read a file - %v", err) } if !reflect.DeepEqual(part1Disk1Origin, part1Replaced) { t.Fatalf("part.1 not healed correctly") } // Test 2, Corrupt part.1
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Mar 27 15:10:40 GMT 2024 - 47.6K bytes - Viewed (0) -
cmd/admin-heal-ops.go
for _, d := range res.After.Drives { // For failed items we report the endpoint and drive state // This will help users take corrective actions for drives h.healFailedItemsMap[d.Endpoint+","+d.State]++ } h.lastHealActivity = UTCNow() } func (h *healSequence) countHeals(healType madmin.HealItemType, healed bool) { h.mutex.Lock() defer h.mutex.Unlock() if !healed { h.scannedItemsMap[healType]++ } else {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
istioctl/pkg/injector/injector-list.go
func renderCounts(injectedRevision string, counts revisionCount) string { if counts.pods == 0 { return "<no pods>" } podText := strconv.Itoa(counts.pods) if counts.disabled > 0 { podText += fmt.Sprintf(" (injection disabled: %d)", counts.disabled) } if counts.needsRestart > 0 { podText += fmt.Sprintf(" NEEDS RESTART: %d", counts.needsRestart) } return fmt.Sprintf("%s: %s", injectedRevision, podText)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jan 04 03:08:06 GMT 2024 - 10.4K bytes - Viewed (0) -
tests/transaction_test.go
t.Fatalf("Failed to save point, got error %v", err) } user1 := *GetUser("transaction-save-point-1", Config{}) tx.Create(&user1) if err := tx.First(&User{}, "name = ?", user1.Name).Error; err != nil { t.Fatalf("Should find saved record") } if err := tx.RollbackTo("save_point1").Error; err != nil { t.Fatalf("Failed to save point, got error %v", err) }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Sat Jun 10 13:05:19 GMT 2023 - 10.9K bytes - Viewed (0) -
tests/sql_builder_test.go
stmt := dryRunDB.Create(&user).Statement if stmt.SQL.String() == "" || len(stmt.Vars) != 9 { t.Errorf("Failed to generate sql, got %v", stmt.SQL.String()) } stmt2 := dryRunDB.Find(&user, "id = ?", user.ID).Statement if stmt2.SQL.String() == "" || len(stmt2.Vars) != 1 { t.Errorf("Failed to generate sql, got %v", stmt2.SQL.String()) } } type ageInt int8 func (ageInt) String() string {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Jan 12 08:42:21 GMT 2024 - 16.7K bytes - Viewed (0) -
internal/grid/connection.go
toDial = strings.Replace(toDial, "https://", "wss://", 1) toDial += RoutePath dialer := ws.DefaultDialer dialer.ReadBufferSize = readBufferSize dialer.WriteBufferSize = writeBufferSize dialer.Timeout = defaultDialTimeout if c.dialer != nil { dialer.NetDial = c.dialer.DialContext } if c.header == nil { c.header = make(http.Header, 2) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
pi, k8sErr = getK8sPodInfo(kClient, podName, podNamespace) if k8sErr == nil { break } log.Debugf("Failed to get %s/%s pod info: %v", podNamespace, podName, k8sErr) time.Sleep(podRetrievalInterval) } if k8sErr != nil { log.Errorf("Failed to get %s/%s pod info: %v", podNamespace, podName, k8sErr) return k8sErr }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 10.5K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultWagonManager.java
throw new TransferFailedException("Connection failed: " + e.getMessage(), e); } catch (AuthenticationException e) { throw new TransferFailedException("Authentication failed: " + e.getMessage(), e); } catch (AuthorizationException e) { throw new TransferFailedException("Authorization failed: " + e.getMessage(), e); } finally {
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Sep 14 11:48:15 GMT 2023 - 29.9K bytes - Viewed (0) -
docs/site-replication/run-multi-site-minio-idp.sh
if [ $? -ne 0 ]; then echo "adding user failed, exiting.." exit_1 fi ./mc admin policy attach minio1 consoleAdmin --user=foobarx if [ $? -ne 0 ]; then echo "adding policy mapping failed, exiting.." exit_1 fi sleep 10 # unset policy for foobarx in minio2 ./mc admin policy detach minio2 consoleAdmin --user=foobarx if [ $? -ne 0 ]; then echo "unset policy mapping failed, exiting.." exit_1 fi
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 07 00:19:24 GMT 2024 - 11.9K bytes - Viewed (0) -
cmd/metrics.go
float64(v), string(k), ) } for k, v := range bgSeq.getHealedItemsMap() { ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(healMetricsNamespace, "objects", "healed"), "Objects healed in current self healing run", []string{"type"}, nil), prometheus.GaugeValue, float64(v), string(k), ) } for k, v := range bgSeq.getHealFailedItemsMap() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0)