Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 52 for Disconnected (0.13 sec)

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

    								this.transport.disconnect(true);
    							} catch (IOException e1) {
    								log.warn("Got NT_STATUS_USER_SESSION_DELETED, disconnected transport with error", e1);
    							}   
                            }
                            log.debug("Session expired, trying reauth", e);
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 14 17:41:04 UTC 2021
    - 49K bytes
    - Viewed (0)
  2. cmd/peer-rest-client.go

    				return nil
    			}
    			gridConn.Store(gc)
    			return gc
    		},
    	}
    }
    
    // Wrapper to restClient.Call to handle network errors, in case of network error the connection is marked disconnected
    // permanently. The only way to restore the connection is at the xl-sets layer by xlsets.monitorAndConnectEndpoints()
    // after verifying format.json
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  3. cmd/erasure-sets.go

    				globalLocalDrivesMu.Unlock()
    			}
    			s.erasureDisksMu.Unlock()
    		}(endpoint)
    	}
    
    	wg.Wait()
    }
    
    // monitorAndConnectEndpoints this is a monitoring loop to keep track of disconnected
    // endpoints by reconnecting them and making sure to place them into right position in
    // the set topology, this monitoring happens at a given monitoring interval.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (0)
  4. cmd/erasure-multipart.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 pi, IncompleteBody{Bucket: bucket, Object: object}
    		}
    
    		return pi, toObjectErr(err, minioMetaMultipartBucket, partPath)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  5. cmd/storage-rest-server.go

    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    	defer rc.Close()
    
    	_, err = xioutil.Copy(w, rc)
    	if !xnet.IsNetworkOrHostDown(err, true) { // do not need to log disconnected clients
    		storageLogIf(r.Context(), err)
    	}
    }
    
    // ListDirHandler - list a directory.
    func (s *storageRESTServer) ListDirHandler(ctx context.Context, params *grid.MSS, out chan<- *ListDirResult) *grid.RemoteErr {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. src/main/java/jcifs/smb1/smb1/SmbFile.java

     */
        public void connect() throws IOException {
            if (isConnected() && tree.session.transport.tconHostName == null) {
                /* Tree thinks it is connected but transport disconnected
                 * under it, reset tree to reflect the truth.
                 */
                tree.treeDisconnect(true);
            }
    
            if( isConnected() ) {
                return;
            }
    
            getUncPath0();
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Mar 13 12:00:57 UTC 2023
    - 107.9K bytes
    - Viewed (0)
  9. 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)
  10. guava-tests/test/com/google/common/collect/ImmutableRangeMapTest.java

        }
      }
    
      public void testOverlapRejection() {
        for (Range<Integer> range1 : RANGES) {
          for (Range<Integer> range2 : RANGES) {
            boolean expectRejection =
                range1.isConnected(range2) && !range1.intersection(range2).isEmpty();
            ImmutableRangeMap.Builder<Integer, Integer> builder = ImmutableRangeMap.builder();
            builder.put(range1, 1).put(range2, 2);
            try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 9.4K bytes
    - Viewed (0)
Back to top