dujeonglee / networkcodingrev Goto Github PK
View Code? Open in Web Editor NEWIntra-session Network Coding Transport Protocol for IPv4 and IPv6
License: MIT License
Intra-session Network Coding Transport Protocol for IPv4 and IPv6
License: MIT License
Support IPv6
Intra-session network coding has more gains in multicast transmission cases.
Multicast for reliable and best-effort transmission modes will be the most useful feature of this library.
if((*pp_block)->m_DecodingReady)
{
p_block = (*pp_block);
if(p_block->Decoding())
{
c_Session->m_SequenceNumberForService++;
}
}
else
{
for(u08 i = 0 ; i < (*pp_block)->m_DecodedPacketBuffer.size() ; i++)
{
if(i != reinterpret_cast<Header::Data*>((*pp_block)->m_DecodedPacketBuffer[i].get())->m_ExpectedRank-1)
{
break;
}
do
{
u08* pkt;
try
{
TEST_EXCEPTION(std::bad_alloc());
pkt = new u08[reinterpret_cast<Header::Data*>((*pp_block)->m_DecodedPacketBuffer[i].get())->m_TotalSize];
This Line->memcpy(pkt, (*pp_block)->m_DecodedPacketBuffer[i].get(), reinterpret_cast<Header::Data*>((*pp_block)->m_DecodedPacketBuffer[i].get())->m_TotalSize); <- This line.
while(c_Session->m_RxTaskQueue.Enqueue([this, pkt](){
c_Reception->m_RxCallback(pkt+sizeof(Header::Data)+reinterpret_cast<Header::Data*>(pkt)->m_MaximumRank-1, ntohs(reinterpret_cast<Header::Data*>(pkt)->m_PayloadSize), &c_Session->m_SenderAddress, sizeof(c_Session->m_SenderAddress));
delete [] pkt;
})==false);
reinterpret_cast<Header::Data*>((*pp_block)->m_DecodedPacketBuffer[i].get())->m_Flags |= Header::Data::DataHeaderFlag::FLAGS_CONSUMED;
break;
}
catch (const std::bad_alloc& ex)
{
EXCEPTION_PRINT;
}
}
while(1);
}
break;
}
Stack Trace
__memcpy_avx_unaligned () at ../sysdeps/x86_64/multiarch/memcpy-avx-unaligned.S:238
238 ../sysdeps/x86_64/multiarch/memcpy-avx-unaligned.S: No such file or directory.
(gdb) bt
#0 __memcpy_avx_unaligned () at ../sysdeps/x86_64/multiarch/memcpy-avx-unaligned.S:238
#1 0x000000000041f490 in NetworkCoding::ReceptionBlock::Receive (this=0x7fffe0089ea0,
buffer=0x7ffff6f4e880 "\001\004\024\t%\t(\t5\004\004\002", <incomplete sequence \302>, length=1044, sender_addr=0x7ffff6f4e7f0,
sender_addr_len=16) at rx.cpp:492
#2 0x0000000000420101 in NetworkCoding::ReceptionSession::Receive (this=0x7fffe00008c0,
buffer=0x7ffff6f4e880 "\001\004\024\t%\t(\t5\004\004\002", <incomplete sequence \302>, length=1044, sender_addr=0x7ffff6f4e7f0,
sender_addr_len=16) at rx.cpp:615
#3 0x000000000042042b in NetworkCoding::Reception::RxHandler (this=0x65a5e0,
buffer=0x7ffff6f4e880 "\001\004\024\t%\t(\t5\004\004\002", <incomplete sequence \302>, size=1044, sender_addr=0x7ffff6f4e7f0,
sender_addr_len=16) at rx.cpp:640
#4 0x000000000042668e in NetworkCoding::NCSocket::NCSocket(unsigned short, long, long, std::function<void (unsigned char*, unsigned short, sockaddr_in const*, unsigned int)>)::{lambda()#1}::operator()() const () at ncsocket.h:124
#5 0x00000000004283be in std::_Bind_simple<NetworkCoding::NCSocket::NCSocket(unsigned short, long, long, std::function<void (unsigned char*, unsigned short, sockaddr_in const*, unsigned int)>)::{lambda()#1} ()>::_M_invoke<>(std::_Index_tuple<>) (this=0x65a6b8)
at /usr/include/c++/5/functional:1531
#6 0x0000000000428314 in std::_Bind_simple<NetworkCoding::NCSocket::NCSocket(unsigned short, long, long, std::function<void (unsigned char*, unsigned short, sockaddr_in const*, unsigned int)>)::{lambda()#1} ()>::operator()() (this=0x65a6b8) at /usr/include/c++/5/functional:1520
#7 0x00000000004282a4 in std::thread::_Impl<std::_Bind_simple<NetworkCoding::NCSocket::NCSocket(unsigned short, long, long, std::function<void (unsigned char*, unsigned short, sockaddr_in const*, unsigned int)>)::{lambda()#1} ()> >::_M_run() (this=0x65a6a0)
at /usr/include/c++/5/thread:115
#8 0x00007ffff78f0c80 in ?? () from /usr/lib/x86_64-linux-gnu/libstdc++.so.6
#9 0x00007ffff7bc16ba in start_thread (arg=0x7ffff6f4f700) at pthread_create.c:333
#10 0x00007ffff735f82d in clone () at ../sysdeps/unix/sysv/linux/x86_64/clone.S:109
(gdb)
Some decoded packets are not correct.
#0 0x0807d930 in AVLTreeElement<NetworkCoding::DataTypes::SessionKey, NetworkCoding::ReceptionSession*>::~AVLTreeElement (this=0x80bfba0, __in_chrg=)
at ../basiclibrary/avltree/AVLTree.h:207
#1 0x0807b685 in AVLTree<NetworkCoding::DataTypes::SessionKey, NetworkCoding::ReceptionSession*>::Clear (this=0x80c0764) at ../basiclibrary/avltree/AVLTree.h:918
#2 0x0807838d in NetworkCoding::Reception::~Reception (this=0x80c0760,
__in_chrg=) at rx.cpp:761
#3 0x0804f5ac in NetworkCoding::NCSocket::~NCSocket (this=0x80bfba0,
__in_chrg=) at ncsocket.h:257
#4 0x0804df78 in FreeSocket (handle=0x80bfba0) at api.cpp:61
#5 0x0804a77e in AsyncReceiveFunction (port=0xbffff8c4 "10000") at main.cpp:157
#6 0x0804a908 in main (argc=3, argv=0xbffff764) at main.cpp:172
#0 0x0807b66f in AVLTree<NetworkCoding::DataTypes::SessionKey, NetworkCoding::ReceptionSession*>::Clear (this=0x80c0764) at ../basiclibrary/avltree/AVLTree.h:917
#1 0x0807838d in NetworkCoding::Reception::~Reception (this=0x80c0760,
__in_chrg=) at rx.cpp:761
#2 0x0804f5ac in NetworkCoding::NCSocket::~NCSocket (this=0x80bfba0,
__in_chrg=) at ncsocket.h:257
#3 0x0804df78 in FreeSocket (handle=0x80bfba0) at api.cpp:61
#4 0x0804a77e in AsyncReceiveFunction (port=0xbffff8c4 "10000") at main.cpp:157
#5 0x0804a908 in main (argc=3, argv=0xbffff764) at main.cpp:172
A declarative, efficient, and flexible JavaScript library for building user interfaces.
๐ Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
An Open Source Machine Learning Framework for Everyone
The Web framework for perfectionists with deadlines.
A PHP framework for web artisans
Bring data to life with SVG, Canvas and HTML. ๐๐๐
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
Some thing interesting about web. New door for the world.
A server is a program made to process requests and deliver data to clients.
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Some thing interesting about visualization, use data art
Some thing interesting about game, make everyone happy.
We are working to build community through open source technology. NB: members must have two-factor auth.
Open source projects and samples from Microsoft.
Google โค๏ธ Open Source for everyone.
Alibaba Open Source for everyone
Data-Driven Documents codes.
China tencent open source team.