sampler_dir=${modules_dir}/sampler
parser_dir=${modules_dir}/parser
-driver_dir=${modules_dir}/driver
-common_dir=${modules_dir}/../common
-
install_dir="/opt/swap/sdk"
rm ${kprobe_arch_dir}/asm
#include <linux/rculist.h>
#include <linux/slab.h>
#include <linux/spinlock.h>
-#include <dbi_kprobes_deps.h>
+#include <kprobe/dbi_kprobes_deps.h>
struct chunk {
unsigned long *data;
*
*/
-#include "dbi_kprobes.h"
+#include <kprobe/dbi_kprobes.h>
struct uprobe {
struct kprobe kp;
sspt/ip.o sspt/sspt_page.o sspt/sspt_file.o sspt/sspt_proc.o \
pf/proc_filters.o pf/pf_group.o \
img/img_proc.o img/img_file.o img/img_ip.o \
- ../driver/us_def_handler.o
+ us_def_handler.o
#include <dbi_kprobes.h>
#include <dbi_kprobes_deps.h>
#include <ksyms.h>
-#include "us_proc_inst.h"
#include "us_slot_manager.h"
-#include "storage.h"
#include "sspt/sspt.h"
#include "helper.h"
#include "sspt_page.h"
#include "sspt_file.h"
-/* FIXME: */
-#include "../../driver/us_def_handler.h"
+#include "us_def_handler.h"
struct us_ip *create_ip(unsigned long offset, const char *args)
{
#include <linux/list.h>
//#include "../../kprobe/dbi_kprobes.h"
-#include <swap_uprobes.h>
+#include <uprobe/swap_uprobes.h>
// TODO: tmp struct ip_data
struct ip_data {
#include "sspt_file.h"
#include "sspt_proc.h"
#include "sspt_debug.h"
+#include "us_proc_types.h"
#include <swap_uprobes.h>
#include "us_def_handler.h"
-#include "../../driver/storage.h"
-
-#include "picl.h"
-#include "../../common/ec_probe.h"
-
#include <us_manager.h>
#include <pf/pf_group.h>
ret = dbi_register_ujprobe(&ip->jprobe);
if (ret) {
- if (ret == -ENOEXEC) {
- pack_event_info(ERR_MSG_ID, RECORD_ENTRY, "dp",
- 0x1, ip->jprobe.up.kp.addr);
- }
printk("dbi_register_ujprobe() failure %d\n", ret);
return ret;
}
#include "sspt_file.h"
#include "sspt_page.h"
#include "sspt_proc.h"
-#include <storage.h>
#include <linux/slab.h>
#include <linux/list.h>
#include <linux/hash.h>
file->vm_start = vma->vm_start;
file->vm_end = vma->vm_end;
- ptr_pack_task_event_info(task, DYN_LIB_PROBE_ID, RECORD_ENTRY, "dspdd",
- task->tgid, file->dentry->d_iname, vma->vm_start,
- vma->vm_end - vma->vm_start, 0);
+// ptr_pack_task_event_info(task, DYN_LIB_PROBE_ID, RECORD_ENTRY, "dspdd",
+// task->tgid, file->dentry->d_iname, vma->vm_start,
+// vma->vm_end - vma->vm_start, 0);
}
#include <linux/slab.h>
#include <linux/list.h>
#include <us_slot_manager.h>
-#include <us_proc_inst.h>
#include <writer/swap_writer_module.h>
#define mm_read_lock(task, mm, atomic, lock) \
--- /dev/null
+typedef struct
+{
+ struct list_head list;
+ char *name;
+ int installed;
+ struct jprobe jprobe;
+ struct kretprobe retprobe;
+ unsigned long offset;
+ unsigned long got_addr;
+
+ unsigned flag_retprobe:1;
+ unsigned flag_got:1;
+} us_proc_ip_t;
+
+typedef struct
+{
+ int installed;
+ struct jprobe jprobe;
+ unsigned long addr;
+ struct list_head list;
+} us_proc_vtp_t;
+
+typedef struct
+{
+ unsigned func_addr;
+ unsigned got_addr;
+ unsigned real_func_addr;
+} us_proc_plt_t;
+
+typedef struct
+{
+ char *path;
+ char *path_dyn;
+ struct dentry *m_f_dentry;
+ unsigned ips_count;
+ us_proc_ip_t *p_ips;
+ unsigned vtps_count;
+ us_proc_vtp_t *p_vtps;
+ int loaded;
+ unsigned plt_count;
+ us_proc_plt_t *p_plt;
+ unsigned long vma_start;
+ unsigned long vma_end;
+ unsigned vma_flag;
+} us_proc_lib_t;
+
+typedef struct {
+ char *path;
+ struct dentry *m_f_dentry;
+ pid_t tgid;
+ unsigned unres_ips_count;
+ unsigned unres_vtps_count;
+ int is_plt;
+ unsigned libs_count;
+ us_proc_lib_t *p_libs;
+
+ // new_dpf
+ struct sspt_proc *pp;
+} inst_us_proc_t;
--- /dev/null
+#include <linux/module.h>
+#include <asm/percpu.h>
+//#include <ec_probe.h>
+//#include <picl.h>
+#include <swap_uprobes.h>
+#include <sspt/ip.h>
+#include <dbi_kprobes_deps.h>
+//#include "storage.h"
+//#include "us_proc_inst.h"
+#include <sspt/sspt.h>
+#include <writer/swap_writer_module.h>
+
+DEFINE_PER_CPU(struct us_ip *, gpCurIp) = NULL;
+EXPORT_PER_CPU_SYMBOL_GPL(gpCurIp);
+DEFINE_PER_CPU(struct pt_regs *, gpUserRegs) = NULL;
+EXPORT_PER_CPU_SYMBOL_GPL(gpUserRegs);
+
+unsigned long ujprobe_event_pre_handler(struct us_ip *ip, struct pt_regs *regs)
+{
+ __get_cpu_var(gpCurIp) = ip;
+ __get_cpu_var(gpUserRegs) = regs;
+
+ return 0;
+}
+EXPORT_SYMBOL_GPL(ujprobe_event_pre_handler);
+
+void ujprobe_event_handler(unsigned long arg0, unsigned long arg1,
+ unsigned long arg2, unsigned long arg3,
+ unsigned long arg4, unsigned long arg5)
+{
+ struct us_ip *ip = __get_cpu_var(gpCurIp);
+ struct us_ip *regs = __get_cpu_var(gpUserRegs);
+ unsigned long addr = (unsigned long)ip->jprobe.up.kp.addr;
+
+#if defined(CONFIG_ARM)
+ addr = ip->offset & 0x01 ? addr | 0x01 : addr;
+#endif
+
+ entry_event(ip->jprobe.args, regs, PT_US, PST_NONE);
+
+ swap_ujprobe_return();
+}
+EXPORT_SYMBOL_GPL(ujprobe_event_handler);
+
+static void send_plt(struct us_ip *ip)
+{
+ unsigned long addr = (unsigned long)ip->jprobe.up.kp.addr;
+ struct vm_area_struct *vma = find_vma(current->mm, addr);
+
+ if (vma && check_vma(vma)) {
+ char *name = NULL;
+ unsigned long real_addr;
+ unsigned long real_got = current->mm->exe_file == vma->vm_file ?
+ ip->got_addr :
+ ip->got_addr + vma->vm_start;
+
+ if (!read_proc_vm_atomic(current, real_got, &real_addr, sizeof(real_addr))) {
+ printk("Failed to read got %lx at memory address %lx!\n", ip->got_addr, real_got);
+ return;
+ }
+
+ vma = find_vma(current->mm, real_addr);
+ if (vma && (vma->vm_start <= real_addr) && (vma->vm_end > real_addr)) {
+ name = vma->vm_file ? vma->vm_file->f_dentry->d_iname : NULL;
+ } else {
+ printk("Failed to get vma, includes %lx address\n", real_addr);
+ return;
+ }
+
+// if (name)
+// pack_event_info(PLT_ADDR_PROBE_ID, RECORD_RET, "ppsp",
+// addr, real_addr, name,
+// real_addr - vma->vm_start);
+// else
+// pack_event_info(PLT_ADDR_PROBE_ID, RECORD_RET, "ppp",
+// addr, real_addr,
+// real_addr - vma->vm_start);
+ }
+}
+
+int uretprobe_event_handler(struct uretprobe_instance *probe,
+ struct pt_regs *regs,
+ struct us_ip *ip)
+{
+ int retval = regs_return_value(regs);
+ unsigned long addr = (unsigned long)ip->jprobe.up.kp.addr;
+
+ if (ip->got_addr && ip->flag_got == 0) {
+ send_plt(ip);
+ ip->flag_got = 1;
+ }
+
+#if defined(CONFIG_ARM)
+ addr = ip->offset & 0x01 ? addr | 0x01 : addr;
+#endif
+
+ exit_event(regs);
+
+ return 0;
+}
+EXPORT_SYMBOL_GPL(uretprobe_event_handler);
--- /dev/null
+#ifndef _US_DEF_HANDLER_H
+#define _US_DEF_HANDLER_H
+
+#include <asm/percpu.h>
+
+struct us_ip;
+struct pt_regs;
+struct uretprobe_instance;
+
+DECLARE_PER_CPU(struct us_ip *, gpCurIp);
+DECLARE_PER_CPU(struct pt_regs *, gpUserRegs);
+
+unsigned long ujprobe_event_pre_handler(struct us_ip *ip,
+ struct pt_regs *regs);
+void ujprobe_event_handler(unsigned long arg0, unsigned long arg1,
+ unsigned long arg2, unsigned long arg3,
+ unsigned long arg4, unsigned long arg5);
+int uretprobe_event_handler(struct uretprobe_instance *p,
+ struct pt_regs *regs, struct us_ip *ip);
+
+#endif /* _US_DEF_HANDLER_H */
#include <linux/module.h>
-#include <sspt/sspt.h>
-#include <sspt/sspt_proc.h>
-#include <sspt/sspt_page.h>
+#include <us_manager/sspt/sspt.h>
+#include <us_manager/sspt/sspt_proc.h>
+#include <us_manager/sspt/sspt_page.h>
#include <helper.h>
#include "pf/proc_filters.h"
}
// FIXME: its seems to be bad decision to replace 'current' pointer temporarily
current_thread_info()->task = task;
- ret = do_mmap_pgoff(NULL, 0, len, prot, flags, 0);
+ ret = do_mmap(NULL, 0, len, prot, flags, 0);
current_thread_info()->task = otask;
if (!atomic) {
downgrade_write (&mm->mmap_sem);
sm->slot_size = UPROBES_TRAMP_LEN;
sm->alloc = sm_alloc_us;
sm->free = sm_free_us;
- INIT_HLIST_NODE(&sm->page_list);
+ INIT_HLIST_HEAD(&sm->page_list);
sm->data = task;
return sm;