Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 74 for Readlink (0.05 seconds)

  1. doc/godebug.md

    and other reparse points with non-default [`os.ModeType`](/pkg/os#ModeType) bits
    (such as [`os.ModeDir`](/pkg/os#ModeDir)) do not have the `ModeIrregular` bit set.
    
    Go 1.23 changed [`os.Readlink`](/pkg/os#Readlink) and [`filepath.EvalSymlinks`](/pkg/path/filepath#EvalSymlinks)
    to avoid trying to normalize volumes to drive letters, which was not always even possible.
    This behavior is controlled by the `winreadlinkvolume` setting.
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Mar 20 15:49:10 GMT 2026
    - 26K bytes
    - Click Count (0)
  2. internal/disk/stat_linux.go

    					// Check if there is a parent device:
    					//   e.g. if the mount is based on /dev/nvme0n1p1, let's calculate the
    					//        real device name (nvme0n1) to get its sysfs information
    					parentDevPath, e := os.Readlink("/sys/class/block/" + devName)
    					if e == nil {
    						parentDev := filepath.Base(filepath.Dir(parentDevPath))
    						qst, err = bfs.SysBlockDeviceQueueStats(parentDev)
    					}
    				}
    				if err == nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  3. internal/grid/muxclient.go

    		Payload:    req,
    		DeadlineMS: uint32(m.deadline.Milliseconds()),
    	}
    	if m.subroute != nil {
    		msg.Flags |= FlagSubroute
    	}
    	ch := make(chan Response, 1)
    	m.respMu.Lock()
    	if m.closed {
    		m.respMu.Unlock()
    		return nil, ErrDisconnected
    	}
    	m.respWait = ch
    	m.respMu.Unlock()
    	ctx := m.ctx
    
    	// Add deadline if none.
    	if msg.DeadlineMS == 0 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  4. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

       */
      @SuppressWarnings("removal") // b/487687332
      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 {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 20:19:19 GMT 2026
    - 12.3K bytes
    - Click Count (0)
  5. cmd/leak-detect_test.go

    	deadline := UTCNow().Add(leakDetectDeadline * time.Second)
    	for {
    		// get sack snapshot of relevant go routines.
    		leaked := initialSnapShot.CompareCurrentSnapshot()
    		// current stack snapshot matches the initial one, no leaks, return.
    		if len(leaked) == 0 {
    			return
    		}
    		// wait a test again will deadline.
    		if UTCNow().Before(deadline) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  6. 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();
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 24 18:55:30 GMT 2025
    - 1.8K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/core/io/ReaderUtil.java

         * @return a line of text, or {@literal null} if the end of the stream has been reached
         * @see BufferedReader#readLine()
         */
        public static String readLine(final BufferedReader reader) {
            assertArgumentNotNull("reader", reader);
    
            try {
                return reader.readLine();
            } catch (final IOException e) {
                throw new IORuntimeException(e);
            }
        }
    
        /**
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Thu Jul 31 08:16:49 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/HeadersReader.kt

      /** Read a single line counted against the header size limit. */
      fun readLine(): String {
        val line = source.readUtf8LineStrict(headerLimit)
        headerLimit -= line.length.toLong()
        return line
      }
    
      /** Reads headers or trailers. */
      fun readHeaders(): Headers {
        val result = Headers.Builder()
        while (true) {
          val line = readLine()
          if (line.isEmpty()) break
          result.addLenient(line)
        }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 1.4K bytes
    - Click Count (0)
  9. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

        val reader = BufferedReader(InputStreamReader(connection.inputStream, UTF_8))
        assertThat(connection.responseCode).isEqualTo(HttpURLConnection.HTTP_OK)
        assertThat(reader.readLine()).isEqualTo("hello world")
        val request = server.takeRequest()
        assertThat(request.requestLine).isEqualTo("GET / HTTP/1.1")
        assertThat(request.headers["Accept-Language"]).isEqualTo("en-US")
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Aug 03 22:38:00 GMT 2025
    - 28K bytes
    - Click Count (0)
  10. guava-testlib/src/com/google/common/testing/GcFinalization.java

       */
      @SuppressWarnings("removal") // b/487687332
      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 {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 20:19:19 GMT 2026
    - 12.3K bytes
    - Click Count (0)
Back to Top