github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-06-30 10:05:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Replace Libssl occurrences with Ssllib for consistency

Browse Source
This commit is contained in:
M. Mert Yildiran 2022-05-30 22:34:01 +03:00
parent e0a7a04543
commit fcb7663b99
No known key found for this signature in database
GPG Key ID: D42ADB236521BF7A
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tap/tlstapper/tls_poller.go
View File

@ -88,7 +88,7 @@ func (p *tlsPoller) close() error {
return p.chunksReader.Close() return p.chunksReader.Close()
} }
func (p *tlsPoller) pollLibssl(emitter api.Emitter, options *api.TrafficFilteringOptions, streamsMap api.TcpStreamMap) { func (p *tlsPoller) pollSsllib(emitter api.Emitter, options *api.TrafficFilteringOptions, streamsMap api.TcpStreamMap) {
chunks := make(chan *tlsChunk) chunks := make(chan *tlsChunk)
go p.pollChunksPerfBuffer(chunks) go p.pollChunksPerfBuffer(chunks)

8
tap/tlstapper/tls_tapper.go
View File

@ -60,7 +60,7 @@ func (t *TlsTapper) Init(chunksBufferSize int, logBufferSize int, procfs string,
} }
func (t *TlsTapper) Poll(emitter api.Emitter, options *api.TrafficFilteringOptions, streamsMap api.TcpStreamMap) { func (t *TlsTapper) Poll(emitter api.Emitter, options *api.TrafficFilteringOptions, streamsMap api.TcpStreamMap) {
t.poller.pollLibssl(emitter, options, streamsMap) t.poller.pollSsllib(emitter, options, streamsMap)
t.poller.pollGolang(emitter, options, streamsMap) t.poller.pollGolang(emitter, options, streamsMap)
} }
@ -69,7 +69,7 @@ func (t *TlsTapper) PollForLogging() {
} }
func (t *TlsTapper) GlobalSsllibTap(sslLibrary string) error { func (t *TlsTapper) GlobalSsllibTap(sslLibrary string) error {
return t.tapLibsslPid(GLOABL_TAP_PID, sslLibrary, api.UNKNOWN_NAMESPACE) return t.tapSsllibPid(GLOABL_TAP_PID, sslLibrary, api.UNKNOWN_NAMESPACE)
} }
func (t *TlsTapper) GlobalGolangTap(_pid string) error { func (t *TlsTapper) GlobalGolangTap(_pid string) error {
@ -94,7 +94,7 @@ func (t *TlsTapper) AddSsllibPid(procfs string, pid uint32, namespace string) er
return nil // hide the error on purpose, its OK for a process to not use libssl.so return nil // hide the error on purpose, its OK for a process to not use libssl.so
} }
return t.tapLibsslPid(pid, sslLibrary, namespace) return t.tapSsllibPid(pid, sslLibrary, namespace)
} }
func (t *TlsTapper) AddGolangPid(pid uint32, namespace string) error { func (t *TlsTapper) AddGolangPid(pid uint32, namespace string) error {
@ -174,7 +174,7 @@ func setupRLimit() error {
return nil return nil
} }
func (t *TlsTapper) tapLibsslPid(pid uint32, sslLibrary string, namespace string) error { func (t *TlsTapper) tapSsllibPid(pid uint32, sslLibrary string, namespace string) error {
logger.Log.Infof("Tapping TLS (pid: %v) (sslLibrary: %v)", pid, sslLibrary) logger.Log.Infof("Tapping TLS (pid: %v) (sslLibrary: %v)", pid, sslLibrary)
newSsl := sslHooks{} newSsl := sslHooks{}