Changes in uspace/srv/klog/klog.c [a35b458:5a6cc679] in mainline

File:

• uspace/srv/klog/klog.c (modified) (12 diffs)

uspace/srv/klog/klog.c

@@ -61 +61 @@
         uint32_t level;
         char message[0];
-
+        
 } __attribute__((__packed__)) log_entry_t;
 
@@ -107 +107 @@
                 return;
         }
-
+        
         size_t offset = 0;
         while (offset < len) {
                 size_t entry_len = *((unaligned_size_t *) (buffer + offset));
-
+                
                 if (offset + entry_len > len || entry_len < sizeof(log_entry_t))
                         break;
-
+                
                 log_entry_t *buf = malloc(entry_len + 1);
                 if (buf == NULL)
                         break;
-
+                
                 item_t *item = malloc(sizeof(item_t));
                 if (item == NULL) {
@@ -124 +124 @@
                         break;
                 }
-
+                
                 memcpy(buf, buffer + offset, entry_len);
                 *((uint8_t *) buf + entry_len) = 0;
@@ -131 +131 @@
                 item->data = buf;
                 prodcons_produce(&pc, &item->link);
-
+                
                 offset += entry_len;
         }
@@ -148 +148 @@
 static errno_t consumer(void *data)
 {
-
+        
         while (true) {
                 link_t *link = prodcons_consume(&pc);
                 item_t *item = list_get_instance(link, item_t, link);
-
+                
                 if (item->size < sizeof(log_entry_t)) {
                         free(item->data);
@@ -158 +158 @@
                         continue;
                 }
-
+                
                 if (item->data->facility == LF_USPACE) {
                         /* Avoid reposting messages */
@@ -165 +165 @@
                         continue;
                 }
-
+                
                 log_t ctx = kernel_ctx;
                 if (item->data->facility < facility_len) {
                         ctx = facility_ctx[item->data->facility];
                 }
-
+                
                 log_level_t lvl = item->data->level;
                 if (lvl > LVL_LIMIT)
                         lvl = LVL_NOTE;
-
+                
                 log_msg(ctx, lvl, "%s", item->data->message);
-
+                
                 free(item->data);
                 free(item);
         }
-
+        
         return EOK;
 }
@@ -199 +199 @@
          * starving.
          */
-
+        
         fibril_mutex_lock(&mtx);
-
+        
         producer();
-
+        
         async_event_unmask(EVENT_KLOG);
         fibril_mutex_unlock(&mtx);
@@ -215 +215 @@
                 return rc;
         }
-
+        
         kernel_ctx = log_create("kernel", LOG_NO_PARENT);
         for (unsigned int i = 0; i < facility_len; i++) {
                 facility_ctx[i] = log_create(facility_name[i], kernel_ctx);
         }
-
+        
         buffer = malloc(BUFFER_SIZE);
         if (buffer == NULL) {
@@ -226 +226 @@
                 return 1;
         }
-
+        
         prodcons_initialize(&pc);
         rc = async_event_subscribe(EVENT_KLOG, klog_notification_received, NULL);
@@ -234 +234 @@
                 return rc;
         }
-
+        
         fid_t fid = fibril_create(consumer, NULL);
         if (!fid) {
@@ -241 +241 @@
                 return ENOMEM;
         }
-
+        
         fibril_add_ready(fid);
         async_event_unmask(EVENT_KLOG);
-
+        
         fibril_mutex_lock(&mtx);
         producer();
         fibril_mutex_unlock(&mtx);
-
+        
         task_retval(0);
         async_manager();
-
+        
         return 0;
 }