Skip to content

Instantly share code, notes, and snippets.

wifi:transfer2go Rishi$ bash test/run.sh pull dataset
### Perform test of pull model
Kill previous transfer2go processes (if any)
create agents areas in /tmp/transfer2go
Create config and catalogs
main agent: mainAgent (http://localhost:8989)
source agent: sourceAgent (http://localhost:8000)
destination agent: destinationAgent (http://localhost:9000)
create large file in source area
0+0 records in
wifi:transfer2go Rishi$ bash test/run.sh push dataset
### Perform test of push model
Kill previous transfer2go processes (if any)
create agents areas in /tmp/transfer2go
Create config and catalogs
main agent: mainAgent (http://localhost:8989)
source agent: sourceAgent (http://localhost:8000)
destination agent: destinationAgent (http://localhost:9000)
create large file in source area
0+0 records in
wifi:transfer2go Rishi$ bash test/run.sh push dataset
### Perform test of push model
Kill previous transfer2go processes (if any)
create agents areas in /tmp/transfer2go
Create config and catalogs
main agent: mainAgent (http://localhost:8989)
source agent: sourceAgent (http://localhost:8000)
destination agent: destinationAgent (http://localhost:9000)
create large file in source area
0+0 records in
=============== Destination =============
11881 rshah 20 0 286m 10m 4720 S 1.3 0.0 0:01.57 transfer2go
11881 rshah 20 0 610m 20m 4952 S 3.3 0.1 0:01.67 transfer2go
11881 rshah 20 0 1034m 263m 4996 S 29.5 0.7 0:02.56 transfer2go
11881 rshah 20 0 1309m 535m 4996 S 34.2 1.5 0:03.59 transfer2go
11881 rshah 20 0 1838m 895m 4996 S 28.5 2.5 0:04.45 transfer2go
11881 rshah 20 0 1838m 1.0g 4996 S 23.2 2.8 0:05.15 transfer2go
11881 rshah 20 0 2895m 1.6g 4996 S 42.5 4.6 0:06.43 transfer2go
11881 rshah 20 0 2895m 1.8g 4996 S 19.6 5.0 0:07.02 transfer2go
======================== source-server =========================
PID USER PR NI VIRT RES SHR S %CPU %MEM TIME+ COMMAND
12076 root 20 0 112704 6468 4428 S 6.7 0.3 0:00.10 transfer2go
12076 root 20 0 112704 6468 4428 S 0.3 0.3 0:00.11 transfer2go
12076 root 20 0 277616 8612 5152 S 8.0 0.5 0:00.35 transfer2go
12076 root 20 0 277616 8612 5152 S 8.6 0.5 0:00.61 transfer2go
12076 root 20 0 352408 8612 5152 S 8.0 0.5 0:00.85 transfer2go
12076 root 20 0 352408 8612 5152 S 7.6 0.5 0:01.08 transfer2go
12076 root 20 0 352408 8864 5216 S 6.6 0.5 0:01.28 transfer2go
12076 root 20 0 352408 8864 5216 R 7.0 0.5 0:01.49 transfer2go
if err == nil {
t.SrcUrl = srcUrl
t.SrcAlias = srcAlias
log.WithFields(log.Fields{
"srcUrl": srcUrl,
"srcAlias": srcAlias,
"err": err,
}).Println("Selected Agent")
} else {
package cache;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;
import java.util.TreeMap;
public class Zeta {
public static void main(String[] args) {
package zeta;
import java.util.ArrayDeque;
import java.util.Deque;
import java.util.HashMap;
public class dep {
public static void main(String[] args) {
int[][] node = new int[10][10];
node[0][3] = 1;
package test
import (
"encoding/json"
"testing"
"time"
"github.com/stretchr/testify/assert"
"github.com/vkuznet/transfer2go/core"
"github.com/vkuznet/transfer2go/utils"
CREATE TABLE FILES(id INTEGER PRIMARY KEY, lfn TEXT UNIQUE, pfn TEXT, blockid INTEGER, datasetid INTEGER, bytes INTEGER, hash TEXT, transfertime INTEGER, timestamp INTEGER, FOREIGN KEY(blockid) REFERENCES BLOCKS(id), FOREIGN KEY(datasetid) REFERENCES DATASETS(id));
CREATE TABLE DATASETS(id INTEGER PRIMARY KEY, dataset TEXT UNIQUE);
CREATE TABLE BLOCKS(id INTEGER PRIMARY KEY, block TEXT UNIQUE, datasetid INTEGER, FOREIGN KEY(datasetid) REFERENCES DATASETS(id));
CREATE TABLE REQUESTS(id INTEGER PRIMARY KEY, file TEXT, block TEXT, dataset TEXT, srcurl TEXT, dsturl TEXT, status TEXT, priority INTEGER);
CREATE TABLE TRANSACTION(megabytes REAL, cpu REAL, ram REAL, totalfiles INTEGER, primary key (megabytes, totalfiles));