Changes in kernel/generic/src/ipc/event.c [cfaa35a:8a637a4] in mainline

File:

• kernel/generic/src/ipc/event.c (modified) (9 diffs)

kernel/generic/src/ipc/event.c

@@ -58 +58 @@
 }
 
-static event_t *evno2event(int evno, task_t *t)
+static event_t *evno2event(int evno, task_t *task)
 {
         ASSERT(evno < EVENT_TASK_END);
-
+        
         event_t *event;
-
+        
         if (evno < EVENT_END)
                 event = &events[(event_type_t) evno];
         else
-                event = &t->events[(event_task_type_t) evno - EVENT_END];
-
+                event = &task->events[(event_task_type_t) evno - EVENT_END];
+        
         return event;
 }
@@ -86 +86 @@
                 event_initialize(evno2event(i, task));
 }
-
 
 /** Unsubscribe kernel events associated with an answerbox
@@ -252 +251 @@
  *
  * @return EOK if the subscription was successful.
- * @return EEXISTS if the notifications of the given type are
+ * @return EEXIST if the notifications of the given type are
  *         already subscribed.
  *
@@ -260 +259 @@
 {
         int res;
-
+        
         spinlock_lock(&event->lock);
         
@@ -270 +269 @@
                 res = EOK;
         } else
-                res = EEXISTS;
+                res = EEXIST;
+        
+        spinlock_unlock(&event->lock);
+        
+        return res;
+}
+
+/** Unsubscribe event notifications
+ *
+ * @param evno      Event type.
+ * @param answerbox Answerbox used to send the notifications to.
+ *
+ * @return EOK if the subscription was successful.
+ * @return EEXIST if the notifications of the given type are
+ *         already subscribed.
+ *
+ */
+static int event_unsubscribe(event_t *event, answerbox_t *answerbox)
+{
+        int res;
+        
+        spinlock_lock(&event->lock);
+        
+        if (event->answerbox == answerbox) {
+                event->answerbox = NULL;
+                event->counter = 0;
+                event->imethod = 0;
+                event->masked = false;
+                res = EOK;
+        } else
+                res = ENOENT;
         
         spinlock_unlock(&event->lock);
@@ -297 +326 @@
 }
 
-/** Event notification syscall wrapper
+/** Event notification subscription syscall wrapper
  *
  * @param evno    Event type to subscribe.
@@ -305 +334 @@
  * @return EOK on success.
  * @return ELIMIT on unknown event type.
- * @return EEXISTS if the notifications of the given type are
+ * @return EEXIST if the notifications of the given type are
  *         already subscribed.
  *
  */
-sysarg_t sys_event_subscribe(sysarg_t evno, sysarg_t imethod)
+sysarg_t sys_ipc_event_subscribe(sysarg_t evno, sysarg_t imethod)
 {
         if (evno >= EVENT_TASK_END)
@@ -316 +345 @@
         return (sysarg_t) event_subscribe(evno2event(evno, TASK),
             (sysarg_t) imethod, &TASK->answerbox);
+}
+
+/** Event notification unsubscription syscall wrapper
+ *
+ * @param evno    Event type to unsubscribe.
+ *
+ * @return EOK on success.
+ * @return ELIMIT on unknown event type.
+ * @return ENOENT if the notification of the given type is not
+           subscribed.
+ *
+ */
+sysarg_t sys_ipc_event_unsubscribe(sysarg_t evno)
+{
+        if (evno >= EVENT_TASK_END)
+                return ELIMIT;
+        
+        return (sysarg_t) event_unsubscribe(evno2event(evno, TASK),
+            &TASK->answerbox);
 }
 
@@ -331 +379 @@
  *
  */
-sysarg_t sys_event_unmask(sysarg_t evno)
+sysarg_t sys_ipc_event_unmask(sysarg_t evno)
 {
         if (evno >= EVENT_TASK_END)