github/weave-scope
1
0
Fork 0
mirror of https://github.com/weaveworks/scope.git synced 2026-03-03 02:00:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: a bit of inlining

Browse Source
This commit is contained in:
Matthias Radestock
2017-07-10 15:09:19 +01:00
parent 3baeb3d238
commit e2cbe7ac26
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
probe/endpoint/ebpf.go
View File

@@ -177,13 +177,12 @@ func (t *EbpfTracker) handleFdInstall(ev tracer.EventType, pid int, fd int) {
if !ok {
return
}
conn := ebpfConnection{
t.openConnections[tuple] = ebpfConnection{
incoming: true,
tuple: tuple,
pid: pid,
networkNamespace: netns,
}
t.openConnections[tuple] = conn
if !process.IsProcInAccept("/proc", strconv.Itoa(pid)) {
t.tracer.RemoveFdInstallWatcher(uint32(pid))
}
@@ -202,21 +201,19 @@ func (t *EbpfTracker) handleConnection(ev tracer.EventType, tuple fourTuple, pid
switch ev {
case tracer.EventConnect:
conn := ebpfConnection{
t.openConnections[tuple] = ebpfConnection{
incoming: false,
tuple: tuple,
pid: pid,
networkNamespace: networkNamespace,
}
t.openConnections[tuple] = conn
case tracer.EventAccept:
conn := ebpfConnection{
t.openConnections[tuple] = ebpfConnection{
incoming: true,
tuple: tuple,
pid: pid,
networkNamespace: networkNamespace,
}
t.openConnections[tuple] = conn
case tracer.EventClose:
if deadConn, ok := t.openConnections[tuple]; ok {
delete(t.openConnections, tuple)