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
  76 int __renew_logctx(struct log_ctx *lc, char *peer_name,
  77                 enum log_level log_level, char *logfile, uint32_t flags)
  78 {
  79         return 0;
  80 }
  81
  82 int (*renew_logctx)(struct log_ctx *lc, char *peer_name,
  83         enum log_level log_level, char *logfile, uint32_t flags) = __renew_logctx;
  84
  85 int __init_logctx(struct log_ctx *lc, char *peer_name,
  86                 enum log_level log_level, char *logfile, uint32_t flags)
  87 {
  88         if (peer_name){
  89                 strncpy(lc->peer_name, peer_name, MAX_PEER_NAME);
  90                 lc->peer_name[MAX_PEER_NAME -1] = 0;
  91         }
  92         else {
  93                 return -1;
  94         }
  95
  96         lc->log_level = log_level;
  97         lc->logfile = NULL;
  98         return 0;
  99 }
 100 int (*init_logctx)(struct log_ctx *lc, char *peer_name,
 101         enum log_level log_level, char *logfile, uint32_t flags) = __init_logctx;
 102
 103 void __xseg_log2(struct log_ctx *lc, unsigned int level, char *fmt, ...)
 104 {
 105         va_list ap;
 106         struct timeval t;
 107         struct tm broken;
 108         char buffer[1500];
 109         char *buf = buffer;
 110         char *type = NULL, *pn = NULL;
 111
 112         va_start(ap, fmt);
 113         switch (level) {
 114                 case E: type = "XSEG[EE]"; break;
 115                 case W: type = "XSEG[WW]"; break;
 116                 case I: type = "XSEG[II]"; break;
 117                 case D: type = "XSEG[DD]"; break;
 118                 default: type = "XSEG[UNKNONW]"; break;
 119         }
 120         pn = lc->peer_name;
 121         if (!pn)
 122                 pn = "Invalid peer name";
 123
 124         do_gettimeofday(&t);
 125         time_to_tm(t.tv_sec, 0, &broken);
 126
 127         buf += sprintf(buf, "%s: %s: ", type, lc->peer_name);
 128         buf += sprintf(buf, "%d:%d:%d:%ld\n\t", broken.tm_hour, broken.tm_min,
 129                          broken.tm_sec, t.tv_usec);
 130         buf += vsprintf(buf, fmt, ap);
 131         buf += sprintf(buf, "\n");
 132
 133         (void)printk(KERN_INFO "%s\n", buffer);
 134         va_end(ap);
 135
 136         return;
 137 }
 138
 139 void xseg_printtrace(void)
 140 {
 141         dump_stack();
 142 }
 143
 144 module_init(xsegmod_init);
 145 module_exit(xsegmod_exit);
 146
 147 MODULE_DESCRIPTION("xseg");
 148 MODULE_AUTHOR("XSEG");
 149 MODULE_LICENSE("BSD");
 150