@@ -316,16 +316,16 @@ func verifyCMAPEvents(client *clientEntity, expectedEvents *expectedEvents) erro
316316 switch {
317317 case evt .ConnectionCreatedEvent != nil :
318318 if _ , pooled , err = getNextPoolEvent (pooled , event .ConnectionCreated ); err != nil {
319- return newEventVerificationError (idx , client , err .Error ())
319+ return newEventVerificationError (idx , client , "failed to get next pool event: %v" , err .Error ())
320320 }
321321 case evt .ConnectionReadyEvent != nil :
322322 if _ , pooled , err = getNextPoolEvent (pooled , event .ConnectionReady ); err != nil {
323- return newEventVerificationError (idx , client , err .Error ())
323+ return newEventVerificationError (idx , client , "failed to get next pool event: %v" , err .Error ())
324324 }
325325 case evt .ConnectionClosedEvent != nil :
326326 var actual * event.PoolEvent
327327 if actual , pooled , err = getNextPoolEvent (pooled , event .ConnectionClosed ); err != nil {
328- return newEventVerificationError (idx , client , err .Error ())
328+ return newEventVerificationError (idx , client , "failed to get next pool event: %v" , err .Error ())
329329 }
330330
331331 if expectedReason := evt .ConnectionClosedEvent .Reason ; expectedReason != nil {
@@ -335,12 +335,12 @@ func verifyCMAPEvents(client *clientEntity, expectedEvents *expectedEvents) erro
335335 }
336336 case evt .ConnectionCheckedOutEvent != nil :
337337 if _ , pooled , err = getNextPoolEvent (pooled , event .GetSucceeded ); err != nil {
338- return newEventVerificationError (idx , client , err .Error ())
338+ return newEventVerificationError (idx , client , "failed to get next pool event: %v" , err .Error ())
339339 }
340340 case evt .ConnectionCheckOutFailedEvent != nil :
341341 var actual * event.PoolEvent
342342 if actual , pooled , err = getNextPoolEvent (pooled , event .GetFailed ); err != nil {
343- return newEventVerificationError (idx , client , err .Error ())
343+ return newEventVerificationError (idx , client , "failed to get next pool event: %v" , err .Error ())
344344 }
345345
346346 if expectedReason := evt .ConnectionCheckOutFailedEvent .Reason ; expectedReason != nil {
@@ -350,12 +350,12 @@ func verifyCMAPEvents(client *clientEntity, expectedEvents *expectedEvents) erro
350350 }
351351 case evt .ConnectionCheckedInEvent != nil :
352352 if _ , pooled , err = getNextPoolEvent (pooled , event .ConnectionReturned ); err != nil {
353- return newEventVerificationError (idx , client , err .Error ())
353+ return newEventVerificationError (idx , client , "failed to get next pool event: %v" , err .Error ())
354354 }
355355 case evt .PoolClearedEvent != nil :
356356 var actual * event.PoolEvent
357357 if actual , pooled , err = getNextPoolEvent (pooled , event .PoolCleared ); err != nil {
358- return newEventVerificationError (idx , client , err .Error ())
358+ return newEventVerificationError (idx , client , "failed to get next pool event: %v" , err .Error ())
359359 }
360360 if expectServiceID := evt .PoolClearedEvent .HasServiceID ; expectServiceID != nil {
361361 if err := verifyServiceID (* expectServiceID , actual .ServiceID ); err != nil {
@@ -515,7 +515,7 @@ func verifySDAMEvents(client *clientEntity, expectedEvents *expectedEvents) erro
515515 case evt .ServerDescriptionChangedEvent != nil :
516516 var got * event.ServerDescriptionChangedEvent
517517 if got , changed , err = getNextServerDescriptionChangedEvent (changed ); err != nil {
518- return newEventVerificationError (idx , client , err .Error ())
518+ return newEventVerificationError (idx , client , "failed to get next server description changed event: %v" , err .Error ())
519519 }
520520
521521 prevDesc := evt .ServerDescriptionChangedEvent .NewDescription
@@ -546,7 +546,7 @@ func verifySDAMEvents(client *clientEntity, expectedEvents *expectedEvents) erro
546546 case evt .ServerHeartbeatStartedEvent != nil :
547547 var got * event.ServerHeartbeatStartedEvent
548548 if got , started , err = getNextServerHeartbeatStartedEvent (started ); err != nil {
549- return newEventVerificationError (idx , client , err .Error ())
549+ return newEventVerificationError (idx , client , "failed to get next server heartbeat started event: %v" , err .Error ())
550550 }
551551
552552 if want := evt .ServerHeartbeatStartedEvent .Awaited ; want != nil && * want != got .Awaited {
@@ -555,7 +555,7 @@ func verifySDAMEvents(client *clientEntity, expectedEvents *expectedEvents) erro
555555 case evt .ServerHeartbeatSucceededEvent != nil :
556556 var got * event.ServerHeartbeatSucceededEvent
557557 if got , succeeded , err = getNextServerHeartbeatSucceededEvent (succeeded ); err != nil {
558- return newEventVerificationError (idx , client , err .Error ())
558+ return newEventVerificationError (idx , client , "failed to get next server heartbeat succeeded event: %v" , err .Error ())
559559 }
560560
561561 if want := evt .ServerHeartbeatSucceededEvent .Awaited ; want != nil && * want != got .Awaited {
@@ -564,15 +564,15 @@ func verifySDAMEvents(client *clientEntity, expectedEvents *expectedEvents) erro
564564 case evt .ServerHeartbeatFailedEvent != nil :
565565 var got * event.ServerHeartbeatFailedEvent
566566 if got , failed , err = getNextServerHeartbeatFailedEvent (failed ); err != nil {
567- return newEventVerificationError (idx , client , err .Error ())
567+ return newEventVerificationError (idx , client , "failed to get next server heartbeat failed event: %v" , err .Error ())
568568 }
569569
570570 if want := evt .ServerHeartbeatFailedEvent .Awaited ; want != nil && * want != got .Awaited {
571571 return newEventVerificationError (idx , client , "want awaited %v, got %v" , * want , got .Awaited )
572572 }
573573 case evt .TopologyDescriptionChangedEvent != nil :
574574 if _ , tchanged , err = getNextTopologyDescriptionChangedEvent (tchanged ); err != nil {
575- return newEventVerificationError (idx , client , err .Error ())
575+ return newEventVerificationError (idx , client , "failed to get next description changed event: %v" , err .Error ())
576576 }
577577 }
578578 }
0 commit comments