'Apply locking to the create snapshot operation.'

@coordination.synchronized('{self.driver_prefix}-{snapshot.volume.id}')
def create_snapshot(self, snapshot):

    return self._create_snapshot(snapshot)
