mirror of
https://github.com/weaveworks/scope.git
synced 2026-03-04 10:41:14 +00:00
Merge branch '356-ftrace'
This commit is contained in:
@@ -181,6 +181,8 @@ func (f *Ftrace) events(out chan<- *syscall) {
|
||||
|
||||
func (f *Ftrace) start() error {
|
||||
for _, e := range []struct{ class, event string }{
|
||||
{"syscalls", "sys_enter_socket"},
|
||||
{"syscalls", "sys_exit_socket"},
|
||||
{"syscalls", "sys_enter_connect"},
|
||||
{"syscalls", "sys_exit_connect"},
|
||||
{"syscalls", "sys_enter_accept"},
|
||||
|
||||
@@ -69,7 +69,15 @@ func main() {
|
||||
syscalls := make(chan *syscall, 100)
|
||||
go ftrace.events(syscalls)
|
||||
|
||||
onSocket := func(s *syscall) {
|
||||
|
||||
}
|
||||
|
||||
onConnection := func(s *syscall) {
|
||||
if s.returnCode != 0 {
|
||||
return
|
||||
}
|
||||
|
||||
fdStr, ok := s.args["fd"]
|
||||
if !ok {
|
||||
panic("no pid")
|
||||
@@ -105,6 +113,8 @@ func main() {
|
||||
case s := <-syscalls:
|
||||
|
||||
switch s.name {
|
||||
case "socket":
|
||||
onSocket(s)
|
||||
case "connect":
|
||||
onConnection(s)
|
||||
case "accept", "accept4":
|
||||
|
||||
Reference in New Issue
Block a user