Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 1,066 for readOp (0.11 sec)

  1. src/main/java/org/codelibs/fess/dict/synonym/SynonymFile.java

            final List<SynonymItem> itemList = new ArrayList<>();
            try (BufferedReader reader = new BufferedReader(new InputStreamReader(in, Constants.UTF_8))) {
                long id = 0;
                String line = null;
                while ((line = reader.readLine()) != null) {
                    if (line.length() == 0 || line.charAt(0) == '#') {
                        if (updater != null) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  2. build-logic/build-init-samples/src/main/kotlin/gradlebuild/samples/SamplesGenerator.kt

            // clear the target directory to remove renamed files and reset the README file
            target.asFile.deleteRecursively()
    
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Tue Oct 22 11:11:17 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  3. build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java

            PrintStream ps = new PrintStream(os, true);
            new Thread(() -> {
                try {
                    BufferedReader reader = new BufferedReader(new InputStreamReader(forkedProcessOutput));
                    String line;
                    while ((line = reader.readLine()) != null) {
                        ps.println(line);
                    }
                } catch (Exception e) {
                    e.printStackTrace();
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Mon Aug 19 15:07:24 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  4. internal/hash/checksum.go

    	return NewChecksumWithType(NewChecksumType(alg), value)
    }
    
    // AppendTo will append the checksum to b.
    // 'parts' is used when checksum has ChecksumMultipart set.
    // ReadCheckSums reads the values back.
    func (c *Checksum) AppendTo(b []byte, parts []byte) []byte {
    	if c == nil {
    		return nil
    	}
    	var tmp [binary.MaxVarintLen32]byte
    	n := binary.PutUvarint(tmp[:], uint64(c.Type))
    	crc := c.Raw
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/helper/DocumentHelper.java

            if (title == null) {
                return StringUtil.EMPTY; // empty
            }
    
            final int[] spaceChars = getSpaceChars();
            try (final Reader reader = new StringReader(title)) {
                return TextUtil.normalizeText(reader).initialCapacity(title.length()).spaceChars(spaceChars).execute();
            } catch (final IOException e) {
                return StringUtil.EMPTY; // empty
            }
        }
    
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 12K bytes
    - Viewed (0)
  6. internal/dsync/drwmutex.go

    	isReadLock := false
    	return dm.lockBlocking(ctx, cancel, id, source, isReadLock, opts)
    }
    
    // RLock holds a read lock on dm.
    //
    // If one or more read locks are already in use, it will grant another lock.
    // Otherwise the calling go routine blocks until the mutex is available.
    func (dm *DRWMutex) RLock(id, source string) {
    	isReadLock := true
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  7. cmd/metrics-v3-system-drive.go

    	// iostat related
    	driveReadsPerSecMD = NewGaugeMD(driveReadsPerSec,
    		"Reads per second on a drive",
    		allDriveLabels...)
    	driveReadsKBPerSecMD = NewGaugeMD(driveReadsKBPerSec,
    		"Kilobytes read per second on a drive",
    		allDriveLabels...)
    	driveReadsAwaitMD = NewGaugeMD(driveReadsAwait,
    		"Average time for read requests served on a drive",
    		allDriveLabels...)
    	driveWritesPerSecMD = NewGaugeMD(driveWritesPerSec,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun May 12 17:23:50 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  8. tensorflow/c/c_api_experimental.cc

      TF_CheckpointReader* reader = new TF_CheckpointReader(filename, status);
      if (!status->status.ok()) {
        TF_DeleteCheckpointReader(reader);
        return nullptr;
      }
      const auto& m = reader->GetVariableToDataTypeMap();
      for (auto it = m.begin(); it != m.end(); ++it)
        reader->variable_list.push_back(it->first);
      std::sort(reader->variable_list.begin(), reader->variable_list.end());
      return reader;
    }
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Sat Oct 12 16:27:48 UTC 2024
    - 29.5K bytes
    - Viewed (0)
  9. internal/hash/reader_test.go

    	}
    }
    
    // Tests hash reader checksum verification.
    func TestHashReaderVerification(t *testing.T) {
    	testCases := []struct {
    		desc              string
    		src               io.Reader
    		size              int64
    		actualSize        int64
    		md5hex, sha256hex string
    		err               error
    	}{
    		0: {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 10.3K bytes
    - Viewed (0)
  10. cmd/post-policy-fan-out.go

    				if err != nil {
    					errs[idx] = err
    					return
    				}
    
    				reader, err = reader.WithEncryption(hr, &objectEncryptionKey)
    				if err != nil {
    					errs[idx] = err
    					return
    				}
    			}
    
    			objInfo, err := objectAPI.PutObject(ctx, bucket, req.Key, reader, ObjectOptions{
    				Versioned:        globalBucketVersioningSys.PrefixEnabled(bucket, req.Key),
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 3.5K bytes
    - Viewed (0)
Back to top