Commit Graph

50627 Commits

Author SHA1 Message Date
Thomas Jackson
bdbf6a33d2 misc cleanup 2015-04-07 20:53:26 -07:00
Thomas Jackson
6ab5da87c4 Cleanup async 2015-04-07 20:53:26 -07:00
Thomas Jackson
de26e7eae2 Handle timeouts in auth/pub connect 2015-04-07 20:53:26 -07:00
Thomas Jackson
8c7ee3109d Begin work on async auth/pub/req channels.
For a while we'll have to maintin sync and async versions. The plan is to replace the sync ones with wraps around the async ones.
2015-04-07 20:53:26 -07:00
Thomas Jackson
1a88eeeed4 Add basic Pub channel tests 2015-04-07 20:53:26 -07:00
Thomas Jackson
d619dfbf96 Add initial req_channel tests 2015-04-07 20:53:26 -07:00
Thomas Jackson
00021ce7f4 Pylint 2015-04-07 20:53:26 -07:00
Thomas Jackson
4baec173b5 Remove unecessary imports 2015-04-07 20:53:26 -07:00
Thomas Jackson
b9d03c5307 Remove recv() from pub_channels (now we use on_recv) 2015-04-07 20:53:26 -07:00
Thomas Jackson
9094c10a1b Since each minion object handles its own events, lets not double send :) 2015-04-07 20:53:25 -07:00
Thomas Jackson
4dd74a17a4 Remove Event poller (since we are doing IOLoops now) 2015-04-07 20:53:25 -07:00
Thomas Jackson
9cda2f03d6 Cleanup multiminion to work on the ioloop 2015-04-07 20:53:25 -07:00
Thomas Jackson
e11a914cb2 Add support for un-registering the on_recv 2015-04-07 20:53:25 -07:00
Thomas Jackson
1392cd6638 Add timeouts to tcp implementation 2015-04-07 20:53:25 -07:00
Thomas Jackson
5fb59c8692 Cleanup some IOLoops 2015-04-07 20:53:25 -07:00
Thomas Jackson
714e61f116 Don't set 'enc' to clear on clear returns, some jobs don't return dicts 2015-04-07 20:53:25 -07:00
Thomas Jackson
71c8deaddb loop_interval is a float, lets leave it that way 2015-04-07 20:53:25 -07:00
Thomas Jackson
180408eae0 Make publisher not wait for writes 2015-04-07 20:53:25 -07:00
Thomas Jackson
034df057c6 Last switch over to iter_transport_opts (support 1->N transports) 2015-04-07 20:53:25 -07:00
Thomas Jackson
f22539d3b1 Make SaltMessageClient auto-reconnect 2015-04-07 20:53:25 -07:00
Thomas Jackson
78b69b1f63 Add scheduler 2015-04-07 20:53:25 -07:00
Thomas Jackson
54f476005f cleanup 2015-04-07 20:53:24 -07:00
Thomas Jackson
58982b0352 Cleanup pub channel
Move to on_recv, remove old poller interfaces
2015-04-07 20:53:24 -07:00
Thomas Jackson
8ab5fdc36d Basic multisyndic working now 2015-04-07 20:53:24 -07:00
Thomas Jackson
798c062d86 Misc cleanup to single minion 2015-04-07 20:53:24 -07:00
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