- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 476 for npipe (0.03 sec)
-
src/net/rpc/jsonrpc/all_test.go
// Copied from package net. func myPipe() (*pipe, *pipe) { r1, w1 := io.Pipe() r2, w2 := io.Pipe() return &pipe{r1, w2}, &pipe{r2, w1} } type pipe struct { *io.PipeReader *io.PipeWriter } type pipeAddr int func (pipeAddr) Network() string { return "pipe" } func (pipeAddr) String() string { return "pipe" } func (p *pipe) Close() error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 07 01:09:53 UTC 2022 - 7.8K bytes - Viewed (0) -
src/main/java/jcifs/SmbPipeResource.java
/** * The pipe should be opened for both reading and writing. */ public static final int PIPE_TYPE_RDWR = SmbConstants.O_RDWR; /** * Pipe operations should behave like the <code>CallNamedPipe</code> Win32 Named Pipe function. */ public static final int PIPE_TYPE_CALL = 0x0100; /**
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 2.1K bytes - Viewed (0) -
src/syscall/exec_bsd.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 29 18:51:35 UTC 2023 - 7.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbPipeHandleImpl.java
/** * @param pipe */ public SmbPipeHandleImpl ( SmbNamedPipe pipe ) { this.pipe = pipe; this.transact = ( pipe.getPipeType() & SmbPipeResource.PIPE_TYPE_TRANSACT ) == SmbPipeResource.PIPE_TYPE_TRANSACT; this.call = ( pipe.getPipeType() & SmbPipeResource.PIPE_TYPE_CALL ) == SmbPipeResource.PIPE_TYPE_CALL; this.openFlags = ( pipe.getPipeType() & 0xFFFF00FF ) | SmbConstants.O_EXCL;
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Mon Apr 13 17:05:22 UTC 2020 - 10.3K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TransCallNamedPipeResponse.java
*/ package jcifs.smb1.smb1; class TransCallNamedPipeResponse extends SmbComTransactionResponse { private SmbNamedPipe pipe; TransCallNamedPipeResponse( SmbNamedPipe pipe ) { this.pipe = pipe; } int writeSetupWireFormat( byte[] dst, int dstIndex ) { return 0; } int writeParametersWireFormat( byte[] dst, int dstIndex ) { return 0;
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 2K bytes - Viewed (0) -
src/text/template/parse/parse.go
pipe.IsAssign = next.typ == itemAssign t.nextNonSpace() pipe.Decl = append(pipe.Decl, t.newVariable(v.pos, v.val)) t.vars = append(t.vars, v.val) case next.typ == itemChar && next.val == ",": t.nextNonSpace() pipe.Decl = append(pipe.Decl, t.newVariable(v.pos, v.val)) t.vars = append(t.vars, v.val) if context == "range" && len(pipe.Decl) < 2 { switch t.peekNonSpace().typ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 20:57:51 UTC 2024 - 21.3K bytes - Viewed (0) -
src/io/pipe_test.go
} if err = r.Close(); err != nil { t.Errorf("r.Close: %v", err) } } } // Test close on Read side during Read. func TestPipeReadClose2(t *testing.T) { c := make(chan int, 1) r, _ := Pipe() go delayClose(t, r, c, pipeTest{}) n, err := r.Read(make([]byte, 64)) <-c if n != 0 || err != ErrClosedPipe {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 9K bytes - Viewed (0) -
src/cmd/go/terminal_test.go
// invocation (rather than, e.g., putting a pipe in the way). // // See issue 18153. testenv.MustHaveGoBuild(t) // Start with a "self test" to make sure that if we *don't* pass in a // terminal, the test can correctly detect that. (cmd/go doesn't guarantee // that it won't add a terminal in the middle, but that would be pretty weird.) t.Run("pipe", func(t *testing.T) { r, w, err := os.Pipe() if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Dec 07 18:18:50 UTC 2022 - 3.3K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/DcerpcPipeHandle.java
} @Override public CIFSContext getTransportContext () { return this.pipe.getContext(); } @Override public String getServer () { return this.pipe.getLocator().getServer(); } @Override public String getServerWithDfs () { return this.pipe.getLocator().getServerWithDfs(); } @Override
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jan 26 11:51:07 UTC 2020 - 5.2K bytes - Viewed (0) -
src/os/exec/exec_unix.go
// whether the provided stdin copy error should be ignored. func skipStdinCopyError(err error) bool { // Ignore EPIPE errors copying to stdin if the program // completed successfully otherwise. // See Issue 9173. pe, ok := err.(*fs.PathError) return ok && pe.Op == "write" && pe.Path == "|1" && pe.Err == syscall.EPIPE
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 26 13:47:05 UTC 2022 - 635 bytes - Viewed (0)