@@ -316,16 +316,16 @@ func verifyCMAPEvents(client *clientEntity, expectedEvents *expectedEvents) erro
316316switch {
317317case evt .ConnectionCreatedEvent != nil :
318318if _ , 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}
321321case evt .ConnectionReadyEvent != nil :
322322if _ , 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}
325325case evt .ConnectionClosedEvent != nil :
326326var actual * event.PoolEvent
327327if 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
331331if expectedReason := evt .ConnectionClosedEvent .Reason ; expectedReason != nil {
@@ -335,12 +335,12 @@ func verifyCMAPEvents(client *clientEntity, expectedEvents *expectedEvents) erro
335335}
336336case evt .ConnectionCheckedOutEvent != nil :
337337if _ , 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}
340340case evt .ConnectionCheckOutFailedEvent != nil :
341341var actual * event.PoolEvent
342342if 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
346346if expectedReason := evt .ConnectionCheckOutFailedEvent .Reason ; expectedReason != nil {
@@ -350,12 +350,12 @@ func verifyCMAPEvents(client *clientEntity, expectedEvents *expectedEvents) erro
350350}
351351case evt .ConnectionCheckedInEvent != nil :
352352if _ , 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}
355355case evt .PoolClearedEvent != nil :
356356var actual * event.PoolEvent
357357if 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}
360360if expectServiceID := evt .PoolClearedEvent .HasServiceID ; expectServiceID != nil {
361361if err := verifyServiceID (* expectServiceID , actual .ServiceID ); err != nil {
@@ -515,7 +515,7 @@ func verifySDAMEvents(client *clientEntity, expectedEvents *expectedEvents) erro
515515case evt .ServerDescriptionChangedEvent != nil :
516516var got * event.ServerDescriptionChangedEvent
517517if 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
521521prevDesc := evt .ServerDescriptionChangedEvent .NewDescription
@@ -546,7 +546,7 @@ func verifySDAMEvents(client *clientEntity, expectedEvents *expectedEvents) erro
546546case evt .ServerHeartbeatStartedEvent != nil :
547547var got * event.ServerHeartbeatStartedEvent
548548if 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
552552if want := evt .ServerHeartbeatStartedEvent .Awaited ; want != nil && * want != got .Awaited {
@@ -555,7 +555,7 @@ func verifySDAMEvents(client *clientEntity, expectedEvents *expectedEvents) erro
555555case evt .ServerHeartbeatSucceededEvent != nil :
556556var got * event.ServerHeartbeatSucceededEvent
557557if 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
561561if want := evt .ServerHeartbeatSucceededEvent .Awaited ; want != nil && * want != got .Awaited {
@@ -564,15 +564,15 @@ func verifySDAMEvents(client *clientEntity, expectedEvents *expectedEvents) erro
564564case evt .ServerHeartbeatFailedEvent != nil :
565565var got * event.ServerHeartbeatFailedEvent
566566if 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
570570if want := evt .ServerHeartbeatFailedEvent .Awaited ; want != nil && * want != got .Awaited {
571571return newEventVerificationError (idx , client , "want awaited %v, got %v" , * want , got .Awaited )
572572}
573573case evt .TopologyDescriptionChangedEvent != nil :
574574if _ , 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