- Sort Score
- Num 10 results
- Language All
Results 91 - 100 of 306 for unpipe (0.11 seconds)
-
ci/devinfra/docker/windows/Dockerfile
# This Dockerfile creates an image that has: # - the correct MTU setting for networking from inside the container to work. # - Visual Studio 2022 Build Tools # - MSVC 14.39 # - LLVM/Clang 18.1.4 # - MSYS2 + curl, git, patch, vim, unzip, zip # - Python 3.12.3 # - Bazelisk 1.19.0 # - JDK 21 (Azul Zulu) FROM mcr.microsoft.com/windows/servercore:ltsc2019 SHELL ["powershell.exe", "-ExecutionPolicy", "Bypass", "-Command", \
Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Fri Jan 17 16:35:57 GMT 2025 - 8.4K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb1/trans/TransTransactNamedPipeResponse.java
* * This response contains the data returned from the named pipe * after a transact operation (write then read) has been completed. */ public class TransTransactNamedPipeResponse extends SmbComTransactionResponse { private final byte[] outputBuffer; /** * Constructs a response for a named pipe transaction. * * @param config the configuration to use
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 2.9K bytes - Click Count (0) -
compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/ArtifactDescriptorUtils.java
} return pomArtifact; } /** * Creates POM artifact out of passed in artifact by dropping classifier (if exists) and rewriting extension to * "pom". Unconditionally, unlike {@link #toPomArtifact(Artifact)} that does this only for artifacts without * classifiers. * * @since 4.0.0 */ public static Artifact toPomArtifactUnconditionally(Artifact artifact) {Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Oct 16 06:12:36 GMT 2025 - 4K bytes - Click Count (0) -
src/test/java/jcifs/CIFSContextTest.java
// Given String url = "smb://server/share/pipe"; int pipeType = 1; SmbPipeResource mockPipe = mock(SmbPipeResource.class); when(mockContext.getPipe(url, pipeType)).thenReturn(mockPipe); // When SmbPipeResource pipe = mockContext.getPipe(url, pipeType); // Then assertEquals(mockPipe, pipe); verify(mockContext).getPipe(url, pipeType); }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 8.8K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbPipeInputStream.java
} /** * This stream class is unbuffered. Therefore this method will always * return 0 for streams connected to regular files. However, a * stream created from a Named Pipe this method will query the server using a * "peek named pipe" operation and return the number of available bytes * on the server. */ @Override public int available() throws IOException {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 3.8K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbPipeOutputStream.java
return this.handle.ensureOpen(); } /** * Gets the pipe handle implementation for this output stream. * * @return the handle */ protected SmbPipeHandleImpl getHandle() { return this.handle; } @Override public void close() { // ignore, the shared file descriptor is closed by the pipe handle }
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 2.1K bytes - Click Count (0) -
src/test/java/jcifs/smb1/smb1/NetServerEnum2Test.java
assertEquals(ServerMessageBlock.SMB_COM_TRANSACTION, netServerEnum2.command); assertEquals(SmbComTransaction.NET_SERVER_ENUM2, netServerEnum2.subCommand); assertEquals("\\PIPE\\LANMAN", netServerEnum2.name); assertEquals(8, netServerEnum2.maxParameterCount); assertEquals(16384, netServerEnum2.maxDataCount); assertEquals(0, netServerEnum2.maxSetupCount);
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 7.6K bytes - Click Count (0) -
android/guava/src/com/google/common/io/ByteSink.java
import java.io.InputStream; import java.io.OutputStream; import java.io.OutputStreamWriter; import java.io.Writer; import java.nio.charset.Charset; /** * A destination to which bytes can be written, such as a file. Unlike an {@link OutputStream}, a * {@code ByteSink} is not an open, stateful stream that can be written to and closed. Instead, it * is an immutable <i>supplier</i> of {@code OutputStream} instances. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 4.9K bytes - Click Count (0) -
internal/ringbuffer/README.md
If you want to block when reading or writing, you must enable it: ```go rb := ringbuffer.New(1024).SetBlocking(true) ``` Enabling blocking will cause the ring buffer to behave like a buffered [io.Pipe](https://pkg.go.dev/io#Pipe). Regular Reads will block until data is available, but not wait for a full buffer. Writes will block until there is space available and writes bigger than the buffer will wait for reads to make space.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed May 15 00:11:04 GMT 2024 - 2.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/crawler/util/FieldConfigs.java
/** * Configuration class that holds parsed configuration values for a field. * This class parses pipe-separated configuration values and provides methods * to check for specific configuration options. */ public static class Config { /** * Array of parsed configuration values split by pipe character and trimmed. */ private final String[] values; /**Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 4.3K bytes - Click Count (0)