SHS/pip
4
3
Fork 0
Code Issues 67 Pull Requests 1 Actions Releases Wiki Activity

pip 0.4.2 alpha r2

Browse Source 
git-svn-id: svn://db.shs.com.ru/pip@3 12ceb7fc-bf1f-11e4-8940-5bc7170c53b5
This commit is contained in:
Бычков Андрей
2015-02-28 13:05:45 +00:00
parent 03100ecfc3
commit 8e451c891d
11 changed files with 213 additions and 331 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
main.cpp
View File

@@ -1,17 +1,19 @@
#include "pip.h"
#include "pifiletransfer.h"
#include "pidatatransfer.h"
class Ob: public PIObject {
PIOBJECT(Ob)
public:
Ob() {
sft.setName("sft");
sft.setDirectory(sft.directory().cd("..\\"));
piCout << "Send File Transfer DIrectory" << sft.directory().absolutePath();
//sft.setDirectory(sft.directory().cd("..\\"));
//piCout << "Send File Transfer DIrectory" << sft.directory().absolutePath();
CONNECTU(&sft, sendRequest, this, ssend);
rft.setName("rft");
rft.setDirectory(rft.directory().cd("..\\1"));
piCout << "Receive File Transfer DIrectory" << rft.directory().absolutePath();
//rft.setDirectory(rft.directory().cd("..\\1"));
//piCout << "Receive File Transfer DIrectory" << rft.directory().absolutePath();
CONNECTU(&rft, sendRequest, this, rsend);
}
@@ -19,12 +21,12 @@ public:
PIDir dir = PIDir::current();
dir.cd("..\\");
piCout << dir.absolutePath();
PIVector<PIDir::DirEntry> des = dir.allEntries();
PIVector<PIFile::FileInfo> des = dir.allEntries();
piCout << "all entries" << des.size();
PIDir::DirEntry sde;
piForeachC(PIDir::DirEntry de, des) {
PIFile::FileInfo sde;
piForeachC(PIFile::FileInfo de, des) {
//piCout << (de.isDir() ? "dir:" : "file") << de.name << de.size;
if (de.name == "0") sde = de;
if (de.name() == "0") sde = de;
}
//sft.setPacketSize(64096);
sft.send(sde);
@@ -32,21 +34,21 @@ public:
private:
EVENT_HANDLER1(void, ssend, PIByteArray &, data) {
// piCout << "[sender]" << sft.stateString() << ". datasize =" << data.size()
// << "(" << PIString::readableSize(sft.bytesFileCur()) << "/" << PIString::readableSize(sft.bytesFileAll()) << ", "
// << PIString::readableSize(sft.bytesTotalCur()) << "/" << PIString::readableSize(sft.bytesTotalAll()) << ")";
piCout << "[sender]" << sft.stateString() << ". datasize =" << data.size()
<< "(" << PIString::readableSize(sft.bytesFileCur()) << "/" << PIString::readableSize(sft.bytesFileAll()) << ", "
<< PIString::readableSize(sft.bytesTotalCur()) << "/" << PIString::readableSize(sft.bytesTotalAll()) << ")";
if(rand()%100 != 90) rft.received(data);
}
EVENT_HANDLER1(void, rsend, PIByteArray &, data) {
// piCout << "[receiver]" << rft.stateString() << ". datasize =" << data.size()
// << "(" << PIString::readableSize(rft.bytesFileCur()) << "/" << PIString::readableSize(rft.bytesFileAll()) << ", "
// << PIString::readableSize(rft.bytesTotalCur()) << "/" << PIString::readableSize(rft.bytesTotalAll()) << ")";
piCout << "[receiver]" << rft.stateString() << ". datasize =" << data.size()
<< "(" << PIString::readableSize(rft.bytesFileCur()) << "/" << PIString::readableSize(rft.bytesFileAll()) << ", "
<< PIString::readableSize(rft.bytesTotalCur()) << "/" << PIString::readableSize(rft.bytesTotalAll()) << ")";
if(rand()%100 != 90) sft.received(data);
}
PIFileTransfer sft;
PIFileTransfer rft;
PIBaseTransfer sft;
PIBaseTransfer rft;
};
@@ -98,6 +100,11 @@ private:
};
int main (int argc, char * argv[]) {
Ob o;
PITimeMeasurer tm;
o.startsend();
piCout << tm.elapsed_s();
return 0;
if (!(argc == 3 || argc == 4)) {
piCout << "UDPFileTransfer";
piCout << "USE: piptest [src_ip_port] [dst_ip_port] {filename}";
@@ -119,11 +126,6 @@ int main (int argc, char * argv[]) {
}
WAIT_FOR_EXIT
return 0;
// Ob o;
// ft.setPacketSize(65536);
// PITimeMeasurer tm;
// o.startsend();
// piCout << tm.elapsed_s();
// return 0;
}