Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 457 for connected (0.05 sec)

  1. internal/store/store.go

    )
    
    type logger = func(ctx context.Context, err error, id string, errKind ...any)
    
    // ErrNotConnected - indicates that the target connection is not active.
    var ErrNotConnected = errors.New("not connected to target server/service")
    
    // Target - store target interface
    type Target interface {
    	Name() string
    	SendFromStore(key Key) error
    }
    
    // Store - Used to persist items.
    type Store[I any] interface {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  2. guava/src/com/google/common/graph/GraphConstants.java

              + "so it cannot be reused to connect the following nodes: %s.";
      static final String MULTIPLE_EDGES_CONNECTING =
          "Cannot call edgeConnecting() when parallel edges exist between %s and %s. Consider calling "
              + "edgesConnecting() instead.";
      static final String PARALLEL_EDGES_NOT_ALLOWED =
          "Nodes %s and %s are already connected by a different edge. To construct a graph "
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Jan 18 02:54:30 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  3. internal/http/dial_dnscache.go

    // function. LookupHost may implement an internal DNS caching implementation, lookupHost
    // input if nil then net.DefaultResolver.LookupHost is used.
    //
    // It dials one by one and returns first connected `net.Conn`.
    // If it fails to dial all IPs from cache it returns first error. If no baseDialFunc
    // is given, it sets default dial function.
    //
    // You can use returned dial function for `http.Transport.DialContext`.
    //
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  4. misc/ios/detect.go

    import (
    	"bytes"
    	"crypto/x509"
    	"fmt"
    	"os"
    	"os/exec"
    	"strings"
    )
    
    func main() {
    	udids := getLines(exec.Command("idevice_id", "-l"))
    	if len(udids) == 0 {
    		fail("no udid found; is a device connected?")
    	}
    
    	mps := detectMobileProvisionFiles(udids)
    	if len(mps) == 0 {
    		fail("did not find mobile provision matching device udids %q", udids)
    	}
    
    	fmt.Println("# Available provisioning profiles below.")
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Thu Oct 19 23:33:30 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt

     *     possible for shared exchanges to make requests to different host names! See
     *     [RealConnection.isEligible] for details.
     *
     *  3. Attempt plans from prior connect attempts for this call. These occur as either follow-ups to
     *     failed connect attempts (such as trying the next [ConnectionSpec]), or as attempts that lost
     *     a race in fast follow-up.
     *
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  6. docs/site-replication/README.md

    ## Configuring Site Replication
    
    - Configure an alias in `mc` for each of the sites. For example if you have three MinIO sites, you may run:
    
    ```sh
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  7. src/main/java/jcifs/http/NtlmHttpURLConnection.java

            this.setInstanceFollowRedirects(this.connection.getInstanceFollowRedirects());
        }
    
        @Override
        public void connect() throws IOException {
            if (this.connected) {
                return;
            }
            this.connection.connect();
            this.connected = true;
        }
    
        private void handshake() {
            if (this.handshakeComplete) {
                return;
            }
            try {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 25.6K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/SmbSessionImpl.java

    /**
     *
     */
    final class SmbSessionImpl implements SmbSessionInternal {
    
        private static final Logger log = LoggerFactory.getLogger(SmbSessionImpl.class);
    
        /*
         * 0 - not connected
         * 1 - connecting
         * 2 - connected
         * 3 - disconnecting
         */
        private final AtomicInteger connectionState = new AtomicInteger();
        private int uid;
        private List<SmbTreeImpl> trees;
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 68.9K bytes
    - Viewed (0)
  9. internal/dsync/dsync-client_test.go

    type ReconnectRESTClient struct {
    	u    *url.URL
    	rest *rest.Client
    }
    
    // newClient constructs a ReconnectRESTClient object with addr and endpoint initialized.
    // It _doesn't_ connect to the remote endpoint. See Call method to see when the
    // connect happens.
    func newClient(endpoint string) NetLocker {
    	u, err := url.Parse(endpoint)
    	if err != nil {
    		panic(err)
    	}
    
    	tr := &http.Transport{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Jan 20 17:36:09 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  10. src/main/java/jcifs/dcerpc/DcerpcHandle.java

            this.securityProvider = securityProvider;
        }
    
        /**
         * Gets the server hostname or address currently connected to
         * @return the server connected to
         */
        public abstract String getServer();
    
        /**
         * Gets the server hostname resolved through DFS (Distributed File System)
         * @return the server resolved by DFS
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 15.9K bytes
    - Viewed (0)
Back to top