- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 299 for writeLoc (0.15 sec)
-
src/net/iprawsock_plan9.go
return 0, nil, syscall.EPLAN9 } func (c *IPConn) readMsg(b, oob []byte) (n, oobn, flags int, addr *IPAddr, err error) { return 0, 0, 0, nil, syscall.EPLAN9 } func (c *IPConn) writeTo(b []byte, addr *IPAddr) (int, error) { return 0, syscall.EPLAN9 } func (c *IPConn) writeMsg(b, oob []byte, addr *IPAddr) (n, oobn int, err error) { return 0, 0, syscall.EPLAN9 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 29 23:57:04 UTC 2018 - 874 bytes - Viewed (0) -
src/internal/poll/sendfile_linux.go
func SendFile(dstFD *FD, src int, remain int64) (written int64, err error, handled bool) { defer func() { TestHookDidSendFile(dstFD, src, written, err, handled) }() if err := dstFD.writeLock(); err != nil { return 0, err, false } defer dstFD.writeUnlock() if err := dstFD.pd.prepareWrite(dstFD.isFile); err != nil { return 0, err, false } dst := dstFD.Sysfd for remain > 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 1.4K bytes - Viewed (0) -
platforms/core-execution/build-cache-spi/src/main/java/org/gradle/caching/BuildCacheEntryWriter.java
* * @param output output stream to write build cache entry to * @throws IOException when an I/O error occurs when writing the cache entry to the given output stream */ void writeTo(OutputStream output) throws IOException; /** * Returns the size of the build cache entry to be written. * * @return the size of the build cache entry to be written. * @since 4.1 */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Feb 05 16:09:36 UTC 2024 - 1.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/duplex/AsyncRequestBody.kt
class AsyncRequestBody : RequestBody() { private val requestBodySinks: BlockingQueue<BufferedSink> = LinkedBlockingQueue() override fun contentType(): MediaType? = null override fun writeTo(sink: BufferedSink) { requestBodySinks.add(sink) } override fun isDuplex(): Boolean = true @Throws(InterruptedException::class) fun takeSink(): BufferedSink {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 1.5K bytes - Viewed (0) -
src/strings/reader_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 5.9K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ResponseProducer.java
import java.io.IOException; interface ResponseProducer { default boolean isFailure() { return false; } /** * Called to handle a request. Is *not* called under lock. */ void writeTo(int requestId, HttpExchange exchange) throws IOException; /** * Returns the failure, if any. */ default RuntimeException getFailure() { throw new IllegalStateException(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.1K bytes - Viewed (0) -
platforms/core-execution/build-cache-local/src/main/java/org/gradle/caching/local/internal/DirectoryBuildCache.java
persistentCache.withFileLock(() -> { // Additional locking necessary because of https://github.com/gradle/gradle/issues/3537 lock.writeLock().lock(); try { storeInsideLock(key, file); } finally { lock.writeLock().unlock(); } }); } private void storeInsideLock(HashCode key, File sourceFile) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:53 UTC 2024 - 7K bytes - Viewed (0) -
src/internal/poll/sendfile_windows.go
// TransmitFile does not work with pipes return 0, syscall.ESPIPE } if ft, _ := syscall.GetFileType(src); ft == syscall.FILE_TYPE_PIPE { return 0, syscall.ESPIPE } if err := fd.writeLock(); err != nil { return 0, err } defer fd.writeUnlock() o := &fd.wop o.handle = src // TODO(brainman): skip calling syscall.Seek if OS allows it
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 2.2K bytes - Viewed (0) -
platforms/core-runtime/io/src/main/java/org/gradle/internal/io/StreamByteBuffer.java
return output; } public InputStream getInputStream() { return input; } public void writeTo(OutputStream target) throws IOException { while (prepareRead() != -1) { currentReadChunk.writeTo(target); } } public void readFrom(InputStream inputStream, int len) throws IOException { int bytesLeft = len;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:14 UTC 2024 - 16.6K bytes - Viewed (0) -
.teamcity/src/main/kotlin/promotion/BasePromotionBuildType.kt
// we only allow 1 promotion job running at the same time to avoid website xml conflicts feature { type = "JetBrains.SharedResources" param("locks-param", "WebsiteReleasesXml writeLock") } } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 24 03:34:53 UTC 2024 - 2.1K bytes - Viewed (0)