Skip to content

Commit

Permalink
remove unneeded function
Browse files Browse the repository at this point in the history
  • Loading branch information
moh-osman3 committed May 7, 2024
1 parent 4f59f0e commit f925e98
Showing 1 changed file with 0 additions and 24 deletions.
24 changes: 0 additions & 24 deletions collector/processor/concurrentbatchprocessor/batch_processor.go
Original file line number Diff line number Diff line change
Expand Up @@ -433,30 +433,6 @@ func allSame(x []context.Context) bool {
return true
}

func equalMaps(m1, m2 map[string][]string) bool {
if len(m1) != len(m2) {
return false
}

for key, val1 := range m1 {
if val2, ok := m2[key]; ok {
if len(val1) != len(val2) {
return false
}

for idx := range val1 {
if val1[idx] != val2[idx] {
return false
}
}
} else { // key not found
return false
}
}

return true
}

func (bp *batchProcessor) countAcquire(ctx context.Context, bytes int64) error {
err := bp.sem.Acquire(ctx, bytes)
if err == nil && bp.telemetry.batchInFlightBytes != nil {
Expand Down

0 comments on commit f925e98

Please sign in to comment.