Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 714 for Contexto (0.09 sec)

  1. tensorflow/c/eager/parallel_device/parallel_device_remote_test.cc

                      .ok());
      ASSERT_TRUE(worker_server2->Start().ok());
    
      TFE_ContextSetServerDef(context.get(), 0, serialized.data(),
                              serialized.size(), status.get());
      EXPECT_EQ(TF_OK, TF_GetCode(status.get())) << TF_Message(status.get());
    
      BasicTestsForTwoDevices(context.get(),
                              "/job:worker/replica:0/task:1/device:CPU:0",
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Wed Jul 10 07:18:05 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  2. cmd/data-scanner.go

    func (d *dynamicSleeper) Timer(ctx context.Context) func() {
    	t := time.Now()
    	return func() {
    		doneAt := time.Now()
    		d.Sleep(ctx, doneAt.Sub(t))
    	}
    }
    
    // Sleep sleeps the specified time multiplied by the sleep factor.
    // If the factor is updated the sleep will be done again with the new factor.
    func (d *dynamicSleeper) Sleep(ctx context.Context, base time.Duration) {
    	for {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  3. internal/grid/trace.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package grid
    
    import (
    	"context"
    	"fmt"
    	"net/http"
    	"strings"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/pubsub"
    )
    
    // TraceParamsKey allows to pass trace parameters to the request via context.
    // This is only needed when un-typed requests are used.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  4. cmd/metrics-v3-api.go

    //
    // This is a `MetricsLoaderFn`.
    //
    // This includes node level S3 HTTP metrics.
    //
    // This function currently ignores `opts`.
    func loadAPIRequestsHTTPMetrics(ctx context.Context, m MetricValues, _ *metricsCache) error {
    	// Collect node level S3 HTTP metrics.
    	httpStats := globalHTTPStats.toServerHTTPStats(false)
    
    	// Currently we only collect S3 API related stats, so we set the "type"
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  5. tests/serializer_test.go

    }
    
    func (es EncryptedString) Value(ctx context.Context, field *schema.Field, dst reflect.Value, fieldValue interface{}) (interface{}, error) {
    	return "hello" + string(es), nil
    }
    
    type CustomSerializer struct {
    	prefix []byte
    }
    
    func NewCustomSerializer(prefix string) *CustomSerializer {
    	return &CustomSerializer{prefix: []byte(prefix)}
    }
    
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Fri Apr 21 14:09:38 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  6. cmd/erasure-metadata-utils_test.go

    			},
    			nil, nil,
    		},
    		// Checks if wrapped context cancellation errors are grouped as one.
    		{canceledErrs, nil, context.Canceled},
    	}
    	// Validates list of all the testcases for returning valid errors.
    	for i, testCase := range testCases {
    		gotErr := reduceReadQuorumErrs(context.Background(), testCase.errs, testCase.ignoredErrs, 5)
    		if gotErr != testCase.err {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  7. scripts/playwright/cookie_param_models/image01.py

    def run(playwright: Playwright) -> None:
        browser = playwright.chromium.launch(headless=False)
        # Update the viewport manually
        context = browser.new_context(viewport={"width": 960, "height": 1080})
        browser = playwright.chromium.launch(headless=False)
        context = browser.new_context()
        page = context.new_page()
        page.goto("http://localhost:8000/docs")
        page.get_by_role("link", name="/items/").click()
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Tue Sep 17 18:54:10 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  8. callbacks/update.go

    			for i := 0; i < stmt.ReflectValue.Len(); i++ {
    				if stmt.ReflectValue.CanAddr() {
    					field.Set(stmt.Context, stmt.ReflectValue.Index(i), value)
    				}
    			}
    		}
    	case reflect.Struct:
    		assignValue = func(field *schema.Field, value interface{}) {
    			if stmt.ReflectValue.CanAddr() {
    				field.Set(stmt.Context, stmt.ReflectValue, value)
    			}
    		}
    	default:
    		assignValue = func(field *schema.Field, value interface{}) {
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Mon Mar 18 05:44:55 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  9. cmd/storage-rest-server.go

    	if !s.checkID(opts.DiskID) {
    		return nil, grid.NewRemoteErr(errDiskNotFound)
    	}
    	info, err := s.getStorage().DiskInfo(context.Background(), *opts)
    	if err != nil {
    		info.Error = err.Error()
    	}
    	return &info, nil
    }
    
    func (s *storageRESTServer) NSScannerHandler(ctx context.Context, params *nsScannerOptions, out chan<- *nsScannerResp) *grid.RemoteErr {
    	if !s.checkID(params.DiskID) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  10. doc/next/6-stdlib/99-minor/testing/36532.md

    The new [T.Context] and [B.Context] methods return a context that's canceled
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Aug 20 17:36:54 UTC 2024
    - 141 bytes
    - Viewed (0)
Back to top