- Sort Score
- Result 10 results
- Languages All
Results 301 - 310 of 714 for Contexto (0.1 sec)
-
cmd/metrics-v3-system-network.go
"Total number of bytes received from other peer nodes") ) // loadNetworkInternodeMetrics - reads internode network metrics. // // This is a `MetricsLoaderFn`. func loadNetworkInternodeMetrics(ctx context.Context, m MetricValues, _ *metricsCache) error { connStats := globalConnStats.toServerConnStats() rpcStats := rest.GetRPCStats() if globalIsDistErasure { m.Set(internodeErrorsTotal, float64(rpcStats.Errs))
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Mar 10 09:15:15 UTC 2024 - 2.4K bytes - Viewed (0) -
buildscripts/heal-manual.go
} start, _, err := madmClnt.Heal(context.Background(), "healing-rewrite-bucket", "", opts, "", false, false) if err != nil { log.Fatalln(err) } fmt.Println("Healstart sequence ===") enc := json.NewEncoder(os.Stdout) if err = enc.Encode(&start); err != nil { log.Fatalln(err) } fmt.Println() for {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Feb 27 09:47:58 UTC 2024 - 2.3K bytes - Viewed (0) -
cmd/s3-zip-handlers.go
} return input[:idx+len(archivePattern)-1], input[idx+len(archivePattern):], nil } // getObjectInArchiveFileHandler - GET Object in the archive file func (api objectAPIHandlers) getObjectInArchiveFileHandler(ctx context.Context, objectAPI ObjectLayer, bucket, object string, w http.ResponseWriter, r *http.Request) { if crypto.S3.IsRequested(r.Header) || crypto.S3KMS.IsRequested(r.Header) { // If SSE-S3 or SSE-KMS present -> AWS fails with undefined error
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.8K bytes - Viewed (0) -
tensorflow/c/eager/c_api_test.cc
TFE_Op* CloneOp(const TFE_Op* other) { TF_Status* status = TF_NewStatus(); TFE_Context* context = TFE_OpGetContext(other, status); CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status); const char* op_name = TFE_OpGetName(other, status); CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status); TFE_Op* ret = TFE_NewOp(context, op_name, status); CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
Registered: Tue Oct 29 12:39:09 UTC 2024 - Last Modified: Thu Aug 03 20:50:20 UTC 2023 - 94.6K bytes - Viewed (0) -
cmd/metrics-v3-system-memory.go
memAvailableMD = NewGaugeMD(memAvailable, "Available memory on the node") ) // loadMemoryMetrics - `MetricsLoaderFn` for node memory metrics. func loadMemoryMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { memMetrics, err := c.memoryMetrics.Get() if err != nil { metricsLogIf(ctx, err) return err } m.Set(memTotal, float64(memMetrics.Total))
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Apr 17 05:10:25 UTC 2024 - 2.2K bytes - Viewed (0) -
cmd/admin-handlers-users-race_test.go
//go:build !race // +build !race // Tests in this file are not run under the `-race` flag as they are too slow // and cause context deadline errors. package cmd import ( "context" "fmt" "runtime" "testing" "time" "github.com/minio/madmin-go/v3" minio "github.com/minio/minio-go/v7" "github.com/minio/pkg/v3/sync/errgroup" )
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jun 28 09:06:25 UTC 2024 - 4K bytes - Viewed (0) -
cmd/mrf.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. //go:generate msgp -file=$GOFILE package cmd import ( "context" "encoding/binary" "errors" "fmt" "io" "sync" "sync/atomic" "time" "github.com/google/uuid" "github.com/minio/madmin-go/v3" "github.com/minio/pkg/v3/wildcard"
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 6.5K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/upgrades/UpgradedProperties.java
*/ public static boolean shouldAcceptForUpgradedProperty(JApiMethod jApiMethod, Violation violation, ViolationCheckContext context) { Map<AccessorKey, UpgradedProperty> currentAccessors = context.getUserData(CURRENT_ACCESSORS_OF_UPGRADED_PROPERTIES); Map<AccessorKey, ReplacedAccessor> oldRemovedAccessors = context.getUserData(OLD_REMOVED_ACCESSORS_OF_UPGRADED_PROPERTIES);
Registered: Wed Oct 30 11:36:09 UTC 2024 - Last Modified: Wed Oct 02 14:20:08 UTC 2024 - 9.1K bytes - Viewed (0) -
cmd/metacache-bucket.go
cachesRoot map[string][]string `msg:"-"` // Internal state mu sync.RWMutex `msg:"-"` updated bool `msg:"-"` } type deleteAllStorager interface { deleteAll(ctx context.Context, bucket, prefix string) } // newBucketMetacache creates a new bucketMetacache. // Optionally remove all existing caches. func newBucketMetacache(bucket string, cleanup bool) *bucketMetacache { if cleanup {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6.6K bytes - Viewed (0) -
cmd/api-response.go
} func writeErrorResponseString(ctx context.Context, w http.ResponseWriter, err APIError, reqURL *url.URL) { // Generate string error response. writeResponse(w, err.HTTPStatusCode, []byte(err.Description), mimeNone) } // writeErrorResponseJSON - writes error response in JSON format; // useful for admin APIs. func writeErrorResponseJSON(ctx context.Context, w http.ResponseWriter, err APIError, reqURL *url.URL) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Oct 25 02:13:19 UTC 2024 - 33.6K bytes - Viewed (0)