publish

Author: tagomoris

.gitignore

@@ -0,0 +1,2 @@
+*~
+.DS_Store

.project

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>isucon2</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.wst.common.project.facet.core.builder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.wst.common.project.facet.core.nature</nature>
+	</natures>
+</projectDescription>

README.md

@@ -0,0 +1,77 @@
+# ISUCON 2 #
+
+CAUTION: this project is open for only #isucon administrators
+
+## web app ##
+
+- /webapp/perl
+- /webapp/php
+- /webapp/nodejs
+- /webapp/ruby
+- /webapp/python
+- /webapp/java
+
+### Webアプリの基本方針 ###
+
+- 処理はすべてリクエストを受け取ってから実施する
+  - DBへのクエリ
+  - テンプレートからのレンダリング
+- 全てのコンテンツをアプリケーションから渡す
+  - js/css/画像も含めて
+  - キャッシュ等はとりあえず全て無し
+
+### 実装するリクエストハンドラ ###
+
+- `/`
+  - GET
+  - artistのリスト
+    - `SELECT * FROM artist ORDER BY id`
+
+- `/artist/:artistid`
+  - GET
+  - ticketのリスト 合計の残り枚数表示
+    - `SELECT id, name FROM artist WHERE id = ? LIMIT 1`
+    - `SELECT id, name FROM ticket WHERE artist_id = ? ORDER BY id`
+    - `SELECT COUNT(*) FROM variation INNER JOIN stock ON stock.variation_id = variation.id WHERE variation.ticket_id = ? AND stock.order_id IS NULL`
+
+- `/ticket/:ticket`
+  - GET
+  - variationのリスト 各種残り枚数表示
+    - `SELECT t.*, a.name AS artist_name FROM ticket t INNER JOIN artist a ON t.artist_id = a.id WHERE t.id = ? LIMIT 1`
+    - `SELECT id, name FROM variation WHERE ticket_id = ? ORDER BY id`
+    - `SELECT seat_id, order_id FROM stock WHERE variation_id = ?`
+    - `SELECT COUNT(*) FROM stock WHERE variation_id = ? AND order_id IS NULL`
+  
+- `/buy`
+  - POST
+  - チケットの購入 stockの在庫を1つ抑え席番を表示 `member_id`を受け取り`order_request`に保存
+    - `START TRANSACTION`
+    - `INSERT INTO order_request (member_id) VALUES (?)`
+    - `UPDATE stock SET order_id = ? WHERE variation_id = ? AND order_id IS NULL ORDER BY RAND() LIMIT 1`
+    - `COMMIT`
+
+- なお、全ページ左側のサイドバーに「最近購入されたチケット10件」を表示
+ - ```
+SELECT stock.seat_id, variation.name AS v_name, ticket.name AS t_name, artist.name AS a_name FROM stock
+  JOIN variation ON stock.variation_id = variation.id
+  JOIN ticket ON variation.ticket_id = ticket.id
+  JOIN artist ON ticket.artist_id = artist.id
+WHERE order_id IS NOT NULL
+ORDER BY order_id DESC LIMIT 10
+```
+
+### staticファイル ###
+
+- images
+ - isucon_title ロゴ
+- js
+ - jquery 最新版minified
+ - jquery-ui 最新版minified
+ - isucon2.js
+- css
+ - jquery-ui ui-lightness
+ - isucon2.css デザイン調整用
+
+## benchmark tool ##
+
+- /tools

tools/.gitignore

@@ -0,0 +1,5 @@
+http_load/http_load-12mar2006
+http_load_isucon2/http_load
+http_load_isucon2/*.o
+urlfile
+node_modules

tools/README.md

@@ -0,0 +1,4 @@
+# benchmark tools #
+
+    $ npm install
+    $ ./bench.js subcommand PARALLELS SECONDS TARGET_IP TARGET_PORT TARGET_ARTIST_ID TARGET_TICKET_ID

tools/agent.js

@@ -0,0 +1,183 @@
+var async = require('async'),
+    fs = require('fs'),
+    http = require('http'),
+    child = require('child_process');
+
+var express = require('express'),
+    app = express();
+
+var config = JSON.parse(fs.readFileSync(__dirname + '/agent.json'));
+
+var BENCH_AGENT_PING_STARTING = 2000,
+    BENCH_AGENT_PING_INTERVAL = 5000;
+
+// app.use(express.logger());
+app.use(express.bodyParser()); /* json, urlencoded, multipart */
+app.use(express.errorHandler({ dumpExceptions: true, showStack: true }));
+
+var maxSlots = {primary:config.slots.primary, secondary:config.slots.secondary};
+var slots = {primary:config.slots.primary, secondary:config.slots.secondary};
+
+app.get('/status', function(req, res){ /* returns slot status */
+  res.json(slots);
+}); 
+
+function command(subcmd, parallels, seconds, ip, port, artist, ticket) {
+  return ['node bench.js', subcmd, parallels, seconds, ip, port, artist, ticket].join(' ');
+};
+
+function execSubCommand(subcmd, params, callback) {
+  var parallels = params.parallels,
+      seconds = params.seconds,
+      ip = params.ip,
+      port = params.port,
+      artist = params.artist,
+      ticket = params.ticket;
+  var p = child.exec(
+    command(subcmd, parallels, seconds, ip, port, artist, ticket),
+    { maxBuffer: 1000 * 1024 },
+    function(err, stdout, stderr){
+      if (err) {
+        // JSON.stringify([Error] object) is drop 'message' attribute...
+        var error = {message:'agent bench command execute error, code:' + err.code};
+        callback({err:error});
+        return;
+      }
+      if (stderr && stderr.length > 0) {
+        console.log(JSON.stringify({
+          date: (new Date()),
+          param: {subcmd:subcmd,parallels:parallels,seconds:seconds},
+          target: {ip:ip,port:port,artist:artist,ticket:ticket},
+          stdout:stdout,
+          stderr:stderr
+        }, null, ' '));
+      }
+      callback(JSON.parse(stdout));
+    }
+  );
+  return p;
+};
+
+function getSlot() {
+  if (slots.primary > 0) {
+    slots.primary -= 1;
+    return true;
+  }
+  if (slots.secondary > 0) {
+    slots.secondary -= 1;
+    return true;
+  }
+  return false;
+};
+
+function releaseSlot() {
+  if (slots.secondary < maxSlots.secondary) {
+    slots.secondary += 1;
+    return;
+  }
+  slots.primary += 1;
+};
+
+var runnings = {};
+
+app.post('/:subcmd/:benchid/:sessionid/:parallels/:seconds/:ip/:port/:artist/:ticket', function(req,res){
+  var subcmd = req.params.subcmd,
+      benchid = req.params.benchid,
+      sessionid = req.params.sessionid;
+  if (! getSlot()) { res.json(400, {err:'no more slots available for subcommand:' + subcmd}); return; }
+
+  var child = execSubCommand(subcmd, req.params, function(result){
+    releaseSlot();
+    if (runnings[sessionid]) {
+      /* send result to manager */
+      delete runnings[sessionid];
+      if (config.manager.skip) {
+        console.log(JSON.stringify({sessionid:sessionid,result:result}, null, ' '));
+      } else {
+        sendResult({benchid:benchid,sessionid:sessionid,result:result});
+      }
+    } else { // session killed
+      // nothing to do
+    }
+  });
+  runnings[sessionid] = child;
+  res.json(200, {});
+});
+
+app.post('/kill/:sessionid', function(req,res){
+  var sessionid = req.params.sessionid;
+  if (runnings[sessionid]) {
+    runnings[sessionid].kill('SIGTERM');
+    delete runnings[sessionid];
+    releaseSlot();
+  }
+  res.json(200, {});
+});
+
+function uriEncodeForFormData(str){
+  // see: https://developer.mozilla.org/en/JavaScript/Reference/Global_Objects/encodeURIComponent
+  return encodeURIComponent(str).replace(/%20/g, '+');
+};
+function generateFormBody(obj){
+  var pairs = [];
+  for (var key in obj){
+    pairs.push(uriEncodeForFormData(key) + '=' + uriEncodeForFormData(obj[key]));
+  }
+  return pairs.join('&');
+};
+/* in init sequence, communicate with manager, and get  */
+function postManager(path, data, type){
+  var headers = { 'User-Agent': 'Isucon2 Bench Agent RPC' };
+  var body;
+  if (!type || type === 'form') {
+    body = generateFormBody(data);
+    headers['Content-Type'] = 'application/x-www-form-urlencoded';
+  } else if (type === 'json') {
+    body = JSON.stringify(data);
+    headers['Content-Type'] = 'application/json';
+  } else {
+    throw {message:'unknown format for postManager:type'};
+  }
+  headers['Content-Length'] = (new Buffer(body, 'utf8')).length;
+
+  var options = {
+    host: config.manager.address,
+    port: config.manager.port,
+    path: path,
+    headers: headers,
+    method: 'POST'
+  };
+  var req = http.request(options, function(res){
+    if (res.statusCode !== 200)
+      console.log('Error, Isucon2 manager returns code:' + res.statusCode + ', for path:' + path);
+  });
+  req.on('error', function(err){
+    console.log('Error, Failed to send status to Isucon2 manager for path:' + path);
+    console.log(err);
+  });
+  req.end(body);
+}
+
+function sendStatus(){
+  postManager('/ping', {port:config.agent.port, primary:slots.primary, secondary:slots.secondary});
+};
+function sendResult(data){
+  postManager('/result', data, 'json');
+};
+
+if (!config.agent || !config.manager || !config.slots) {
+  if (!config.testing) {
+    console.log('Fatal, manager address and/or agent slots information missing.');
+    process.exit(1);
+  }
+}
+setTimeout(function(){
+  if (config.manager.skip) {
+    console.log('WARNING: Skipping to send status to manager by configuration config.manager.skip');
+    return;
+  }
+  sendStatus();
+  setInterval(sendStatus, BENCH_AGENT_PING_INTERVAL);
+}, BENCH_AGENT_PING_STARTING);
+
+app.listen(config.agent.port);

tools/agent.json

@@ -0,0 +1,15 @@
+{
+    "manager": {
+        "skip": false,
+        "address": "localhost",
+        "port": 5001
+    },
+    "agent": {
+        "port": 5002
+    },
+    "slots": {
+        "primary": 4,
+        "secondary": 1
+    },
+    "testing": false
+}

tools/agent.production.json

@@ -0,0 +1,15 @@
+{
+    "manager": {
+        "skip": false,
+        "address": "125.6.152.241",
+        "port": 5001
+    },
+    "agent": {
+        "port": 5002
+    },
+    "slots": {
+        "primary": 30,
+        "secondary": 2
+    },
+    "testing": false
+}