Index

A | B | C | D | E | F | G | H | I | J | K | L | M | N | O | P | Q | R | S | T | U | V | W | Y

---

A

Accept (class in cogen.core.sockets) accept() (cogen.core.sockets.Socket method) add() (cogen.core.schedulers.Scheduler method) add_token() (cogen.core.proactors.base.ProactorBase method) add_waiter() (cogen.core.coroutines.CoroutineInstance method) AddCoro (class in cogen.core.events)

addr (cogen.core.sockets.Accept attribute) (cogen.core.sockets.Connect attribute) args (cogen.core.events.AddCoro attribute) (cogen.core.events.OldCall attribute)

B

bind() (cogen.core.sockets.Socket method) (cogen.web.wsgi.WSGIServer method) bind_addr (cogen.web.wsgi.WSGIServer attribute) blocksize (cogen.core.sockets.SendFile attribute)

buff (cogen.core.sockets.Recv attribute) (cogen.core.sockets.Send attribute) (cogen.core.sockets.SendAll attribute)

C

Call() (in module cogen.core.events) caller (cogen.core.coroutines.CoroutineInstance attribute) cbuff (cogen.core.sockets.Accept attribute) chunk (class in cogen.core.pipe) chunk_sentinel (class in cogen.core.pipe) cleanup() (cogen.core.events.Join method) (cogen.core.events.Sleep method) (cogen.core.events.TimedOperation method) (cogen.core.events.WaitForSignal method) (cogen.core.sockets.SocketOperation method) close() (cogen.core.proactors.base.ProactorBase method) (cogen.core.sockets.Socket method) cogen.core (module) cogen.core.coroutines (module) cogen.core.events (module) cogen.core.pipe (module) cogen.core.proactors (module) cogen.core.proactors.base (module) cogen.core.proactors.select_impl (module) cogen.core.pubsub (module) cogen.core.queue (module) cogen.core.schedulers (module) cogen.core.sockets (module) cogen.core.util (module)

cogen.web (module) cogen.web.async (module) cogen.web.wsgi (module) compact() (cogen.core.pubsub.PublishSubscribeQueue method) conn (cogen.core.sockets.Accept attribute) (cogen.core.sockets.Connect attribute) Connect (class in cogen.core.sockets) connect() (cogen.core.sockets.Socket method) connect_attempted (cogen.core.sockets.Connect attribute) ConnectionClass (cogen.web.wsgi.WSGIServer attribute) ConnectionClosed ConnectionError coro (cogen.core.coroutines.CoroutineInstance attribute) (cogen.core.events.AddCoro attribute) (cogen.core.events.Join attribute) (cogen.core.events.OldCall attribute) (cogen.core.events.Signal attribute) (cogen.core.events.TimedOperation attribute) (cogen.core.sockets.SocketOperation attribute) (in module cogen.core.coroutines) CoroutineException CoroutineInstance (class in cogen.core.coroutines)

D

debug (cogen.core.coroutines.CoroutineInstance attribute) debug() (in module cogen.core.util)

delta (cogen.core.events.TimedOperation attribute)

E

Empty empty() (cogen.core.queue.Queue method)

exception (cogen.core.coroutines.CoroutineInstance attribute)

F

f_args (cogen.core.coroutines.CoroutineInstance attribute) f_kws (cogen.core.coroutines.CoroutineInstance attribute) fetch() (cogen.core.pubsub.PublishSubscribeQueue method) file_handle (cogen.core.sockets.SendFile attribute) fileno() (cogen.core.sockets.Socket method) (cogen.core.sockets.SocketOperation method) finalize() (cogen.core.coroutines.CoroutineInstance method) (cogen.core.events.AddCoro method) (cogen.core.events.Operation method) (cogen.core.events.Signal method) (cogen.core.events.WaitForSignal method) (cogen.core.pipe.Iterate method) (cogen.core.pipe.IterateToken method) (cogen.core.sockets.Accept method) (cogen.core.sockets.Connect method) (cogen.core.sockets.Recv method) (cogen.core.sockets.Send method) (cogen.core.sockets.SendAll method) (cogen.core.sockets.SendFile method)

flags (cogen.core.sockets.SocketOperation attribute) fmt_list() (in module cogen.core.util) Full full() (cogen.core.queue.Queue method)

G

get() (cogen.core.queue.Queue method) get_first() (in module cogen.core.proactors) get_nowait() (cogen.core.queue.Queue method) getdefaulttimeout() (in module cogen.core.sockets)

getpeername() (cogen.core.sockets.Socket method) getsockname() (cogen.core.sockets.Socket method) gettimeout() (cogen.core.sockets.Socket method)

H

handle_error() (cogen.core.coroutines.CoroutineInstance method) handle_error_event() (cogen.core.proactors.base.ProactorBase method) handle_event() (cogen.core.proactors.base.ProactorBase method) handle_timeouts() (cogen.core.schedulers.Scheduler method) has_any() (in module cogen.core.proactors) has_ctypes_iocp() (in module cogen.core.proactors) has_epoll() (in module cogen.core.proactors)

has_iocp() (in module cogen.core.proactors) has_kqueue() (in module cogen.core.proactors) has_poll() (in module cogen.core.proactors) has_select() (in module cogen.core.proactors) has_stdlib_epoll() (in module cogen.core.proactors) has_stdlib_kqueue() (in module cogen.core.proactors)

I

iter_run() (cogen.core.schedulers.Scheduler method) iter_token (cogen.core.pipe.IteratedCoroutineInstance attribute) Iterate (class in cogen.core.pipe) IteratedCoroutineInstance (class in cogen.core.pipe)

IterateToken (class in cogen.core.pipe) IterationStopped

J

Join (class in cogen.core.events) join() (cogen.core.queue.Queue method)

K

kwargs (cogen.core.events.AddCoro attribute) (cogen.core.events.OldCall attribute)

L

last_checkpoint (cogen.core.events.TimedOperation attribute) last_update (cogen.core.sockets.SocketOperation attribute) lastop (cogen.core.coroutines.CoroutineInstance attribute) LazyStartResponseMiddleware (class in cogen.web.async) len (cogen.core.events.Signal attribute) (cogen.core.sockets.Recv attribute)

length (cogen.core.sockets.SendFile attribute) listen() (cogen.core.sockets.Socket method) local (class in cogen.core.coroutines)

M

makefile() (cogen.core.sockets.Socket method)

N

name (cogen.core.coroutines.CoroutineInstance attribute) (cogen.core.events.Signal attribute) (cogen.core.events.WaitForSignal attribute)

next_timer_delta() (cogen.core.schedulers.Scheduler method)

O

offset (cogen.core.sockets.SendFile attribute) OldCall (class in cogen.core.events) Operation (class in cogen.core.events)

OperationTimeout

P

perform_accept() (in module cogen.core.proactors.base) perform_connect() (in module cogen.core.proactors.base) perform_recv() (in module cogen.core.proactors.base) perform_send() (in module cogen.core.proactors.base) perform_sendall() (in module cogen.core.proactors.base) perform_sendfile() (in module cogen.core.proactors.base) position (cogen.core.sockets.SendFile attribute) prio (cogen.core.coroutines.CoroutineInstance attribute) (cogen.core.events.Operation attribute) (cogen.core.events.Signal attribute) priority (class in cogen.core.util) ProactorBase (class in cogen.core.proactors.base) process() (cogen.core.coroutines.CoroutineInstance method) (cogen.core.events.AddCoro method) (cogen.core.events.Join method) (cogen.core.events.OldCall method) (cogen.core.events.Operation method) (cogen.core.events.Signal method) (cogen.core.events.Sleep method) (cogen.core.events.TimedOperation method) (cogen.core.events.WaitForSignal method) (cogen.core.pipe.Iterate method) (cogen.core.pipe.IterateToken method) (cogen.core.sockets.Accept method) (cogen.core.sockets.Connect method) (cogen.core.sockets.Recv method) (cogen.core.sockets.Send method) (cogen.core.sockets.SendAll method) (cogen.core.sockets.SendFile method)

process_op() (cogen.core.schedulers.Scheduler method) publish() (cogen.core.pubsub.PublishSubscribeQueue method) PublishSubscribeQueue (class in cogen.core.pubsub) put() (cogen.core.queue.Queue method) put_nowait() (cogen.core.queue.Queue method)

Q

qsize() (cogen.core.queue.Queue method) Queue (class in cogen.core.queue)

R

recipients (cogen.core.events.Signal attribute) Recv (class in cogen.core.sockets) recv() (cogen.core.sockets.Socket method) register_fd() (cogen.core.proactors.base.ProactorBase method) remove_token() (cogen.core.proactors.base.ProactorBase method) remove_waiter() (cogen.core.coroutines.CoroutineInstance method) render_headers() (cogen.web.wsgi.WSGIConnection method) request_accept() (cogen.core.proactors.base.ProactorBase method) request_connect() (cogen.core.proactors.base.ProactorBase method) request_generic() (cogen.core.proactors.base.ProactorBase method) request_recv() (cogen.core.proactors.base.ProactorBase method) request_send() (cogen.core.proactors.base.ProactorBase method) request_sendall() (cogen.core.proactors.base.ProactorBase method)

request_sendfile() (cogen.core.proactors.base.ProactorBase method) result (cogen.core.coroutines.CoroutineInstance attribute) (cogen.core.events.AddCoro attribute) (cogen.core.events.Signal attribute) (cogen.core.events.WaitForSignal attribute) run() (cogen.core.proactors.select_impl.SelectProactor method) (cogen.core.schedulers.Scheduler method) (cogen.web.wsgi.WSGIConnection method) run_act() (cogen.core.proactors.base.ProactorBase method) run_op() (cogen.core.coroutines.CoroutineInstance method) (cogen.core.pipe.IteratedCoroutineInstance method) running (cogen.core.coroutines.CoroutineInstance attribute)

S

Scheduler (class in cogen.core.schedulers) SelectProactor (class in cogen.core.proactors.select_impl) Send (class in cogen.core.sockets) send() (cogen.core.sockets.Socket method) SendAll (class in cogen.core.sockets) sendall() (cogen.core.sockets.Socket method) SendFile (class in cogen.core.sockets) sendfile() (cogen.core.sockets.Socket method) sent (cogen.core.sockets.Send attribute) (cogen.core.sockets.SendAll attribute) (cogen.core.sockets.SendFile attribute) serve() (cogen.web.wsgi.WSGIServer method) server_factory() (in module cogen.web.wsgi) set_options() (cogen.core.proactors.base.ProactorBase method) set_timeout() (cogen.core.events.TimedOperation method) setblocking() (cogen.core.sockets.Socket method) setdefaulttimeout() (in module cogen.core.sockets) setsockopt() (cogen.core.sockets.Socket method)

settimeout() (cogen.core.sockets.Socket method) shutdown() (cogen.core.sockets.Socket method) Signal (class in cogen.core.events) simple_response() (cogen.web.wsgi.WSGIConnection method) Sleep (class in cogen.core.events) sock (cogen.core.sockets.SocketOperation attribute) Socket (class in cogen.core.sockets) SocketOperation (class in cogen.core.sockets) start_response() (cogen.web.async.LazyStartResponseMiddleware method) (cogen.web.wsgi.WSGIConnection method) state (cogen.core.coroutines.CoroutineInstance attribute) (cogen.core.events.Operation attribute) stop() (cogen.core.pipe.IterateToken method) (cogen.core.schedulers.Scheduler method) subscribe() (cogen.core.pubsub.PublishSubscribeQueue method) SynchronousInputMiddleware (class in cogen.web.async)

T

task_done() (cogen.core.queue.Queue method) TimedOperation (class in cogen.core.events) timeout (cogen.core.events.TimedOperation attribute)

try_run_act() (cogen.core.proactors.base.ProactorBase method)

U

unregister_fd() (cogen.core.proactors.base.ProactorBase method) unsubscribe() (cogen.core.pubsub.PublishSubscribeQueue method)

V

value (cogen.core.events.Signal attribute) (cogen.core.pipe.chunk attribute)

W

waiters (cogen.core.coroutines.CoroutineInstance attribute) WaitForSignal (class in cogen.core.events) weak_timeout (cogen.core.events.TimedOperation attribute) wrapped_sendfile() (in module cogen.core.proactors.base)

WSGIConnection (class in cogen.web.wsgi) WSGIFileWrapper (class in cogen.web.wsgi) WSGIServer (class in cogen.web.wsgi)

Y

yield_event() (cogen.core.proactors.base.ProactorBase method)