1 /* 2 * This file is part of gtkD. 3 * 4 * gtkD is free software; you can redistribute it and/or modify 5 * it under the terms of the GNU Lesser General Public License 6 * as published by the Free Software Foundation; either version 3 7 * of the License, or (at your option) any later version, with 8 * some exceptions, please read the COPYING file. 9 * 10 * gtkD is distributed in the hope that it will be useful, 11 * but WITHOUT ANY WARRANTY; without even the implied warranty of 12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 13 * GNU Lesser General Public License for more details. 14 * 15 * You should have received a copy of the GNU Lesser General Public License 16 * along with gtkD; if not, write to the Free Software 17 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110, USA 18 */ 19 20 // generated automatically - do not change 21 // find conversion definition on APILookup.txt 22 // implement new conversion functionalities on the wrap.utils pakage 23 24 25 module gio.DatagramBasedIF; 26 27 private import gio.Cancellable; 28 private import gio.c.functions; 29 public import gio.c.types; 30 private import glib.ErrorG; 31 private import glib.GException; 32 private import glib.Source; 33 public import gtkc.giotypes; 34 35 36 /** 37 * A #GDatagramBased is a networking interface for representing datagram-based 38 * communications. It is a more or less direct mapping of the core parts of the 39 * BSD socket API in a portable GObject interface. It is implemented by 40 * #GSocket, which wraps the UNIX socket API on UNIX and winsock2 on Windows. 41 * 42 * #GDatagramBased is entirely platform independent, and is intended to be used 43 * alongside higher-level networking APIs such as #GIOStream. 44 * 45 * It uses vectored scatter/gather I/O by default, allowing for many messages 46 * to be sent or received in a single call. Where possible, implementations of 47 * the interface should take advantage of vectored I/O to minimise processing 48 * or system calls. For example, #GSocket uses recvmmsg() and sendmmsg() where 49 * possible. Callers should take advantage of scatter/gather I/O (the use of 50 * multiple buffers per message) to avoid unnecessary copying of data to 51 * assemble or disassemble a message. 52 * 53 * Each #GDatagramBased operation has a timeout parameter which may be negative 54 * for blocking behaviour, zero for non-blocking behaviour, or positive for 55 * timeout behaviour. A blocking operation blocks until finished or there is an 56 * error. A non-blocking operation will return immediately with a 57 * %G_IO_ERROR_WOULD_BLOCK error if it cannot make progress. A timeout operation 58 * will block until the operation is complete or the timeout expires; if the 59 * timeout expires it will return what progress it made, or 60 * %G_IO_ERROR_TIMED_OUT if no progress was made. To know when a call would 61 * successfully run you can call g_datagram_based_condition_check() or 62 * g_datagram_based_condition_wait(). You can also use 63 * g_datagram_based_create_source() and attach it to a #GMainContext to get 64 * callbacks when I/O is possible. 65 * 66 * When running a non-blocking operation applications should always be able to 67 * handle getting a %G_IO_ERROR_WOULD_BLOCK error even when some other function 68 * said that I/O was possible. This can easily happen in case of a race 69 * condition in the application, but it can also happen for other reasons. For 70 * instance, on Windows a socket is always seen as writable until a write 71 * returns %G_IO_ERROR_WOULD_BLOCK. 72 * 73 * As with #GSocket, #GDatagramBaseds can be either connection oriented (for 74 * example, SCTP) or connectionless (for example, UDP). #GDatagramBaseds must be 75 * datagram-based, not stream-based. The interface does not cover connection 76 * establishment — use methods on the underlying type to establish a connection 77 * before sending and receiving data through the #GDatagramBased API. For 78 * connectionless socket types the target/source address is specified or 79 * received in each I/O operation. 80 * 81 * Like most other APIs in GLib, #GDatagramBased is not inherently thread safe. 82 * To use a #GDatagramBased concurrently from multiple threads, you must 83 * implement your own locking. 84 * 85 * Since: 2.48 86 */ 87 public interface DatagramBasedIF{ 88 /** Get the main Gtk struct */ 89 public GDatagramBased* getDatagramBasedStruct(bool transferOwnership = false); 90 91 /** the main Gtk struct as a void* */ 92 protected void* getStruct(); 93 94 95 /** */ 96 public static GType getType() 97 { 98 return g_datagram_based_get_type(); 99 } 100 101 /** 102 * Checks on the readiness of @datagram_based to perform operations. The 103 * operations specified in @condition are checked for and masked against the 104 * currently-satisfied conditions on @datagram_based. The result is returned. 105 * 106 * %G_IO_IN will be set in the return value if data is available to read with 107 * g_datagram_based_receive_messages(), or if the connection is closed remotely 108 * (EOS); and if the datagram_based has not been closed locally using some 109 * implementation-specific method (such as g_socket_close() or 110 * g_socket_shutdown() with @shutdown_read set, if it’s a #GSocket). 111 * 112 * If the connection is shut down or closed (by calling g_socket_close() or 113 * g_socket_shutdown() with @shutdown_read set, if it’s a #GSocket, for 114 * example), all calls to this function will return %G_IO_ERROR_CLOSED. 115 * 116 * %G_IO_OUT will be set if it is expected that at least one byte can be sent 117 * using g_datagram_based_send_messages() without blocking. It will not be set 118 * if the datagram_based has been closed locally. 119 * 120 * %G_IO_HUP will be set if the connection has been closed locally. 121 * 122 * %G_IO_ERR will be set if there was an asynchronous error in transmitting data 123 * previously enqueued using g_datagram_based_send_messages(). 124 * 125 * Note that on Windows, it is possible for an operation to return 126 * %G_IO_ERROR_WOULD_BLOCK even immediately after 127 * g_datagram_based_condition_check() has claimed that the #GDatagramBased is 128 * ready for writing. Rather than calling g_datagram_based_condition_check() and 129 * then writing to the #GDatagramBased if it succeeds, it is generally better to 130 * simply try writing right away, and try again later if the initial attempt 131 * returns %G_IO_ERROR_WOULD_BLOCK. 132 * 133 * It is meaningless to specify %G_IO_ERR or %G_IO_HUP in @condition; these 134 * conditions will always be set in the output if they are true. Apart from 135 * these flags, the output is guaranteed to be masked by @condition. 136 * 137 * This call never blocks. 138 * 139 * Params: 140 * condition = a #GIOCondition mask to check 141 * 142 * Returns: the #GIOCondition mask of the current state 143 * 144 * Since: 2.48 145 */ 146 public GIOCondition conditionCheck(GIOCondition condition); 147 148 /** 149 * Waits for up to @timeout microseconds for condition to become true on 150 * @datagram_based. If the condition is met, %TRUE is returned. 151 * 152 * If @cancellable is cancelled before the condition is met, or if @timeout is 153 * reached before the condition is met, then %FALSE is returned and @error is 154 * set appropriately (%G_IO_ERROR_CANCELLED or %G_IO_ERROR_TIMED_OUT). 155 * 156 * Params: 157 * condition = a #GIOCondition mask to wait for 158 * timeout = the maximum time (in microseconds) to wait, 0 to not block, or -1 159 * to block indefinitely 160 * cancellable = a #GCancellable 161 * 162 * Returns: %TRUE if the condition was met, %FALSE otherwise 163 * 164 * Since: 2.48 165 * 166 * Throws: GException on failure. 167 */ 168 public bool conditionWait(GIOCondition condition, long timeout, Cancellable cancellable); 169 170 /** 171 * Creates a #GSource that can be attached to a #GMainContext to monitor for 172 * the availability of the specified @condition on the #GDatagramBased. The 173 * #GSource keeps a reference to the @datagram_based. 174 * 175 * The callback on the source is of the #GDatagramBasedSourceFunc type. 176 * 177 * It is meaningless to specify %G_IO_ERR or %G_IO_HUP in @condition; these 178 * conditions will always be reported in the callback if they are true. 179 * 180 * If non-%NULL, @cancellable can be used to cancel the source, which will 181 * cause the source to trigger, reporting the current condition (which is 182 * likely 0 unless cancellation happened at the same time as a condition 183 * change). You can check for this in the callback using 184 * g_cancellable_is_cancelled(). 185 * 186 * Params: 187 * condition = a #GIOCondition mask to monitor 188 * cancellable = a #GCancellable 189 * 190 * Returns: a newly allocated #GSource 191 * 192 * Since: 2.48 193 */ 194 public Source createSource(GIOCondition condition, Cancellable cancellable); 195 196 /** 197 * Receive one or more data messages from @datagram_based in one go. 198 * 199 * @messages must point to an array of #GInputMessage structs and 200 * @num_messages must be the length of this array. Each #GInputMessage 201 * contains a pointer to an array of #GInputVector structs describing the 202 * buffers that the data received in each message will be written to. 203 * 204 * @flags modify how all messages are received. The commonly available 205 * arguments for this are available in the #GSocketMsgFlags enum, but the 206 * values there are the same as the system values, and the flags 207 * are passed in as-is, so you can pass in system-specific flags too. These 208 * flags affect the overall receive operation. Flags affecting individual 209 * messages are returned in #GInputMessage.flags. 210 * 211 * The other members of #GInputMessage are treated as described in its 212 * documentation. 213 * 214 * If @timeout is negative the call will block until @num_messages have been 215 * received, the connection is closed remotely (EOS), @cancellable is cancelled, 216 * or an error occurs. 217 * 218 * If @timeout is 0 the call will return up to @num_messages without blocking, 219 * or %G_IO_ERROR_WOULD_BLOCK if no messages are queued in the operating system 220 * to be received. 221 * 222 * If @timeout is positive the call will block on the same conditions as if 223 * @timeout were negative. If the timeout is reached 224 * before any messages are received, %G_IO_ERROR_TIMED_OUT is returned, 225 * otherwise it will return the number of messages received before timing out. 226 * (Note: This is effectively the behaviour of `MSG_WAITFORONE` with 227 * recvmmsg().) 228 * 229 * To be notified when messages are available, wait for the %G_IO_IN condition. 230 * Note though that you may still receive %G_IO_ERROR_WOULD_BLOCK from 231 * g_datagram_based_receive_messages() even if you were previously notified of a 232 * %G_IO_IN condition. 233 * 234 * If the remote peer closes the connection, any messages queued in the 235 * underlying receive buffer will be returned, and subsequent calls to 236 * g_datagram_based_receive_messages() will return 0 (with no error set). 237 * 238 * If the connection is shut down or closed (by calling g_socket_close() or 239 * g_socket_shutdown() with @shutdown_read set, if it’s a #GSocket, for 240 * example), all calls to this function will return %G_IO_ERROR_CLOSED. 241 * 242 * On error -1 is returned and @error is set accordingly. An error will only 243 * be returned if zero messages could be received; otherwise the number of 244 * messages successfully received before the error will be returned. If 245 * @cancellable is cancelled, %G_IO_ERROR_CANCELLED is returned as with any 246 * other error. 247 * 248 * Params: 249 * messages = an array of #GInputMessage structs 250 * flags = an int containing #GSocketMsgFlags flags for the overall operation 251 * timeout = the maximum time (in microseconds) to wait, 0 to not block, or -1 252 * to block indefinitely 253 * cancellable = a %GCancellable 254 * 255 * Returns: number of messages received, or -1 on error. Note that the number 256 * of messages received may be smaller than @num_messages if @timeout is 257 * zero or positive, if the peer closed the connection, or if @num_messages 258 * was larger than `UIO_MAXIOV` (1024), in which case the caller may re-try 259 * to receive the remaining messages. 260 * 261 * Since: 2.48 262 * 263 * Throws: GException on failure. 264 */ 265 public int receiveMessages(GInputMessage[] messages, int flags, long timeout, Cancellable cancellable); 266 267 /** 268 * Send one or more data messages from @datagram_based in one go. 269 * 270 * @messages must point to an array of #GOutputMessage structs and 271 * @num_messages must be the length of this array. Each #GOutputMessage 272 * contains an address to send the data to, and a pointer to an array of 273 * #GOutputVector structs to describe the buffers that the data to be sent 274 * for each message will be gathered from. 275 * 276 * @flags modify how the message is sent. The commonly available arguments 277 * for this are available in the #GSocketMsgFlags enum, but the 278 * values there are the same as the system values, and the flags 279 * are passed in as-is, so you can pass in system-specific flags too. 280 * 281 * The other members of #GOutputMessage are treated as described in its 282 * documentation. 283 * 284 * If @timeout is negative the call will block until @num_messages have been 285 * sent, @cancellable is cancelled, or an error occurs. 286 * 287 * If @timeout is 0 the call will send up to @num_messages without blocking, 288 * or will return %G_IO_ERROR_WOULD_BLOCK if there is no space to send messages. 289 * 290 * If @timeout is positive the call will block on the same conditions as if 291 * @timeout were negative. If the timeout is reached before any messages are 292 * sent, %G_IO_ERROR_TIMED_OUT is returned, otherwise it will return the number 293 * of messages sent before timing out. 294 * 295 * To be notified when messages can be sent, wait for the %G_IO_OUT condition. 296 * Note though that you may still receive %G_IO_ERROR_WOULD_BLOCK from 297 * g_datagram_based_send_messages() even if you were previously notified of a 298 * %G_IO_OUT condition. (On Windows in particular, this is very common due to 299 * the way the underlying APIs work.) 300 * 301 * If the connection is shut down or closed (by calling g_socket_close() or 302 * g_socket_shutdown() with @shutdown_write set, if it’s a #GSocket, for 303 * example), all calls to this function will return %G_IO_ERROR_CLOSED. 304 * 305 * On error -1 is returned and @error is set accordingly. An error will only 306 * be returned if zero messages could be sent; otherwise the number of messages 307 * successfully sent before the error will be returned. If @cancellable is 308 * cancelled, %G_IO_ERROR_CANCELLED is returned as with any other error. 309 * 310 * Params: 311 * messages = an array of #GOutputMessage structs 312 * flags = an int containing #GSocketMsgFlags flags 313 * timeout = the maximum time (in microseconds) to wait, 0 to not block, or -1 314 * to block indefinitely 315 * cancellable = a %GCancellable 316 * 317 * Returns: number of messages sent, or -1 on error. Note that the number of 318 * messages sent may be smaller than @num_messages if @timeout is zero 319 * or positive, or if @num_messages was larger than `UIO_MAXIOV` (1024), in 320 * which case the caller may re-try to send the remaining messages. 321 * 322 * Since: 2.48 323 * 324 * Throws: GException on failure. 325 */ 326 public int sendMessages(GOutputMessage[] messages, int flags, long timeout, Cancellable cancellable); 327 }