Remove mail_receive_nonblock ()

kernel/proc/mail.c

@@ -147,51 +147,3 @@ void proc_mail_receive (struct proc* proc, struct proc_mail* mail, struct resche
   /* nothing to receive */
   proc_sq_suspend (proc, &mail->recv_sq, &mail->resource->lock, fr, rctx);
 }
-
-bool proc_mail_receive_nonblock (struct proc* proc, struct proc_mail* mail,
-                                 struct reschedule_ctx* rctx, void* recv_buffer, size_t recv_size) {
-  uint64_t fp, fr, fssq;
-
-  spin_lock (&proc->lock, &fp);
-  proc->mail_recv_buffer = recv_buffer;
-  proc->mail_recv_size = recv_size;
-  spin_unlock (&proc->lock, fp);
-
-  spin_lock (&mail->resource->lock, &fr);
-
-  /* consume mesg if available */
-  if (mail->packets_count > 0) {
-    struct mail_packet* packet = list_entry (mail->packets, struct mail_packet, packets_link);
-    list_remove (mail->packets, &packet->packets_link);
-    mail->packets_count--;
-
-    memcpy (recv_buffer, packet->packet_buffer, min (recv_size, packet->packet_size));
-    free (packet->packet_buffer);
-    free (packet);
-
-    /* check for suspended sender */
-    spin_lock (&mail->send_sq.lock, &fssq);
-
-    struct list_node_link* node = mail->send_sq.proc_list;
-
-    if (node != NULL) {
-      struct proc_sq_entry* sq_entry = list_entry (node, struct proc_sq_entry, sq_link);
-      struct proc* resumed_proc = sq_entry->proc;
-
-      spin_unlock (&mail->send_sq.lock, fssq);
-      spin_unlock (&mail->resource->lock, fr);
-
-      proc_sq_resume (resumed_proc, sq_entry, rctx);
-      return true;
-    }
-
-    spin_unlock (&mail->send_sq.lock, fssq);
-    spin_unlock (&mail->resource->lock, fr);
-
-    return true;
-  }
-
-  spin_unlock (&mail->resource->lock, fr);
-
-  return false;
-}

kernel/proc/mail.h

@@ -37,7 +37,4 @@ void proc_mail_send (struct proc* proc, struct proc_mail* mail, struct reschedul
 void proc_mail_receive (struct proc* proc, struct proc_mail* mail, struct reschedule_ctx* rctx,
                         void* recv_buffer, size_t recv_size);
 
-bool proc_mail_receive_nonblock (struct proc* proc, struct proc_mail* mail,
-                                 struct reschedule_ctx* rctx, void* recv_buffer, size_t recv_size);
-
 #endif // _KERNEL_PROC_MAIL_H

kernel/syscall/syscall.c

@@ -274,35 +274,6 @@ DEFINE_SYSCALL (sys_mail_receive) {
   return SYSRESULT (ST_OK);
 }
 
-/* int mail_receive_nonblock (void* recv_mesg, size_t mesg_size) */
-DEFINE_SYSCALL (sys_mail_receive_nonblock) {
-  uint64_t fp;
-
-  uintptr_t uvaddr_mesg = a1;
-  size_t mesg_size = (size_t)a2;
-
-  spin_lock (&proc->lock, &fp);
-  struct procgroup* procgroup = proc->procgroup;
-  spin_unlock (&proc->lock, fp);
-
-  void* mesg = sys_get_user_buffer (procgroup, uvaddr_mesg, mesg_size);
-
-  if (mesg == NULL)
-    return SYSRESULT (-ST_BAD_ADDRESS_SPACE);
-
-  struct proc_resource* mail_resource = proc_find_resource (procgroup, 0);
-
-  if (mail_resource == NULL)
-    return SYSRESULT (-ST_NOT_FOUND);
-
-  bool r = proc_mail_receive_nonblock (proc, &mail_resource->u.mail, rctx, mesg, mesg_size);
-
-  if (r)
-    return SYSRESULT (ST_OK);
-  else
-    return SYSRESULT (-ST_TRY_AGAIN);
-}
-
 /* int device_do (int device_id, int cmd, void* a1, void* a2, void* a3, void* a4) */
 DEFINE_SYSCALL (sys_device_do) {
   uint64_t fpg, fd, fp;
@@ -1131,7 +1102,6 @@ static syscall_handler_func_t handler_table[] = {
     [SYS_ENV_GET] = &sys_env_get,
     [SYS_EXEC_PARTIAL] = &sys_exec_partial,
     [SYS_EXEC_PARTIAL_FINI] = &sys_exec_partial_fini,
-    [SYS_MAIL_RECEIVE_NONBLOCK] = &sys_mail_receive_nonblock,
     [SYS_GET_SELF_PID] = &sys_get_self_pid,
     [SYS_STREAM_WRITE] = &sys_stream_write,
     [SYS_STREAM_READ] = &sys_stream_read,