X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=src%2Fvserver.h;h=6037db3d5164a8725ee23ac7c6c1162062dcca54;hb=ae84d4a660a154bd0247584a5813e4a01b46bf4b;hp=b2d352e2286b75661dd5e0dbd2790eb8a9e426a6;hpb=3e51c597d3876b9f4bb9d7aa59835f4ec3fab140;p=fprobe-ulog.git diff --git a/src/vserver.h b/src/vserver.h index b2d352e..6037db3 100644 --- a/src/vserver.h +++ b/src/vserver.h @@ -1,41 +1,86 @@ #ifndef __VSERVER_H__ #define __VSERVER_H__ -#define __NR_vserver 273 - -#include +#include #include #include -#include +#include +#include + +#define VSERVER_CONFIG_PATH "/etc/vservers" +#define SLICE_ID_FILE "slice_id" -#define VC_CMD(c, i, v) (((c & 0x3F) << 24) \ - | (((i) & 0xFF) << 16) | ((v) & 0xFFF)) -#define VC_CMD_GET_VHI_NAME VC_CMD(2,2,0) +char* get_current_username (unsigned int uid) +{ + struct passwd *passwd_entry; + if ((passwd_entry = getpwuid(uid)) == NULL) { + fprintf(stderr, "Could not look up user record for %d\n", uid); + return NULL; + } -struct vhi_name_struct { - uint32_t field; - char name[65]; + return (strdup(passwd_entry->pw_name)); +} + +#define HASH_SIZE (1<<12) +#define HASH_TABLE_MASK (HASH_SIZE - 1) + +struct hash_entry { + unsigned int xid; + uint32_t slice_id; }; -enum vhi_name_field { - VHIN_CONTEXT=0, - VHIN_SYSNAME, - VHIN_NODENAME, - VHIN_RELEASE, - VHIN_VERSION, - VHIN_MACHINE, - VHIN_DOMAINNAME, -}; - -uint32_t vserver(uint32_t cmd, uint32_t id, void *data) -{ - return syscall(__NR_vserver, cmd, id, data); +struct hash_entry slice_id_hash[HASH_SIZE]; + +void set_hash_entry(unsigned int xid, uint32_t slice_id) { + int idx = xid & HASH_TABLE_MASK; + int i; + for (i = idx;i!=idx;i=(i+1) & HASH_TABLE_MASK) { + struct hash_entry *entry = &slice_id_hash[i]; + if (entry->xid == 0 || entry->xid == xid) { + entry->xid = slice_id; + break; + } + } +} + +uint32_t xid_to_slice_id_slow(unsigned int xid) { + uint32_t slice_id; + char *slice_name = get_current_username (xid); + char *slice_path = (char *) malloc(sizeof(VSERVER_CONFIG_PATH) + strlen(slice_name) + sizeof(SLICE_ID_FILE) + sizeof("//")); + sprintf(slice_path,"%s/%s/%s",VSERVER_CONFIG_PATH,slice_name,SLICE_ID_FILE); + FILE *fp = fopen(slice_path, "r"); + if (fp) { + fscanf(fp,"%u",&slice_id); + set_hash_entry(xid, slice_id); + } + else + slice_id = xid; // Let's leave some evidence behind, even if it's imperfect. + fclose(fp); + return slice_id; } -uint32_t get_vhi_name(uint32_t xid) { - struct vhi_name_struct cmd; - cmd.field = VHIN_CONTEXT; - vserver(VC_CMD_GET_VHI_NAME, xid, &cmd); - return (*((uint32_t *) cmd.name)); +uint32_t xid_to_slice_id_fast(unsigned int xid) { + int idx = xid & HASH_TABLE_MASK; + int i; + uint32_t slice_id; + for (i = idx;i!=idx;i=(i+1) & HASH_TABLE_MASK) { + struct hash_entry *entry = &slice_id_hash[i]; + if (entry->xid == xid) { + entry->xid = slice_id; + break; + } + } + } + +uint32_t xid_to_slice_id(unsigned int xid) { + uint32_t slice_id; + if (xid == 0) + return 0; + else if ((slice_id = xid_to_slice_id_fast(xid)) != 0) + return slice_id; + else + return xid_to_slice_id_slow(xid); +} + #endif