- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 34 for channel2 (0.05 seconds)
-
android/guava/src/com/google/common/io/ByteStreams.java
* <ol> * <li>Use sendfile(2) or equivalent. Requires that both the input channel and the output * channel have their own file descriptors. Generally this only happens when both channels * are files or sockets. This performs zero copies - the bytes never enter userspace. * <li>Use mmap(2) or equivalent. Requires that either the input channel or the output channel
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 31.1K bytes - Click Count (0) -
android/guava/src/com/google/common/io/Files.java
try { RandomAccessFile raf = closer.register(new RandomAccessFile(file, mode == MapMode.READ_ONLY ? "r" : "rw")); FileChannel channel = closer.register(raf.getChannel()); return channel.map(mode, 0, size == -1 ? channel.size() : size); } catch (Throwable e) { throw closer.rethrow(e); } finally { closer.close(); } } /**Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Jan 05 22:13:21 GMT 2026 - 32.8K bytes - Click Count (0) -
README.md
- **Community Forum**: Engage with others on the [Gradle Forum](https://discuss.gradle.org/) for discussions, tips, and best practices. - **Community Slack**: [Join our Slack Channel](https://gradle.org/slack-invite) for real-time discussions, with specialized channels like `#github-integrations` for integration topics. - **Newsletter**: Subscribe to the [Gradle Newsletter](https://newsletter.gradle.org) for news, tutorials, and community highlights.
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Thu Feb 12 18:58:41 GMT 2026 - 7.8K bytes - Click Count (0) -
src/main/java/org/codelibs/core/io/FileUtil.java
assertArgumentNotNull("file", file); final FileInputStream is = InputStreamUtil.create(file); try { final FileChannel channel = is.getChannel(); final long fileSize = ChannelUtil.size(channel); if (fileSize > maxSize) { throw new IORuntimeException(new IOException(
Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Thu Feb 12 12:10:45 GMT 2026 - 13.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/io/ByteStreamsTest.java
import java.io.FilterInputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.io.RandomAccessFile; import java.nio.channels.Channels; import java.nio.channels.ReadableByteChannel; import java.nio.channels.WritableByteChannel; import java.util.Arrays; import org.jspecify.annotations.NullUnmarked; /** * Unit test for {@link ByteStreams}. * * @author Chris Nokleberg */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 22K bytes - Click Count (0) -
.teamcity/src/main/kotlin/model/CIBuildModel.kt
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Tue Jan 20 03:53:25 GMT 2026 - 27.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/io/ByteStreamsTest.java
import java.io.FilterInputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.io.RandomAccessFile; import java.nio.channels.Channels; import java.nio.channels.ReadableByteChannel; import java.nio.channels.WritableByteChannel; import java.util.Arrays; import org.jspecify.annotations.NullUnmarked; /** * Unit test for {@link ByteStreams}. * * @author Chris Nokleberg */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 22K bytes - Click Count (0) -
internal/stmt_store/stmt_store.go
// The prepared channel is used to synchronize the statement preparation state. cacheStmt := &Stmt{ Transaction: isTransaction, prepared: make(chan struct{}), } // Cache the Stmt object with the associated key. s.Set(key, cacheStmt) // Unlock after completing initialization to prevent deadlocks. locker.Unlock() // Ensure the prepared channel is closed after the function execution completes.Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Sat Mar 21 11:35:55 GMT 2026 - 6.1K bytes - Click Count (0) -
.teamcity/src/main/kotlin/configurations/PerformanceTest.kt
) param("env.PERFORMANCE_STAGE", stage.stageName.toString()) param("env.PERFORMANCE_CHANNEL", performanceTestBuildSpec.channel()) param("env.PERFORMANCE_DB_PASSWORD_TCAGENT", "%performance.db.password.tcagent%") when (os) { Os.WINDOWS -> param("env.PATH", "%env.PATH%;C:/Program Files/7-zip")Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Thu Jan 29 01:37:22 GMT 2026 - 6.1K bytes - Click Count (0) -
.teamcity/src/main/kotlin/configurations/PerformanceTestsPass.kt
param("env.PERFORMANCE_DB_PASSWORD_TCAGENT", "%performance.db.password.tcagent%") param("performance.db.username", "tcagent") param("env.PERFORMANCE_CHANNEL", performanceTestSpec.channel()) } features { publishBuildStatusToGithub(model) } val performanceResultsDir = "perf-results"
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Wed Jan 07 10:42:35 GMT 2026 - 5.8K bytes - Click Count (0)