Search Options

Results per page
Sort
Preferred Languages
Advance

Results 441 - 450 of 819 for Contexto (0.09 sec)

  1. cmd/handler-api.go

    			f.ServeHTTP(w, r)
    			return
    		}
    
    		if tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt); ok {
    			tc.FuncName = "s3.MaxClients"
    		}
    
    		w.Header().Set("X-RateLimit-Limit", strconv.Itoa(cap(pool)))
    		w.Header().Set("X-RateLimit-Remaining", strconv.Itoa(cap(pool)-len(pool)))
    
    		ctx := r.Context()
    		select {
    		case pool <- struct{}{}:
    			defer func() { <-pool }()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  2. docs/debugging/s3-check-md5/main.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/>.
    
    package main
    
    import (
    	"context"
    	"crypto/md5"
    	"flag"
    	"fmt"
    	"io"
    	"log"
    	"net/url"
    	"os"
    	"path"
    	"strconv"
    	"strings"
    	"time"
    
    	"github.com/minio/minio-go/v7"
    	"github.com/minio/minio-go/v7/pkg/credentials"
    )
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Feb 17 01:15:57 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  3. cmd/handler-utils_test.go

    package cmd
    
    import (
    	"bytes"
    	"context"
    	"encoding/xml"
    	"io"
    	"net/http"
    	"net/textproto"
    	"os"
    	"reflect"
    	"testing"
    
    	"github.com/minio/minio/internal/config"
    )
    
    // Tests validate bucket LocationConstraint.
    func TestIsValidLocationConstraint(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  4. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/JavadocConverter.java

                tagValue = new StringBuilder();
            }
    
            @Override
            public void onText(String text) {
                if (tagValue != null) {
                    tagValue.append(text);
                    return;
                }
    
                if (!handlerStack.isEmpty()) {
                    handlerStack.getFirst().onText(text);
                    return;
                }
    
                nodes.appendChild(text);
            }
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 29.3K bytes
    - Viewed (0)
  5. cmd/metrics-v3-cluster-erasure-set.go

    )
    
    func b2f(v bool) float64 {
    	if v {
    		return 1
    	}
    	return 0
    }
    
    // loadClusterErasureSetMetrics - `MetricsLoaderFn` for cluster storage erasure
    // set metrics.
    func loadClusterErasureSetMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	result, _ := c.esetHealthResult.Get()
    
    	m.Set(erasureSetOverallWriteQuorum, float64(result.WriteQuorum))
    	m.Set(erasureSetOverallHealth, b2f(result.Healthy))
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue May 14 07:25:56 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  6. tensorflow/c/c_api_experimental.cc

    TF_CAPI_EXPORT extern void TFE_AbortCollectiveOps(TFE_Context* ctx,
                                                      TF_Status* status) {
      tensorflow::EagerContext* context =
          tensorflow::ContextFromInterface(tensorflow::unwrap(ctx));
      auto collective_executor_handle = context->GetCollectiveExecutorHandle();
      collective_executor_handle->get()->StartAbort(status->status);
    }
    
    TF_CAPI_EXPORT extern void TFE_CollectiveOpsCheckPeerHealth(
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Sat Oct 12 16:27:48 UTC 2024
    - 29.5K bytes
    - Viewed (0)
  7. cmd/erasure-common.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/>.
    
    package cmd
    
    import (
    	"context"
    	"math/rand"
    	"sync"
    	"time"
    )
    
    func (er erasureObjects) getOnlineDisks() (newDisks []StorageAPI) {
    	disks := er.getDisks()
    	var wg sync.WaitGroup
    	var mu sync.Mutex
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  8. internal/event/target/kafka.go

    	if err != nil {
    		if !errors.Is(err, sarama.ErrOutOfBrokers) {
    			target.loggerOnce(context.Background(), err, target.ID().String())
    		}
    		return err
    	}
    
    	producer, err := sarama.NewSyncProducerFromClient(client)
    	if err != nil {
    		if !errors.Is(err, sarama.ErrOutOfBrokers) {
    			target.loggerOnce(context.Background(), err, target.ID().String())
    		}
    		return err
    	}
    	target.client = client
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  9. scan.go

    	for idx, field := range fields {
    		if field == nil {
    			continue
    		}
    
    		if len(joinFields) == 0 || len(joinFields[idx]) == 0 {
    			db.AddError(field.Set(db.Statement.Context, reflectValue, values[idx]))
    		} else { // joinFields count is larger than 2 when using join
    			var isNilPtrValue bool
    			var relValue reflect.Value
    			// does not contain raw dbname
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  10. cmd/data-usage-cache.go

    		existing.merge(flat)
    		d.replaceHashed(dataUsageHash(key), &eHash, existing)
    	}
    }
    
    type objectIO interface {
    	GetObjectNInfo(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, opts ObjectOptions) (reader *GetObjectReader, err error)
    	PutObject(ctx context.Context, bucket, object string, data *PutObjReader, opts ObjectOptions) (objInfo ObjectInfo, err error)
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
Back to top