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
a781875b
Commit
a781875b
authored
Oct 08, 2013
by
Dominik Charousset
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
removed 'virtual' wherever 'override' is used
parent
86a74805
Changes
11
Hide whitespace changes
Inline
Side-by-side
Showing
11 changed files
with
26 additions
and
26 deletions
+26
-26
cppa/detail/object_array.hpp
cppa/detail/object_array.hpp
+6
-6
cppa/detail/thread_pool_scheduler.hpp
cppa/detail/thread_pool_scheduler.hpp
+2
-2
cppa/io/buffered_writing.hpp
cppa/io/buffered_writing.hpp
+1
-1
cppa/mailbox_based.hpp
cppa/mailbox_based.hpp
+1
-1
cppa/prioritizing.hpp
cppa/prioritizing.hpp
+4
-4
cppa/sb_actor.hpp
cppa/sb_actor.hpp
+1
-1
cppa/thread_mapped_actor.hpp
cppa/thread_mapped_actor.hpp
+1
-1
cppa/threaded.hpp
cppa/threaded.hpp
+3
-3
cppa/typed_actor.hpp
cppa/typed_actor.hpp
+1
-1
examples/curl/curl_fuse.cpp
examples/curl/curl_fuse.cpp
+4
-4
unit_testing/test_spawn.cpp
unit_testing/test_spawn.cpp
+2
-2
No files found.
cppa/detail/object_array.hpp
View file @
a781875b
...
@@ -54,17 +54,17 @@ class object_array : public abstract_tuple {
...
@@ -54,17 +54,17 @@ class object_array : public abstract_tuple {
void
push_back
(
const
object
&
what
);
void
push_back
(
const
object
&
what
);
v
irtual
v
oid
*
mutable_at
(
size_t
pos
)
override
;
void
*
mutable_at
(
size_t
pos
)
override
;
virtual
size_t
size
()
const
override
;
size_t
size
()
const
override
;
virtual
object_array
*
copy
()
const
override
;
object_array
*
copy
()
const
override
;
virtual
const
void
*
at
(
size_t
pos
)
const
override
;
const
void
*
at
(
size_t
pos
)
const
override
;
virtual
const
uniform_type_info
*
type_at
(
size_t
pos
)
const
override
;
const
uniform_type_info
*
type_at
(
size_t
pos
)
const
override
;
virtual
const
std
::
string
*
tuple_type_names
()
const
override
;
const
std
::
string
*
tuple_type_names
()
const
override
;
private:
private:
...
...
cppa/detail/thread_pool_scheduler.hpp
View file @
a781875b
...
@@ -61,9 +61,9 @@ class thread_pool_scheduler : public scheduler {
...
@@ -61,9 +61,9 @@ class thread_pool_scheduler : public scheduler {
void
enqueue
(
scheduled_actor
*
what
);
void
enqueue
(
scheduled_actor
*
what
);
virtual
local_actor_ptr
exec
(
spawn_options
opts
,
scheduled_actor_ptr
ptr
)
override
;
local_actor_ptr
exec
(
spawn_options
opts
,
scheduled_actor_ptr
ptr
)
override
;
virtual
local_actor_ptr
exec
(
spawn_options
opts
,
init_callback
init_cb
,
void_function
f
)
override
;
local_actor_ptr
exec
(
spawn_options
opts
,
init_callback
init_cb
,
void_function
f
)
override
;
private:
private:
...
...
cppa/io/buffered_writing.hpp
View file @
a781875b
...
@@ -53,7 +53,7 @@ class buffered_writing : public Base {
...
@@ -53,7 +53,7 @@ class buffered_writing : public Base {
:
super
{
std
::
forward
<
Ts
>
(
args
)...},
m_middleman
{
mm
},
m_out
{
out
}
:
super
{
std
::
forward
<
Ts
>
(
args
)...},
m_middleman
{
mm
},
m_out
{
out
}
,
m_has_unwritten_data
{
false
}
{
}
,
m_has_unwritten_data
{
false
}
{
}
virtual
continue_writing_result
continue_writing
()
override
{
continue_writing_result
continue_writing
()
override
{
CPPA_LOG_TRACE
(
""
);
CPPA_LOG_TRACE
(
""
);
CPPA_LOG_DEBUG_IF
(
!
m_has_unwritten_data
,
"nothing to write (done)"
);
CPPA_LOG_DEBUG_IF
(
!
m_has_unwritten_data
,
"nothing to write (done)"
);
while
(
m_has_unwritten_data
)
{
while
(
m_has_unwritten_data
)
{
...
...
cppa/mailbox_based.hpp
View file @
a781875b
...
@@ -62,7 +62,7 @@ class mailbox_based : public Base {
...
@@ -62,7 +62,7 @@ class mailbox_based : public Base {
template
<
typename
...
Ts
>
template
<
typename
...
Ts
>
mailbox_based
(
Ts
&&
...
args
)
:
Base
(
std
::
forward
<
Ts
>
(
args
)...)
{
}
mailbox_based
(
Ts
&&
...
args
)
:
Base
(
std
::
forward
<
Ts
>
(
args
)...)
{
}
v
irtual
v
oid
cleanup
(
std
::
uint32_t
reason
)
override
{
void
cleanup
(
std
::
uint32_t
reason
)
override
{
detail
::
sync_request_bouncer
f
{
reason
};
detail
::
sync_request_bouncer
f
{
reason
};
m_mailbox
.
close
(
f
);
m_mailbox
.
close
(
f
);
Base
::
cleanup
(
reason
);
Base
::
cleanup
(
reason
);
...
...
cppa/prioritizing.hpp
View file @
a781875b
...
@@ -44,7 +44,7 @@ class prioritizing : public Base {
...
@@ -44,7 +44,7 @@ class prioritizing : public Base {
public:
public:
virtual
mailbox_element
*
try_pop
()
override
{
mailbox_element
*
try_pop
()
override
{
auto
result
=
m_high_priority_mailbox
.
try_pop
();
auto
result
=
m_high_priority_mailbox
.
try_pop
();
return
(
result
)
?
result
:
this
->
m_mailbox
.
try_pop
();
return
(
result
)
?
result
:
this
->
m_mailbox
.
try_pop
();
}
}
...
@@ -56,18 +56,18 @@ class prioritizing : public Base {
...
@@ -56,18 +56,18 @@ class prioritizing : public Base {
typedef
prioritizing
combined_type
;
typedef
prioritizing
combined_type
;
v
irtual
v
oid
cleanup
(
std
::
uint32_t
reason
)
override
{
void
cleanup
(
std
::
uint32_t
reason
)
override
{
detail
::
sync_request_bouncer
f
{
reason
};
detail
::
sync_request_bouncer
f
{
reason
};
m_high_priority_mailbox
.
close
(
f
);
m_high_priority_mailbox
.
close
(
f
);
Base
::
cleanup
(
reason
);
Base
::
cleanup
(
reason
);
}
}
virtual
bool
mailbox_empty
()
override
{
bool
mailbox_empty
()
override
{
return
m_high_priority_mailbox
.
empty
()
return
m_high_priority_mailbox
.
empty
()
&&
this
->
m_mailbox
.
empty
();
&&
this
->
m_mailbox
.
empty
();
}
}
v
irtual
v
oid
enqueue
(
const
message_header
&
hdr
,
any_tuple
msg
)
override
{
void
enqueue
(
const
message_header
&
hdr
,
any_tuple
msg
)
override
{
typename
Base
::
mailbox_type
*
mbox
=
nullptr
;
typename
Base
::
mailbox_type
*
mbox
=
nullptr
;
if
(
hdr
.
priority
==
message_priority
::
high
)
{
if
(
hdr
.
priority
==
message_priority
::
high
)
{
mbox
=
&
m_high_priority_mailbox
;
mbox
=
&
m_high_priority_mailbox
;
...
...
cppa/sb_actor.hpp
View file @
a781875b
...
@@ -61,7 +61,7 @@ class sb_actor : public Base {
...
@@ -61,7 +61,7 @@ class sb_actor : public Base {
* @brief Overrides {@link event_based_actor::init()} and sets
* @brief Overrides {@link event_based_actor::init()} and sets
* the initial actor behavior to <tt>Derived::init_state</tt>.
* the initial actor behavior to <tt>Derived::init_state</tt>.
*/
*/
v
irtual
v
oid
init
()
override
{
void
init
()
override
{
become
(
util
::
dptr
<
Derived
>
(
this
)
->
init_state
);
become
(
util
::
dptr
<
Derived
>
(
this
)
->
init_state
);
}
}
...
...
cppa/thread_mapped_actor.hpp
View file @
a781875b
...
@@ -76,7 +76,7 @@ class thread_mapped_actor : public extend<local_actor, thread_mapped_actor>::
...
@@ -76,7 +76,7 @@ class thread_mapped_actor : public extend<local_actor, thread_mapped_actor>::
inline
void
initialized
(
bool
value
)
{
m_initialized
=
value
;
}
inline
void
initialized
(
bool
value
)
{
m_initialized
=
value
;
}
virtual
bool
initialized
()
const
override
;
bool
initialized
()
const
override
;
private:
private:
...
...
cppa/threaded.hpp
View file @
a781875b
...
@@ -105,7 +105,7 @@ class threaded : public Base {
...
@@ -105,7 +105,7 @@ class threaded : public Base {
m_initialized
=
value
;
m_initialized
=
value
;
}
}
virtual
bool
initialized
()
const
override
{
bool
initialized
()
const
override
{
return
m_initialized
;
return
m_initialized
;
}
}
...
@@ -133,11 +133,11 @@ class threaded : public Base {
...
@@ -133,11 +133,11 @@ class threaded : public Base {
}
}
}
}
v
irtual
v
oid
enqueue
(
const
message_header
&
hdr
,
any_tuple
msg
)
override
{
void
enqueue
(
const
message_header
&
hdr
,
any_tuple
msg
)
override
{
enqueue_impl
(
this
->
m_mailbox
,
hdr
,
std
::
move
(
msg
));
enqueue_impl
(
this
->
m_mailbox
,
hdr
,
std
::
move
(
msg
));
}
}
virtual
bool
chained_enqueue
(
const
message_header
&
hdr
,
any_tuple
msg
)
override
{
bool
chained_enqueue
(
const
message_header
&
hdr
,
any_tuple
msg
)
override
{
enqueue
(
hdr
,
std
::
move
(
msg
));
enqueue
(
hdr
,
std
::
move
(
msg
));
return
false
;
return
false
;
}
}
...
...
cppa/typed_actor.hpp
View file @
a781875b
...
@@ -95,7 +95,7 @@ class typed_actor : public event_based_actor {
...
@@ -95,7 +95,7 @@ class typed_actor : public event_based_actor {
});
});
}
}
v
irtual
v
oid
do_become
(
behavior
&&
,
bool
)
override
{
void
do_become
(
behavior
&&
,
bool
)
override
{
CPPA_LOG_ERROR
(
"typed actors are not allowed to call become()"
);
CPPA_LOG_ERROR
(
"typed actors are not allowed to call become()"
);
quit
(
exit_reason
::
unallowed_function_call
);
quit
(
exit_reason
::
unallowed_function_call
);
}
}
...
...
examples/curl/curl_fuse.cpp
View file @
a781875b
...
@@ -152,7 +152,7 @@ class client_job : public base_actor {
...
@@ -152,7 +152,7 @@ class client_job : public base_actor {
protected:
protected:
v
irtual
v
oid
init
()
override
{
void
init
()
override
{
print
()
<<
"init"
<<
color
::
reset_endl
;
print
()
<<
"init"
<<
color
::
reset_endl
;
send
(
m_parent
,
send
(
m_parent
,
atom
(
"read"
),
atom
(
"read"
),
...
@@ -186,7 +186,7 @@ class client : public base_actor {
...
@@ -186,7 +186,7 @@ class client : public base_actor {
protected:
protected:
v
irtual
v
oid
init
()
override
{
void
init
()
override
{
using
std
::
chrono
::
milliseconds
;
using
std
::
chrono
::
milliseconds
;
link_to
(
m_parent
);
link_to
(
m_parent
);
print
()
<<
"init"
<<
color
::
reset_endl
;
print
()
<<
"init"
<<
color
::
reset_endl
;
...
@@ -224,7 +224,7 @@ class curl_worker : public base_actor {
...
@@ -224,7 +224,7 @@ class curl_worker : public base_actor {
protected:
protected:
v
irtual
v
oid
init
()
override
{
void
init
()
override
{
print
()
<<
"init"
<<
color
::
reset_endl
;
print
()
<<
"init"
<<
color
::
reset_endl
;
m_curl
=
curl_easy_init
();
m_curl
=
curl_easy_init
();
curl_easy_setopt
(
m_curl
,
CURLOPT_WRITEFUNCTION
,
&
curl_worker
::
cb
);
curl_easy_setopt
(
m_curl
,
CURLOPT_WRITEFUNCTION
,
&
curl_worker
::
cb
);
...
@@ -314,7 +314,7 @@ class curl_master : public base_actor {
...
@@ -314,7 +314,7 @@ class curl_master : public base_actor {
protected:
protected:
v
irtual
v
oid
init
()
override
{
void
init
()
override
{
print
()
<<
"init"
<<
color
::
reset_endl
;
print
()
<<
"init"
<<
color
::
reset_endl
;
// spawn workers
// spawn workers
for
(
size_t
i
=
0
;
i
<
num_curl_workers
;
++
i
)
{
for
(
size_t
i
=
0
;
i
<
num_curl_workers
;
++
i
)
{
...
...
unit_testing/test_spawn.cpp
View file @
a781875b
...
@@ -418,7 +418,7 @@ void test_typed_actors() {
...
@@ -418,7 +418,7 @@ void test_typed_actors() {
struct
master
:
event_based_actor
{
struct
master
:
event_based_actor
{
v
irtual
v
oid
init
()
override
{
void
init
()
override
{
become
(
become
(
on
(
atom
(
"done"
))
>>
[]()
{
on
(
atom
(
"done"
))
>>
[]()
{
self
->
quit
(
exit_reason
::
user_defined
);
self
->
quit
(
exit_reason
::
user_defined
);
...
@@ -431,7 +431,7 @@ struct slave : event_based_actor {
...
@@ -431,7 +431,7 @@ struct slave : event_based_actor {
slave
(
actor_ptr
master
)
:
master
{
master
}
{
}
slave
(
actor_ptr
master
)
:
master
{
master
}
{
}
v
irtual
v
oid
init
()
override
{
void
init
()
override
{
link_to
(
master
);
link_to
(
master
);
become
(
become
(
others
()
>>
CPPA_UNEXPECTED_MSG_CB
()
others
()
>>
CPPA_UNEXPECTED_MSG_CB
()
...
...
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