[IMPROVE] implement bidirectionality sspt tree
[kernel/swap-modules.git] / driver / sspt / sspt_file.c
1 /*
2  *  Dynamic Binary Instrumentation Module based on KProbes
3  *  modules/driver/sspt/sspt_file.c
4  *
5  * This program is free software; you can redistribute it and/or modify
6  * it under the terms of the GNU General Public License as published by
7  * the Free Software Foundation; either version 2 of the License, or
8  * (at your option) any later version.
9  *
10  * This program is distributed in the hope that it will be useful,
11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
13  * GNU General Public License for more details.
14  *
15  * You should have received a copy of the GNU General Public License
16  * along with this program; if not, write to the Free Software
17  * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
18  *
19  * Copyright (C) Samsung Electronics, 2013
20  *
21  * 2013         Vyacheslav Cherkashin <v.cherkashin@samsung.com>
22  *
23  */
24
25 #include "sspt_file.h"
26 #include "sspt_page.h"
27 #include <linux/slab.h>
28 #include <linux/list.h>
29 #include <linux/hash.h>
30
31 static int calculation_hash_bits(int cnt)
32 {
33         int bits;
34         for (bits = 1; cnt >>= 1; ++bits);
35
36         return bits;
37 }
38
39 struct sspt_file *sspt_file_create(char *name, struct dentry *dentry, int page_cnt)
40 {
41         struct sspt_file *obj = kmalloc(sizeof(*obj), GFP_ATOMIC);
42
43         if (obj) {
44                 int i, table_size;
45                 INIT_LIST_HEAD(&obj->list);
46                 obj->procs = NULL;
47                 obj->name = name;
48                 obj->dentry = dentry;
49                 obj->loaded = 0;
50                 obj->vm_start = 0;
51                 obj->vm_end = 0;
52
53                 obj->page_probes_hash_bits = calculation_hash_bits(page_cnt);//PAGE_PROBES_HASH_BITS;
54                 table_size = (1 << obj->page_probes_hash_bits);
55
56                 obj->page_probes_table = kmalloc(sizeof(*obj->page_probes_table)*table_size, GFP_ATOMIC);
57
58                 for (i = 0; i < table_size; ++i) {
59                         INIT_HLIST_HEAD(&obj->page_probes_table[i]);
60                 }
61         }
62
63         return obj;
64 }
65
66 void sspt_file_free(struct sspt_file *file)
67 {
68         struct hlist_node *p, *n;
69         struct hlist_head *head;
70         struct sspt_page *page;
71         int i, table_size = (1 << file->page_probes_hash_bits);
72
73         for (i = 0; i < table_size; ++i) {
74                 head = &file->page_probes_table[i];
75                 hlist_for_each_entry_safe(page, p, n, head, hlist) {
76                         hlist_del(&page->hlist);
77                         sspt_page_free(page);
78                 }
79         }
80
81         kfree(file->page_probes_table);
82         kfree(file);
83 }
84
85 static void sspt_add_page(struct sspt_file *file, struct sspt_page *page)
86 {
87         page->file = file;
88         hlist_add_head(&page->hlist, &file->page_probes_table[hash_ptr((void *)page->offset,
89                                 file->page_probes_hash_bits)]);
90 }
91
92 struct sspt_file *sspt_file_copy(const struct sspt_file *file)
93 {
94         struct sspt_file *file_out;
95
96         if (file == NULL) {
97                 printk("### WARNING: file_p == NULL\n");
98                 return NULL;
99         }
100
101         file_out = kmalloc(sizeof(*file_out), GFP_ATOMIC);
102         if (file_out) {
103                 struct sspt_page *page = NULL;
104                 struct hlist_node *node = NULL;
105                 struct hlist_head *head = NULL;
106                 int i, table_size;
107                 INIT_LIST_HEAD(&file_out->list);
108                 file_out->procs = NULL;
109                 file_out->dentry = file->dentry;
110                 file_out->name = file->name;
111                 file_out->loaded = 0;
112                 file_out->vm_start = 0;
113                 file_out->vm_end = 0;
114
115                 file_out->page_probes_hash_bits = file->page_probes_hash_bits;
116                 table_size = (1 << file_out->page_probes_hash_bits);
117
118                 file_out->page_probes_table =
119                                 kmalloc(sizeof(*file_out->page_probes_table)*table_size, GFP_ATOMIC);
120
121                 for (i = 0; i < table_size; ++i) {
122                         INIT_HLIST_HEAD(&file_out->page_probes_table[i]);
123                 }
124
125                 // copy pages
126                 for (i = 0; i < table_size; ++i) {
127                         head = &file->page_probes_table[i];
128                         hlist_for_each_entry(page, node, head, hlist) {
129                                 sspt_add_page(file_out, sspt_page_copy(page));
130                         }
131                 }
132         }
133
134         return file_out;
135 }
136
137 static struct sspt_page *sspt_find_page(struct sspt_file *file, unsigned long offset)
138 {
139         struct hlist_node *node;
140         struct hlist_head *head;
141         struct sspt_page *page;
142
143         head = &file->page_probes_table[hash_ptr((void *)offset, file->page_probes_hash_bits)];
144         hlist_for_each_entry(page, node, head, hlist) {
145                 if (page->offset == offset) {
146                         return page;
147                 }
148         }
149
150         return NULL;
151 }
152
153 static struct sspt_page *sspt_find_page_or_new(struct sspt_file *file, unsigned long offset)
154 {
155         struct sspt_page *page = sspt_find_page(file, offset);
156
157         if (page == NULL) {
158                 page = sspt_page_create(offset);
159                 sspt_add_page(file, page);
160         }
161
162         return page;
163 }
164
165 struct sspt_page *sspt_find_page_mapped(struct sspt_file *file, unsigned long page)
166 {
167         unsigned long offset;
168
169         if (file->vm_start > page || file->vm_end < page) {
170                 // TODO: or panic?!
171                 printk("ERROR: file_p[vm_start..vm_end] <> page: file_p[vm_start=%lx, vm_end=%lx, path=%s, d_iname=%s] page=%lx\n",
172                                 file->vm_start, file->vm_end, file->name, file->dentry->d_iname, page);
173                 return NULL;
174         }
175
176         offset = page - file->vm_start;
177
178         return sspt_find_page(file, offset);
179 }
180
181 void sspt_file_add_ip(struct sspt_file *file, struct ip_data *ip_d)
182 {
183         unsigned long offset = ip_d->offset & PAGE_MASK;
184         struct sspt_page *page = sspt_find_page_or_new(file, offset);
185
186         // FIXME: delete ip
187         struct us_ip *ip = create_ip_by_ip_data(ip_d);
188
189         sspt_add_ip(page, ip);
190 }
191
192 struct sspt_page *sspt_get_page(struct sspt_file *file, unsigned long offset_addr)
193 {
194         unsigned long offset = offset_addr & PAGE_MASK;
195         struct sspt_page *page = sspt_find_page_or_new(file, offset);
196
197         spin_lock(&page->lock);
198
199         return page;
200 }
201
202 void sspt_put_page(struct sspt_page *page)
203 {
204         spin_unlock(&page->lock);
205 }