I hereby claim:
- I am alejandrobernardis on github.
- I am abernardis (https://keybase.io/abernardis) on keybase.
- I have a public key whose fingerprint is 0B58 EC83 D7A8 6CF2 793C D003 07A2 572D D367 D6D0
To claim this, I am signing this object:
| #!/usr/bin/env python | |
| """This is a demonstration of sharing file descriptors across processes. | |
| It uses Tornado (need a recent post-2.0 version from github) and the | |
| multiprocessing module (from python 2.6+). To run it, start one copy | |
| of fdserver.py and one or more copies of testserver.py (in different | |
| terminals, or backgrounded, etc). Fetch http://localhost:8000 and | |
| you'll see the requests getting answered by different processes (it's | |
| normal for several requests to go to the same process under light | |
| load, but under heavier load it tends to even out). |
| #!/usr/bin/env python2.7 | |
| # -*- coding: utf-8 -*- | |
| # Copyright (c) ${YEAR} Asumi Kamikaze Inc. | |
| # Licensed under the MIT License. | |
| # Author: Alejandro M. Bernardis | |
| # Email: alejandro (dot) bernardis (at) asumikamikaze (dot) com | |
| # Created: ${DAY}/${MONTH_NAME_SHORT}/${YEAR} ${HOUR}:${MINUTE} |
I hereby claim:
To claim this, I am signing this object:
| import macropy.activate | |
| import test |
| """Demo of streaming requests with Tornado. | |
| This script features a client using AsyncHTTPClient's body_producer | |
| feature to slowly produce a large request body, and two server | |
| handlers to receive this body (one is a proxy that forwards to the | |
| other, also using body_producer). | |
| It also demonstrates flow control: if --client_delay is smaller than | |
| --server_delay, the client will eventually be suspended to allow the | |
| server to catch up. You can see this in the logs, as the "client |
| import time | |
| from tornado.concurrent import run_on_executor | |
| from concurrent.futures import ThreadPoolExecutor # `pip install futures` for python2 | |
| MAX_WORKERS = 4 | |
| class Handler(tornado.web.RequestHandler): | |
| executor = ThreadPoolExecutor(max_workers=MAX_WORKERS) |
| # | |
| # https://groups.google.com/d/msg/python-tornado/1LsOhqwOOTI/2Sp7RSM7sfcJ | |
| # | |
| # | |
| import os | |
| import time | |
| from tornado import gen, ioloop, httpserver, web | |
| def fork_processes(num_processes): |
| DEPLOY_PATH := ./deploy | |
| NODE_PATH := ./node_modules | |
| STATIC_PATH := ./static | |
| STATIC_STRUCT := ./static/{component,style,data,image,script,stylus,vendor,view} | |
| VENDOR_PATH := ./static/vendor | |
| OK := " - Ok." | |
| NOT_FOUND := " - Not found." | |
| FAIL := " - Fail." | |
| SERVER_PID := /tmp/pyserver.pid |
| package kc.ant; | |
| import java.io.File; | |
| import java.io.FileInputStream; | |
| import java.io.FileOutputStream; | |
| import java.util.Properties; | |
| public class KCVersion { | |
| /** |
| tar cfvz ./Desktop/dots.tar.gz .profile .profile.pysave .gitconfig .tm_properties .vimrc .viminfo |