Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for isConnected (0.1 sec)

  1. src/main/java/jcifs/smb/SmbSessionImpl.java

        }
    
    
        /**
         * {@inheritDoc}
         *
         * @see java.lang.Object#finalize()
         */
        @Override
        protected void finalize () throws Throwable {
            if ( isConnected() && this.usageCount.get() != 0 ) {
                log.warn("Session was not properly released");
            }
        }
    
    
        /**
         * {@inheritDoc}
         *
         * @see java.lang.AutoCloseable#close()
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 14 17:41:04 UTC 2021
    - 49K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/SmbFile.java

        /**
         * @return
         * @throws CIFSException
         * 
         */
        synchronized SmbTreeHandleImpl ensureTreeConnected () throws CIFSException {
            if ( this.treeHandle == null || !this.treeHandle.isConnected() ) {
                if ( this.treeHandle != null && this.transportContext.getConfig().isStrictResourceLifecycle() ) {
                    this.treeHandle.release();
                }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu May 23 01:50:13 UTC 2024
    - 82.3K bytes
    - Viewed (0)
  3. docs/bucket/notifications/README.md

      go func() {
       for {
        // Reconnect if the connection is lost.
        if stanConnection == nil || stanConnection.NatsConn() == nil ||  !stanConnection.NatsConn().IsConnected() {
         stanConnection, _ = stan.Connect("test-cluster", "test-client", stan.NatsURL("nats://yourusername:yoursecret@0.0.0.0:4222"), stan.SetConnectionLostHandler(func(c stan.Conn, _ error) {
          if c.NatsConn() != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 84K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb/SmbTransportImpl.java

        }
    
    
        boolean matches ( Address addr, int prt, InetAddress laddr, int lprt, String hostName ) {
            if ( this.state == 5 || this.state == 6 ) {
                // don't reuse disconnecting/disconnected transports
                return false;
            }
            if ( hostName == null )
                hostName = addr.getHostName();
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Wed Jan 18 23:47:00 UTC 2023
    - 67K bytes
    - Viewed (0)
  5. cmd/api-errors.go

    		HTTPStatusCode: http.StatusServiceUnavailable,
    	},
    	ErrClientDisconnected: {
    		Code:           "ClientDisconnected",
    		Description:    "Client disconnected before response was ready",
    		HTTPStatusCode: 499, // No official code, use nginx value.
    	},
    	ErrTooManyRequests: {
    		Code:           "TooManyRequests",
    		Description:    "Please reduce your request rate",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 92.1K bytes
    - Viewed (0)
  6. cmd/erasure-object.go

    			// An in-quorum errFileNotFound means that client stream
    			// prematurely closed and we do not find any xl.meta or
    			// part.1's - in such a scenario we must return as if client
    			// disconnected. This means that erasure.Encode() CreateFile()
    			// did not do anything.
    			return ObjectInfo{}, IncompleteBody{Bucket: bucket, Object: object}
    		}
    		return ObjectInfo{}, toObjectErr(err, bucket, object)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
Back to top