This commit is contained in:
Sebastian Piwell
2016-05-13 10:20:51 -04:00
parent 929fe810df
commit 489b7bbcd2
7 changed files with 89 additions and 207 deletions

View File

@@ -343,7 +343,7 @@ std::vector<float*> DataPlane::readData(std::string& dataBuffer){
numValues++;
}
}
std::cout << "Actual size: " << numValues << " Expected: " << _dimensions.x*_dimensions.y << std::endl;
// std::cout << "Actual size: " << numValues << " Expected: " << _dimensions.x*_dimensions.y << std::endl;
if(numValues != _dimensions.x*_dimensions.y){
LWARNING("Number of values read and expected are not the same");
return std::vector<float*>();

View File

@@ -71,7 +71,6 @@ void IswaGroup::registerCygnet(IswaCygnet* cygnet, IswaManager::CygnetType type)
return;
}
if(type == IswaManager::CygnetType::Data){
DataPlane* dataplane = static_cast<DataPlane*>(cygnet);
@@ -171,7 +170,6 @@ void IswaGroup::registerProperties(){
OsEng.gui()._iswa.registerProperty(&_delete);
_delete.onChange([this]{
clearGroup();
// IswaManager::ref().unregisterGroup(_id);
});
}

View File

@@ -36,7 +36,6 @@ namespace openspace {
ScreenSpaceCygnet::ScreenSpaceCygnet(const ghoul::Dictionary& dictionary)
: ScreenSpaceImage(dictionary)
, _updateInterval("updateInterval", "Update Interval", 1.0, 0.0 , 10.0)
{
// hacky, have to first get as float and then cast to int.
float cygnetid;

View File

@@ -42,10 +42,8 @@ public:
virtual void update() override;
private:
int _cygnetId;
properties::FloatProperty _updateInterval;
int _updateTime;
double _openSpaceTime;

View File

@@ -49,9 +49,7 @@ namespace {
namespace openspace{
IswaManager::IswaManager()
// :_iswaNames("iswaNames", "iSWA Cygnets")
{
IswaManager::IswaManager(){
_month["JAN"] = "01";
_month["FEB"] = "02";
_month["MAR"] = "03";
@@ -81,11 +79,11 @@ IswaManager::IswaManager()
LWARNING("Download to memory was aborted: " + err);
}
);
}
IswaManager::~IswaManager(){
_groups.clear();
_cygnetInformation.clear();
}
void IswaManager::addIswaCygnet(std::string info){
@@ -148,9 +146,7 @@ void IswaManager::addIswaCygnet(int id, std::string info, int group){
metaFuture->json,
metadataCallback
);
}else{
//create kameleonplane
// createKameleonPlane(info);
}else{
std::shared_ptr<MetadataFuture> metaFuture = std::make_shared<MetadataFuture>();
metaFuture->id = -1;
metaFuture->group = group;
@@ -171,52 +167,13 @@ void IswaManager::addIswaCygnet(int id, std::string info, int group){
metaFuture->json,
metadataCallback
);
}
}
}
void IswaManager::deleteIswaCygnet(std::string name){
OsEng.scriptEngine().queueScript("openspace.removeSceneGraphNode('" + name + "')");
}
void IswaManager::deleteScreenSpaceCygnet(int id){
if(_cygnetInformation.find(id) == _cygnetInformation.end()){
LWARNING("Could not find Cygnet with id = " + std::to_string(id));
return;
}
std::string script = "openspace.unregisterScreenSpaceRenderable('" + _cygnetInformation[id]->name + "');";
OsEng.scriptEngine().queueScript(script);
}
std::shared_ptr<DownloadManager::FileFuture> IswaManager::downloadImageToMemory(int id, std::string& buffer){
return DlManager.downloadToMemory(
iswaUrl(id, "image"),
buffer,
[](const DownloadManager::FileFuture& f){
if(f.isFinished){
LDEBUG("Download to memory finished");
} else if (f.isAborted){
LWARNING("Download to memory was aborted: " + f.errorMessage);
}
}
);
}
std::shared_ptr<DownloadManager::FileFuture> IswaManager::downloadDataToMemory(int id, std::string& buffer){
return DlManager.downloadToMemory(
iswaUrl(id, "data"),
buffer,
[](const DownloadManager::FileFuture& f){
if(f.isFinished){
LDEBUG("Download to memory finished");
} else if (f.isAborted){
LWARNING("Download to memory was aborted: " + f.errorMessage);
}
}
);
}
std::future<DownloadManager::MemoryFile> IswaManager::fetchImageCygnet(int id){
return std::move( DlManager.fetchFile(
iswaUrl(id, "image"),
@@ -241,7 +198,6 @@ std::future<DownloadManager::MemoryFile> IswaManager::fetchDataCygnet(int id){
) );
}
std::string IswaManager::iswaUrl(int id, std::string type){
std::string url;
if(id < 0){
@@ -267,6 +223,44 @@ std::string IswaManager::iswaUrl(int id, std::string type){
return url;
}
void IswaManager::registerToGroup(int id, CygnetType type, IswaCygnet* cygnet){
if(_groups.find(id) == _groups.end()){
_groups.insert(std::pair<int, std::shared_ptr<IswaGroup>>(id, std::make_shared<IswaGroup>(id)));
}
_groups[id]->registerCygnet(cygnet, type);
}
void IswaManager::unregisterFromGroup(int id, IswaCygnet* cygnet){
if(_groups.find(id) != _groups.end()){
_groups[id]->unregisterCygnet(cygnet);
}
}
void IswaManager::registerOptionsToGroup(int id, const std::vector<properties::SelectionProperty::Option>& options){
if(_groups.find(id) != _groups.end()){
_groups[id]->registerOptions(options);
}
}
std::shared_ptr<IswaGroup> IswaManager::iswaGroup(std::string name){
for(auto group : _groups){
if(group.second->name() == name){
return group.second;
}
}
return nullptr;
}
std::map<int, std::shared_ptr<CygnetInfo>>& IswaManager::cygnetInformation(){
return _cygnetInformation;
}
std::map<int, std::shared_ptr<IswaGroup>>& IswaManager::groups(){
return _groups;
}
std::shared_ptr<MetadataFuture> IswaManager::downloadMetadata(int id){
std::shared_ptr<MetadataFuture> metaFuture = std::make_shared<MetadataFuture>();
@@ -287,36 +281,6 @@ std::shared_ptr<MetadataFuture> IswaManager::downloadMetadata(int id){
return metaFuture;
}
void IswaManager::createScreenSpace(int id){
std::string script = "openspace.iswa.addScreenSpaceCygnet("
"{CygnetId =" + std::to_string(id) + "});";
OsEng.scriptEngine().queueScript(script);
}
void IswaManager::createPlane(std::shared_ptr<MetadataFuture> data){
// check if this plane already exist
std::string name = _type[data->type] + _geom[data->geom] + std::to_string(data->id);
if(data->group > 0){
auto it = _groups.find(data->group);
if(it == _groups.end() || (*it).second->checkType((CygnetType) data->type))
name += "_Group" + std::to_string(data->group);
}
data->name = name;
if( OsEng.renderEngine().scene()->sceneGraphNode(name) ){
LERROR("A node with name \"" + name +"\" already exist");
return;
}
std::string luaTable = parseJSONToLuaTable(data);
if(luaTable != ""){
std::string script = "openspace.addSceneGraphNode(" + luaTable + ");";
OsEng.scriptEngine().queueScript(script);
}
}
std::string IswaManager::parseJSONToLuaTable(std::shared_ptr<MetadataFuture> data){
if(data->json != ""){
json j = json::parse(data->json);
@@ -369,113 +333,34 @@ std::string IswaManager::parseJSONToLuaTable(std::shared_ptr<MetadataFuture> dat
return "";
}
// void IswaManager::createKameleonPlane(std::string kwPath, int group){
// kwPath = "${OPENSPACE_DATA}/" + kwPath;
// const std::string& extension = ghoul::filesystem::File(absPath(kwPath)).fileExtension();
// if(FileSys.fileExists(absPath(kwPath)) && extension == "cdf"){
// std::string luaTable = parseKWToLuaTable(kwPath, group);
// if(!luaTable.empty()){
// std::cout << luaTable << std::endl;
// std::string script = "openspace.addSceneGraphNode(" + luaTable + ");";
// OsEng.scriptEngine().queueScript(script);
// }
// }else{
// LWARNING( kwPath + " is not a cdf file or can't be found.");
// }
// }
//
// std::string IswaManager::parseKWToLuaTable(std::string kwPath, int group){
// if(kwPath != ""){
// const std::string& extension = ghoul::filesystem::File(absPath(kwPath)).fileExtension();
// if(extension == "cdf"){
// KameleonWrapper kw = KameleonWrapper(absPath(kwPath));
// std::string parent = kw.getParent();
// std::string frame = kw.getFrame();
// glm::vec3 min = kw.getGridMin();
// glm::vec3 max = kw.getGridMax();
// glm::vec4 spatialScale;
// std::string coordinateType;
// std::tuple < std::string, std::string, std::string > gridUnits = kw.getGridUnits();
// if (std::get<0>(gridUnits) == "R" && std::get<1>(gridUnits) == "R" && std::get<2>(gridUnits) == "R") {
// spatialScale.x = 6.371f;
// spatialScale.y = 6.371f;
// spatialScale.z = 6.371f;
// spatialScale.w = 6;
// coordinateType = "Cartesian";
// }else{
// spatialScale = glm::vec4(1.0);
// spatialScale.w = 1; //-log10(1.0f/max.x);
// coordinateType = "Polar";
// }
// std::string table = "{"
// "Name = 'KameleonPlane0',"
// "Parent = '" + parent + "', "
// "Renderable = {"
// "Type = 'KameleonPlane', "
// "Id = 0 ,"
// "Frame = '" + frame + "' , "
// "GridMin = " + std::to_string(min) + ", "
// "GridMax = " + std::to_string(max) + ", "
// "SpatialScale = " + std::to_string(spatialScale) + ", "
// "UpdateTime = 0, "
// "kwPath = '" + kwPath + "' ,"
// "axisCut = 'y' ,"
// "CoordinateType = '" + coordinateType + "', "
// "Group = "+ std::to_string(group) + " ,"
// "}"
// "}"
// ;
// // std::cout << table << std::endl;
// return table;
// }
// }
// return "";
// }
void IswaManager::registerGroup(int id){
_groups.insert(std::pair<int, std::shared_ptr<IswaGroup>>(id, std::make_shared<IswaGroup>(id)));
void IswaManager::createScreenSpace(int id){
std::string script = "openspace.iswa.addScreenSpaceCygnet("
"{CygnetId =" + std::to_string(id) + "});";
OsEng.scriptEngine().queueScript(script);
}
void IswaManager::unregisterGroup(int id){
if(_groups.find(id) != _groups.end())
_groups[id]->clearGroup();
}
void IswaManager::createPlane(std::shared_ptr<MetadataFuture> data){
// check if this plane already exist
std::string name = _type[data->type] + _geom[data->geom] + std::to_string(data->id);
void IswaManager::registerToGroup(int id, CygnetType type, IswaCygnet* cygnet){
if(_groups.find(id) == _groups.end()){
registerGroup(id);
if(data->group > 0){
auto it = _groups.find(data->group);
if(it == _groups.end() || (*it).second->checkType((CygnetType) data->type))
name += "_Group" + std::to_string(data->group);
}
_groups[id]->registerCygnet(cygnet, type);
}
data->name = name;
void IswaManager::unregisterFromGroup(int id, IswaCygnet* cygnet){
if(_groups.find(id) != _groups.end()){
_groups[id]->unregisterCygnet(cygnet);
}
}
void IswaManager::registerOptionsToGroup(int id, const std::vector<properties::SelectionProperty::Option>& options){
if(_groups.find(id) != _groups.end()){
_groups[id]->registerOptions(options);
}
}
std::shared_ptr<IswaGroup> IswaManager::iswaGroup(std::string name){
for(auto group : _groups){
if(group.second->name() == name){
return group.second;
}
if( OsEng.renderEngine().scene()->sceneGraphNode(name) ){
LERROR("A node with name \"" + name +"\" already exist");
return;
}
return nullptr;
std::string luaTable = parseJSONToLuaTable(data);
if(luaTable != ""){
std::string script = "openspace.addSceneGraphNode(" + luaTable + ");";
OsEng.scriptEngine().queueScript(script);
}
}
void IswaManager::fillCygnetInfo(std::string jsonString){

View File

@@ -78,38 +78,27 @@ public:
void addIswaCygnet(std::string info);
void addIswaCygnet(int id, std::string info = "Texture", int group = -1);
void deleteIswaCygnet(std::string);
void deleteScreenSpaceCygnet(int id);
std::shared_ptr<DownloadManager::FileFuture> downloadImageToMemory(int id, std::string& buffer);
std::shared_ptr<DownloadManager::FileFuture> downloadDataToMemory(int id, std::string& buffer);
std::future<DownloadManager::MemoryFile> fetchImageCygnet(int id);
std::future<DownloadManager::MemoryFile> fetchDataCygnet(int id);
std::string iswaUrl(int id, std::string type = "image");
void registerGroup(int id);
void unregisterGroup(int id);
void registerToGroup(int id, CygnetType type, IswaCygnet* cygnet);
void unregisterFromGroup(int id, IswaCygnet* cygnet);
void registerOptionsToGroup(int id, const std::vector<properties::SelectionProperty::Option>& options);
std::shared_ptr<IswaGroup> iswaGroup(std::string name);
std::map<int, std::shared_ptr<CygnetInfo>>& cygnetInformation();
std::map<int, std::shared_ptr<IswaGroup>>& groups();
static scripting::ScriptEngine::LuaLibrary luaLibrary();
std::string iswaUrl(int id, std::string type = "image");
void createScreenSpace(int id);
std::map<int, std::shared_ptr<CygnetInfo>>& cygnetInformation(){
return _cygnetInformation;
}
private:
std::shared_ptr<MetadataFuture> downloadMetadata(int id);
void createPlane(std::shared_ptr<MetadataFuture> data);
std::string parseJSONToLuaTable(std::shared_ptr<MetadataFuture> data);
void createKameleonPlane(std::string kwPath, int group = -1);
std::string parseKWToLuaTable(std::string kwPath, int group);
void createScreenSpace(int id);
void createPlane(std::shared_ptr<MetadataFuture> data);
void fillCygnetInfo(std::string jsonString);
@@ -117,13 +106,11 @@ private:
std::map<int, std::string> _type;
std::map<int, std::string> _geom;
std::map<int, std::shared_ptr<IswaGroup>> _groups;
std::shared_ptr<ccmc::Kameleon> _kameleon;
std::set<std::string> _kameleonFrames;
std::map<int, std::shared_ptr<IswaGroup>> _groups;
std::map<int, std::shared_ptr<CygnetInfo>> _cygnetInformation;
// properties::SelectionProperty _iswaNames;
};
} //namespace openspace

View File

@@ -33,7 +33,7 @@ int iswa_addCygnet(lua_State* L) {
}
int iswa_addScreenSpaceCygnet(lua_State* L){
static const std::string _loggerCat = "registerScreenSpaceRenderable";
static const std::string _loggerCat = "addScreenSpaceCygnet";
using ghoul::lua::errorLocation;
int nArguments = lua_gettop(L);
@@ -84,14 +84,29 @@ int iswa_removeCygnet(lua_State* L){
}
int iswa_removeScrenSpaceCygnet(lua_State* L){
static const std::string _loggerCat = "removeScreenSpaceCygnet";
int id = lua_tonumber(L, 1);
IswaManager::ref().deleteScreenSpaceCygnet(id);
auto cygnetInformation = IswaManager::ref().cygnetInformation();
if(cygnetInformation.find(id) == cygnetInformation.end()){
LWARNING("Could not find Cygnet with id = " + std::to_string(id));
return 0;
}
std::string script = "openspace.unregisterScreenSpaceRenderable('" + cygnetInformation[id]->name + "');";
OsEng.scriptEngine().queueScript(script);
return 0;
}
int iswa_removeGroup(lua_State* L){
int id = lua_tonumber(L, 1);
IswaManager::ref().unregisterGroup(id);
// IswaManager::ref().unregisterGroup(id);
auto groups = IswaManager::ref().groups();
if(groups.find(id) != groups.end())
groups[id]->clearGroup();
return 0;
}