Search Options

Results per page
Sort
Preferred Languages
Advance

Results 411 - 420 of 512 for reading_ (0.07 sec)

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

          stream.writeObject(factory);
          stream.writeObject(backingMap());
        }
    
        @GwtIncompatible // java.io.ObjectInputStream
        @J2ktIncompatible
        @SuppressWarnings("unchecked") // reading data stored by writeObject
        private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
          stream.defaultReadObject();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 86.3K bytes
    - Viewed (0)
  2. cmd/test-utils_test.go

    	}
    
    	// httptest Recorder to capture all the response by the http handler.
    	rec := httptest.NewRecorder()
    	// reading the body to preserve it so that it can be used again for second attempt of sending unsigned HTTP request.
    	// If the body is read in the handler the same request cannot be made use of.
    	buf, err := io.ReadAll(anonReq.Body)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  3. docs/debugging/xl-meta/main.go

    		// block -> data
    		combineSharedBlocks := make(map[int][]byte)
    		combineFilledBlocks := make(map[int][]byte)
    	nextFile:
    		for key, file := range files[partIdx] {
    			fmt.Println("Reading base version", file[0], "part", part)
    			var combined []byte
    			var missingAll int
    			var lastValidAll int
    
    			attempt := 0
    			for block := 0; ; block++ {
    				combineFilled := combineFilledBlocks[block]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
  4. cmd/object-api-utils.go

    }
    
    // Returns true if input bucket is a reserved minio bucket 'minio'.
    func isMinioReservedBucket(bucketName string) bool {
    	return bucketName == minioReservedBucket
    }
    
    // returns a slice of hosts by reading a slice of DNS records
    func getHostsSlice(records []dns.SrvRecord) []string {
    	hosts := make([]string, len(records))
    	for i, r := range records {
    		hosts[i] = net.JoinHostPort(r.Host, string(r.Port))
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  5. cmd/bucket-replication-metrics_gen.go

    			return
    		}
    		switch msgp.UnsafeString(field) {
    		case "Curr":
    			z.Curr, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "Curr")
    				return
    			}
    		case "Avg":
    			z.Avg, err = dc.ReadFloat32()
    			if err != nil {
    				err = msgp.WrapError(err, "Avg")
    				return
    			}
    		case "Max":
    			z.Max, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "Max")
    				return
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/reflect/ClassPathTest.java

        }
      }
    
      private void doTestExistsThrowsSecurityException() throws IOException, URISyntaxException {
        File file = null;
        // In Java 9, Logger may read the TZ database. Only disallow reading the class path URLs.
        final PermissionCollection readClassPathFiles =
            new FilePermission("", "read").newPermissionCollection();
        for (URL url : ClassPath.parseJavaClassPath()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jul 24 22:09:38 UTC 2024
    - 27.6K bytes
    - Viewed (0)
  7. cmd/object_api_suite_test.go

    		}, MakeBucketOptions{
    			VersioningEnabled: true,
    		})
    	})
    }
    
    // ExecExtendedObjectLayerTest will execute the tests with combinations of encrypted & compressed.
    // This can be used to test functionality when reading and writing data.
    func ExecExtendedObjectLayerTest(t *testing.T, objTest objTestType) {
    	execExtended(t, func(t *testing.T, init func(), bucketOptions MakeBucketOptions) {
    		ExecObjectLayerTest(t, objTest)
    	})
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  8. cmd/erasure-metadata.go

    				fmt.Fprintf(h, "part.%d", part.Number)
    				fmt.Fprintf(h, "part.%d", part.Size)
    			}
    			// Previously we checked if we had quorum on DataDir value.
    			// We have removed this check to allow reading objects with different DataDir
    			// values in a few drives (due to a rebalance-stop race bug)
    			// provided their their etags or ModTimes match.
    
    			if !meta.Deleted && meta.Size != 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/testing/NullPointerTester.java

            }
          }
          return map.values();
        }
    
        private ImmutableList<Method> getVisibleMethods(Class<?> cls) {
          // Don't use cls.getPackage() because it does nasty things like reading
          // a file.
          String visiblePackage = Reflection.getPackageName(cls);
          ImmutableList.Builder<Method> builder = ImmutableList.builder();
          for (Class<?> type : TypeToken.of(cls).getTypes().rawTypes()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  10. docs/en/docs/deployment/concepts.md

    ## Recap
    
    You have been reading here some of the main concepts that you would probably need to keep in mind when deciding how to deploy your application:
    
    * Security - HTTPS
    * Running on startup
    * Restarts
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Sep 18 16:09:57 UTC 2024
    - 17.8K bytes
    - Viewed (0)
Back to top