Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1051 - 1060 of 7,014 for _return (0.07 sec)

  1. internal/s3select/json/preader.go

    func (r *PReader) Read(dst sql.Record) (sql.Record, error) {
    	// If we have have any records left, return these before any error.
    	for len(r.current) <= r.recordsRead {
    		if r.err != nil {
    			return nil, r.err
    		}
    		// Move to next block
    		item, ok := <-r.queue
    		if !ok {
    			r.err = io.EOF
    			return nil, r.err
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. cmd/bucket-metadata.go

    			return b, err
    		}
    	}
    
    	// migrate unencrypted remote targets
    	if err = b.migrateTargetConfig(ctx, objectAPI); err != nil {
    		return b, err
    	}
    
    	return b, nil
    }
    
    // loadBucketMetadata loads and migrates to bucket metadata.
    func loadBucketMetadata(ctx context.Context, objectAPI ObjectLayer, bucket string) (BucketMetadata, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/smb2/create/Smb2CreateRequest.java

            return new Smb2CreateResponse(tc.getConfig(), this.name);
        }
    
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.internal.RequestWithPath#getPath()
         */
        @Override
        public String getPath () {
            return '\\' + this.name;
        }
    
    
        /**
         * {@inheritDoc}
         *
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sat Jun 01 09:52:11 UTC 2019
    - 14.3K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/CommandExtractor.java

                cmdList.add(getCommandValue(buf.toString(), params));
            }
            return cmdList;
        }
    
        private String getCommandValue(final String key, final Map<String, String> params) {
            final String value = params.get(key);
            if (value == null) {
                return key;
            }
            return value;
        }
    
        protected static class MonitorThread extends Thread {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  5. api/maven-api-core/src/main/java/org/apache/maven/api/Type.java

         */
        String TEST_JAR = "test-jar";
    
        /**
         * Returns the dependency type id.
         * The id uniquely identifies this <i>dependency type</i>.
         *
         * @return the id of this type, never {@code null}.
         */
        @Nonnull
        String id();
    
        /**
         * Returns the dependency type language.
         *
         * @return the language of this type, never {@code null}.
         */
        @Nonnull
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Mon May 13 09:53:45 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  6. guava-testlib/src/com/google/common/collect/testing/Helpers.java

            return max(0, data.size() + delta);
          }
    
          @Override
          public T get(int index) {
            return data.get(index);
          }
    
          @Override
          public T set(int index, T element) {
            return data.set(index, element);
          }
    
          @Override
          public boolean add(T element) {
            return data.add(element);
          }
    
          @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/base/NullnessCasts.java

       * without having to add {@code @SuppressWarnings}, the code can call this method.
       *
       * <p>Why <i>not</i> just add {@code SuppressWarnings}? The problem is that this method is
       * typically useful for {@code return} statements. That leaves the code with two options: Either
       * add the suppression to the whole method (which turns off checking for a large section of code),
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 17 15:44:29 UTC 2021
    - 3.1K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

            public Lock get() {
              return new ReentrantLock(true);
            }
          };
    
      private static final Supplier<Semaphore> SEMAPHORE_SUPPLER =
          new Supplier<Semaphore>() {
            @Override
            public Semaphore get() {
              return new Semaphore(1, false);
            }
          };
    
      private static List<Striped<?>> weakImplementations() {
        return ImmutableList.<Striped<?>>builder()
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 26 12:58:35 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

            public Lock get() {
              return new ReentrantLock(true);
            }
          };
    
      private static final Supplier<Semaphore> SEMAPHORE_SUPPLER =
          new Supplier<Semaphore>() {
            @Override
            public Semaphore get() {
              return new Semaphore(1, false);
            }
          };
    
      private static List<Striped<?>> weakImplementations() {
        return ImmutableList.<Striped<?>>builder()
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 26 12:58:35 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  10. cmd/warm-backend-gcs.go

    	_, err := pager.NextPage(&gcsObjects)
    	if err != nil {
    		return false, gcsToObjectError(err, gcs.Bucket, gcs.Prefix)
    	}
    	if len(gcsObjects) > 0 {
    		return true, nil
    	}
    	return false, nil
    }
    
    func newWarmBackendGCS(conf madmin.TierGCS, tier string) (*warmBackendGCS, error) {
    	// Validation code
    	if conf.Creds == "" {
    		return nil, errors.New("empty credentials unsupported")
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
Back to top