Skip to content

Instantly share code, notes, and snippets.

View ktosiu's full-sized avatar

Marcin Boćkowski ktosiu

View GitHub Profile
@ktosiu
ktosiu / app.py
Created May 15, 2016 21:11 — forked from mattbennett/app.py
Nameko celery integration
from flask import Flask, request
from nameko.standalone.rpc import ServiceRpcProxy
app = Flask(__name__)
@app.route('/')
def task_list():
return """
<html>
#!/usr/bin/env python
import dpkt, socket
f = open('t.cap', 'rb')
pcap = dpkt.pcap.Reader(f)
c = 0
ptr_c = 0
log = open('4-seg-ip-dns-filter','w')
@ktosiu
ktosiu / gist:c0d73f412e4269a2e9d0e9e62f72f27e
Created May 29, 2016 17:32 — forked from tmc/gist:777085
multiprocessing gevent chat example
import sys
import gevent
from gevent.monkey import patch_all; patch_all()
from gevent import server, event, socket
from multiprocessing import Process, current_process, cpu_count
"""
Simple multiprocess StreamServer that proxies messages between clients.
Avoids using a multiprocessing.Event since it blocks on a semaphore.
@ktosiu
ktosiu / gist:62f893b9303e0d53a210c90b2eff66f8
Created May 29, 2016 18:54 — forked from mdbecker/gist:1309633
multiprocess && gevent example
from multiprocessing import Pool as MPool
from time import sleep
import datetime
import multiprocessing
import random
def time_request():
from gevent import monkey; monkey.patch_socket
from jsonrequester import JsonRequester
# Unlike Twisted, Tulip and Tornado, gevent can use existing Python libraries:
# Django, Flask, requests, redis-py, SQLAlchemy to name a few
from gevent import monkey; monkey.patch_all()
import gevent
import requests
from flask import Flask
app = Flask(__name__)
@ktosiu
ktosiu / test_pcap.c
Created June 29, 2016 00:06 — forked from physacco/test_pcap.c
A "hello world" example for libpcap.
#include <stdio.h>
#include <stdlib.h>
#include <pcap/pcap.h>
/* callback function when packet have captured */
static void mycb(u_char *user,
const struct pcap_pkthdr *h, const u_char *packet)
{
static int count = 1;
printf("Packet %d:\n", count);
@ktosiu
ktosiu / FileClient.java
Created August 19, 2016 20:36 — forked from carl-olin/FileClient.java
Simple java file transfer
package client;
import java.io.DataOutputStream;
import java.io.FileInputStream;
import java.io.IOException;
import java.net.Socket;
public class FileClient {
private Socket s;
import logging
class QueueHandler(logging.Handler):
"""
This handler sends events to a queue. Typically, it would be used together
with a multiprocessing Queue to centralise logging to file in one process
(in a multi-process application), so as to avoid file write contention
between processes.
This code is new in Python 3.2, but this class can be copy pasted into
@ktosiu
ktosiu / echo.py
Created October 5, 2016 05:16 — forked from xjdrew/echo.py
gevent echo service
import gevent
from gevent import monkey;monkey.patch_all()
import socket
def handle_client(csock):
while True:
data = csock.recv(1024)
csock.sendall(data)
csock.close()
@ktosiu
ktosiu / gevent-example.py
Created October 5, 2016 05:16
gevent example
#!/usr/bin/env python
import gevent.monkey
gevent.monkey.patch_all()
import gevent
from gevent.queue import JoinableQueue
import time
import random
q = JoinableQueue()
workers = []