| #include "comm.h" | 
 | #include "util.h" | 
 | #include <errno.h> | 
 | #include <stdlib.h> | 
 | #include <stdio.h> | 
 | #include <string.h> | 
 | #include <linux/refcount.h> | 
 |  | 
 | struct comm_str { | 
 | 	char *str; | 
 | 	struct rb_node rb_node; | 
 | 	refcount_t refcnt; | 
 | }; | 
 |  | 
 | /* Should perhaps be moved to struct machine */ | 
 | static struct rb_root comm_str_root; | 
 |  | 
 | static struct comm_str *comm_str__get(struct comm_str *cs) | 
 | { | 
 | 	if (cs) | 
 | 		refcount_inc(&cs->refcnt); | 
 | 	return cs; | 
 | } | 
 |  | 
 | static void comm_str__put(struct comm_str *cs) | 
 | { | 
 | 	if (cs && refcount_dec_and_test(&cs->refcnt)) { | 
 | 		rb_erase(&cs->rb_node, &comm_str_root); | 
 | 		zfree(&cs->str); | 
 | 		free(cs); | 
 | 	} | 
 | } | 
 |  | 
 | static struct comm_str *comm_str__alloc(const char *str) | 
 | { | 
 | 	struct comm_str *cs; | 
 |  | 
 | 	cs = zalloc(sizeof(*cs)); | 
 | 	if (!cs) | 
 | 		return NULL; | 
 |  | 
 | 	cs->str = strdup(str); | 
 | 	if (!cs->str) { | 
 | 		free(cs); | 
 | 		return NULL; | 
 | 	} | 
 |  | 
 | 	refcount_set(&cs->refcnt, 1); | 
 |  | 
 | 	return cs; | 
 | } | 
 |  | 
 | static struct comm_str *comm_str__findnew(const char *str, struct rb_root *root) | 
 | { | 
 | 	struct rb_node **p = &root->rb_node; | 
 | 	struct rb_node *parent = NULL; | 
 | 	struct comm_str *iter, *new; | 
 | 	int cmp; | 
 |  | 
 | 	while (*p != NULL) { | 
 | 		parent = *p; | 
 | 		iter = rb_entry(parent, struct comm_str, rb_node); | 
 |  | 
 | 		cmp = strcmp(str, iter->str); | 
 | 		if (!cmp) | 
 | 			return comm_str__get(iter); | 
 |  | 
 | 		if (cmp < 0) | 
 | 			p = &(*p)->rb_left; | 
 | 		else | 
 | 			p = &(*p)->rb_right; | 
 | 	} | 
 |  | 
 | 	new = comm_str__alloc(str); | 
 | 	if (!new) | 
 | 		return NULL; | 
 |  | 
 | 	rb_link_node(&new->rb_node, parent, p); | 
 | 	rb_insert_color(&new->rb_node, root); | 
 |  | 
 | 	return new; | 
 | } | 
 |  | 
 | struct comm *comm__new(const char *str, u64 timestamp, bool exec) | 
 | { | 
 | 	struct comm *comm = zalloc(sizeof(*comm)); | 
 |  | 
 | 	if (!comm) | 
 | 		return NULL; | 
 |  | 
 | 	comm->start = timestamp; | 
 | 	comm->exec = exec; | 
 |  | 
 | 	comm->comm_str = comm_str__findnew(str, &comm_str_root); | 
 | 	if (!comm->comm_str) { | 
 | 		free(comm); | 
 | 		return NULL; | 
 | 	} | 
 |  | 
 | 	return comm; | 
 | } | 
 |  | 
 | int comm__override(struct comm *comm, const char *str, u64 timestamp, bool exec) | 
 | { | 
 | 	struct comm_str *new, *old = comm->comm_str; | 
 |  | 
 | 	new = comm_str__findnew(str, &comm_str_root); | 
 | 	if (!new) | 
 | 		return -ENOMEM; | 
 |  | 
 | 	comm_str__put(old); | 
 | 	comm->comm_str = new; | 
 | 	comm->start = timestamp; | 
 | 	if (exec) | 
 | 		comm->exec = true; | 
 |  | 
 | 	return 0; | 
 | } | 
 |  | 
 | void comm__free(struct comm *comm) | 
 | { | 
 | 	comm_str__put(comm->comm_str); | 
 | 	free(comm); | 
 | } | 
 |  | 
 | const char *comm__str(const struct comm *comm) | 
 | { | 
 | 	return comm->comm_str->str; | 
 | } |