File tree 1 file changed +4
-4
lines changed
1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -31,12 +31,12 @@ class CMQMaster { // : public ZeroMQ {
31
31
Rf_error (" Could not bind port after " , i, " tries" );
32
32
}
33
33
void send_work (SEXP data) {
34
- std::cerr << " setting worker " << cur << " active\n " ;
34
+ // std::cerr << "setting worker " << cur << " active\n";
35
35
peer_active[cur] = true ;
36
36
send (data);
37
37
}
38
38
void send_shutdown (SEXP data) {
39
- std::cerr << " setting worker " << cur << " inactive\n " ;
39
+ // std::cerr << "setting worker " << cur << " inactive\n";
40
40
peer_active[cur] = false ;
41
41
send (data);
42
42
}
@@ -69,14 +69,14 @@ class CMQMaster { // : public ZeroMQ {
69
69
memcpy (RAW (msg), content.data (), content.size ());
70
70
msg = R_unserialize (msg);
71
71
} else {
72
- std::cerr << " notify disconnect from " << cur << " \n " ;
72
+ // std::cerr << "notify disconnect from " << cur << "\n";
73
73
if (peer_active[cur])
74
74
Rf_error (" Unexpected worker disconnect: check your logs" );
75
75
peer_active.erase (cur);
76
76
ev = 0 ;
77
77
}
78
78
79
- std::cerr << peer_active.size () << " peers\n " ;
79
+ // std::cerr << peer_active.size() << " peers\n";
80
80
} while (ev == 0 );
81
81
82
82
return msg;
You can’t perform that action at this time.
0 commit comments