X-Git-Url: https://git.saurik.com/apple/syslog.git/blobdiff_plain/8158235332f5a3f4f20cebe26bf739b481ca2df5..ed18769501f7359c4c437714c48aa2d35ec21604:/syslogd.tproj/bsd_out.c

diff --git a/syslogd.tproj/bsd_out.c b/syslogd.tproj/bsd_out.c
index c7c0639..9cd9d43 100644
--- a/syslogd.tproj/bsd_out.c
+++ b/syslogd.tproj/bsd_out.c
@@ -416,7 +416,7 @@ _bsd_send_repeat_msg(struct config_rule *r)
 }
 
 static int
-_bsd_send(aslmsg msg, struct config_rule *r, char **out, char **fwd, time_t now)
+_bsd_send(asl_msg_t *msg, struct config_rule *r, char **out, char **fwd, time_t now)
 {
 	char *sf, *outmsg;
 	const char *vlevel, *vfacility;
@@ -460,10 +460,10 @@ _bsd_send(aslmsg msg, struct config_rule *r, char **out, char **fwd, time_t now)
 	if ((*fwd == NULL) && (r->type == DST_TYPE_SOCK))
 	{
 		pf = 7;
-		vlevel = asl_get(msg, ASL_KEY_LEVEL);
+		vlevel = asl_msg_get_val_for_key(msg, ASL_KEY_LEVEL);
 		if (vlevel != NULL) pf = atoi(vlevel);
 
-		fc = asl_syslog_faciliy_name_to_num(asl_get(msg, ASL_KEY_FACILITY));
+		fc = asl_syslog_faciliy_name_to_num(asl_msg_get_val_for_key(msg, ASL_KEY_FACILITY));
 		if (fc > 0) pf |= fc;
 
 		sf = NULL;
@@ -492,7 +492,7 @@ _bsd_send(aslmsg msg, struct config_rule *r, char **out, char **fwd, time_t now)
 		 * The kernel printf routine already sends them to /dev/console
 		 * so writing them here would cause duplicates.
 		 */
-		vfacility = asl_get(msg, ASL_KEY_FACILITY);
+		vfacility = asl_msg_get_val_for_key(msg, ASL_KEY_FACILITY);
 		if ((vfacility != NULL) && (!strcmp(vfacility, FACILITY_KERNEL)) && (r->type == DST_TYPE_CONS)) do_write = 0;
 		if ((do_write == 1) && (r->type == DST_TYPE_FILE) && (is_dup == 1))
 		{
@@ -576,7 +576,7 @@ _bsd_send(aslmsg msg, struct config_rule *r, char **out, char **fwd, time_t now)
 }
 
 static int
-_bsd_rule_match(aslmsg msg, struct config_rule *r)
+_bsd_rule_match(asl_msg_t *msg, struct config_rule *r)
 {
 	uint32_t i, test, f;
 	int32_t pri;
@@ -596,7 +596,7 @@ _bsd_rule_match(aslmsg msg, struct config_rule *r)
 		if ((test == 0) && (r->pri[i] == -2)) continue;
 
 		f = 0;
-		val = asl_get(msg, ASL_KEY_FACILITY);
+		val = asl_msg_get_val_for_key(msg, ASL_KEY_FACILITY);
 
 		if (strcmp(r->facility[i], "*") == 0)
 		{
@@ -620,7 +620,7 @@ _bsd_rule_match(aslmsg msg, struct config_rule *r)
 			continue;
 		}
 
-		val = asl_get(msg, ASL_KEY_LEVEL);
+		val = asl_msg_get_val_for_key(msg, ASL_KEY_LEVEL);
 		if (val == NULL) continue;
 
 		pri = atoi(val);
@@ -633,7 +633,7 @@ _bsd_rule_match(aslmsg msg, struct config_rule *r)
 }
 
 static int
-_bsd_match_and_send(aslmsg msg)
+_bsd_match_and_send(asl_msg_t *msg)
 {
 	struct config_rule *r;
 	char *out, *fwd;
@@ -658,7 +658,7 @@ _bsd_match_and_send(aslmsg msg)
 }
 
 void
-bsd_out_message(aslmsg msg)
+bsd_out_message(asl_msg_t *msg, int64_t msize)
 {
 	if (msg == NULL) return;
 
@@ -668,6 +668,10 @@ bsd_out_message(aslmsg msg)
 	dispatch_async(bsd_out_queue, ^{
 		_bsd_match_and_send(msg);
 		asl_msg_release((asl_msg_t *)msg);
+
+		/* end of the output module chain (after asl) - decrement global memory stats */
+		OSAtomicAdd64(-1ll * msize, &global.memory_size);
+
 		OSAtomicDecrement32(&global.bsd_queue_count);
 	});
 }
@@ -732,7 +736,7 @@ bsd_out_init(void)
 
 		/* start a timer to close idle files */
 		bsd_idle_timer = dispatch_source_create(DISPATCH_SOURCE_TYPE_TIMER, 0, 0, bsd_out_queue);
-		dispatch_source_set_event_handler(bsd_idle_timer, ^{ _bsd_close_idle_files(); });		
+		dispatch_source_set_event_handler(bsd_idle_timer, ^{ _bsd_close_idle_files(); });
 		dispatch_source_set_timer(bsd_idle_timer, dispatch_time(DISPATCH_TIME_NOW, NSEC_PER_SEC * CLOSE_ON_IDLE_SEC), NSEC_PER_SEC * CLOSE_ON_IDLE_SEC, 0);
 		dispatch_resume(bsd_idle_timer);
 	});
@@ -775,7 +779,7 @@ _bsd_out_close_internal(void)
 			free(r->facility);
 		}
 
-		
+
 		TAILQ_REMOVE(&bsd_out_rule, r, entries);
 		free(r);
 	}