mrjoes’s gists

mrjoes / gist:1462715

Created December 11, 2011 21:00

Dummy websocket client

	import websocket
	import threading
	import random
	import time
	import sys

	class Worker(threading.Thread):
	def __init__(self, args, *kwargs):
	self.lock = threading.RLock()
	self.packets_sent = 0

mrjoes / gist:1462720

Created December 11, 2011 21:01

Dummy server

	from tornado import web, websocket, ioloop

	class Test(websocket.WebSocketHandler):
	clients = set()

	def open(self):
	self.clients.add(self)

	def on_message(self, msg):
	for c in self.clients:

mrjoes / gist:1472044

Created December 13, 2011 12:57

	sent: number of messages sent by one client per second
	recv: total number of messages received per one second
	pings: in milliseconds

	node.js echo server with commented log output:
	clients: 5, sent: 8759.521709, recv: 43795.308466, min_ping: 0, max_ping: 4, avg_ping: 0.399996, errors: 0
	clients: 25, sent: 1998.742675, recv: 49938.586699, min_ping: 0, max_ping: 20, avg_ping: 1.998743, errors: 0
	clients: 50, sent: 1051.625850, recv: 52363.271976, min_ping: 0, max_ping: 59, avg_ping: 5.885065, errors: 0
	clients: 100, sent: 514.820466, recv: 50273.736734, min_ping: 0, max_ping: 233, avg_ping: 22.884596, errors: 0
	clients: 150, sent: 365.081970, recv: 52460.994307, min_ping: 0, max_ping: 473, avg_ping: 46.202689, errors: 0

mrjoes / gist:1494609

Created December 18, 2011 21:59

mrjoes / gist:1657577

Created January 22, 2012 16:23

	import Queue
	import threading
	import functools
	import traceback

	from tornado.ioloop import IOLoop

	THREAD_LIMIT = 8

	_task_queue = Queue.Queue(THREAD_LIMIT * 2)

mrjoes / gist:1657598

Created January 22, 2012 16:30

	# With a callback
	def test():
	def handle_user(username, first_name, last_name, exception=None):
	if exception:
	# Blow up
	return

	print username, first_name, last_name

	get_user_id(10, handle_user)

mrjoes / gist:2008269

Created March 9, 2012 19:38

	Error thrown at line 667, column 4 in <anonymous function: XHRObject.prototype._start>(method, url, payload) in http://cdn.sockjs.org/sockjs-0.2.1.js:
	that.xhr.send(payload);
	called from line 615, column 43 in <anonymous function: utils.XHRObject>() in http://cdn.sockjs.org/sockjs-0.2.1.js:
	that._start(method, url, payload);
	Uncaught exception: ReferenceError: Security violation

	Error thrown at line 667, column 4 in <anonymous function: XHRObject.prototype._start>(method, url, payload) in http://cdn.sockjs.org/sockjs-0.2.1.js:
	that.xhr.send(payload);
	called from line 615, column 43 in <anonymous function: utils.XHRObject>() in http://cdn.sockjs.org/sockjs-0.2.1.js:
	that._start(method, url, payload);

mrjoes / gist:2008333

Created March 9, 2012 19:54

	<!DOCTYPE html>
	<html>
	<head>
	<script src="http://ajax.googleapis.com/ajax/libs/jquery/1.4.2/jquery.min.js"></script>
	<script src="http://cdn.sockjs.org/sockjs-0.1.2.min.js"></script>
	<script>
	$(function() {
	var conn = null;

	function log(msg) {

mrjoes / gist:2008335

Created March 9, 2012 19:55

	# -- coding: utf-8 --
	"""
	Simple sockjs-tornado chat application. By default will listen on port 8080.
	"""
	import tornado.ioloop
	import tornado.web

	import sockjs.tornado

mrjoes / gist:2175276

Created March 23, 2012 21:31

	from sqlalchemy import create_engine
	from sqlalchemy.orm import scoped_session, sessionmaker


	# Simple database and session wrapper. I use it in my Flask app too.
	class Database(object):
	def __init__(self):
	self.session_maker = sessionmaker()
	self.session = scoped_session(self.session_maker)
	self.engine = None

Serge S. Koval mrjoes