X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=src%2Fmeshlink%2B%2B.h;h=dee2c7060d04bc352b59901f911fc7d8a78a7009;hb=a18da7ad8a0d9f28dabf97d15407ece748538888;hp=8287e0382632777df5d4c0f1a7e59d4c398259ad;hpb=7075cf7bc81998b6cf72ccb6748050cd40b006be;p=meshlink

diff --git a/src/meshlink++.h b/src/meshlink++.h
index 8287e038..dee2c706 100644
--- a/src/meshlink++.h
+++ b/src/meshlink++.h
@@ -98,6 +98,18 @@ typedef void (*channel_receive_cb_t)(mesh *mesh, channel *channel, const void *d
  */
 typedef void (*channel_poll_cb_t)(mesh *mesh, channel *channel, size_t len);
 
+/// A callback for cleaning up buffers submitted for asynchronous I/O.
+/** This callbacks signals that MeshLink has finished using this buffer.
+ *  The ownership of the buffer is now back into the application's hands.
+ *
+ *  @param mesh      A handle which represents an instance of MeshLink.
+ *  @param channel   A handle for the channel which used this buffer.
+ *  @param data      A pointer to a buffer containing the enqueued data.
+ *  @param len       The length of the buffer.
+ *  @param priv      A private pointer which was set by the application when submitting the buffer.
+ */
+typedef void (*aio_cb_t)(mesh *mesh, channel *channel, const void *data, size_t len, void *priv);
+
 /// A class describing a MeshLink node.
 class node: public meshlink_node_t {
 };
@@ -113,6 +125,7 @@ public:
 	static const uint32_t ORDERED = MESHLINK_CHANNEL_ORDERED;
 	static const uint32_t FRAMED = MESHLINK_CHANNEL_FRAMED;
 	static const uint32_t DROP_LATE = MESHLINK_CHANNEL_DROP_LATE;
+	static const uint32_t NO_PARTIAL = MESHLINK_CHANNEL_NO_PARTIAL;
 	static const uint32_t TCP = MESHLINK_CHANNEL_TCP;
 	static const uint32_t UDP = MESHLINK_CHANNEL_UDP;
 };
@@ -637,6 +650,30 @@ public:
 		meshlink_set_channel_poll_cb(handle, channel, (meshlink_channel_poll_cb_t)cb);
 	}
 
+	/// Set the send buffer size of a channel.
+	/** This function sets the desired size of the send buffer.
+	 *  The default size is 128 kB.
+	 *
+	 *  @param channel   A handle for the channel.
+	 *  @param size      The desired size for the send buffer.
+	 *                   If a NULL pointer is given, the callback will be disabled.
+	 */
+	void set_channel_sndbuf(channel *channel, size_t size) {
+		meshlink_set_channel_sndbuf(handle, channel, size);
+	}
+
+	/// Set the receive buffer size of a channel.
+	/** This function sets the desired size of the receive buffer.
+	 *  The default size is 128 kB.
+	 *
+	 *  @param channel   A handle for the channel.
+	 *  @param size      The desired size for the send buffer.
+	 *                   If a NULL pointer is given, the callback will be disabled.
+	 */
+	void set_channel_rcvbuf(channel *channel, size_t size) {
+		meshlink_set_channel_rcvbuf(handle, channel, size);
+	}
+
 	/// Open a reliable stream channel to another node.
 	/** This function is called whenever a remote node wants to open a channel to the local node.
 	 *  The application then has to decide whether to accept or reject this channel.
@@ -714,11 +751,49 @@ public:
 	 *  @param len          The length of the data.
 	 *
 	 *  @return             The amount of data that was queued, which can be less than len, or a negative value in case of an error.
+	 *                      If MESHLINK_CHANNEL_NO_PARTIAL is set, then the result will either be len,
+	 *                      0 if the buffer is currently too full, or -1 if len is too big even for an empty buffer.
 	 */
 	ssize_t channel_send(channel *channel, void *data, size_t len) {
 		return meshlink_channel_send(handle, channel, data, len);
 	}
 
+	/// Transmit data on a channel asynchronously
+	/** This registers a buffer that will be used to send data to the remote node.
+	 *  Multiple buffers can be registered, in which case data will be sent in the order the buffers were registered.
+	 *  While there are still buffers with unsent data, the poll callback will not be called.
+	 *
+	 *  @param channel      A handle for the channel.
+	 *  @param data         A pointer to a buffer containing data sent by the source, or NULL if there is no data to send.
+	 *                      After meshlink_channel_aio_send() returns, the buffer may not be modified or freed by the application
+	 *                      until the callback routine is called.
+	 *  @param len          The length of the data, or 0 if there is no data to send.
+	 *  @param cb           A pointer to the function which will be called when MeshLink has finished using the buffer.
+	 *
+	 *  @return             True if the buffer was enqueued, false otherwise.
+	 */
+	bool channel_aio_send(channel *channel, const void *data, size_t len, meshlink_aio_cb_t cb, void *priv) {
+		return meshlink_channel_aio_send(handle, channel, data, len, cb, priv);
+	}
+
+	/// Receive data on a channel asynchronously
+	/** This registers a buffer that will be filled with incoming channel data.
+	 *  Multiple buffers can be registered, in which case data will be received in the order the buffers were registered.
+	 *  While there are still buffers that have not been filled, the receive callback will not be called.
+	 *
+	 *  @param channel      A handle for the channel.
+	 *  @param data         A pointer to a buffer that will be filled with incoming data.
+	 *                      After meshlink_channel_aio_receive() returns, the buffer may not be modified or freed by the application
+	 *                      until the callback routine is called.
+	 *  @param len          The length of the data.
+	 *  @param cb           A pointer to the function which will be called when MeshLink has finished using the buffer.
+	 *
+	 *  @return             True if the buffer was enqueued, false otherwise.
+	 */
+	bool channel_aio_receive(channel *channel, const void *data, size_t len, meshlink_aio_cb_t cb, void *priv) {
+		return meshlink_channel_aio_receive(handle, channel, data, len, cb, priv);
+	}
+
 	/// Get the amount of bytes in the send buffer.
 	/** This returns the amount of bytes in the send buffer.
 	 *  These bytes have not been received by the peer yet.