projects
/
feisty_meow.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
fixing extensions
[feisty_meow.git]
/
octopi
/
library
/
octopus
/
tentacle.cpp
diff --git
a/octopi/library/octopus/tentacle.cpp
b/octopi/library/octopus/tentacle.cpp
index cda8f3d2d90a03f15ff40813bce11436278638b3..beb2fb4e07af6d444cf22a1a77fabb6c18873382 100644
(file)
--- a/
octopi/library/octopus/tentacle.cpp
+++ b/
octopi/library/octopus/tentacle.cpp
@@
-75,8
+75,8
@@
tentacle::tentacle(const string_array &group_name, bool backgrounded,
: _group(new string_array(group_name)),
_pending(new queueton),
_input_guard(new mutex),
: _group(new string_array(group_name)),
_pending(new queueton),
_input_guard(new mutex),
- _action(N
IL
),
- _products(N
IL
),
+ _action(N
ULL_POINTER
),
+ _products(N
ULL_POINTER
),
_backgrounded(backgrounded)
{
// we only start the thread if they've said they'll support backgrounding.
_backgrounded(backgrounded)
{
// we only start the thread if they've said they'll support backgrounding.
@@
-106,13
+106,13
@@
entity_data_bin *tentacle::get_storage() { return _products; }
void tentacle::attach_storage(entity_data_bin &storage)
{
_products = &storage;
void tentacle::attach_storage(entity_data_bin &storage)
{
_products = &storage;
- if (_action) _action->start(N
IL
);
+ if (_action) _action->start(N
ULL_POINTER
);
}
void tentacle::detach_storage()
{
if (_action) _action->stop();
}
void tentacle::detach_storage()
{
if (_action) _action->stop();
- _products = N
IL
;
+ _products = N
ULL_POINTER
;
}
bool tentacle::store_product(infoton *product,
}
bool tentacle::store_product(infoton *product,
@@
-158,9
+158,9
@@
outcome tentacle::enqueue(infoton *to_chow, const octopus_request_id &item_id)
infoton *tentacle::next_request(octopus_request_id &item_id)
{
GRAB_CONSUMER_LOCK;
infoton *tentacle::next_request(octopus_request_id &item_id)
{
GRAB_CONSUMER_LOCK;
- if (!_pending->elements()) return N
IL
; // nothing to return.
+ if (!_pending->elements()) return N
ULL_POINTER
; // nothing to return.
infoton *to_return = (*_pending)[0]->_product;
infoton *to_return = (*_pending)[0]->_product;
- (*_pending)[0]->_product = N
IL
;
+ (*_pending)[0]->_product = N
ULL_POINTER
;
// clean out so destructor doesn't delete the object.
item_id = (*_pending)[0]->_id;
_pending->zap(0, 0);
// clean out so destructor doesn't delete the object.
item_id = (*_pending)[0]->_id;
_pending->zap(0, 0);
@@
-170,7
+170,7
@@
infoton *tentacle::next_request(octopus_request_id &item_id)
void tentacle::propel_arm()
{
FUNCDEF("propel_arm");
void tentacle::propel_arm()
{
FUNCDEF("propel_arm");
- infoton *next_item = N
IL
;
+ infoton *next_item = N
ULL_POINTER
;
do {
octopus_request_id id;
next_item = next_request(id);
do {
octopus_request_id id;
next_item = next_request(id);