diff options
Diffstat (limited to 'tapset/LKET/aio.stp')
-rwxr-xr-x | tapset/LKET/aio.stp | 77 |
1 files changed, 51 insertions, 26 deletions
diff --git a/tapset/LKET/aio.stp b/tapset/LKET/aio.stp index d5e3625d..ea81d024 100755 --- a/tapset/LKET/aio.stp +++ b/tapset/LKET/aio.stp @@ -41,6 +41,10 @@ probe addevent.aio.return * system call is sys_io_setup, which will create an aio_context * capable of receiving at least maxevents. */ +probe addevent.aio.io_setup = + addevent.aio.io_setup.entry, addevent.aio.io_setup.return +{} + probe addevent.aio.io_setup.entry += _addevent.aio.io_setup.entry { @@ -50,13 +54,13 @@ probe addevent.aio.io_setup.entry probe _addevent.aio.io_setup.entry = syscall.io_setup { - log_aio_setup(HOOKID_AIO_IO_SETUP_ENTRY, maxevents, ctxp_uaddr) + log_aio_setup(maxevents, ctxp_uaddr) } -function log_aio_setup(hookid:long, nr_events:long, ctxp_uaddr:long) +function log_aio_setup(nr_events:long, ctxp_uaddr:long) %{ /* nr_events|ctxp_uaddr */ - _lket_trace(_GROUP_AIO, THIS->hookid, "%4b%8b", + _lket_trace(_GROUP_AIO, _HOOKID_AIO_IO_SETUP_ENTRY, "%4b%8b", THIS->nr_events, THIS->ctxp_uaddr); %} @@ -82,6 +86,10 @@ function log_aio_return(hookid:long, retval:long) * system call is sys_io_submit which will queue the nr iocbs * pointed to by iocbpp_uaddr for processing. */ +probe addevent.aio.io_submit = + addevent.aio.io_submit.entry, addevent.aio.io_submit.return +{} + probe addevent.aio.io_submit.entry += _addevent.aio.io_submit.entry { @@ -91,13 +99,13 @@ probe addevent.aio.io_submit.entry probe _addevent.aio.io_submit.entry = syscall.io_submit { - log_aio_submit(HOOKID_AIO_IO_SUBMIT_ENTRY, ctx_id, nr, iocbpp_uaddr) + log_aio_submit(ctx_id, nr, iocbpp_uaddr) } -function log_aio_submit(hookid:long, ctx_id:long, nr:long, iocbpp_uaddr:long) +function log_aio_submit(ctx_id:long, nr:long, iocbpp_uaddr:long) %{ /* ctx_id | no_iocbs | iocbpp */ - _lket_trace(_GROUP_AIO, THIS->hookid, "%8b%4b%8b", + _lket_trace(_GROUP_AIO, _HOOKID_AIO_IO_SUBMIT_ENTRY, "%8b%4b%8b", THIS->ctx_id, THIS->nr, THIS->iocbpp_uaddr); %} @@ -116,6 +124,10 @@ probe _addevent.aio.io_submit.return /* Called by sys_io_submit, will iterate iocbpp and process them * one by one */ +probe addevent.aio.io_submit_one + = addevent.aio.io_submit_one.entry, addevent.aio.io_submit_one.return +{} + probe addevent.aio.io_submit_one.entry += _addevent.aio.io_submit_one.entry { @@ -126,21 +138,24 @@ probe addevent.aio.io_submit_one.entry probe _addevent.aio.io_submit_one.entry = kernel.function("io_submit_one") { - log_io_submit_one(HOOKID_AIO_IO_SUBMIT_ONE_ENTRY, $ctx, $user_iocb) + log_io_submit_one($ctx, $user_iocb, $user_iocb->aio_lio_opcode, + $user_iocb->aio_reqprio, $user_iocb->aio_fildes, + $user_iocb->aio_buf, $user_iocb->aio_nbytes, + $user_iocb->aio_offset ) } -function log_io_submit_one(hookid:long, ctx:long, user_iocb_uaddr:long) +function log_io_submit_one(ctx:long, user_iocb_uaddr:long, aio_lio_opcode:long, + aio_reqprio:long, aio_fildes:long, aio_buf:long, aio_nbytes:long, + aio_offset:long) %{ - struct iocb *user_iocb = (struct iocb *)((long)THIS->user_iocb_uaddr); - /* ctx | user_iocb_addr | aio_lio_opcode | >aio_reqprio | aio_fildes | aio_buf | aio_nbytes | >aio_offset */ - _lket_trace(_GROUP_AIO, THIS->hookid, + _lket_trace(_GROUP_AIO, _HOOKID_AIO_IO_SUBMIT_ONE_ENTRY, "%8b%8b%2b%2b%4b%8b%8b%8b", - THIS->ctx, THIS->user_iocb_uaddr, (_FMT_)user_iocb->aio_lio_opcode, - (_FMT_)user_iocb->aio_reqprio, (_FMT_)user_iocb->aio_fildes, - (_FMT_)user_iocb->aio_buf, (_FMT_)user_iocb->aio_nbytes, - (_FMT_)user_iocb->aio_offset); + THIS->ctx, THIS->user_iocb_uaddr, THIS->aio_lio_opcode, + THIS->aio_reqprio, THIS->aio_fildes, + THIS->aio_buf, THIS->aio_nbytes, + THIS->aio_offset); %} probe addevent.aio.io_submit_one.return @@ -160,6 +175,10 @@ probe _addevent.aio.io_submit_one.return * system call is sys_io_destroy, which will destroy the aio_context * specified. */ +probe addevent.aio.io_destroy = + addevent.aio.io_destroy.entry, addevent.aio.io_destroy.return +{} + probe addevent.aio.io_destroy.entry += _addevent.aio.io_destroy.entry { @@ -169,12 +188,12 @@ probe addevent.aio.io_destroy.entry probe _addevent.aio.io_destroy.entry = syscall.io_destroy { - log_io_destroy(HOOKID_AIO_IO_DESTROY_ENTRY, ctx) + log_io_destroy(ctx) } -function log_io_destroy(hookid:long, ctx:long) +function log_io_destroy(ctx:long) %{ - _lket_trace(_GROUP_AIO, THIS->hookid, "%8b", THIS->ctx); + _lket_trace(_GROUP_AIO, _HOOKID_AIO_IO_DESTROY_ENTRY, "%8b", THIS->ctx); %} @@ -196,6 +215,10 @@ probe _addevent.aio.io_destroy.return * least min_nr events and up to nr events from the completion queue * for the aio_context specified by ctx_id. */ +probe addevent.aio.io_getevents + = addevent.aio.io_getevents.entry, addevent.aio.io_getevents.return +{} + probe addevent.aio.io_getevents.entry += _addevent.aio.io_getevents.entry { @@ -205,11 +228,10 @@ probe addevent.aio.io_getevents.entry probe _addevent.aio.io_getevents.entry = syscall.io_getevents { - log_io_getevents(HOOKID_AIO_IO_GETEVENTS_ENTRY, ctx_id, - min_nr, nr, events_uaddr, timeout_uaddr) + log_io_getevents(ctx_id, min_nr, nr, events_uaddr, timeout_uaddr) } -function log_io_getevents(hookid:long, ctx_id:long, min_nr:long, nr:long, +function log_io_getevents(ctx_id:long, min_nr:long, nr:long, events_uaddr:long, timeout:long) %{ struct timespec __user *timeout = (struct timespec *)((long)THIS->timeout); @@ -218,7 +240,7 @@ function log_io_getevents(hookid:long, ctx_id:long, min_nr:long, nr:long, if (unlikely(copy_from_user(&ts, timeout, sizeof(ts)))) return; - _lket_trace(_GROUP_AIO, THIS->hookid, + _lket_trace(_GROUP_AIO, _HOOKID_AIO_IO_GETEVENTS_ENTRY, "%8b%4b%4b%8b%4b%4b", THIS->ctx_id, THIS->min_nr, THIS->nr, THIS->events_uaddr, (_FMT_)ts.tv_sec, (_FMT_)ts.tv_nsec); @@ -241,6 +263,10 @@ probe _addevent.aio.io_getevents.return * system call is sys_io_cancel, which will attempt to cancel * an iocb previously passed to io_submit. */ +probe addevent.aio.io_cancel + = addevent.aio.io_cancel.entry, addevent.aio.io_cancel.return +{} + probe addevent.aio.io_cancel.entry += _addevent.aio.io_cancel.entry { @@ -250,13 +276,12 @@ probe addevent.aio.io_cancel.entry probe _addevent.aio.io_cancel.entry = syscall.io_cancel { - log_aio_cancel(HOOKID_AIO_IO_CANCEL_ENTRY, ctx_id, - iocb_uaddr, result_uaddr) + log_aio_cancel(ctx_id, iocb_uaddr, result_uaddr) } -function log_aio_cancel(hookid:long, ctx_id:long, iocb_uaddr:long, result_uaddr:long) +function log_aio_cancel(ctx_id:long, iocb_uaddr:long, result_uaddr:long) %{ - _lket_trace(_GROUP_AIO, THIS->hookid, "%8b%8b%8b", + _lket_trace(_GROUP_AIO, _HOOKID_AIO_IO_CANCEL_ENTRY, "%8b%8b%8b", THIS->ctx_id, THIS->iocb_uaddr, THIS->result_uaddr); %} |