Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 756 for remoto (0.15 sec)

  1. internal/grid/connection.go

    			}
    		}
    	}
    }
    
    /*
    var ErrDone = errors.New("done for now")
    
    var ErrRemoteRestart = errors.New("remote restarted")
    
    
    // Stateless connects to the remote handler and return all packets sent back.
    // If the remote is restarted will return ErrRemoteRestart.
    // If nil will be returned remote call sent EOF or ErrDone is returned by the callback.
    // If ErrDone is returned on cb nil will be returned.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  2. internal/grid/grid.go

    func ConnectWSWithRoutePath(dial ContextDialer, auth AuthFn, tls *tls.Config, routePath string) func(ctx context.Context, remote string) (net.Conn, error) {
    	return func(ctx context.Context, remote string) (net.Conn, error) {
    		toDial := strings.Replace(remote, "http://", "ws://", 1)
    		toDial = strings.Replace(toDial, "https://", "wss://", 1)
    		toDial += routePath
    
    		dialer := ws.DefaultDialer
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  3. docs/bucket/lifecycle/DESIGN.md

    ### Transition Status
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 4.3K bytes
    - Viewed (0)
  4. tensorflow/c/eager/c_api_remote_test.cc

    TEST(CAPI, RemoteExecuteSilentCopies) {
      TestRemoteExecuteSilentCopiesOp(/*async=*/false, /*remote=*/true);
    }
    TEST(CAPI, RemoteExecuteSilentCopiesAsync) {
      TestRemoteExecuteSilentCopiesOp(/*async=*/true, /*remote=*/true);
    }
    TEST(CAPI, RemoteExecuteSilentCopiesLocal) {
      TestRemoteExecuteSilentCopiesOp(/*async=*/false, /*remote=*/false);
    }
    TEST(CAPI, RemoteExecuteSilentCopiesLocalAsync) {
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Wed Aug 12 00:14:22 UTC 2020
    - 5.4K bytes
    - Viewed (0)
  5. internal/grid/trace.go

    func (c *Connection) traceRequests(p *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType]) {
    	c.trace = &tracer{
    		Publisher: p,
    		TraceType: madmin.TraceInternal,
    		Prefix:    "grid",
    		Local:     c.Local,
    		Remote:    c.Remote,
    		Subroute:  "",
    	}
    }
    
    // subroute adds a specific subroute to the request.
    func (c *tracer) subroute(subroute string) *tracer {
    	if c == nil {
    		return nil
    	}
    	c2 := *c
    	c2.Subroute = subroute
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  6. tensorflow/c/eager/immediate_execution_distributed_manager.h

      // Set up distributed execution environment on local and remote tasks.
      // When `reset_context` is true, initialize new cluster context state based
      // on cluster configurations provided in `server_def`; otherwise, update
      // existing context state with the provided `server_def`. Contexts created
      // on remote tasks will be considered stale and garbage collected after
      // `keep_alive_secs` of inactivity.
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  7. cmd/object-api-errors.go

    	if e.Bucket != "" {
    		return fmt.Sprintf("Remote service endpoint offline, target bucket: %s or remote service credentials: %s invalid \n\t%s", e.Bucket, e.AccessKey, e.Err.Error())
    	}
    	return fmt.Sprintf("Remote service endpoint %s not available\n\t%s", e.Endpoint, e.Err.Error())
    }
    
    // BucketRemoteIdenticalToSource remote already exists for this target type.
    type BucketRemoteIdenticalToSource struct {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Aug 09 02:05:14 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  8. cmd/peer-rest-client.go

    			continue
    		}
    		all[i] = newPeerRESTClient(host, endpoints.FindGridHostsFromPeer(host))
    		remote = append(remote, all[i])
    	}
    	if len(all) != len(remote)+1 {
    		peersLogIf(context.Background(), fmt.Errorf("Expected number of all hosts (%v) to be remote +1 (%v)", len(all), len(remote)), logger.WarningKind)
    	}
    	return remote, all
    }
    
    // MonitorBandwidth - send http trace request to peer nodes
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  9. cmd/batch-replicate_test.go

        prefix: object-prefix1 # 'PREFIX' is optional
        # If your source is the 'local' alias specified to 'mc batch start', then the 'endpoint' and 'credentials' fields are optional and can be omitted
        # Either the 'source' or 'remote' *must* be the "local" deployment
    #    endpoint: "http://127.0.0.1:9000"
    #    # path: "on|off|auto" # "on" enables path-style bucket lookup. "off" enables virtual host (DNS)-style bucket lookup. Defaults to "auto"
    #    credentials:
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  10. internal/grid/debug.go

    func (t *TestGrid) WaitAllConnect(ctx context.Context) {
    	for _, manager := range t.Managers {
    		for _, remote := range manager.Targets() {
    			if manager.HostName() == remote {
    				continue
    			}
    			if err := manager.Connection(remote).WaitForConnect(ctx); err != nil {
    				panic(err)
    			}
    		}
    	}
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
Back to top