Thomas Jackson
f6e239a4eb
pylint cleanup
2015-04-08 08:10:20 -07:00
Thomas Jackson
6b3d1bcb76
pylint cleanup
2015-04-08 08:09:30 -07:00
Thomas Jackson
5c7df1431b
pylint cleanup
2015-04-08 08:08:42 -07:00
Thomas Jackson
4ee8c2e091
pylint cleanup
2015-04-08 08:08:30 -07:00
Thomas Jackson
a30a0f8887
pylint cleanup
2015-04-08 08:06:16 -07:00
Thomas Jackson
2683843bdf
pylint cleanup
2015-04-08 08:04:45 -07:00
Thomas Jackson
cc06dd620d
Pylint
2015-04-08 08:04:02 -07:00
Thomas Jackson
171bd327d1
Pylint cleanup in TCP transport module
2015-04-08 08:03:16 -07:00
Thomas Jackson
9ad56d48ce
Pylint
2015-04-08 07:59:26 -07:00
Thomas Jackson
098515b3ff
Pylint
2015-04-08 07:58:29 -07:00
Thomas Jackson
348118ff6d
Mock/stub out _send_pub in ClearFuncs
...
Before we were attempting to serialize a MagicMock object
2015-04-07 21:36:13 -07:00
Thomas Jackson
bf97e8c16f
Make sure to close server processes after each test.
...
Waiting for the destructor doesn't necessarily work, since its not gauranteed to run immediately.
2015-04-07 21:25:53 -07:00
Thomas Jackson
f5e2650227
Add basic tests for asyncEventpublisher
2015-04-07 21:01:43 -07:00
Thomas Jackson
0f4126a13e
Cleanup AsyncEvent publisher
...
And remove PollingEventPublisher
2015-04-07 21:01:43 -07:00
Thomas Jackson
cb02d0e021
Remove "close()" api-- just use a destructor
2015-04-07 21:01:43 -07:00
Thomas Jackson
d21e180a5a
Fix race condition in integration test startup
2015-04-07 21:01:43 -07:00
Thomas Jackson
dfd606a365
Add tornado dependancy
2015-04-07 21:01:43 -07:00
Thomas Jackson
1e38bd173f
Fix merge
2015-04-07 21:01:43 -07:00
Thomas Jackson
b673dcf540
Lint cleanup
2015-04-07 21:01:43 -07:00
Thomas Jackson
396f021b20
More cleanup of tcp wire framing-- pushing msgpacks down a layer
2015-04-07 21:01:43 -07:00
Thomas Jackson
0363cf3e2e
Simplify TCP wire protocol
2015-04-07 21:01:42 -07:00
Thomas Jackson
2781cb83c1
Make sure to hand out RAET channels on the old interface
2015-04-07 21:01:42 -07:00
Thomas Jackson
3b5281f34f
Term context of AsyncEventPublisher on destroy()
2015-04-07 21:01:42 -07:00
Thomas Jackson
bedde63f62
SNDTIMEO is not implemented in pyzmq, and since we are using linger this gets us the same thing
2015-04-07 21:01:42 -07:00
Thomas Jackson
d87c62b453
Make transport unit tests pull configs from test suite instead of from /etc/salt
2015-04-07 21:01:42 -07:00
Thomas Jackson
d626d83c7d
Handle case where we miss first sign-in
2015-04-07 21:01:42 -07:00
Thomas Jackson
02995a1055
Fix calls to send() to not specify a callback of int
2015-04-07 21:01:42 -07:00
Thomas Jackson
ec4a777c37
Share creds between all channels (if you can).
...
This allows sync and async callers to Auth to have access to the same creds.
2015-04-07 21:01:42 -07:00
Thomas Jackson
e17824a0b1
Change _handle_payload to return a future.
...
This means we can make more and more of the core async (using coroutines) without having to change the transport modules-- as they all already expect futures.
2015-04-07 21:01:15 -07:00
Thomas Jackson
9affc2d896
Overwrite the current IOLoop for blocking calls
...
This adds a context manager which will temporarily overwrite the current ioloop for these blocking calls. This way you can safely call blocking methods which are made on top of ioloops without library methods attaching your future to the wrong ioloop.
2015-04-07 21:01:07 -07:00
Thomas Jackson
e372de40fc
Cleanup auth future, and pass io_loop to instance
2015-04-07 20:53:29 -07:00
Thomas Jackson
b3300527c1
Better message_id handling
...
This caps the number of inflight messages to maxint on the system, so we can wrap the message IDs instead of forever increasing in size
2015-04-07 20:53:29 -07:00
Thomas Jackson
98842a86da
Fix zmq pub channels
2015-04-07 20:53:29 -07:00
Thomas Jackson
61eb58ccf7
Migrate zeromq req channel to async interfaces
2015-04-07 20:53:29 -07:00
Thomas Jackson
cb922635f1
Attempt to return nice errors even if it wasn't properly msgpackd
2015-04-07 20:53:29 -07:00
Thomas Jackson
b625b01650
Properly bubble up auth failures to the future
2015-04-07 20:53:29 -07:00
Thomas Jackson
d325de0b0a
Fix exceptional case where no timeout is set
2015-04-07 20:53:29 -07:00
Thomas Jackson
49603ffc9e
Add weakref to SAuth
2015-04-07 20:53:29 -07:00
Thomas Jackson
8ec07297fa
Change the Auth base class to AsyncAuth
2015-04-07 20:53:29 -07:00
Thomas Jackson
aac233739e
Move syncwrapper to utils-- since we'll have more uses for it
2015-04-07 20:53:29 -07:00
Thomas Jackson
e89da4e26b
Make AsyncAuth singleton per io_loop
...
In addition this makes the singleton instance mapping use weakrefs-- so if the io_loop goes away (or we don't reference the object anywhere) we will remove the auth instance. This allows for us to "unload" an auth without having to exit the interpreter or forcibly delete it
2015-04-07 20:53:28 -07:00
Thomas Jackson
c6245c869e
Reset asyncauth singleton in tests
2015-04-07 20:53:28 -07:00
Thomas Jackson
952d7244b5
Switch tcp req channel over to async auth libraries
2015-04-07 20:53:28 -07:00
Thomas Jackson
f7c7551224
Remove sleep from saltmessageclient
...
Now we will only run the send routine if we have something to send out. This reduces CPU load (no unecessary runs) and latency (no sleep)
2015-04-07 20:53:28 -07:00
Thomas Jackson
cade95a356
Make Sync wrapper for async req channels
2015-04-07 20:53:28 -07:00
Thomas Jackson
fd4fff89c7
Misc cleanup
2015-04-07 20:53:28 -07:00
Thomas Jackson
c7553288bf
Fix rebase collisions
...
there were some refactors which have happened over the last month, fixing those
2015-04-07 20:53:28 -07:00
Thomas Jackson
30f9d37909
Merge cleanup
2015-04-07 20:53:28 -07:00
Thomas Jackson
98b53bd1d9
Fix mocking, not quite sure how this magic mock works
2015-04-07 20:53:28 -07:00
Thomas Jackson
e04ef8b004
Always attempt to send errors to clients
2015-04-07 20:53:28 -07:00
