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

load timestamp into shared memory

Browse Source
This commit is contained in:
Dennis Luxen 2013-09-27 13:53:49 +02:00
parent ff7dcf9c17
commit eb5bd8e6ac
1 changed files with 27 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
datastore.cpp
View File

@ -138,7 +138,24 @@ int main(int argc, char * argv[]) {
//TODO load search tree size
//TODO load checksum
//TODO load rsearch tree size
//TODO load timestamp size
//load timestamp size
SimpleLogger().Write() << "Loading timestamp";
std::string m_timestamp;
if( boost::filesystem::exists(timestamp_path) ) {
boost::filesystem::ifstream timestampInStream( timestamp_path );
if(!timestampInStream) {
SimpleLogger().Write(logWARNING) << timestamp_path << " not found";
}
getline(timestampInStream, m_timestamp);
timestampInStream.close();
}
if(m_timestamp.empty()) {
m_timestamp = "n/a";
}
if(25 < m_timestamp.length()) {
m_timestamp.resize(25);
}
shared_layout_ptr->timestamp_length = m_timestamp.length();
//load coordinate size
SimpleLogger().Write(logDEBUG) << "Loading coordinates list";
@ -221,6 +238,15 @@ int main(int argc, char * argv[]) {
}
nodes_input_stream.close();
//store timestamp
char * timestamp_ptr = static_cast<char *>(
shared_memory_ptr + shared_layout_ptr->GetTimeStampOffset()
);
std::copy(
m_timestamp.c_str(),
m_timestamp.c_str()+m_timestamp.length(),
timestamp_ptr
);
@ -274,35 +300,6 @@ int main(int argc, char * argv[]) {
);
std::copy(edge_list.begin(), edge_list.end(), graph_edge_ptr);
// load checksum
SimpleLogger().Write() << "Loading check sum";
SimpleLogger().Write() << "Loading timestamp";
std::string m_timestamp;
if( boost::filesystem::exists(timestamp_path) ) {
boost::filesystem::ifstream timestampInStream( timestamp_path );
if(!timestampInStream) {
SimpleLogger().Write(logWARNING) << timestamp_path << " not found";
}
getline(timestampInStream, m_timestamp);
timestampInStream.close();
}
if(m_timestamp.empty()) {
m_timestamp = "n/a";
}
if(25 < m_timestamp.length()) {
m_timestamp.resize(25);
}
SharedMemory * timestamp_memory = SharedMemoryFactory::Get(
TIMESTAMP, m_timestamp.length()
);
char * timestamp_ptr = static_cast<char *>( timestamp_memory->Ptr() );
std::copy(
m_timestamp.c_str(),
m_timestamp.c_str()+m_timestamp.length(),
timestamp_ptr
);
//Loading information for original edges
boost::filesystem::ifstream edges_input_stream(
edge_data_path,