Lock central call to Adabas

Author: thknieling

adabas/adabasstructure.go

@@ -22,6 +22,7 @@ package adabas
 import (
 	"bytes"
 	"fmt"
+	"sync"
 	"sync/atomic"
 	"time"
 	"unsafe"
@@ -167,6 +168,7 @@ type Status struct {
 	platform         *adatypes.Platform
 	adabas           *Adabas
 	version          string
+	lock             sync.Mutex
 }
 
 // ID Adabas Id

adabas/call.go

@@ -69,6 +69,9 @@ func NewAdabasID() *ID {
 // AdabasClient library support
 func (adabas *Adabas) CallAdabas() (err error) {
 	defer TimeTrack(time.Now(), "Call adabas", adabas)
+	s := adabas.status
+	s.lock.Lock()
+	defer s.lock.Unlock()
 
 	if adatypes.Central.IsDebugLevel() {
 		adatypes.Central.Log.Debugf("Send calling CC %c%c adabasp=%p URL=%s Adabas ID=%v",

adabas/rcall.go

@@ -69,6 +69,9 @@ func NewAdabasID() *ID {
 // AdabasClient library support
 func (adabas *Adabas) CallAdabas() (err error) {
 	defer TimeTrack(time.Now(), "RCall adabas", adabas)
+	s := adabas.status
+	s.lock.Lock()
+	defer s.lock.Unlock()
 
 	if adatypes.Central.IsDebugLevel() {
 		adatypes.Central.Log.Debugf("Call Adabas (local disabled) adabasp=%p  %s%v", adabas, adabas.URL.String(), adabas.ID.String())