Git-Mirrors/RetroShare
1
0
Fork 0
mirror of https://github.com/RetroShare/RetroShare.git synced 2024-10-01 02:35:48 -04:00
Code Issues Actions Packages Projects Releases Wiki Activity

added missing call to SSL_pending, which caused decrypted data to wait in the SSL buffer when the bio is not receiving anything more

Browse Source
This commit is contained in:
csoler 2016-04-29 17:53:21 -04:00
parent a4430647de
commit 654e0fc1d8
4 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
libretroshare/src/pqi/pqissl.cc
View File

@ -1857,6 +1857,10 @@ bool pqissl::moretoread(uint32_t usec)
#endif #endif
return 1; return 1;
} }
else if(SSL_pending(ssl_connection) > 0)
{
return 1 ;
}
else else
{ {
#ifdef PQISSL_DEBUG #ifdef PQISSL_DEBUG

3
libretroshare/src/pqi/pqistreamer.cc
View File

@ -63,6 +63,7 @@ static uint8_t PACKET_SLICING_PROBE_BYTES[8] = { 0x02, 0xaa, 0xbb, 0xcc, 0x00,
#define DEBUG_PQISTREAMER 1 #define DEBUG_PQISTREAMER 1
#define DEBUG_PACKET_SLICING 1 #define DEBUG_PACKET_SLICING 1
***/ ***/
#define DEBUG_PACKET_SLICING 1
#ifdef DEBUG_TRANSFERS #ifdef DEBUG_TRANSFERS
#include "util/rsprint.h" #include "util/rsprint.h"
@ -780,6 +781,8 @@ continue_packet:
std::cerr << "Reading partial packet from mem block " << RsUtil::BinToHex((char*)block,8) << ": packet_id=" << std::hex << slice_packet_id << std::dec << ", len=" << extralen << std::endl; std::cerr << "Reading partial packet from mem block " << RsUtil::BinToHex((char*)block,8) << ": packet_id=" << std::hex << slice_packet_id << std::dec << ", len=" << extralen << std::endl;
#endif #endif
is_partial_packet = true ; is_partial_packet = true ;
mAcceptsPacketSlicing = true ; // this is needed
} }
else else
extralen = getRsItemSize(block) - blen; // old style packet type extralen = getRsItemSize(block) - blen; // old style packet type

3
libretroshare/src/rsserver/p3face-server.cc
View File

@ -47,7 +47,6 @@ int rsserverzone = 101;
/**** /****
#define DEBUG_TICK 1 #define DEBUG_TICK 1
****/ ****/
#define DEBUG_TICK 1
#define WARN_BIG_CYCLE_TIME (0.2) #define WARN_BIG_CYCLE_TIME (0.2)
#ifdef WINDOWS_SYS #ifdef WINDOWS_SYS
@ -140,8 +139,6 @@ void RsServer::data_tick()
double ts = getCurrentTS(); double ts = getCurrentTS();
double delta = ts - mLastts; double delta = ts - mLastts;
std::cerr << "[data tick] delta = " << delta << std::endl;
/* for the fast ticked stuff */ /* for the fast ticked stuff */
if (delta > mTimeDelta) if (delta > mTimeDelta)
{ {

1
libretroshare/src/services/p3rtt.cc
View File

@ -150,7 +150,6 @@ RsServiceInfo p3rtt::getServiceInfo()
int p3rtt::tick() int p3rtt::tick()
{ {
std::cerr << "p3rtt::tick() " << getCurrentTS() << std::endl;
sendPackets(); sendPackets();
return 0; return 0;