Search Options

Results per page
Sort
Preferred Languages
Advance

Results 671 - 680 of 796 for Threads (0.04 sec)

  1. internal/s3select/json/preader.go

    type queueItem struct {
    	input []byte             // raw input sent to the worker
    	dst   chan []jstream.KVS // result of block decode
    	err   error              // any error encountered will be set here
    }
    
    // Read - reads single record.
    // Once Read is called the previous record should no longer be referenced.
    func (r *PReader) Read(dst sql.Record) (sql.Record, error) {
    	// If we have have any records left, return these before any error.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/smb1/SigningDigest.java

            update(sequence, 0, sequence.length);
            index += 8;
            if (response.command == ServerMessageBlock.SMB_COM_READ_ANDX) {
                /* SmbComReadAndXResponse reads directly from the stream into separate byte[] b.
                 */
                final SmbComReadAndXResponse raxr = (SmbComReadAndXResponse) response;
                final int length = response.length - raxr.dataLength;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  3. src/test/java/jcifs/smb/BufferCacheImplTest.java

    import jcifs.Configuration;
    
    @ExtendWith(MockitoExtension.class)
    class BufferCacheImplTest {
    
        @Mock
        Configuration cfg;
    
        // Verifies constructor that accepts Configuration reads the expected values and uses them
        @Test
        @DisplayName("Constructor(Configuration) uses cache size and maximum buffer size from config")
        void constructorUsesConfigurationAndAllocatesWithConfiguredSize() {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  4. cmd/metrics-v3-system-drive.go

    		"Count of online drives")
    	driveCountMD = NewGaugeMD(driveCount,
    		"Count of all drives")
    
    	// 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,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  5. cmd/metrics-v3-cache.go

    	return m
    }
    
    func newDriveMetricsCache() *cachevalue.Cache[storageMetrics] {
    	var (
    		// prevDriveIOStats is used to calculate "per second"
    		// values for IOStat related disk metrics e.g. reads/sec.
    		prevDriveIOStats            map[string]madmin.DiskIOStats
    		prevDriveIOStatsMu          sync.RWMutex
    		prevDriveIOStatsRefreshedAt time.Time
    	)
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  6. docs/SMB3_IMPLEMENTATION_PLAN.md

    jcifs.smb.client.witnessNotificationTimeout=5000
    ```
    
    ## Risk Assessment
    
    ### Technical Risks
    1. **RDMA Complexity**: Limited Java RDMA support may require JNI
    2. **Multi-Channel Synchronization**: Complex thread synchronization required
    3. **Persistent Handle State**: Requires reliable state persistence mechanism
    4. **Backward Compatibility**: Must maintain compatibility with SMB2/SMB1
    
    ### Mitigation Strategies
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 10.7K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

        try {
          transformResult = doTransform(localFunction, sourceResult);
        } catch (Throwable t) {
          restoreInterruptIfIsInterruptedException(t);
          // This exception is irrelevant in this thread, but useful for the client.
          setException(t);
          return;
        } finally {
          function = null;
        }
    
        /*
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 20 18:03:37 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  8. src/bufio/scan_test.go

    		}
    		err := s.Err()
    		if err != nil {
    			t.Errorf("#%d: %v", n, err)
    		}
    	}
    }
    
    // slowReader is a reader that returns only a few bytes at a time, to test the incremental
    // reads in Scanner.Scan.
    type slowReader struct {
    	max int
    	buf io.Reader
    }
    
    func (sr *slowReader) Read(p []byte) (n int, err error) {
    	if len(p) > sr.max {
    		p = p[0:sr.max]
    	}
    	return sr.buf.Read(p)
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Sep 22 16:22:42 UTC 2023
    - 14.3K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/ServerMessageBlock2.java

            }
            SMBUtil.writeInt8(this.sessionId, dst, dstIndex + 40);
    
            return Smb2Constants.SMB2_HEADER_LENGTH;
        }
    
        /**
         * Reads the SMB2 header from the wire format.
         *
         * @param buffer the buffer to read from
         * @param bufferIndex the starting position in the buffer
         * @return number of bytes read
         */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 24K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/thumbnail/impl/HtmlTagBasedGenerator.java

            default -> false;
            };
        }
    
        /**
         * Processes and saves an image from the input stream to the output file as a thumbnail.
         *
         * <p>This method reads image data, validates dimensions, applies subsampling and scaling
         * transformations based on configuration settings, and writes the processed thumbnail
         * to the specified output file.</p>
         *
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 10.5K bytes
    - Viewed (0)
Back to top