|  | @@ -171,23 +171,30 @@ static void test_invoke_large_request(grpc_end2end_test_config config) {
 | 
	
		
			
				|  |  |    op->op = GRPC_OP_SEND_INITIAL_METADATA;
 | 
	
		
			
				|  |  |    op->data.send_initial_metadata.count = 0;
 | 
	
		
			
				|  |  |    op++;
 | 
	
		
			
				|  |  | +  op->op = GRPC_OP_RECV_MESSAGE;
 | 
	
		
			
				|  |  | +  op->data.recv_message = &request_payload_recv;
 | 
	
		
			
				|  |  | +  op++;
 | 
	
		
			
				|  |  | +  GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(s, ops, op - ops, tag(102)));
 | 
	
		
			
				|  |  | +
 | 
	
		
			
				|  |  | +  cq_expect_completion(v_server, tag(102), 1);
 | 
	
		
			
				|  |  | +  cq_verify(v_server);
 | 
	
		
			
				|  |  | +
 | 
	
		
			
				|  |  | +  op = ops;
 | 
	
		
			
				|  |  | +  op->op = GRPC_OP_RECV_CLOSE_ON_SERVER;
 | 
	
		
			
				|  |  | +  op->data.recv_close_on_server.cancelled = &was_cancelled;
 | 
	
		
			
				|  |  | +  op++;
 | 
	
		
			
				|  |  |    op->op = GRPC_OP_SEND_MESSAGE;
 | 
	
		
			
				|  |  |    op->data.send_message = response_payload;
 | 
	
		
			
				|  |  |    op++;
 | 
	
		
			
				|  |  | +  op = ops;
 | 
	
		
			
				|  |  |    op->op = GRPC_OP_SEND_STATUS_FROM_SERVER;
 | 
	
		
			
				|  |  |    op->data.send_status_from_server.trailing_metadata_count = 0;
 | 
	
		
			
				|  |  |    op->data.send_status_from_server.status = GRPC_STATUS_UNIMPLEMENTED;
 | 
	
		
			
				|  |  |    op->data.send_status_from_server.status_details = "xyz";
 | 
	
		
			
				|  |  |    op++;
 | 
	
		
			
				|  |  | -  op->op = GRPC_OP_RECV_MESSAGE;
 | 
	
		
			
				|  |  | -  op->data.recv_message = &request_payload_recv;
 | 
	
		
			
				|  |  | -  op++;
 | 
	
		
			
				|  |  | -  op->op = GRPC_OP_RECV_CLOSE_ON_SERVER;
 | 
	
		
			
				|  |  | -  op->data.recv_close_on_server.cancelled = &was_cancelled;
 | 
	
		
			
				|  |  | -  op++;
 | 
	
		
			
				|  |  | -  GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(s, ops, op - ops, tag(102)));
 | 
	
		
			
				|  |  | +  GPR_ASSERT(GRPC_CALL_OK == grpc_call_start_batch(s, ops, op - ops, tag(103)));
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  | -  cq_expect_completion(v_server, tag(102), 1);
 | 
	
		
			
				|  |  | +  cq_expect_completion(v_server, tag(103), 1);
 | 
	
		
			
				|  |  |    cq_verify(v_server);
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |    cq_expect_completion(v_client, tag(1), 1);
 |