Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 438 for readlink (0.11 sec)

  1. cmd/erasure-server-pool-decom_gen.go

    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		switch msgp.UnsafeString(field) {
    		case "id":
    			z.ID, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "ID")
    				return
    			}
    		case "cl":
    			z.CmdLine, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "CmdLine")
    				return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 04 21:02:54 UTC 2022
    - 26.7K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/io/ByteSourceTest.java

        // Append 10 more bytes to the source.
        source.append(newPreFilledByteArray(5, 10));
    
        // The stream reports no bytes... importantly, it doesn't read the byte at index 5 when it
        // should be reading the byte at index 10.
        // We could use a custom InputStream instead to make the read start at index 10, but since this
        // is a racy situation anyway, this behavior seems reasonable.
        assertEquals(-1, in.read());
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/exec/Crawler.java

                            try {
                                while (!reader.ready()) {
                                    ThreadUtil.sleep(1000L);
                                }
                                command = reader.readLine().trim();
                                if (logger.isDebugEnabled()) {
                                    logger.debug("Process command: {}", command);
                                }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 24K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt

        frame.writeInt(expectedStreamId and 0x7fffffff)
        frame.writeAll(headerBlock)
    
        // Check writer sends the same bytes.
        assertThat(sendHeaderFrames(false, sentHeaders)).isEqualTo(frame)
    
        // Reading the above frames should result in a concatenated headerBlock.
        reader.nextFrame(
          requireSettings = false,
          object : BaseTestHandler() {
            override fun headers(
              inFinished: Boolean,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  5. internal/s3select/csv/reader.go

    	if cap(dst) < skip {
    		dst = make([]byte, 0, skip+1024)
    	}
    	dst = dst[:skip]
    	if skip > 0 {
    		n, err := io.ReadFull(r.buf, dst)
    		if err != nil && err != io.ErrUnexpectedEOF {
    			// If an EOF happens after reading some but not all the bytes,
    			// ReadFull returns ErrUnexpectedEOF.
    			return dst[:n], err
    		}
    		dst = dst[:n]
    		if err == io.ErrUnexpectedEOF {
    			return dst, io.EOF
    		}
    	}
    	// Read until next line.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AtomicDoubleArray.java

      /** Reconstitutes the instance from a stream (that is, deserializes it). */
      private void readObject(ObjectInputStream s) throws IOException, ClassNotFoundException {
        s.defaultReadObject();
    
        int length = s.readInt();
        ImmutableLongArray.Builder builder = ImmutableLongArray.builder();
        for (int i = 0; i < length; i++) {
          builder.add(doubleToRawLongBits(s.readDouble()));
        }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 17:55:55 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/smb1/ACE.java

     * of the access check algorithm used by Windows is required. The following
     * is a basic description of the algorithm. For a more complete description
     * we recommend reading the section on Access Control in Keith Brown's
     * "The .NET Developer's Guide to Windows Security" (which is also
     * available online).
     * <p>
     * Direct ACEs are evaluated first in order. The SID of the user performing
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 7.2K bytes
    - Viewed (0)
  8. cmd/metacache-walk_gen.go

    				return
    			}
    		case "ForwardTo":
    			z.ForwardTo, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "ForwardTo")
    				return
    			}
    		case "Limit":
    			z.Limit, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "Limit")
    				return
    			}
    		case "DiskID":
    			z.DiskID, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "DiskID")
    				return
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 7K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

          return null // Another edit is in progress.
        }
    
        if (entry != null && entry.lockingSourceCount != 0) {
          return null // We can't write this file because a reader is still reading it.
        }
    
        if (mostRecentTrimFailed || mostRecentRebuildFailed) {
          // The OS has become our enemy! If the trim job failed, it means we are storing more data than
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

          "timeout",
          "Read timed out",
        )
        assertThat(webSocket.close(1000, null)).isFalse()
      }
    
      /**
       * There's no read timeout when reading the first byte of a new frame. But as soon as we start
       * reading a frame we enable the read timeout. In this test we have the server returning the first
       * byte of a frame but no more frames.
       */
      @Test
      fun readTimeoutAppliesWithinFrames() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 35.2K bytes
    - Viewed (0)
Back to top