Basic IPC server works!
Lint
Skeleton of client
IPC bind test
Make stand-alone
Adding factories for push and pull channels
Allowing opts passing for consistency
Tests now (mostly) work
Lint
Method documentation
General cleanup. Migrate to inheritence.
Log cleanup
Migrate framing to stand-along module
Migrate ipc.py to new framer
Working except for serialization bug
Debugging
Debugging
It works!!
Remove ZeroMQ from TCP transport :]
General cleanup
Linting
General cleanup
Align socket name with what client expects
Remove unused buffer size flag
exception handling for stream close
Calls to parent class inits
Docs
Remove debugging
Remove unused function
Remove unnecessary pre/post fork on msgclient
Remove unecessary timeout flag
Better stream/socket shutdown in server
Remove unused handler
Removing more unused
More function cleanup
Removing more unneeded cruft
Lint
Round out documentation
More docs
Misc hacks to fix up @cachedout's IPC
This was using a mix of blocking and non-blocking calls, which was making a bit of a mess. connect and write are both non-blocking calls on IOStreams, so we either need to handle all the callbacks or do them in the coroutine fashion (much easier to manage). This meant that in the tests your "write" wouldn't make it out since we didn't wait on the connect.
IMO we should refactor this IPC stuff to have proper async interfaces and wrap if absolutely necessary, but I think its reasonable to ask that as part of this we make some more of the core coroutines :)
for #23236
Lint
Remove init of io_loop because we require start()
Various fixes
Remove uneeded functionality
Remove dup
Cleanup and remove unused functions
Moving toward coroutines
More lint
handle_connection changed to spawn
Singletons for ipcclient
Lint disable
Remove redundent check in close()
Remove duplicates in init
Improved exception handling
Test framework
Require sock path to be passed in
Better testing approach
Remove unecessary __init__
Misc cleanup of unecessary methods
Major rework of the IPC channels to make them work :)
Remove TODO, since the feature was implemented
Add more tests for IPC
Add support for reconnecting clients, as well as a return from the IPCServer
misc cleanup
Lint test case
Lint transport
very commonly a float will be passed to the function due to the way module
execution and yaml parsing works. this will throw a TypeError, which will
cause the function to move on to the shell fallback.
if a single check have multiple os.walk, such as in _check_directory
function, when there are many files in directory, it will use many time
to generate keep files, if there are some new files between
_gen_keep_files and _check_changes, it will say these files are to be
removed, but in actually, these files in require directory and no need
to removed.
When using file.managed with a source of `file://` and no `source_hash`, this code block can be entered which assumes `source_hash` exists. Here, I add `source_hash` to the `if` statement as a temporary fix. Ideally, we could check for a cached templated file without the need for `source_hash`.
