smoke engine

smokengine native performance for network apps

current state:

very experimental

design goals:

• no complexity
• low latency, high performance & scalability

applications:

• mass multiplayer
• realtime
• streaming
• bigdata

sample code net (stable)

  // plain tcp server
  smoke::net_t net;

  net.on_connect([](int fd){
   // on connect event
  });

  net.on_close([](int fd,int err){
  // on close event
  });

  net.on_data([](int fd,const char* data,int nread)->int{
  // on data event

    int r=write(fd,"hello",5);
    close(fd);
    return 0; 
  });

  // run IO loop
  smoke_net_run(&net,"127.0.0.1",port);

sample code http (very experimental)

 smoke::http::http_t app;

  app.get("/counter",[&](int fd,http_req_t& req)->int{
   DBG("get /counter %d\n",fd);
   if(write(fd,HTTPOK,sizeof(HTTPOK)-1)<=0){LOG("write error, %d\n",errno);}
   return 0;
  }); 

  app.get("/test/api",[&](int fd,http_req_t& req)->int{
   DBG("get /test/api %d\n",fd);
   if(write(fd,HTTPOK,sizeof(HTTPOK)-1)<=0){LOG("write error, %d\n",errno);}
   return 0;
  }); 

  app.post("/data",[&](int fd,http_req_t& req)->int{
   DBG("post /data %d\n",fd);
   if(write(fd,HTTPOK,sizeof(HTTPOK)-1)<=0){LOG("write error, %d\n",errno);}
   return 0;
  }); 

   
  app.run("127.0.0.1",port);

app code structure

// config modules
#include "smoke_config.h"

// core engine modules
#include "smoke.h"

// middleware modules
#include "smoke_http.h"

// globals
int host_port;
smoke::net_t net;

// app modules
#include "smoke_app1.h"

// app run
void serve()
{
  smoke::net_run(&net,"127.0.0.1",port);  
}

int main (int argc, char *argv[])
{

  host_port = atoi(argv[1]);

  serve();
}

great libs & frameworks:

nodejs libuv go erlang libev libevent libphenom tornado gevent akka play

testing utils:

sudo sh -c "ulimit -n 65535 && exec su $LOGNAME"

./wrk -t32 -c10000 -d5m --timeout 60s --latency http://127.0.0.1:9090/

ab -n 1000000 -c 10000 http://localhost:9090/

curl -v http://localhost:9090/