|
@@ -19,11 +19,11 @@ var MWorld = conn.model('World', WorldSchema);
|
|
if (cluster.isMaster) {
|
|
if (cluster.isMaster) {
|
|
// Fork workers.
|
|
// Fork workers.
|
|
for (var i = 0; i < numCPUs; i++) {
|
|
for (var i = 0; i < numCPUs; i++) {
|
|
- cluster.fork();
|
|
|
|
|
|
+ cluster.fork();
|
|
}
|
|
}
|
|
|
|
|
|
cluster.on('exit', function(worker, code, signal) {
|
|
cluster.on('exit', function(worker, code, signal) {
|
|
- console.log('worker ' + worker.process.pid + ' died');
|
|
|
|
|
|
+ console.log('worker ' + worker.process.pid + ' died');
|
|
});
|
|
});
|
|
} else {
|
|
} else {
|
|
var app = module.exports = koa();
|
|
var app = module.exports = koa();
|
|
@@ -32,7 +32,7 @@ if (cluster.isMaster) {
|
|
|
|
|
|
// routes
|
|
// routes
|
|
app.use(route.get('/json', jsonHandler));
|
|
app.use(route.get('/json', jsonHandler));
|
|
- // app.use(route.get('/db', dbHandler));
|
|
|
|
|
|
+ app.use(route.get('/db', dbHandler));
|
|
// app.use(route.get('/queries', queriesHandler));
|
|
// app.use(route.get('/queries', queriesHandler));
|
|
// app.use(route.get('/fortune', fortuneHandler));
|
|
// app.use(route.get('/fortune', fortuneHandler));
|
|
// app.use(route.get('/update', updateHandler));
|
|
// app.use(route.get('/update', updateHandler));
|
|
@@ -44,6 +44,10 @@ if (cluster.isMaster) {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ function *dbHandler() {
|
|
|
|
+ var queries = this.request.queries.queries
|
|
|
|
+ }
|
|
|
|
+
|
|
function *textHandler() {
|
|
function *textHandler() {
|
|
this.body = 'Hello, world!'
|
|
this.body = 'Hello, world!'
|
|
}
|
|
}
|