mirror of
https://github.com/saltstack/salt.git
synced 2025-04-17 10:10:20 +00:00
Fix comments
This commit is contained in:
parent
69920366ae
commit
7a597f19b5
7 changed files with 9 additions and 9 deletions
|
@ -284,7 +284,7 @@ class LocalClient(object):
|
|||
'No command was sent, no jid was assigned.')
|
||||
return {}
|
||||
|
||||
# don't install event subscription listeners when the request is async
|
||||
# don't install event subscription listeners when the request is asynchronous
|
||||
# and doesn't care. this is important as it will create event leaks otherwise
|
||||
if not listen:
|
||||
return pub_data
|
||||
|
|
|
@ -456,7 +456,7 @@ def cql_query_with_prepare(query, statement_name, statement_arguments, async=Fal
|
|||
|
||||
# If this was a synchronous call, then we either have an empty list
|
||||
# because there was no return, or we have a return
|
||||
# If this was an async call we only return the empty list
|
||||
# If this was an asynchronous call we only return the empty list
|
||||
return ret
|
||||
|
||||
|
||||
|
|
|
@ -2534,7 +2534,7 @@ class WebsocketEndpoint(object):
|
|||
parent_pipe, child_pipe = Pipe()
|
||||
handler.pipe = parent_pipe
|
||||
handler.opts = self.opts
|
||||
# Process to handle async push to a client.
|
||||
# Process to handle asynchronous push to a client.
|
||||
# Each GET request causes a process to be kicked off.
|
||||
proc = Process(target=event_stream, args=(handler, child_pipe))
|
||||
proc.start()
|
||||
|
|
|
@ -244,7 +244,7 @@ def _json_dumps(obj, **kwargs):
|
|||
|
||||
# # master side
|
||||
# - "runner" (done)
|
||||
# - "wheel" (need async api...)
|
||||
# - "wheel" (need asynchronous api...)
|
||||
|
||||
|
||||
AUTH_TOKEN_HEADER = 'X-Auth-Token'
|
||||
|
@ -653,7 +653,7 @@ class SaltAuthHandler(BaseSaltAPIHandler): # pylint: disable=W0223
|
|||
|
||||
self.write(self.serialize(ret))
|
||||
|
||||
# TODO: make async? Underlying library isn't... and we ARE making disk calls :(
|
||||
# TODO: make asynchronous? Underlying library isn't... and we ARE making disk calls :(
|
||||
def post(self):
|
||||
'''
|
||||
:ref:`Authenticate <rest_tornado-auth>` against Salt's eauth system
|
||||
|
|
|
@ -1440,7 +1440,7 @@ class TCPPubServerChannel(salt.transport.server.PubServerChannel):
|
|||
pull_uri = int(self.opts.get('tcp_master_publish_pull', 4514))
|
||||
else:
|
||||
pull_uri = os.path.join(self.opts['sock_dir'], 'publish_pull.ipc')
|
||||
# TODO: switch to the actual async interface
|
||||
# TODO: switch to the actual asynchronous interface
|
||||
#pub_sock = salt.transport.ipc.IPCMessageClient(self.opts, io_loop=self.io_loop)
|
||||
pub_sock = salt.utils.asynchronous.SyncWrapper(
|
||||
salt.transport.ipc.IPCMessageClient,
|
||||
|
|
|
@ -383,7 +383,7 @@ class SaltEvent(object):
|
|||
io_loop=self.io_loop
|
||||
)
|
||||
|
||||
# For the async case, the connect will be defered to when
|
||||
# For the asynchronous case, the connect will be defered to when
|
||||
# set_event_handler() is invoked.
|
||||
self.cpub = True
|
||||
return self.cpub
|
||||
|
@ -427,7 +427,7 @@ class SaltEvent(object):
|
|||
self.pulluri,
|
||||
io_loop=self.io_loop
|
||||
)
|
||||
# For the async case, the connect will be deferred to when
|
||||
# For the asynchronous case, the connect will be deferred to when
|
||||
# fire_event() is invoked.
|
||||
self.cpush = True
|
||||
return self.cpush
|
||||
|
|
|
@ -57,7 +57,7 @@ class WheelClient(salt.client.mixins.SyncClientMixin,
|
|||
return self.low(fun, kwargs, print_event=kwargs.get('print_event', True), full_return=kwargs.get('full_return', False))
|
||||
|
||||
# TODO: Inconsistent with runner client-- the runner client's master_call gives
|
||||
# an async return, unlike this
|
||||
# an asynchronous return, unlike this
|
||||
def master_call(self, **kwargs):
|
||||
'''
|
||||
Execute a wheel function through the master network interface (eauth).
|
||||
|
|
Loading…
Add table
Reference in a new issue