D4
/
analyzer-d4-log
mirror of https://github.com/D4-project/analyzer-d4-log
2
0
Fork 0
Code Issues Releases Wiki Activity

add: [sshd] typos

nifi
Jean-Louis Huynen 2020-06-08 17:25:31 +02:00
parent 5bb4df40e8
commit a158868857
No known key found for this signature in database
GPG Key ID: 64799157F4BD6B93
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
logcompiler/compiler.go
View File

@ -14,7 +14,7 @@ type (
// It should provide:
// Set to assign a redis connection to it
// Parse to parse a line of log
// Flush recomputes statisitcs and recompile output
// Flush recomputes statistics and recompile output
Compiler interface {
Set(*sync.WaitGroup, *redis.Conn, *redis.Conn, io.Reader, int, *sync.WaitGroup, *chan error, time.Duration)
SetReader(io.Reader)

6
logcompiler/sshd.go
View File

@ -97,13 +97,13 @@ func (s *SSHDCompiler) Pull(c chan error) {
r1 := *s.r1
for {
jsoner := json.NewDecoder(s.reader)
jsoner := json.NewDecoder(s.reader)
DecodeLoop:
for jsoner.More() {
var m GrokedSSHD
err := jsoner.Decode(&m)
if err := jsoner.Decode(&m); err == io.EOF {
// On EOF we break this loop to go to a sleep
// On EOF we break this loop to go to a sleep
break DecodeLoop
} else if err != nil {
s.teardown(err)
@ -532,7 +532,7 @@ func csvStats(s *SSHDCompiler, v string) error {
return nil
}
func MISPexport(s *SSHDCompiler) error {
func (s *SSHDCompiler) MISPexport() error {
today := time.Now()
dstr := fmt.Sprintf("%v%v%v", today.Year(), fmt.Sprintf("%02d", int(today.Month())), fmt.Sprintf("%02d", int(today.Day())))