From: Dr. Michael Lauer <mickey@vanille-media.de>
Date: Sun, 11 Mar 2018 20:13:30 +0000 (+0100)
Subject: posix: Add Posix IPC (Message Queue, Named Semaphores, Shared Memory)
X-Git-Tag: 0.40.1~23
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=2c488b51bd27533d014aef59938bb19477aaffb2;p=thirdparty%2Fvala.git

posix: Add Posix IPC (Message Queue, Named Semaphores, Shared Memory)
---

diff --git a/vapi/posix.vapi b/vapi/posix.vapi
index 02f25b311..13a6c5d11 100644
--- a/vapi/posix.vapi
+++ b/vapi/posix.vapi
@@ -771,6 +771,29 @@ namespace Posix {
 	[CCode (cheader_filename = "math.h")]
 	public float scalbf (float x, float n);
 
+	[SimpleType]
+	[CCode (cname = "mqd_t", cheader_filename = "mqueue.h", lower_case_cprefix = "mq_", free_function = "mq_close", has_type_id = false)]
+	public struct MessageQueue {
+		[CCode (cname = "mq_open")]
+		public MessageQueue (string name, int oflag, mode_t mode = 0, MqAttr? attr = null);
+		public static int unlink (string name);
+		public int notify (sigevent_t? notification = null);
+		public int getattr (MqAttr attr);
+		public int setattr (MqAttr attr, MqAttr? oldattr = null);
+		public int send (uint8[] msg, uint prio = 0);
+		public int timedsend (uint8[] msg, uint prio, timespec abs_timeout);
+		public ssize_t receive (uint8[] msg, out uint prio);
+		public ssize_t timedreceive (uint8[] msg, out uint prio, timespec abs_timeout);
+	}
+
+	[CCode (cname = "struct mq_attr", cheader_filename = "mqueue.h", destroy_function = "", has_type_id = false)]
+	public struct MqAttr {
+		public long mq_flags;
+		public long mq_maxmsg;
+		public long mq_msgsize;
+		public long mq_curmsgs;
+	}
+
 	[CCode (cheader_filename = "netdb.h")]
 	public const int NI_NAMEREQD;
 	[CCode (cheader_filename = "netdb.h")]
@@ -838,6 +861,20 @@ namespace Posix {
 	[CCode (cheader_filename = "pwd.h")]
 	public unowned Passwd? getpwuid (uid_t uid);
 
+	[Compact]
+	[CCode (cname = "sem_t", cheader_filename = "semaphore.h", cprefix = "SEM_", lower_case_cprefix = "sem_", has_type_id = false, copy_function = "", free_function = "sem_close")]
+	public class NamedSemaphore {
+		[CCode (cname = "sem_open")]
+		public NamedSemaphore (string name, int oflag = 0, mode_t mode = 0, uint val = 0);
+		public int getvalue (out int sval);
+		public int post ();
+		public int wait ();
+		public int trywait ();
+		public int timedwait (Posix.timespec abs_timeout);
+		public static int unlink (string name);
+		public const int FAILED;
+	}
+
 	[CCode (cheader_filename = "sys/resource.h")]
 	public const int PRIO_PROCESS;
 	[CCode (cheader_filename = "sys/resource.h")]
@@ -1221,6 +1258,13 @@ namespace Posix {
 		int              sa_flags;
 	}
 
+	[CCode (cname = "struct sigevent", cheader_filename = "signal.h", has_type_id = false)]
+	public struct sigevent_t {
+		sigval_t         sigev_value;
+		int              sigev_signo;
+		int              sigev_notify;
+	}
+
 	[SimpleType]
 	[CCode (cname = "sigval_t", cheader_filename = "signal.h", has_type_id = false)]
 	public struct sigval_t {
@@ -2703,6 +2747,11 @@ namespace Posix {
 	public int mlock(void *addr, size_t len);
 	[CCode (cheader_filename = "sys/mman.h")]
 	public int munlock(void *addr, size_t len);
+	// sys/mman.h - [SHM] Shared Memory
+	[CCode (cheader_filename = "sys/mman.h")]
+	public int shm_open (string name, int oflag, mode_t mode = 0);
+	[CCode (cheader_filename = "sys/mman.h")]
+	public int shm_unlink (string name);
 	// sys/mman.h - Process Memory Locking
 	[CCode (cheader_filename = "sys/mman.h")]
 	public const int MCL_CURRENT;