Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 441 - 450 of 477 for Thread (0.06 seconds)

  1. impl/maven-core/src/main/java/org/apache/maven/execution/DefaultMavenExecutionRequest.java

        // ----------------------------------------------------------------------------
        // We need to allow per execution user and global settings as the embedder
        // might be running in a mode where it's executing many threads with totally
        // different settings.
        // ----------------------------------------------------------------------------
    
        private File userSettingsFile;
    
        private File projectSettingsFile;
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Dec 12 11:02:17 GMT 2024
    - 32.1K bytes
    - Click Count (0)
  2. cmd/streaming-signature-v4.go

    func (cr *s3ChunkedReader) Read(buf []byte) (n int, err error) {
    	if cr.err != nil {
    		if cr.debug {
    			fmt.Printf("s3ChunkedReader: Returning err: %v (%T)\n", cr.err, cr.err)
    		}
    		return 0, cr.err
    	}
    	defer func() {
    		if err != nil && err != io.EOF {
    			if cr.debug {
    				fmt.Println("Read err:", err)
    			}
    		}
    	}()
    	// First, if there is any unread data, copy it to the client
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.2K bytes
    - Click Count (0)
  3. internal/s3select/jstream/decoder.go

    scan:
    	for {
    		offset := d.pos - 1
    
    		// read string key
    		if c != '"' {
    			err = d.mkError(ErrSyntax, "looking for beginning of object key string")
    			break
    		}
    		if k, err = d.string(); err != nil {
    			break
    		}
    
    		// read colon before value
    		if c = d.skipSpaces(); c != ':' {
    			err = d.mkError(ErrSyntax, "after object key")
    			break
    		}
    
    		// read value
    		d.skipSpaces()
    		if d.emitKV {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  4. guava/src/com/google/common/util/concurrent/Striped.java

      }
    
      /**
       * ReadWriteLock implementation whose read and write locks retain a reference back to this lock.
       * Otherwise, a reference to just the read lock or just the write lock would not suffice to ensure
       * the {@code ReadWriteLock} is retained.
       */
      private static final class WeakSafeReadWriteLock implements ReadWriteLock {
        private final ReadWriteLock delegate;
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 16 22:01:32 GMT 2025
    - 20.6K bytes
    - Click Count (0)
  5. okhttp-idna-mapping-table/src/main/resources/okhttp3/internal/idna/IdnaMappingTable.txt

    11A00..11A3E  ; valid                                  # 10.0 ZANABAZAR SQUARE LETTER A..ZANABAZAR SQUARE CLUSTER-FINAL LETTER VA
    11A3F..11A46  ; valid                  ;      ; NV8    # 10.0 ZANABAZAR SQUARE INITIAL HEAD MARK..ZANABAZAR SQUARE CLOSING DOUBLE-LINED HEAD MARK
    11A47         ; valid                                  # 10.0 ZANABAZAR SQUARE SUBJOINER
    11A48..11A4F  ; disallowed                             # NA   <reserved-11A48>..<reserved-11A4F>
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Feb 10 11:25:47 GMT 2024
    - 854.1K bytes
    - Click Count (0)
  6. docs/tr/docs/async.md

    ## Çok Teknik Detaylar
    
    /// warning
    
    Muhtemelen burayı atlayabilirsiniz.
    
    Bunlar, **FastAPI**'nin altta nasıl çalıştığına dair çok teknik ayrıntılardır.
    
    Biraz teknik bilginiz varsa (co-routines, threads, blocking, vb)ve FastAPI'nin "async def" ile normal "def" arasındaki farkı nasıl işlediğini merak ediyorsanız, devam edin.
    
    ///
    
    ### Path fonksiyonu
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Aug 31 09:56:21 GMT 2025
    - 21.8K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/collect/Ordering.java

          Integer uid = uids.get(obj);
          if (uid == null) {
            // One or more integer values could be skipped in the event of a race
            // to generate a UID for the same object from multiple threads, but
            // that shouldn't be a problem.
            uid = counter.getAndIncrement();
            Integer alreadySet = uids.putIfAbsent(obj, uid);
            if (alreadySet != null) {
              uid = alreadySet;
            }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 23 17:50:58 GMT 2025
    - 39.5K bytes
    - Click Count (0)
  8. cmd/endpoint.go

    		}
    	} else {
    		// Only check if the arg is an ip address and ask for scheme since its absent.
    		// localhost, example.com, any FQDN cannot be disambiguated from a regular file path such as
    		// /mnt/export1. So we go ahead and start the minio server in FS modes in these cases.
    		if isHostIP(arg) {
    			return ep, fmt.Errorf("invalid URL endpoint format: missing scheme http or https")
    		}
    		absArg, err := filepath.Abs(arg)
    		if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  9. cmd/server_test.go

    	c.Assert(err, nil)
    	// Since the "If-Modified-Since" header was ahead in time compared to the actual
    	// modified time of the object expecting the response status to be http.StatusNotModified.
    	c.Assert(response.StatusCode, http.StatusOK)
    }
    
    // TestHeadOnBucket - Validates response for HEAD on the bucket.
    // HEAD request on the bucket validates the existence of the bucket.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 118.1K bytes
    - Click Count (0)
  10. CHANGELOG/CHANGELOG-1.2.md

    rollback.
      * <strong>Automated cluster management: </strong>
         * Kubernetes clusters can now span zones within a cloud provider. Pods from a
    service will be automatically spread across zones, enabling applications to
    tolerate zone failure.
         * Simplified way to run a container on every node (DaemonSet API (Beta) in the
    Extensions API group): Kubernetes can schedule a service (such as a logging
    Created: Fri Dec 26 09:05:12 GMT 2025
    - Last Modified: Fri Dec 04 06:36:19 GMT 2020
    - 41.4K bytes
    - Click Count (0)
Back to Top