mirrors/phobos
1
0
Fork 0
mirror of https://github.com/dlang/phobos.git synced 2025-05-14 17:05:58 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fixed user handling of the OwnerTerminated message so it will not always throw.

Browse source
This commit is contained in:
Sean Kelly 2010-10-07 14:19:04 +00:00
parent 15f5f6e8f2
commit 5744b5000c
1 changed files with 22 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

24
std/concurrency.d
View file

@ -775,7 +775,10 @@ private
if( wrap[0] == owner )
{
owner = Tid.init;
throw new OwnerTerminated( wrap[0] );
auto e = new OwnerTerminated( wrap[0] );
if( onStandardMsg( Message( MsgType.standard, e ) ) )
return true;
throw e;
}
return false;
}
@ -803,8 +806,19 @@ private
{
if( onControlMsg( range.front ) )
{
// Although the linkDead message is a control message,
// it can be handled by the user. Since the linkDead
// message throws if not handled, if we get here then
// it has been handled and we can return from receive.
// This is a weird special case that will have to be
// handled in a more general way if more are added.
if( !isLinkDeadMsg( range.front ) )
{
list.removeAt( range );
continue;
}
list.removeAt( range );
continue;
return true;
}
range.popFront();
continue;
@ -980,6 +994,12 @@ private
{
return msg.type == MsgType.priority;
}
pure final bool isLinkDeadMsg( Message msg )
{
return msg.type == MsgType.linkDead;
}
private: