- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 592 for pipe1 (0.04 sec)
-
src/main/java/jcifs/CIFSContext.java
* @throws CIFSException */ SmbResource get ( String url ) throws CIFSException; /** * Get a pipe resource * * @param url * @param pipeType * the type of the pipe * @return the SMB pipe resource at the specified location * @throws CIFSException */ SmbPipeResource getPipe ( String url, int pipeType ) throws CIFSException;
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 3.7K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener_test.go
}}, }, expect: true, }, { desc: "listener-pipe", inFilter: &ListenerFilter{ Address: "", Port: 0, Type: "", }, inListener: &listener.Listener{ Address: &core.Address{ Address: &core.Address_Pipe{ Pipe: &core.Pipe{Path: "unix:///dev/shm/uds.socket"}, }, }, }, expect: true, }, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Sep 11 15:29:30 UTC 2023 - 4.1K bytes - Viewed (0) -
api/go1.9.txt
pkg syscall (darwin-amd64), type Credential struct, NoSetGroups bool pkg syscall (freebsd-386-cgo), func Pipe2([]int, int) error pkg syscall (freebsd-386-cgo), type Credential struct, NoSetGroups bool pkg syscall (freebsd-386), func Pipe2([]int, int) error pkg syscall (freebsd-386), type Credential struct, NoSetGroups bool pkg syscall (freebsd-amd64-cgo), func Pipe2([]int, int) error pkg syscall (freebsd-amd64-cgo), type Credential struct, NoSetGroups bool
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 04 20:20:20 UTC 2021 - 10.7K bytes - Viewed (0) -
src/net/http/filetransport.go
// populated (even if the body itself is still being // written to the res.Body, a pipe) rw, resc := newPopulateResponseWriter() go func() { t.fh.ServeHTTP(rw, req) rw.finish() }() return <-resc, nil } func newPopulateResponseWriter() (*populateResponse, <-chan *Response) { pr, pw := io.Pipe() rw := &populateResponse{ ch: make(chan *Response), pw: pw, res: &Response{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 3.5K bytes - Viewed (0) -
pkg/util/filesystem/util_windows_test.go
for i := range b { b[i] = letter[rand.Intn(len(letter))] } return "\\\\.\\pipe\\test-pipe" + string(b) } testFile := generatePipeName(4) pipeln, err := winio.ListenPipe(testFile, &winio.PipeConfig{SecurityDescriptor: "D:P(A;;GA;;;BA)(A;;GA;;;SY)"}) defer pipeln.Close() require.NoErrorf(t, err, "Failed to listen on named pipe for test purposes: %v", err) result, err := IsUnixDomainSocket(testFile)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 09:10:26 UTC 2024 - 3.2K bytes - Viewed (0) -
src/syscall/exec_linux.go
// so that pass 2 won't stomp on an fd it needs later. if pipe < nextfd { _, _, err1 = RawSyscall(SYS_DUP3, uintptr(pipe), uintptr(nextfd), O_CLOEXEC) if err1 != 0 { goto childerror } pipe = nextfd nextfd++ } for i = 0; i < len(fd); i++ { if fd[i] >= 0 && fd[i] < i { if nextfd == pipe { // don't stomp on pipe nextfd++ }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 07:45:37 UTC 2024 - 23K bytes - Viewed (0) -
src/test/java/jcifs/tests/ReadWriteTest.java
} } } catch ( SmbException e ) { if ( e.getNtStatus() == 0xC00000BB ) { Assume.assumeTrue("Server does not support pipes or it does not exist", false); } throw e; } } } @Test public void testCallPipe () throws IOException {
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 13.2K bytes - Viewed (0) -
internal/ioutil/wait_pipe.go
err = r.PipeReader.CloseWithError(err) r.wait() return err } // WaitPipe implements wait-group backend io.Pipe to provide // synchronization between read() end with write() end. func WaitPipe() (*PipeReader, *PipeWriter) { r, w := io.Pipe() var wg sync.WaitGroup wg.Add(1) return &PipeReader{ PipeReader: r, wait: wg.Wait, }, &PipeWriter{ PipeWriter: w,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 27 14:55:36 UTC 2023 - 1.7K bytes - Viewed (0) -
test/typeparam/issue48645b.go
s.it.Iterate(fn) } func FromIterator[T any](it Iterator[T]) Stream[T] { return Stream[T]{it: it} } func (s Stream[T]) DropWhile(fn func(T) bool) Stream[T] { return Pipe[T, T](s, func(t T) (T, bool) { return t, true }) } func Pipe[T, R any](s Stream[T], op func(d T) (R, bool)) Stream[R] { it := func(fn func(R) bool) { // XXX Not getting the closure right when converting to interface.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 01 19:45:34 UTC 2022 - 1.4K bytes - Viewed (0) -
src/main/java/jcifs/SmbPipeHandle.java
*/ package jcifs; import java.io.InputStream; import java.io.OutputStream; /** * Handle to an open named pipe * * @author mbechler * */ public interface SmbPipeHandle extends AutoCloseable { /** * @return the pipe */ SmbPipeResource getPipe (); /** * * @return this pipe's input stream * @throws CIFSException */
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 1.8K bytes - Viewed (0)