Thomas Jackson
58c16f2714
Rough-in of io_loop in minion
2015-04-07 20:53:24 -07:00
Thomas Jackson
87508754b6
Logging cleanup
2015-04-07 20:53:24 -07:00
Thomas Jackson
759f5b3973
consolidate master-side transport parsing
2015-04-07 20:53:24 -07:00
Thomas Jackson
b192602af6
Switch Req client over to tornado based client
2015-04-07 20:53:24 -07:00
Thomas Jackson
d2bfe50e23
Very basic zmq and tcp support
2015-04-07 20:53:24 -07:00
Thomas Jackson
c1b41b2bee
Migrate zeromq channel over to ioloop as well
2015-04-07 20:53:24 -07:00
Thomas Jackson
35977e42f9
Misc cleanup
2015-04-07 20:53:24 -07:00
Thomas Jackson
9d606294dd
Add un-tested SaltMessageClient
2015-04-07 20:53:23 -07:00
Thomas Jackson
5bee5649db
Switch ReqServer over to IOLoop
2015-04-07 20:53:23 -07:00
Thomas Jackson
b1bb0d62d2
fix typo
2015-04-07 20:53:23 -07:00
Thomas Jackson
2336b338c5
Allow passing in of header
2015-04-07 20:53:23 -07:00
Thomas Jackson
0b035341a5
move publisher to IOLoop
2015-04-07 20:53:23 -07:00
Thomas Jackson
4ff4bfb8f3
Cleanup shutdown of publisher
2015-04-07 20:53:23 -07:00
Thomas Jackson
8815bf312c
Fix socket recv_frame
2015-04-07 20:53:23 -07:00
Thomas Jackson
ae0d92a059
Don't make a copy of the list to iterate (it might be very large). Instead keep a list of who to remove
2015-04-07 20:53:23 -07:00
Thomas Jackson
de21707673
cleanup
2015-04-07 20:53:23 -07:00
Thomas Jackson
b7f4fc25b4
Remove rep_hwm (doesn't do anything)
2015-04-07 20:53:23 -07:00
Thomas Jackson
fb107b0df2
Whitespace cleanup
2015-04-07 20:53:23 -07:00
Thomas Jackson
5492036411
Misc cleanup
2015-04-07 20:53:22 -07:00
Thomas Jackson
543c56d969
Revert register poller, we'll just have the minion exit
2015-04-07 20:53:22 -07:00
Thomas Jackson
6d372d7326
ReqChannel cleanup
...
- Remove recv_noblock from ReqServer channel
- keepalive
- epoll
2015-04-07 20:53:22 -07:00
Thomas Jackson
374d4154ab
Re-work PubChannel
...
- add register_poller (since some people need to change the FD (on failure etc)
- remove recv_noblock
2015-04-07 20:53:22 -07:00
Thomas Jackson
fc83b44fae
Major overhaul of tcp implementation
...
Now using the same crypto stuff as the zeromq implementation
2015-04-07 20:53:22 -07:00
Thomas Jackson
11195c4f2c
Cleanup pubchannel polling
...
zmq poller returns either zmq socket objects of raw FDs. adding an API in the clients to differentiate
2015-04-07 20:53:22 -07:00
Thomas Jackson
5731a01209
Remove testing code
2015-04-07 20:53:22 -07:00
Thomas Jackson
4bd71f9448
More hacking to get tcp working
2015-04-07 20:53:22 -07:00
Thomas Jackson
6fb0ec1edc
Initial addition of tcp channel
2015-04-07 20:53:22 -07:00
Thomas Jackson
0a0caf6304
Hacking to fix various things broken in rebase
2015-04-07 20:53:22 -07:00
Thomas Jackson
8e0316d613
Misc cleanup
2015-04-07 20:53:22 -07:00
Thomas Jackson
0ddd4ec04b
Migrate _auth logic into the ReqServerChannel
2015-04-07 20:53:22 -07:00
Thomas Jackson
ea49cbc628
Change req_fun default to send (which is encrypted)
2015-04-07 20:53:21 -07:00
Thomas Jackson
422d1c28a3
Re-work req_channel in the master daemons, now we don't pass it down the stack, the master-side funcs need to return a dict of opts which specify which send_func to use
2015-04-07 20:53:21 -07:00
Thomas Jackson
8c66c4e857
Initial move of publisher into PubServerChannel
2015-04-07 20:53:21 -07:00
Thomas Jackson
f128e47240
Initial migration of master-side ReqChannels
...
This is an attempt to pull all transport/crypto logic out of the core master classes.
Once this is completed we should be able to re-use all of this code for all transport types
2015-04-07 20:53:21 -07:00
Thomas Jackson
5ae95fff58
Rename channel to client
...
A bit more clear since there are client and server-side classes
2015-04-07 20:53:21 -07:00
Thomas Jackson
1ffac59056
Add local channel to factory
2015-04-07 20:53:21 -07:00
Thomas Jackson
5e661b0cbc
Pull all fallback cleanup into its own function
2015-04-07 20:53:21 -07:00
Thomas Jackson
10e3ec870f
Remove old refs to _init_context_and_poller
2015-04-07 20:53:21 -07:00
Thomas Jackson
fef2e38888
Remove some noe-deprecated and unused functions
2015-04-07 20:53:21 -07:00
Thomas Jackson
2b0d1e5cd3
Refactor minion events to be their own class instead of spread throughout the minion classes
2015-04-07 20:53:21 -07:00
Thomas Jackson
21624eb20e
Remove all final references to self.socket from minion.py
2015-04-07 20:53:21 -07:00
Thomas Jackson
d406b2e1da
Add "socket" interface to pub_channel, so we can wire it into regular pollers
2015-04-07 20:53:21 -07:00
Thomas Jackson
7bbfba2797
More migration to PubChannel
2015-04-07 20:53:20 -07:00
Thomas Jackson
645eaf084b
Cleanup print from debugging
2015-04-07 20:53:20 -07:00
Thomas Jackson
87fb069e05
Implement timeout for PubChannel.recv()
2015-04-07 20:53:20 -07:00
Thomas Jackson
3290c32659
Remove some unused imports
2015-04-07 20:53:20 -07:00
Thomas Jackson
064896d4d9
Update commented out version as well
2015-04-07 20:53:20 -07:00
Thomas Jackson
e376b283ef
Refactor the start_daemon function
2015-04-07 20:53:20 -07:00
Thomas Jackson
403c81c2a6
Move daemon init and execution into the same process.
...
These daemon processes aren't all thread safe, so having the test suite init then fork is disingenuous since that isn't supported anyways.
2015-04-07 20:53:20 -07:00
Thomas Jackson
8996493152
Misc cleanup after rebase
2015-04-07 20:53:20 -07:00
