valitydev/salt
14
0
Fork 0
mirror of https://github.com/valitydev/salt.git synced 2024-11-07 17:09:03 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity
78662d270b
salt/tests/integration/modules/event.py

124 lines
3.7 KiB
Python
Raw Normal View History

Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
# -*- coding: utf-8 -*-
'''
Header updates. More copyright to the SaltSatck team. Code author to me(where applicable).
2012-12-11 10:23:37 +00:00
:codeauthor: :email:`Pedro Algarvio (pedro@algarvio.me)`
Update copyright years of changed files. Added `__main__` execution to `tests/integration/states/pip.py`.
2013-06-25 07:57:26 +00:00
:copyright: © 2012-2013 by the SaltStack Team, see AUTHORS for more details
Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
:license: Apache 2.0, see LICENSE for more details.
Don't include authorship in generated documentation, the Sphinx way.
2013-09-16 16:24:00 +00:00
tests.integration.modules.event
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
'''
Header updates. More copyright to the SaltSatck team. Code author to me(where applicable).
2012-12-11 10:23:37 +00:00
# Import python libs
Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
import time
import threading
from Queue import Queue, Empty
Updated `integration.modules.event` test suite to use `salttesting.helpers.ensure_in_syspath()`
2013-06-27 11:02:41 +00:00
# Import Salt Testing libs
from salttesting.helpers import ensure_in_syspath
ensure_in_syspath('../../')
Header updates. More copyright to the SaltSatck team. Code author to me(where applicable).
2012-12-11 10:23:37 +00:00
# Import salt libs
Updated `integration.modules.event` test suite to use `salttesting.helpers.ensure_in_syspath()`
2013-06-27 11:02:41 +00:00
import integration
Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
from salt.utils import event
Header updates. More copyright to the SaltSatck team. Code author to me(where applicable).
2012-12-11 10:23:37 +00:00
Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
class EventModuleTest(integration.ModuleCase):
stub out event fireing test until we can acertain what is wrong The events are getting cleanly fired, but the test is failing....
2013-03-11 23:09:56 +00:00
def __test_event_fire_master(self):
Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
events = Queue()
def get_event(events):
me = event.MasterEvent(self.master_opts['sock_dir'])
events.put_nowait(
Try not to fail on travis-ci under python 2.6 * Raised max open files by 1024 since running in a vagrant machine 2048 was not enough, though, I think travis-ci defaults to a higher value. * Wait a bit longer on the events testing. * Separated the initial minions connected and minions synced into two different events and functions. Also corrected the `if` expected value when a timeout occurs.
2012-11-06 16:02:36 +00:00
me.get_event(wait=10, tag='salttest', full=False)
Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
)
threading.Thread(target=get_event, args=(events,)).start()
time.sleep(1) # Allow multiprocessing.Process to start
ret = self.run_function(
'event.fire_master',
['event.fire_master: just test it!!!!', 'salttest']
)
self.assertTrue(ret)
Try not to fail on travis-ci under python 2.6 * Raised max open files by 1024 since running in a vagrant machine 2048 was not enough, though, I think travis-ci defaults to a higher value. * Wait a bit longer on the events testing. * Separated the initial minions connected and minions synced into two different events and functions. Also corrected the `if` expected value when a timeout occurs.
2012-11-06 16:02:36 +00:00
eventfired = events.get(block=True, timeout=10)
Add None checks for eventfired in event.py
2013-02-08 00:51:08 +00:00
self.assertIsNotNone(eventfired)
Header updates. More copyright to the SaltSatck team. Code author to me(where applicable).
2012-12-11 10:23:37 +00:00
self.assertIn(
'event.fire_master: just test it!!!!', eventfired['data']
)
Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
ret = self.run_function(
'event.fire_master',
['event.fire_master: just test it!!!!', 'salttest-miss']
)
self.assertTrue(ret)
with self.assertRaises(Empty):
Try not to fail on travis-ci under python 2.6 * Raised max open files by 1024 since running in a vagrant machine 2048 was not enough, though, I think travis-ci defaults to a higher value. * Wait a bit longer on the events testing. * Separated the initial minions connected and minions synced into two different events and functions. Also corrected the `if` expected value when a timeout occurs.
2012-11-06 16:02:36 +00:00
eventfired = events.get(block=True, timeout=10)
Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
Stub out unreliable event test until it can be stabalized
2013-02-08 18:07:40 +00:00
def __test_event_fire(self):
Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
events = Queue()
def get_event(events):
me = event.MinionEvent(**self.minion_opts)
events.put_nowait(
Try not to fail on travis-ci under python 2.6 * Raised max open files by 1024 since running in a vagrant machine 2048 was not enough, though, I think travis-ci defaults to a higher value. * Wait a bit longer on the events testing. * Separated the initial minions connected and minions synced into two different events and functions. Also corrected the `if` expected value when a timeout occurs.
2012-11-06 16:02:36 +00:00
me.get_event(wait=10, tag='salttest', full=False)
Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
)
threading.Thread(target=get_event, args=(events,)).start()
time.sleep(1) # Allow multiprocessing.Process to start
ret = self.run_function(
'event.fire', ['event.fire: just test it!!!!', 'salttest']
)
self.assertTrue(ret)
Try not to fail on travis-ci under python 2.6 * Raised max open files by 1024 since running in a vagrant machine 2048 was not enough, though, I think travis-ci defaults to a higher value. * Wait a bit longer on the events testing. * Separated the initial minions connected and minions synced into two different events and functions. Also corrected the `if` expected value when a timeout occurs.
2012-11-06 16:02:36 +00:00
eventfired = events.get(block=True, timeout=10)
Add None checks for eventfired in event.py
2013-02-08 00:51:08 +00:00
self.assertIsNotNone(eventfired)
Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
self.assertIn('event.fire: just test it!!!!', eventfired)
ret = self.run_function(
'event.fire', ['event.fire: just test it!!!!', 'salttest-miss']
)
self.assertTrue(ret)
with self.assertRaises(Empty):
Try not to fail on travis-ci under python 2.6 * Raised max open files by 1024 since running in a vagrant machine 2048 was not enough, though, I think travis-ci defaults to a higher value. * Wait a bit longer on the events testing. * Separated the initial minions connected and minions synced into two different events and functions. Also corrected the `if` expected value when a timeout occurs.
2012-11-06 16:02:36 +00:00
eventfired = events.get(block=True, timeout=10)
Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
stub out another event test that needs refinement
2013-02-08 20:14:45 +00:00
def __test_event_fire_ipc_mode_tcp(self):
Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
events = Queue()
def get_event(events):
me = event.MinionEvent(**self.sub_minion_opts)
events.put_nowait(
Try not to fail on travis-ci under python 2.6 * Raised max open files by 1024 since running in a vagrant machine 2048 was not enough, though, I think travis-ci defaults to a higher value. * Wait a bit longer on the events testing. * Separated the initial minions connected and minions synced into two different events and functions. Also corrected the `if` expected value when a timeout occurs.
2012-11-06 16:02:36 +00:00
me.get_event(wait=10, tag='salttest', full=False)
Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
)
threading.Thread(target=get_event, args=(events,)).start()
time.sleep(1) # Allow multiprocessing.Process to start
ret = self.run_function(
'event.fire', ['event.fire: just test it!!!!', 'salttest'],
minion_tgt='sub_minion'
)
self.assertTrue(ret)
Try not to fail on travis-ci under python 2.6 * Raised max open files by 1024 since running in a vagrant machine 2048 was not enough, though, I think travis-ci defaults to a higher value. * Wait a bit longer on the events testing. * Separated the initial minions connected and minions synced into two different events and functions. Also corrected the `if` expected value when a timeout occurs.
2012-11-06 16:02:36 +00:00
eventfired = events.get(block=True, timeout=10)
Add None checks for eventfired in event.py
2013-02-08 00:51:08 +00:00
self.assertIsNotNone(eventfired)
Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
self.assertIn('event.fire: just test it!!!!', eventfired)
ret = self.run_function(
'event.fire', ['event.fire: just test it!!!!', 'salttest-miss'],
minion_tgt='sub_minion'
)
self.assertTrue(ret)
with self.assertRaises(Empty):
Try not to fail on travis-ci under python 2.6 * Raised max open files by 1024 since running in a vagrant machine 2048 was not enough, though, I think travis-ci defaults to a higher value. * Wait a bit longer on the events testing. * Separated the initial minions connected and minions synced into two different events and functions. Also corrected the `if` expected value when a timeout occurs.
2012-11-06 16:02:36 +00:00
eventfired = events.get(block=True, timeout=10)
Add tests for saltstack/salt#1900 * Test both master and minion events firing * Allow targeting the minions in `tests.integration.ModuleCase.run_function()` * The above item allows to also test events firing using `tcp` as `ipc_mode` which is being used by the tests `sub_minion`
2012-09-01 06:29:06 +00:00
if __name__ == '__main__':
from integration import run_tests
run_tests(EventModuleTest)
Reference in New Issue Copy Permalink