Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
A
Actor Framework
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Operations
Operations
Metrics
Environments
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
cpp-libs
Actor Framework
Commits
fb0140b7
Commit
fb0140b7
authored
Jun 09, 2011
by
neverlord
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
removed debug output
parent
af0866e2
Changes
4
Show whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
14 additions
and
21 deletions
+14
-21
cppa.creator.user
cppa.creator.user
+1
-1
src/context.cpp
src/context.cpp
+0
-6
src/unicast_network.cpp
src/unicast_network.cpp
+12
-11
unit_testing/test__remote_actor.cpp
unit_testing/test__remote_actor.cpp
+1
-3
No files found.
cppa.creator.user
View file @
fb0140b7
...
...
@@ -135,7 +135,7 @@
</data>
<data>
<variable>
ProjectExplorer.Project.Updater.EnvironmentId
</variable>
<value
type=
"QString"
>
{
07fcd197-092d-45a0-8500-3be614e6ae31
}
</value>
<value
type=
"QString"
>
{
23902c37-f07e-47cd-bb19-c366b9f708db
}
</value>
</data>
<data>
<variable>
ProjectExplorer.Project.Updater.FileVersion
</variable>
...
...
src/context.cpp
View file @
fb0140b7
#include <iostream>
// for thread_specific_ptr
// needed unless the new keyword "thread_local" works in GCC
#include <boost/thread.hpp>
...
...
@@ -10,9 +8,6 @@
#include "cppa/detail/converted_thread_context.hpp"
using
std
::
cout
;
using
std
::
endl
;
using
cppa
::
detail
::
converted_thread_context
;
namespace
{
...
...
@@ -48,7 +43,6 @@ context* self()
context
*
result
=
s_this_context
.
get
();
if
(
result
==
nullptr
)
{
cout
<<
"converted a native thread to an actor"
<<
endl
;
result
=
new
converted_thread_context
;
result
->
ref
();
get_scheduler
()
->
register_converted_context
(
result
);
...
...
src/unicast_network.cpp
View file @
fb0140b7
...
...
@@ -294,7 +294,7 @@ void mailman_loop()
{
bs
<<
out_msg
;
auto
size32
=
static_cast
<
std
::
uint32_t
>
(
bs
.
size
());
cout
<<
"--> "
<<
(
to_string
(
out_msg
)
+
"
\n
"
);
//
cout << "--> " << (to_string(out_msg) + "\n");
auto
sent
=
::
send
(
peer
,
&
size32
,
sizeof
(
size32
),
flags
);
if
(
sent
!=
-
1
)
{
...
...
@@ -303,7 +303,8 @@ cout << "--> " << (to_string(out_msg) + "\n");
if
(
sent
==
-
1
)
{
// peer unreachable
cout
<<
"peer "
<<
*
(
sjob
.
target_peer
)
<<
" unreachable"
<<
endl
;
//cout << "peer " << *(sjob.target_peer)
// << " unreachable" << endl;
peers
.
erase
(
*
(
sjob
.
target_peer
));
}
}
...
...
@@ -404,7 +405,7 @@ void post_office_loop(native_socket_t socket_fd,
read_from_socket
(
socket_fd
,
buf
,
buf_size
);
binary_deserializer
bd
(
buf
,
buf_size
);
meta_msg
->
deserialize
(
&
msg
,
&
bd
);
cout
<<
"<-- "
<<
(
to_string
(
msg
)
+
"
\n
"
);
//
cout << "<-- " << (to_string(msg) + "\n");
if
(
msg
.
content
().
size
()
==
1
&&
msg
.
content
().
utype_info_at
(
0
)
==
atom_tinfo
&&
*
reinterpret_cast
<
const
atom_value
*>
(
msg
.
content
().
at
(
0
))
...
...
@@ -413,8 +414,8 @@ cout << "<-- " << (to_string(msg) + "\n");
actor_ptr
sender
=
msg
.
sender
();
if
(
sender
->
parent_process
()
==
pinfo
)
{
cout
<<
pinfo
<<
" ':Monitor'; actor id = "
<<
sender
->
id
()
<<
endl
;
//
cout << pinfo << " ':Monitor'; actor id = "
//
<< sender->id() << endl;
// local actor?
// this message was send from a proxy
sender
->
attach
(
new
remote_observer
(
peer
));
...
...
@@ -429,16 +430,16 @@ cout << "<-- " << (to_string(msg) + "\n");
}
catch
(
std
::
ios_base
::
failure
&
e
)
{
cout
<<
"std::ios_base::failure: "
<<
e
.
what
()
<<
endl
;
//
cout << "std::ios_base::failure: " << e.what() << endl;
}
catch
(
std
::
exception
&
e
)
{
cout
<<
"["
<<
process_information
::
get
()
<<
"] "
<<
detail
::
to_uniform_name
(
typeid
(
e
))
<<
": "
<<
e
.
what
()
<<
endl
;
//
cout << "[" << process_information::get() << "] "
//
<< detail::to_uniform_name(typeid(e)) << ": "
//
<< e.what() << endl;
}
cout
<<
"["
<<
process_information
::
get
()
<<
"] ~post_office_loop"
<<
endl
;
//
cout << "<-- post_office_loop"
<< endl;
//cout << "[" << process_information::get() << "] ~post_office_loop"
//
<< endl;
}
struct
mm_worker
...
...
unit_testing/test__remote_actor.cpp
View file @
fb0140b7
#include <string>
#include <iostream>
#include <boost/thread.hpp>
#include "test.hpp"
...
...
@@ -59,7 +58,7 @@ size_t test__remote_actor(const char* app_path, bool is_client,
std
::
string
cmd
;
{
std
::
ostringstream
oss
;
oss
<<
app_path
<<
" test__remote_actor "
<<
port
;
//
<< " &>/dev/null";
oss
<<
app_path
<<
" test__remote_actor "
<<
port
<<
" &>/dev/null"
;
cmd
=
oss
.
str
();
}
// execute client_part() in a separate process,
...
...
@@ -68,7 +67,6 @@ size_t test__remote_actor(const char* app_path, bool is_client,
await_all_others_done
();
CPPA_CHECK_EQUAL
(
pongs
(),
5
);
// wait until separate process (in sep. thread) finished execution
std
::
cout
<<
"child.join()"
<<
std
::
endl
;
child
.
join
();
return
CPPA_TEST_RESULT
;
}
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment