@@ -503,7 +503,6 @@ mongoc_cluster_run_command_monitored (mongoc_cluster_t *cluster,
503
503
const mongoc_server_stream_t * server_stream ;
504
504
bson_t reply_local ;
505
505
bson_error_t error_local ;
506
- int32_t compressor_id ;
507
506
bson_iter_t iter ;
508
507
bson_t encrypted = BSON_INITIALIZER ;
509
508
bson_t decrypted = BSON_INITIALIZER ;
@@ -512,7 +511,6 @@ mongoc_cluster_run_command_monitored (mongoc_cluster_t *cluster,
512
511
513
512
server_stream = cmd -> server_stream ;
514
513
server_id = server_stream -> sd -> id ;
515
- compressor_id = mongoc_server_description_compressor_id (server_stream -> sd );
516
514
517
515
callbacks = & cluster -> client -> apm_callbacks ;
518
516
if (!reply ) {
@@ -545,13 +543,7 @@ mongoc_cluster_run_command_monitored (mongoc_cluster_t *cluster,
545
543
mongoc_apm_command_started_cleanup (& started_event );
546
544
}
547
545
548
- if (mongoc_cluster_uses_server_api (cluster ) ||
549
- server_stream -> sd -> max_wire_version >= WIRE_VERSION_MIN ) {
550
- retval = mongoc_cluster_run_opmsg (cluster , cmd , reply , error );
551
- } else {
552
- retval = mongoc_cluster_run_command_opquery (
553
- cluster , cmd , compressor_id , reply , error );
554
- }
546
+ retval = mongoc_cluster_run_opmsg (cluster , cmd , reply , error );
555
547
556
548
if (retval && callbacks -> succeeded ) {
557
549
bson_t fake_reply = BSON_INITIALIZER ;
0 commit comments