- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 397 for send0 (0.01 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)