Skip to content

Commit

Permalink
hard code
Browse files Browse the repository at this point in the history 
Signed-off-by: SamYuan1990 <yy19902439@126.com>
  • Loading branch information
@SamYuan1990
SamYuan1990 committed Oct 23, 2020
1 parent 8c39893 commit be200d9
Show file tree
Hide file tree
Showing 8 changed files with 197 additions and 36 deletions.
3 changes: 3 additions & 0 deletions .gitmodules
View file
@@ -0,0 +1,3 @@
[submodule "minifabric"]
path = minifabric
url = git@github.com:SamYuan1990/minifabric.git
36 changes: 36 additions & 0 deletions config.yaml
View file
@@ -0,0 +1,36 @@
# Definition of nodes
peer1: &peer1
addr: peer1.org0.example.com:7051
tls_ca_cert: /config/minifabric/vars/keyfiles/peerOrganizations/org0.example.com/msp/tlscacerts/tlsca1.org0.example.com-cert.pem

peer2: &peer2
addr: peer1.org1.example.com:7051
tls_ca_cert: /config/minifabric/vars/keyfiles/peerOrganizations/org1.example.com/msp/tlscacerts/tlsca1.org1.example.com-cert.pem

orderer1: &orderer1
addr: orderer1.example.com:7050
tls_ca_cert: /config/minifabric/vars/keyfiles/ordererOrganizations/example.com/msp/tlscacerts/tlsca.example.com-cert.pem

# Nodes to interact with
endorsers:
- *peer1
- *peer2
# we might support multi-committer in the future for more complex test scenario,
# i.e. consider tx committed only if it's done on >50% of nodes. But for now,
# it seems sufficient to support single committer.
committer: *peer2
orderer: *orderer1

# Invocation configs
channel: mychannel
chaincode: simple
args:
- query
- a
mspid: org0-example-com

private_key: /config/minifabric/vars/keyfiles/peerOrganizations/org0.example.com/users/Admin@org0.example.com/msp/keystore/priv_sk
sign_cert: /config/minifabric/vars/keyfiles/peerOrganizations/org0.example.com/users/Admin@org0.example.com/msp/signcerts/Admin@org0.example.com-cert.pem
num_of_conn: 10
client_per_conn: 10

70 changes: 68 additions & 2 deletions lib/libs.js
View file
@@ -1,6 +1,8 @@
const fs = require('fs');
const path = require('path');
const parse = require('csv-parse/lib/sync');
const sleep = require('system-sleep');
const process = require('child_process');

exports.BatchTimeout = 'BatchTimeout'
exports.MaxMessageCount = 'MaxMessageCount'
Expand Down Expand Up @@ -45,10 +47,74 @@ exports.init = function init(){
}
}

exports.run = function run(data){
exports.appendRS = function appendRS(data){
try {
fs.appendFileSync('./data/rs.csv', '\n'+data);
} catch (err) {
/* 处理错误 */
}
}
}

/*CmdInfo
Startup
Teardown
Sleep
tapeConfig
tapeCount
*/
exports.run = function run(CmdInfo,BatchTimeout,MaxMessageCount,AbsoluteMaxBytes,PreferredMaxBytes){
var tapeCmd = 'docker';
var startup;
var teardown;
BatchTimeout.forEach(BatchTimeoutElement =>{
MaxMessageCount.forEach(MaxMessageCountElement => {
AbsoluteMaxBytes.forEach(AbsoluteMaxBytesElement => {
PreferredMaxBytes.forEach(PreferredMaxBytesElement => {
var TurnInfo = {
Chaincode:CmdInfo.Chaincode,
BatchTimeout:BatchTimeoutElement,
MaxMessageCount:MaxMessageCountElement,
AbsoluteMaxBytes:AbsoluteMaxBytesElement,
PreferredMaxBytes:PreferredMaxBytesElement,
}
startup(startup,TurnInfo);
tapeTPS = tapeTPS(CmdInfo,tapeCmd);
TPS = convertTPS(tapeTPS);
teardown(teardown);
//'sample,0.75,10,2,256, 180.038278,'
appendRS(TurnInfo.Chaincode+','+
TurnInfo.BatchTimeout+','+
TurnInfo.MaxMessageCountElement+','+
TurnInfo.AbsoluteMaxBytesElement+','+
TurnInfo.PreferredMaxBytesElement+','+
TPS+',');
sleep(CmdInfo.Sleep*1000);
})
})
})
});
}

// docker run --name tape -e TAPE_LOGLEVEL=debug --network minifab -v $PWD:/config tape tape /config/config.yaml 500
exports.tapeTPS = function tapeTPS(CmdInfo,tapeCmd){
rs = process.spawnSync(tapeCmd,[
'run',
'--name',
'tape',
'-e',
'TAPE_LOGLEVEL=debug',
'--network',
'minifab',
'-v',
path.resolve('./')+':/config',
'tape',
'tape',
'/config/config.yaml',
500//CmdInfo.tapeConfig,CmdInfo.tapeCount
]);
str=rs.output.toString('utf-8',0);
str = str.substring(str.indexOf('tps:'));
str = str.substring(0,str.indexOf('\n'));
str = str.substring(4);
return str;
}
1 change: 1 addition & 0 deletions minifabric
Submodule minifabric added at 76621d
43 changes: 43 additions & 0 deletions package-lock.json
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

3 changes: 2 additions & 1 deletion package.json
View file
Expand Up @@ -29,7 +29,8 @@
"express": "~4.16.1",
"http-errors": "~1.6.3",
"morgan": "~1.9.1",
"pug": "^3.0.0"
"pug": "^3.0.0",
"system-sleep": "^1.3.7"
},
"devDependencies": {
"chai": "^4.2.0",
Expand Down
32 changes: 16 additions & 16 deletions routes/api.js
View file
Expand Up @@ -29,22 +29,22 @@ router.get('/getTPS', function(req, res, next) {

router.get('/run', function(req, res, next) {
libs.init();
libs.run('sample,0.75,10,2,256, 180.038278,');
libs.run('sample,0.75,40,2,256, 291.310916,');
libs.run('sample,0.75,80,2,256, 333.041573,');
libs.run('sample,0.75,120,2,256, 351.752320,');
libs.run('sample,1,10,2,256, 172.872861,');
libs.run('sample,1,40,2,256, 291.617799,');
libs.run('sample,1,80,2,256, 337.826232,');
libs.run('sample,1,120,2,256, 319.039588,');
libs.run('sample,2,10,2,256, 182.105577,');
libs.run('sample,2,40,2,256, 260.276446,');
libs.run('sample,2,80,2,256, 323.542760,');
libs.run('sample,2,120,2,256, 323.526945,');
libs.run('sample,1.5,10,2,256, 172.745382,');
libs.run('sample,1.5,40,2,256, 268.041591,');
libs.run('sample,1.5,80,2,256, 348.150198,');
libs.run('sample,1.5,120,2,256, 310.915616,');
libs.appendRS('sample,0.75,10,2,256, 180.038278,');
libs.appendRS('sample,0.75,40,2,256, 291.310916,');
libs.appendRS('sample,0.75,80,2,256, 333.041573,');
libs.appendRS('sample,0.75,120,2,256, 351.752320,');
libs.appendRS('sample,1,10,2,256, 172.872861,');
libs.appendRS('sample,1,40,2,256, 291.617799,');
libs.appendRS('sample,1,80,2,256, 337.826232,');
libs.appendRS('sample,1,120,2,256, 319.039588,');
libs.appendRS('sample,2,10,2,256, 182.105577,');
libs.appendRS('sample,2,40,2,256, 260.276446,');
libs.appendRS('sample,2,80,2,256, 323.542760,');
libs.appendRS('sample,2,120,2,256, 323.526945,');
libs.appendRS('sample,1.5,10,2,256, 172.745382,');
libs.appendRS('sample,1.5,40,2,256, 268.041591,');
libs.appendRS('sample,1.5,80,2,256, 348.150198,');
libs.appendRS('sample,1.5,120,2,256, 310.915616,');
res.send('success');
});

Expand Down
45 changes: 28 additions & 17 deletions test/lib.test.js
View file
Expand Up @@ -3,24 +3,35 @@ var expect = require('chai').expect;

describe('# libs', function () {

it('run', function(done){
it('tapeTPS', function(done){
var CmdInfo = {
tapeConfig:'1',
tapeCount:'1'
}
tapeCmd = 'docker'
rs = libs.tapeTPS(CmdInfo,tapeCmd);
expect(true).to.deep.equal(parseFloat(rs)>0);
done();
})

it('appendRS', function(done){
libs.init();
libs.run('sample,0.75,10,2,256, 180.038278,');
libs.run('sample,0.75,40,2,256, 291.310916,');
libs.run('sample,0.75,80,2,256, 333.041573,');
libs.run('sample,0.75,120,2,256, 351.752320,');
libs.run('sample,1,10,2,256, 172.872861,');
libs.run('sample,1,40,2,256, 291.617799,');
libs.run('sample,1,80,2,256, 337.826232,');
libs.run('sample,1,120,2,256, 319.039588,');
libs.run('sample,2,10,2,256, 182.105577,');
libs.run('sample,2,40,2,256, 260.276446,');
libs.run('sample,2,80,2,256, 323.542760,');
libs.run('sample,2,120,2,256, 323.526945,');
libs.run('sample,1.5,10,2,256, 172.745382,');
libs.run('sample,1.5,40,2,256, 268.041591,');
libs.run('sample,1.5,80,2,256, 348.150198,');
libs.run('sample,1.5,120,2,256, 310.915616,');
libs.appendRS('sample,0.75,10,2,256, 180.038278,');
libs.appendRS('sample,0.75,40,2,256, 291.310916,');
libs.appendRS('sample,0.75,80,2,256, 333.041573,');
libs.appendRS('sample,0.75,120,2,256, 351.752320,');
libs.appendRS('sample,1,10,2,256, 172.872861,');
libs.appendRS('sample,1,40,2,256, 291.617799,');
libs.appendRS('sample,1,80,2,256, 337.826232,');
libs.appendRS('sample,1,120,2,256, 319.039588,');
libs.appendRS('sample,2,10,2,256, 182.105577,');
libs.appendRS('sample,2,40,2,256, 260.276446,');
libs.appendRS('sample,2,80,2,256, 323.542760,');
libs.appendRS('sample,2,120,2,256, 323.526945,');
libs.appendRS('sample,1.5,10,2,256, 172.745382,');
libs.appendRS('sample,1.5,40,2,256, 268.041591,');
libs.appendRS('sample,1.5,80,2,256, 348.150198,');
libs.appendRS('sample,1.5,120,2,256, 310.915616,');
done();
})

Expand Down

0 comments on commit be200d9

Please sign in to comment.