Mark D. Roth пре 8 година
родитељ
комит
9d76dbe5d3
2 измењених фајлова са 3 додато и 4 уклоњено
  1. 2 2
      src/core/lib/surface/call.c
  2. 1 2
      test/core/end2end/fuzzers/api_fuzzer.c

+ 2 - 2
src/core/lib/surface/call.c

@@ -1478,8 +1478,8 @@ static grpc_call_error call_start_batch(grpc_exec_ctx *exec_ctx,
         /* If the outgoing buffer is already compressed, mark it as so in the
         /* If the outgoing buffer is already compressed, mark it as so in the
            flags. These will be picked up by the compression filter and further
            flags. These will be picked up by the compression filter and further
            (wasteful) attempts at compression skipped. */
            (wasteful) attempts at compression skipped. */
-        if (op->data.send_message.send_message->data.raw.compression
-            > GRPC_COMPRESS_NONE) {
+        if (op->data.send_message.send_message->data.raw.compression >
+            GRPC_COMPRESS_NONE) {
           call->sending_stream.base.flags |= GRPC_WRITE_INTERNAL_COMPRESS;
           call->sending_stream.base.flags |= GRPC_WRITE_INTERNAL_COMPRESS;
         }
         }
         stream_op->send_message = &call->sending_stream.base;
         stream_op->send_message = &call->sending_stream.base;

+ 1 - 2
test/core/end2end/fuzzers/api_fuzzer.c

@@ -934,8 +934,7 @@ int LLVMFuzzerTestOneInput(const uint8_t *data, size_t size) {
               } else {
               } else {
                 has_ops |= 1 << GRPC_OP_SEND_MESSAGE;
                 has_ops |= 1 << GRPC_OP_SEND_MESSAGE;
                 g_active_call->send_message =
                 g_active_call->send_message =
-                    op->data.send_message.send_message =
-                    read_message(&inp);
+                    op->data.send_message.send_message = read_message(&inp);
               }
               }
               break;
               break;
             case GRPC_OP_SEND_CLOSE_FROM_CLIENT:
             case GRPC_OP_SEND_CLOSE_FROM_CLIENT: