Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 397 for send0 (0.01 sec)

  1. src/main/java/jcifs/internal/smb2/rdma/disni/DisniRdmaConnection.java

            }
        }
    
        @Override
        public void send(ByteBuffer data, RdmaMemoryRegion region) throws IOException {
            if (state != RdmaConnectionState.ESTABLISHED && state != RdmaConnectionState.CONNECTED) {
                throw new IOException("Connection not established");
            }
    
            try {
                // In real implementation, this would send using DiSNI:
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 10.2K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/smb1/SmbRandomAccessFile.java

            }
    
            int r, n;
            final SmbComReadAndXResponse response = new SmbComReadAndXResponse(b, off);
            do {
                r = len > readSize ? readSize : len;
                file.send(new SmbComReadAndX(file.fid, fp, r, null), response);
                n = response.dataLength;
                if (n <= 0) {
                    return (int) (fp - start > 0L ? fp - start : -1);
                }
                fp += n;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 14.1K bytes
    - Viewed (0)
  3. docs/en/docs/tutorial/request-form-models.md

    You can use Pydantic's model configuration to `forbid` any `extra` fields:
    
    {* ../../docs_src/request_form_models/tutorial002_an_py39.py hl[12] *}
    
    If a client tries to send some extra data, they will receive an **error** response.
    
    For example, if the client tries to send the form fields:
    
    * `username`: `Rick`
    * `password`: `Portal Gun`
    * `extra`: `Mr. Poopybutthole`
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  4. cmd/globals.go

    	// global Trace system to send HTTP request/response
    	// and Storage/OS calls info to registered listeners.
    	globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8)
    
    	// global Listen system to send S3 API events to registered listeners
    	globalHTTPListen = pubsub.New[event.Event, pubsub.Mask](0)
    
    	// global console system to send console logs to
    	// registered listeners
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (1)
  5. src/test/java/jcifs/smb/SmbTreeImplTest.java

            when(response.getService()).thenReturn("A:");
            when(response.isValidTid()).thenReturn(true);
            when(response.getTid()).thenReturn(1);
            when(session.send(any(), any())).thenReturn(response);
            when(config.isIpcSigningEnforced()).thenReturn(false);
    
            SmbTreeImpl tree = new SmbTreeImpl(session, "SHARE", "A:");
            tree.treeConnect(null, null);
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaProvider.java

    import jcifs.internal.smb2.rdma.RdmaProvider;
    
    /**
     * TCP fallback RDMA provider.
     *
     * This provider uses regular TCP connections but maintains the RDMA
     * interface for compatibility. It only supports send/receive operations
     * and does not provide true RDMA read/write capabilities.
     */
    public class TcpRdmaProvider implements RdmaProvider {
    
        /**
         * Creates a new TCP RDMA provider instance
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 2.9K bytes
    - Viewed (0)
  7. doc/go_mem.html

    <h3 id="chan">Channel communication</h3>
    
    <p>
    Channel communication is the main method of synchronization
    between goroutines.  Each send on a particular channel
    is matched to a corresponding receive from that channel,
    usually in a different goroutine.
    </p>
    
    <p class="rule">
    A send on a channel is synchronized before the completion of the
    corresponding receive from that channel.
    </p>
    
    <p>
    This program:
    </p>
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Aug 05 15:41:37 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/smb1/SmbFileOutputStream.java

                    }
                    file.send(reqx, rspx);
                    fp += rspx.count;
                    len -= rspx.count;
                    off += rspx.count;
                } else {
                    req.setParam(file.fid, fp, len - w, b, off, w);
                    fp += rsp.count;
                    len -= rsp.count;
                    off += rsp.count;
                    file.send(req, rsp);
                }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 11K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbPipeInputStream.java

                    req.setMaxOutputResponse(16);
                    req.setFlags(Smb2IoctlRequest.SMB2_O_IOCTL_IS_FSCTL);
                    final Smb2IoctlResponse resp = th.send(req, RequestParam.NO_RETRY);
                    return ((SrvPipePeekResponse) resp.getOutputData()).getReadDataAvailable();
                }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool.go

    					perDiskLimit:   opts.Limit,
    					minDisks:       listingQuorum,
    					reportNotFound: false,
    					agreed:         send,
    					partial: func(entries metaCacheEntries, _ []error) {
    						entry, ok := entries.resolve(&resolver)
    						if ok {
    							send(*entry)
    						}
    					},
    					finished: nil,
    				}
    
    				if err := listPathRaw(ctx, lopts); err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
Back to top