Merge pull request #525 from toni-moreno/fix/udp_closed_mm

fix: fix already closed connections on multiindex measurements
toni-moreno · Nov 15, 2022 · d645bf2 · d645bf2
2 parents c92f015 + dfdee63
commit d645bf2
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 2 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,13 @@
+# v0.13.1 ( 2022-11-15 )
+
+### New Features
+
+### Fixes
+
+* fix #524
+
+### breaking changes
+
 # v0.13.0 ( 2022-02-16 )
 
 ### New Features

diff --git a/package.json b/package.json
@@ -4,7 +4,7 @@
     "company": "Toni Inc"
   },
   "name": "snmpcollector",
-  "version": "0.12.0",
+  "version": "0.13.1",
   "repository": {
     "type": "git",
     "url": "http://github.com/toni-moreno/snmpcollector.git"

diff --git a/pkg/data/measurement/measurement.go b/pkg/data/measurement/measurement.go
@@ -196,7 +196,8 @@ func (m *Measurement) InitMultiIndex() error {
 
 		// create entirely new measurement based on provided CFG
 		mm := New(&mcfg, m.measFilters, m.mFilters, m.Active, m.Log)
-		mm.SetSNMPClient(*m.snmpClient)
+		// use same pointer on same snmpClient as multimeas inherits connection flow from the main measurement
+		mm.snmpClient = m.snmpClient
 		err := mm.Init()
 		if err != nil {
 			return fmt.Errorf("init multi measurement %s..%s", m.ID, v.Label)
@@ -797,6 +798,7 @@ func (m *Measurement) loadIndexedLabels() (map[string]string, error) {
 	}
 	// needed to get data for different indexes
 	m.curIdxPos = m.idxPosInOID
+
 	err := m.snmpClient.Walk(m.cfg.IndexOID, setRawData)
 	if err != nil {
 		m.Log.Errorf("LOADINDEXEDLABELS - SNMP WALK error: %s", err)