kputs fixed and lock added for kmsg
This commit is contained in:
@@ -2,35 +2,47 @@
|
|||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include <kmsg.h>
|
#include <kmsg.h>
|
||||||
#include <aal/debug.h>
|
#include <aal/debug.h>
|
||||||
|
#include <aal/lock.h>
|
||||||
|
|
||||||
struct aal_kmsg_buf kmsg_buf AAL_KMSG_ALIGN;
|
struct aal_kmsg_buf kmsg_buf AAL_KMSG_ALIGN;
|
||||||
|
|
||||||
extern int vsnprintf(char *buf, size_t size, const char *fmt, va_list args);
|
extern int vsnprintf(char *buf, size_t size, const char *fmt, va_list args);
|
||||||
|
static aal_spinlock_t kmsg_lock;
|
||||||
|
|
||||||
/* TODO: lock */
|
/* TODO: lock */
|
||||||
void kputs(char *buf)
|
void kputs(char *buf)
|
||||||
{
|
{
|
||||||
int len = strlen(buf);
|
int len = strlen(buf);
|
||||||
|
unsigned long flags;
|
||||||
|
|
||||||
|
flags = aal_mc_spinlock_lock(&kmsg_lock);
|
||||||
|
|
||||||
if (len + kmsg_buf.tail > kmsg_buf.len) {
|
if (len + kmsg_buf.tail > kmsg_buf.len) {
|
||||||
len = kmsg_buf.len - kmsg_buf.tail;
|
len = kmsg_buf.len - kmsg_buf.tail;
|
||||||
}
|
}
|
||||||
|
|
||||||
strncpy(kmsg_buf.str, buf, len);
|
strncpy(kmsg_buf.str + kmsg_buf.tail, buf, len);
|
||||||
kmsg_buf.tail += len;
|
kmsg_buf.tail += len;
|
||||||
|
|
||||||
|
aal_mc_spinlock_unlock(&kmsg_lock, flags);
|
||||||
}
|
}
|
||||||
|
|
||||||
int kprintf(const char *format, ...)
|
int kprintf(const char *format, ...)
|
||||||
{
|
{
|
||||||
int len;
|
int len;
|
||||||
va_list va;
|
va_list va;
|
||||||
|
unsigned long flags;
|
||||||
|
|
||||||
va_start(va, format);
|
va_start(va, format);
|
||||||
|
|
||||||
|
flags = aal_mc_spinlock_lock(&kmsg_lock);
|
||||||
|
|
||||||
len = vsnprintf(kmsg_buf.str + kmsg_buf.tail,
|
len = vsnprintf(kmsg_buf.str + kmsg_buf.tail,
|
||||||
kmsg_buf.len - kmsg_buf.tail, format, va);
|
kmsg_buf.len - kmsg_buf.tail, format, va);
|
||||||
kmsg_buf.tail += len;
|
kmsg_buf.tail += len;
|
||||||
|
|
||||||
|
aal_mc_spinlock_unlock(&kmsg_lock, flags);
|
||||||
|
|
||||||
va_end(va);
|
va_end(va);
|
||||||
|
|
||||||
return len;
|
return len;
|
||||||
@@ -38,6 +50,7 @@ int kprintf(const char *format, ...)
|
|||||||
|
|
||||||
void kmsg_init(void)
|
void kmsg_init(void)
|
||||||
{
|
{
|
||||||
|
aal_mc_spinlock_init(&kmsg_lock);
|
||||||
kmsg_buf.tail = 0;
|
kmsg_buf.tail = 0;
|
||||||
kmsg_buf.len = sizeof(kmsg_buf.str);
|
kmsg_buf.len = sizeof(kmsg_buf.str);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user