Open-Harbor/osrm-backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

iron out skeleton for implementation of shared sync

Browse Source
This commit is contained in:
Dennis Luxen 2013-10-21 19:06:58 +02:00
parent d0198649f2
commit 4c02002265
1 changed files with 21 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
Library/OSRM.cpp
View File

@ -103,7 +103,17 @@ void OSRM::RunQuery(RouteParameters & route_parameters, http::Reply & reply) {
if(plugin_map.end() != iter) { if(plugin_map.end() != iter) {
reply.status = http::Reply::ok; reply.status = http::Reply::ok;
if( use_shared_memory && barrier->update_ongoing ) { if( use_shared_memory ) {
//TODO lock update pending
//TODO lock query
//TODO unlock update pending
//TODO ++query_count
//TODO unlock query
//wait until we get the mutex and free it immediately //wait until we get the mutex and free it immediately
//TODO: increment semaphore of querying processes //TODO: increment semaphore of querying processes
boost::interprocess::scoped_lock< boost::interprocess::scoped_lock<
@ -111,6 +121,16 @@ void OSRM::RunQuery(RouteParameters & route_parameters, http::Reply & reply) {
> lock(barrier->update_mutex); > lock(barrier->update_mutex);
} }
iter->second->HandleRequest(route_parameters, reply ); iter->second->HandleRequest(route_parameters, reply );
if( use_shared_memory ) {
//TODO unlock update pending
//TODO --query_count
//if (0 == query_count) {
//TODO notify.all query_count 0
//}
//TODO unlock query
}
} else { } else {
reply = http::Reply::stockReply(http::Reply::badRequest); reply = http::Reply::stockReply(http::Reply::badRequest);
} }