code.grnet.gr Git - archipelago/blob - xseg/sys/kernel/xsegmod.c

   1 #include <linux/kernel.h>
   2 #include <linux/types.h>
   3 #include <linux/slab.h>
   4 #include <linux/module.h>
   5 #include <linux/time.h>
   6
   7 #include <sys/domain.h>
   8 #include <sys/util.h>
   9 #include <xtypes/domain.h>
  10 #include <xseg/domain.h>
  11
  12 int (*xseg_snprintf)(char *str, size_t size, const char *format, ...) = snprintf;
  13
  14 char __xseg_errbuf[4096];
  15
  16 static spinlock_t __lock;
  17
  18 void __lock_domain(void)
  19 {
  20         spin_lock_irq(&__lock);
  21 }
  22
  23 void __unlock_domain(void)
  24 {
  25         spin_unlock_irq(&__lock);
  26 }
  27
  28 void __load_plugin(const char *name)
  29 {
  30         return;
  31 }
  32
  33 uint64_t __get_id(void)
  34 {
  35         return (uint64_t)1;
  36 }
  37
  38 int __xseg_preinit(void)
  39 {
  40         return 0;
  41 }
  42
  43 void __xseg_log(const char *msg)
  44 {
  45         (void)printk(KERN_INFO "%s\n", msg);
  46 }
  47
  48 void *xtypes_malloc(unsigned long size)
  49 {
  50         return kmalloc(size, GFP_KERNEL);
  51 }
  52
  53 void xtypes_free(void *ptr)
  54 {
  55         return kfree(ptr);
  56 }
  57
  58 void __get_current_time(struct timeval *tv)
  59 {
  60         do_gettimeofday(tv);
  61 }
  62
  63 static int __init xsegmod_init(void)
  64 {
  65         printk(KERN_INFO "xseg loaded");
  66         return 0;
  67 }
  68
  69 static void __exit xsegmod_exit(void)
  70 {
  71         printk(KERN_INFO "xseg unloaded");
  72         return;
  73 }
  74
  75 int kernel_init_logctx(struct log_ctx *lc, char *peer_name, enum log_level log_level, char *logfile)
  76 {
  77         lc->peer_name = peer_name;
  78         lc->log_level = log_level;
  79         lc->logfile = NULL;
  80         return 0;
  81 }
  82 int (*init_logctx)(struct log_ctx *lc, char *peer_name, enum log_level log_level, char *logfile) = kernel_init_logctx;
  83
  84 void __xseg_log2(struct log_ctx *lc, unsigned int level, char *fmt, ...)
  85 {
  86         va_list ap;
  87         struct timeval t;
  88         struct tm broken;
  89         char buffer[1500];
  90         char *buf = buffer;
  91         char *type = NULL, *pn = NULL;
  92
  93         va_start(ap, fmt);
  94         switch (level) {
  95                 case E: type = "XSEG[EE]"; break;
  96                 case W: type = "XSEG[WW]"; break;
  97                 case I: type = "XSEG[II]"; break;
  98                 case D: type = "XSEG[DD]"; break;
  99                 default: type = "XSEG[UNKNONW]"; break;
 100         }
 101         pn = lc->peer_name;
 102         if (!pn)
 103                 pn = "Invalid peer name";
 104
 105         do_gettimeofday(&t);
 106         time_to_tm(t.tv_sec, 0, &broken);
 107
 108         buf += sprintf(buf, "%s: %s: ", type, lc->peer_name);
 109         buf += sprintf(buf, "%d:%d:%d:%ld\n\t", broken.tm_hour, broken.tm_min,
 110                          broken.tm_sec, t.tv_usec);
 111         buf += vsprintf(buf, fmt, ap);
 112         buf += sprintf(buf, "\n");
 113
 114         (void)printk(KERN_INFO "%s\n", buffer);
 115         va_end(ap);
 116
 117         return;
 118 }
 119
 120 void xseg_printtrace(void)
 121 {
 122         dump_stack();
 123 }
 124
 125 module_init(xsegmod_init);
 126 module_exit(xsegmod_exit);
 127
 128 MODULE_DESCRIPTION("xseg");
 129 MODULE_AUTHOR("XSEG");
 130 MODULE_LICENSE("GPL");
 131