syslog-322.tar.gz

[apple/syslog.git] / syslogd.tproj / klog_in.c

diff --git a/syslogd.tproj/klog_in.c b/syslogd.tproj/klog_in.c
index 7a93c2adf022dcb3b8c06ed4d9af11874f3ee886..d04873876b1b85617225c8d7b5929ac22bab9ced 100644 (file)
--- a/syslogd.tproj/klog_in.c
+++ b/syslogd.tproj/klog_in.c
@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2004 Apple Computer, Inc. All rights reserved.
+ * Copyright (c) 2004-2011 Apple Inc. All rights reserved.
  *
  * @APPLE_LICENSE_HEADER_START@
  * 
@@ -21,6 +21,12 @@
  * @APPLE_LICENSE_HEADER_END@
  */
 
+#include <TargetConditionals.h>
+
+#if TARGET_IPHONE_SIMULATOR
+struct _not_empty;
+#else
+
 #include <sys/types.h>
 #include <sys/stat.h>
 #include <sys/socket.h>
@@ -37,41 +43,57 @@
 #define forever for(;;)
 
 #define MY_ID "klog_in"
-#define MAXLINE 4096
-
-int kfd = -1;
+#define BUFF_SIZE 4096
 
-static int kx = 0;
-static char kline[MAXLINE + 1];
+static char inbuf[BUFF_SIZE];
+static int bx;
+static int kfd = -1;
+static dispatch_source_t in_src;
+static dispatch_queue_t in_queue;
 
-asl_msg_t *
-klog_in_acceptmsg(int fd)
+void
+klog_in_acceptdata(int fd)
 {
-       int n;
-       char c;
+       ssize_t len;
+       uint32_t i;
+       char *p, *q;
+       asl_msg_t *m;
 
-       n = read(fd, &c, 1);
+       len = read(fd, inbuf + bx, BUFF_SIZE - bx);
+       if (len <= 0) return;
 
-       while ((n == 1) && (c != '\n'))
+       p = inbuf;
+       q = p + bx;
+
+       for (i = 0; i < len; i++, q++)
        {
-               if (kx < MAXLINE) kline[kx++] = c;
-               n = read(fd, &c, 1);
+               if (*q == '\n')
+               {
+                       *q = '\0';
+                       m = asl_input_parse(p, q - p, NULL, SOURCE_KERN);
+                       process_message(m, SOURCE_KERN);
+                       p = q + 1;
+               }
        }
 
-       if (kx == 0) return NULL;
-
-       n = kx - 1;
-       kline[kx] = '\0';
-       kx = 0;
-
-       return asl_input_parse(kline, n, NULL, 1);
+       if (p != inbuf)
+       {
+               memmove(inbuf, p, BUFF_SIZE - bx - 1);
+               bx = q - p;
+       }
 }
 
 int
-klog_in_init(void)
+klog_in_init()
 {
+       static dispatch_once_t once;
+
+       dispatch_once(&once, ^{
+               in_queue = dispatch_queue_create(MY_ID, NULL);
+       });
+
        asldebug("%s: init\n", MY_ID);
-       if (kfd >= 0) return kfd;
+       if (kfd >= 0) return 0;
 
        kfd = open(_PATH_KLOG, O_RDONLY, 0);
        if (kfd < 0)
@@ -88,12 +110,10 @@ klog_in_init(void)
                return -1;
        }
 
-       return aslevent_addfd(kfd, ADDFD_FLAGS_LOCAL, klog_in_acceptmsg, NULL, NULL);
-}
+       in_src = dispatch_source_create(DISPATCH_SOURCE_TYPE_READ, (uintptr_t)kfd, 0, in_queue);
+       dispatch_source_set_event_handler(in_src, ^{ klog_in_acceptdata(kfd); });
 
-int
-klog_in_reset(void)
-{
+       dispatch_resume(in_src);
        return 0;
 }
 
@@ -102,8 +122,20 @@ klog_in_close(void)
 {
        if (kfd < 0) return 1;
 
+       dispatch_source_cancel(in_src);
+       dispatch_release(in_src);
+       in_src = NULL;
+
        close(kfd);
        kfd = -1;
 
        return 0;
 }
+
+int
+klog_in_reset(void)
+{
+       return 0;
+}
+
+#endif /* !TARGET_IPHONE_SIMULATOR */