void/ZeroTierOne
2
0
Fork 0
mirror of https://github.com/zerotier/ZeroTierOne.git synced 2025-06-05 03:53:44 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

HTTP test works!

Browse source
This commit is contained in:
Adam Ierymenko 2015-10-28 13:14:53 -07:00
parent c6a918d996
commit c03550de35
2 changed files with 22 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
tests/http/agent.js
View file

@ -9,14 +9,14 @@ var RUN_TEST_EVERY = 1000;
var TEST_DURATION = (60 * 1000); var TEST_DURATION = (60 * 1000);
// Where should I contact to register and query a list of other nodes? // Where should I contact to register and query a list of other nodes?
var SERVER_HOST = '127.0.0.1'; var SERVER_HOST = '174.136.102.178';
var SERVER_PORT = 18080; var SERVER_PORT = 18080;
// Which port should agents use for their HTTP? // Which port should agents use for their HTTP?
var AGENT_PORT = 18888; var AGENT_PORT = 18888;
// Payload size in bytes // Payload size in bytes
var PAYLOAD_SIZE = 4096; var PAYLOAD_SIZE = 100000;
// --------------------------------------------------------------------------- // ---------------------------------------------------------------------------
@ -66,9 +66,9 @@ if (thisAgentId === null) {
//console.log(thisAgentId); //console.log(thisAgentId);
// Create a random (and therefore not very compressable) payload // Create a random (and therefore not very compressable) payload
var payload = ''; var payload = new Buffer(PAYLOAD_SIZE);
while (payload.length < PAYLOAD_SIZE) { for(var xx=0;xx<PAYLOAD_SIZE;++xx) {
payload += String.fromCharCode(Math.round(Math.random() * 255.0)); payload.writeUInt8(Math.round(Math.random() * 255.0),xx);
} }
// Incremented for each test // Incremented for each test
@ -147,7 +147,9 @@ function performTestOnAllPeers(peers,callback)
path: '/' path: '/'
},function(res) { },function(res) {
var bytes = 0; var bytes = 0;
res.on('data',function(chunk) { bytes += chunk.length; }); res.on('data',function(chunk) {
bytes += chunk.length;
});
res.on('end',function() { res.on('end',function() {
if (timedOut) if (timedOut)
return next(null); return next(null);
@ -204,7 +206,7 @@ var expressServer = app.listen(AGENT_PORT,function () {
} }
performTestOnAllPeers(peers,function(results) { performTestOnAllPeers(peers,function(results) {
console.log(results); //console.log(results);
var submit = http.request({ var submit = http.request({
host: SERVER_HOST, host: SERVER_HOST,

14
tests/http/server.js
View file

@ -5,6 +5,8 @@ var SERVER_PORT = 18080;
// --------------------------------------------------------------------------- // ---------------------------------------------------------------------------
var fs = require('fs');
var express = require('express'); var express = require('express');
var app = express(); var app = express();
@ -28,6 +30,8 @@ app.post('/:agentId',function(req,res) {
var agentId = req.params.agentId; var agentId = req.params.agentId;
if ((!agentId)||(agentId.length !== 32)) if ((!agentId)||(agentId.length !== 32))
return res.status(404).send(''); return res.status(404).send('');
var receiveTime = Date.now();
var resultData = null; var resultData = null;
try { try {
resultData = JSON.parse(req.rawBody); resultData = JSON.parse(req.rawBody);
@ -36,9 +40,17 @@ app.post('/:agentId',function(req,res) {
} }
result = { result = {
agentId: agentId, agentId: agentId,
receiveTime: receiveTime,
result: resultData result: resultData
}; };
console.log(result);
var nows = receiveTime.toString(16);
while (nows.length < 16)
nows = '0' + nows;
fs.writeFile('result_'+agentId+'_'+nows,JSON.stringify(result),function(err) {
console.log(result);
});
return res.status(200).send(''); return res.status(200).send('');
}); });