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

---

_

_fileobject (class in cogen.core.sockets)

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)

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)

bufsize (cogen.core.sockets._fileobject attribute)

C

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.sockets._fileobject method) closed (cogen.core.sockets._fileobject attribute) 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 constructor (cogen.core.coroutines.Coroutine attribute) coro (cogen.core.coroutines.CoroutineInstance attribute) (cogen.core.events.AddCoro attribute) (cogen.core.events.Join attribute) (cogen.core.events.Signal attribute) (cogen.core.events.TimedOperation attribute) (cogen.core.sockets.SocketOperation attribute) (in module cogen.core.coroutines) Coroutine (class in cogen.core.coroutines) coroutine (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._fileobject method) (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) flush() (cogen.core.sockets._fileobject method) 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)

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) mode (cogen.core.sockets._fileobject attribute)

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) 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.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

read() (cogen.core.sockets._fileobject method) readline() (cogen.core.sockets._fileobject method) readlines() (cogen.core.sockets._fileobject method) 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) SocketError SocketOperation (class in cogen.core.sockets) softspace (cogen.core.sockets._fileobject attribute) 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_func (cogen.core.coroutines.Coroutine attribute) wrapped_sendfile() (in module cogen.core.proactors.base) write() (cogen.core.sockets._fileobject method)

writelines() (cogen.core.sockets._fileobject method) 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)