Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 118 for reconnected (0.06 sec)

  1. android/guava/src/com/google/common/collect/ImmutableRangeMap.java

          for (int i = 0; i < entries.size(); i++) {
            Range<K> range = entries.get(i).getKey();
            if (i > 0) {
              Range<K> prevRange = entries.get(i - 1).getKey();
              if (range.isConnected(prevRange) && !range.intersection(prevRange).isEmpty()) {
                throw new IllegalArgumentException(
                    "Overlapping ranges: range " + prevRange + " overlaps with entry " + range);
              }
            }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/DirFileEntryEnumIterator2.java

        protected void doCloseInternal () throws CIFSException {
            try {
                @SuppressWarnings ( "resource" )
                SmbTreeHandleImpl th = getTreeHandle();
                if ( this.fileId != null && th.isConnected() ) {
                    th.send(new Smb2CloseRequest(th.getConfig(), this.fileId));
                }
            }
            finally {
                this.fileId = null;
            }
        }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Dec 20 16:15:08 UTC 2020
    - 5.7K bytes
    - Viewed (0)
  3. guava/src/com/google/common/graph/GraphConstants.java

          "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 "
              + "that allows parallel edges, call allowsParallelEdges(true) on the Builder.";
      static final String SELF_LOOPS_NOT_ALLOWED =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jan 22 17:29:38 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  4. src/main/resources/fess_label_fr.properties

    labels.index_label	=	Étiquettes
    labels.index_lang	=	Langues préférées
    labels.index_sort	=	Trier
    labels.index_num	=	résultats par page
    labels.logout_title	=	Se déconnecter
    labels.logout	=	Se déconnecter
    labels.do_you_want_to_logout	=	Voulez-vous vous déconnecter ?
    labels.logout_button	=	Se déconnecter
    labels.profile	=	Changer le mot de passe
    labels.administration	=	Administration
    labels.profile_button	=	Profil
    labels.profile.title	=	Profil
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Mar 22 11:58:34 UTC 2024
    - 46.6K bytes
    - Viewed (0)
  5. src/main/java/jcifs/SmbTransportPool.java

     * @internal
     */
    public interface SmbTransportPool {
    
        /**
         * @param tf
         * @param name
         * @param port
         * @param exclusive
         * @param forceSigning
         * @return a connected transport
         * @throws UnknownHostException
         * @throws IOException
         */
        SmbTransport getSmbTransport ( CIFSContext tf, String name, int port, boolean exclusive, boolean forceSigning )
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun May 17 09:02:44 UTC 2020
    - 6.3K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/Connection.kt

     * HTTP request/response exchanges. Connections may be direct to the origin server or via a proxy.
     *
     * Typically instances of this class are created, connected and exercised automatically by the HTTP
     * client. Applications may use this class to monitor HTTP connections as members of a
     * [connection pool][ConnectionPool].
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  7. internal/config/identity/plugin/config.go

    func (o *AuthNPlugin) doPeriodicHealthCheck() {
    	ticker := time.NewTicker(healthCheckInterval)
    	defer ticker.Stop()
    
    	for {
    		select {
    		case <-ticker.C:
    			now := time.Now()
    			isConnected := o.checkConnectivity(o.shutdownCtx)
    			if isConnected {
    				o.serviceMetrics.setConnSuccess(now)
    			} else {
    				o.serviceMetrics.setConnFailure(now)
    			}
    		case <-o.shutdownCtx.Done():
    			return
    		}
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/SocksProxy.kt

            fromSink.writeByte(ADDRESS_TYPE_IPV4)
            fromSink.write(localAddress)
            fromSink.writeShort(toSocket.localPort)
            fromSink.emit()
            logger.log(Level.INFO, "SocksProxy connected $fromAddress to $toAddress")
    
            // Copy sources to sinks in both directions.
            val toSource = toSocket.source().buffer()
            val toSink = toSocket.sink().buffer()
            openSockets.add(toSocket)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  9. internal/grid/connection_test.go

    		t.Log("Roundtrip:", time.Since(start), resp, err)
    		gotResp <- struct{}{}
    	}()
    	<-gotCall
    	remote.debugMsg(debugKillInbound)
    	local.debugMsg(debugKillInbound)
    	<-gotResp
    
    	// Must reconnect
    	errFatal(remoteConn.WaitForConnect(context.Background()))
    
    	stream, err := remoteConn.NewStream(context.Background(), handlerTest2, []byte(testPayload))
    	errFatal(err)
    	go func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:44:00 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  10. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 21:30:28 UTC 2024
    - 3.4K bytes
    - Viewed (0)
Back to top