\r
virtual void run()\r
{\r
- win32_exception::install_handler();\r
-\r
try\r
{\r
+ win32_exception::install_handler();\r
while(true)\r
{ \r
auto ticket = governor_.acquire();\r
\r
virtual safe_ptr<core::basic_frame> receive(int hints)\r
{\r
+ win32_exception::install_handler();\r
+\r
auto frame = core::basic_frame::late();\r
\r
try\r
\r
virtual void run()\r
{\r
- win32_exception::install_handler();\r
-\r
try\r
{\r
+ win32_exception::install_handler();\r
while(is_running_)\r
{ \r
auto ticket = governor_.acquire();\r
\r
virtual void run()\r
{\r
- win32_exception::install_handler();\r
-\r
try\r
{\r
+ win32_exception::install_handler();\r
for(auto packet = read_next_packet(); packet && is_running_; packet = read_next_packet())\r
{ \r
Concurrency::asend(target_, make_safe_ptr(packet));\r
\r
virtual void run()\r
{\r
- win32_exception::install_handler();\r
-\r
try\r
{\r
+ win32_exception::install_handler();\r
while(true)\r
{\r
auto ticket = governor_.acquire();\r