Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 417 for readlink (0.07 sec)

  1. android/guava/src/com/google/common/util/concurrent/ForwardingCondition.java

      public long awaitNanos(long nanosTimeout) throws InterruptedException {
        return delegate().awaitNanos(nanosTimeout);
      }
    
      @Override
      public boolean awaitUntil(Date deadline) throws InterruptedException {
        return delegate().awaitUntil(deadline);
      }
    
      @Override
      public void signal() {
        delegate().signal();
      }
    
      @Override
      public void signalAll() {
        delegate().signalAll();
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/testing/GcFinalization.java

       */
      @SuppressWarnings("removal") // b/260137033
      public static void awaitDone(Future<?> future) {
        if (future.isDone()) {
          return;
        }
        long timeoutSeconds = timeoutSeconds();
        long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds);
        do {
          System.runFinalization();
          if (future.isDone()) {
            return;
          }
          System.gc();
          try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  3. internal/dsync/dsync-server_test.go

    	return true, nil
    }
    
    const ReadLock = 1
    
    func (l *lockServer) RLock(args *LockArgs) (reply bool, err error) {
    	if d := atomic.LoadInt64(&l.responseDelay); d != 0 {
    		time.Sleep(time.Duration(d))
    	}
    
    	l.mutex.Lock()
    	defer l.mutex.Unlock()
    	var locksHeld int64
    	if locksHeld, reply = l.lockMap[args.Resources[0]]; !reply {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jan 23 16:46:37 UTC 2023
    - 8.3K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/io/SourceSinkTester.java

        try {
          return new CharSource() {
            @Override
            public Reader openStream() throws IOException {
              return new StringReader(string);
            }
          }.readLines();
        } catch (IOException e) {
          throw new AssertionError();
        }
      }
    
      @Override
      public void tearDown() throws IOException {
        factory.tearDown();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 27 18:57:08 UTC 2022
    - 4.9K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/suggest/settings/AnalyzerSettingsTest.java

                final String term = tokens.get(i).getTerm();
                final String reading = readingTokens.get(i).getTerm();
                switch (term) {
                case "fess":
                    matchCount++;
                    assertEquals("fess", reading);
                    break;
                case "検索":
                    matchCount++;
                    assertEquals("ケンサク", reading);
                    break;
                case "無料":
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  6. src/archive/tar/testdata/hdr-only.tar

    fifo file The quick brown fox jumped over the lazy dog! hardlink null sda symlink badlink fifo The quick brown fox jumped over the lazy dog! hardlink sda symli badlink...
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Dec 01 20:16:26 UTC 2015
    - 10K bytes
    - Viewed (0)
  7. internal/grid/grid.go

    	// clientPingInterval will ping the remote handler every 15 seconds.
    	// Clients disconnect when we exceed 2 intervals.
    	clientPingInterval = 15 * time.Second
    
    	// Deadline for single (non-streaming) requests to complete.
    	// Used if no deadline is provided on context.
    	defaultSingleRequestTimeout = time.Minute
    )
    
    var internalByteBuffer = sync.Pool{
    	New: func() any {
    		m := make([]byte, 0, defaultBufferSize)
    		return &m
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  8. src/bytes/reader.go

    // [io.ByteScanner], and [io.RuneScanner] interfaces by reading from
    // a byte slice.
    // Unlike a [Buffer], a Reader is read-only and supports seeking.
    // The zero value for Reader operates like a Reader of an empty slice.
    type Reader struct {
    	s        []byte
    	i        int64 // current reading index
    	prevRune int   // index of previous rune; or < 0
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Jul 16 18:17:37 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/suggest/entity/ElevateWord.java

        public List<String> getRoles() {
            return roles;
        }
    
        public SuggestItem toSuggestItem() {
            final String[][] readingArray =
                    this.getReadings().stream().map(reading -> new String[] { reading }).toArray(count -> new String[count][]);
            return new SuggestItem(new String[] { this.getElevateWord() }, readingArray, fields.toArray(new String[fields.size()]), 1, 0,
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/smb1/SmbNamedPipe.java

     * </pre></td><td>
     * Open the Named Pipe foo for reading and writing. The pipe will behave like the <code>CallNamedPipe</code> interface.
     * </td></tr>
     * <tr><td width="20%"><pre>
     * new SmbNamedPipe( "smb1://server/IPC$/foo",
     *         SmbNamedPipe.PIPE_TYPE_RDWR |
     *         SmbNamedPipe.PIPE_TYPE_TRANSACT );
     * </pre></td><td>
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 7.3K bytes
    - Viewed (0)
Back to top