'Test _create_volume_replica.'

def test_create_volume_replica(self):

    vg = FakeSaveObject()
    rep = Replication()
    self.driver.replica = rep
    session_name = self.driver.get_session_name('1234567890987654321')
    self.assertEqual('ssn-1234567890987654321', session_name)
    rsession_name = self.driver.get_rep_name(session_name)
    self.assertEqual('rssn-1234567890987654321', rsession_name)
    src_ssn = self.driver.client.new('replication/sessions').save()
    self.assertEqual('in_sync', src_ssn.state)
    result = self.driver._create_volume_replica(self.vol, vg, vg, rep.rpo)
    self.assertIsNone(result)
