Security-58286.240.4.tar.gz

[apple/security.git] / OSX / libsecurity_utilities / lib / machserver.cpp

diff --git a/OSX/libsecurity_utilities/lib/machserver.cpp b/OSX/libsecurity_utilities/lib/machserver.cpp
index b2f2b775fbad69ef898e1c9265c7bf73dfe0c4bc..29ffa83a3c97936646451b291667abb3192e464b 100644 (file)
--- a/OSX/libsecurity_utilities/lib/machserver.cpp
+++ b/OSX/libsecurity_utilities/lib/machserver.cpp
@@ -40,6 +40,8 @@
 # include <sys/time.h>
 #endif
 
 # include <sys/time.h>
 #endif
 

+#define SEC_MACH_AUDIT_TOKEN_PID (5)
+

 namespace Security {
 namespace MachPlusPlus {
 
 namespace Security {
 namespace MachPlusPlus {
 


@@ -237,11 +239,19 @@ void MachServer::runServerThread(bool doTimeout)
                                continue;
                        }
                        
                                continue;
                        }
                        

+                       // reset the buffer each time, handlers don't consistently set out params
+                       bufReply.clearBuffer();
+

                        // process received message
                        if (bufRequest.msgId() >= MACH_NOTIFY_FIRST &&
                                bufRequest.msgId() <= MACH_NOTIFY_LAST) {
                                // mach kernel notification message
                                // we assume this is quick, so no thread arbitration here
                        // process received message
                        if (bufRequest.msgId() >= MACH_NOTIFY_FIRST &&
                                bufRequest.msgId() <= MACH_NOTIFY_LAST) {
                                // mach kernel notification message
                                // we assume this is quick, so no thread arbitration here

+                               mach_msg_audit_trailer_t *tlr = bufRequest.auditTrailer();
+                               if (tlr == NULL || tlr->msgh_audit.val[SEC_MACH_AUDIT_TOKEN_PID] != 0) {
+                                       secnotice("machserver", "ignoring invalid notify message");
+                                       continue;
+                               }

                                cdsa_notify_server(bufRequest, bufReply);
                        } else {
                                // normal request message
                                cdsa_notify_server(bufRequest, bufReply);
                        } else {
                                // normal request message


@@ -546,52 +556,57 @@ void MachServer::clearTimer(Timer *timer)
 //
 // Notification hooks and shims. Defaults do nothing.
 //
 //
 // Notification hooks and shims. Defaults do nothing.
 //

-void cdsa_mach_notify_dead_name(mach_port_t, mach_port_name_t port)
+kern_return_t cdsa_mach_notify_dead_name(mach_port_t, mach_port_name_t port)

 {
        try {
                MachServer::active().notifyDeadName(port);
        } catch (...) {
        }
 {
        try {
                MachServer::active().notifyDeadName(port);
        } catch (...) {
        }

+       return KERN_SUCCESS;

 }
 
 void MachServer::notifyDeadName(Port) { }
 
 }
 
 void MachServer::notifyDeadName(Port) { }
 

-void cdsa_mach_notify_port_deleted(mach_port_t, mach_port_name_t port)
+kern_return_t cdsa_mach_notify_port_deleted(mach_port_t, mach_port_name_t port)

 {
        try {
                MachServer::active().notifyPortDeleted(port);
        } catch (...) {
        }
 {
        try {
                MachServer::active().notifyPortDeleted(port);
        } catch (...) {
        }

+       return KERN_SUCCESS;

 }
 
 void MachServer::notifyPortDeleted(Port) { }
 
 }
 
 void MachServer::notifyPortDeleted(Port) { }
 

-void cdsa_mach_notify_port_destroyed(mach_port_t, mach_port_name_t port)
+kern_return_t cdsa_mach_notify_port_destroyed(mach_port_t, mach_port_name_t port)

 {
        try {
                MachServer::active().notifyPortDestroyed(port);
        } catch (...) {
        }
 {
        try {
                MachServer::active().notifyPortDestroyed(port);
        } catch (...) {
        }

+       return KERN_SUCCESS;

 }
 
 void MachServer::notifyPortDestroyed(Port) { }
 
 }
 
 void MachServer::notifyPortDestroyed(Port) { }
 

-void cdsa_mach_notify_send_once(mach_port_t port)
+kern_return_t cdsa_mach_notify_send_once(mach_port_t port)

 {
        try {
                MachServer::active().notifySendOnce(port);
        } catch (...) {
        }
 {
        try {
                MachServer::active().notifySendOnce(port);
        } catch (...) {
        }

+       return KERN_SUCCESS;

 }
 
 void MachServer::notifySendOnce(Port) { }
 
 }
 
 void MachServer::notifySendOnce(Port) { }
 

-void cdsa_mach_notify_no_senders(mach_port_t port, mach_port_mscount_t count)
+kern_return_t cdsa_mach_notify_no_senders(mach_port_t port, mach_port_mscount_t count)

 {
        try {
                MachServer::active().notifyNoSenders(port, count);
        } catch (...) {
        }
 {
        try {
                MachServer::active().notifyNoSenders(port, count);
        } catch (...) {
        }

+       return KERN_SUCCESS;

 }
 
 void MachServer::notifyNoSenders(Port, mach_port_mscount_t) { }
 }
 
 void MachServer::notifyNoSenders(Port, mach_port_mscount_t) { }