Fixed deadlock if buffer disconnects before sending metadata to connectors.
This commit is contained in:
parent
e23a835c26
commit
10f1803857
3 changed files with 3 additions and 3 deletions
|
@ -183,7 +183,7 @@ namespace Connector_HTTP {
|
|||
}
|
||||
ss.setBlocking(false);
|
||||
//make sure metadata is received
|
||||
while ( !Strm.metadata){
|
||||
while ( !Strm.metadata && ss.connected()){
|
||||
if (ss.spool()){
|
||||
while (Strm.parsePacket(ss.Received())){
|
||||
//do nothing
|
||||
|
|
|
@ -127,7 +127,7 @@ namespace Connector_HTTP {
|
|||
}
|
||||
ss.setBlocking(false);
|
||||
//make sure metadata is received
|
||||
while ( !Strm.metadata){
|
||||
while ( !Strm.metadata && ss.connected()){
|
||||
if (ss.spool()){
|
||||
while (Strm.parsePacket(ss.Received())){
|
||||
//do nothing
|
||||
|
|
|
@ -182,7 +182,7 @@ namespace Connector_HTTP {
|
|||
}
|
||||
ss.setBlocking(false);
|
||||
//Do nothing until metadata has been received.
|
||||
while ( !Strm.metadata){
|
||||
while ( !Strm.metadata && ss.connected()){
|
||||
if (ss.spool()){
|
||||
while (Strm.parsePacket(ss.Received())){
|
||||
//do nothing
|
||||
|
|
Loading…
Add table
Reference in a new issue