huangdongxu

import os
import socket
import sys
import eventlet
import datetime

RLOG_PORT = 3726

fds = {}

huangdongxu

void MessagePumpDefault::Run(Delegate* delegate) {
  DCHECK(keep_running_) << "Quit must have been called outside of Run!";

  for (;;) {
    mac::ScopedNSAutoreleasePool autorelease_pool;

    bool did_work = delegate->DoWork();
    if (!keep_running_)
      break;

huangdongxu

bool MessageLoop::DoWork() {
  if (!nestable_tasks_allowed_) {
    // Task can't be executed right now.
    return false;
  }

  for (;;) {
    ReloadWorkQueue();
    if (work_queue_.empty())
      break;

huangdongxu

DWORD __stdcall ThreadFunc(void* params) {
  ThreadParams* thread_params = static_cast<ThreadParams*>(params);
  PlatformThread::Delegate* delegate = thread_params->delegate;
  if (!thread_params->joinable)
    base::ThreadRestrictions::SetSingletonAllowed(false);
  delete thread_params;
  delegate->ThreadMain();
  return NULL;
}

huangdongxu

#!/usr/bin/env python
#coding=utf-8

import os
import sys
import urllib
import urllib2
from BeautifulSoup import BeautifulSoup
import logging
import urlparse

huangdongxu

import os
import sys
import cPickle
import time
import hashlib
import logging
import uuid

import cmemcached

huangdongxu

/*
 * Jakiro
 * @desc   Yet Another Comet Server
 * @author Dongxu Huang <[email protected]>
 * @date   2011-11-18
 */

var port = 8899 // default listen port
var createServer = require("http").createServer // createserver function
var puts  = require("util").puts // output log