]> git.mxchange.org Git - flightgear.git/blob - src/Scenery/tilemgr.cxx
7949a9b94329e3bf3833506ddccba7596dd5562d
[flightgear.git] / src / Scenery / tilemgr.cxx
1 // tilemgr.cxx -- routines to handle dynamic management of scenery tiles
2 //
3 // Written by Curtis Olson, started January 1998.
4 //
5 // Copyright (C) 1997  Curtis L. Olson  - curt@infoplane.com
6 //
7 // This program is free software; you can redistribute it and/or
8 // modify it under the terms of the GNU General Public License as
9 // published by the Free Software Foundation; either version 2 of the
10 // License, or (at your option) any later version.
11 //
12 // This program is distributed in the hope that it will be useful, but
13 // WITHOUT ANY WARRANTY; without even the implied warranty of
14 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
15 // General Public License for more details.
16 //
17 // You should have received a copy of the GNU General Public License
18 // along with this program; if not, write to the Free Software
19 // Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
20 //
21 // $Id$
22
23
24 #ifdef HAVE_CONFIG_H
25 #  include <config.h>
26 #endif
27
28 #ifdef HAVE_WINDOWS_H
29 #  include <windows.h>
30 #endif
31
32 #include <GL/glut.h>
33 #include <simgear/xgl/xgl.h>
34
35 #include <simgear/constants.h>
36 #include <simgear/debug/logstream.hxx>
37 #include <simgear/math/fg_geodesy.hxx>
38 #include <simgear/math/point3d.hxx>
39 #include <simgear/math/polar3d.hxx>
40 #include <simgear/math/vector.hxx>
41
42 // #include <Aircraft/aircraft.hxx>
43 #include <Main/options.hxx>
44 #include <Main/views.hxx>
45 #include <Objects/obj.hxx>
46
47 #ifndef FG_OLD_WEATHER
48 #  include <WeatherCM/FGLocalWeatherDatabase.h>
49 #else
50 #  include <Weather/weather.hxx>
51 #endif
52
53 #include "scenery.hxx"
54 #include "tilecache.hxx"
55 #include "tilemgr.hxx"
56
57 #define TEST_LAST_HIT_CACHE
58
59 extern ssgRoot *scene;
60 extern ssgBranch *terrain;
61
62 // the tile manager
63 FGTileMgr global_tile_mgr;
64
65
66 // a temporary hack until we get everything rewritten with sgdVec3
67 static inline Point3D operator + (const Point3D& a, const sgdVec3 b)
68 {
69     return Point3D(a.x()+b[0], a.y()+b[1], a.z()+b[2]);
70 }
71
72
73 // Constructor
74 FGTileMgr::FGTileMgr ( void ):
75     state( Start )
76 {
77 }
78
79
80 // Destructor
81 FGTileMgr::~FGTileMgr ( void ) {
82 }
83
84
85 // Initialize the Tile Manager subsystem
86 int FGTileMgr::init( void ) {
87     FG_LOG( FG_TERRAIN, FG_INFO, "Initializing Tile Manager subsystem." );
88
89     if ( state != Start ) {
90         FG_LOG( FG_TERRAIN, FG_INFO,
91                 "... Reinitializing." );
92
93         // This is necessay to keep bookeeping straight for the
94         // tile_cache   -- which actually handles all the
95         // (de)allocations  
96         while( load_queue.size() ) {
97             FG_LOG( FG_TERRAIN, FG_INFO, 
98                     "Load queue not empty, popping a tile" );
99             FGLoadRec pending = load_queue.front();
100             load_queue.pop_front();
101             load_tile( pending.b, pending.cache_index );
102         }
103     } else {
104         FG_LOG( FG_TERRAIN, FG_INFO,
105                 "... First time through." );
106     }
107
108     global_tile_cache.init();
109     hit_list.clear();
110
111     state = Inited;
112
113     tile_diameter = current_options.get_tile_diameter();
114     FG_LOG( FG_TERRAIN, FG_INFO, "Tile Diameter = " << tile_diameter);
115     
116     previous_bucket.make_bad();
117     current_bucket.make_bad();
118
119     scroll_direction = SCROLL_INIT;
120     tile_index = -9999;
121
122     longitude = latitude = -1000.0;
123     last_longitude = last_latitude = -1000.0;
124         
125     return 1;
126 }
127
128
129 // schedule a tile for loading
130 int FGTileMgr::sched_tile( const FGBucket& b ) {
131     // see if tile already exists in the cache
132     int cache_index = global_tile_cache.exists( b );
133
134     if ( cache_index >= 0 ) {
135         // tile exists in cache, reenable it.
136         // cout << "REENABLING DISABLED TILE" << endl;
137         FGTileEntry *t = global_tile_cache.get_tile( cache_index );
138         t->select_ptr->select( 1 );
139         t->mark_loaded();
140     } else {
141         // find the next available cache entry and mark it as
142         // scheduled
143         cache_index = global_tile_cache.next_avail();
144         FGTileEntry *t = global_tile_cache.get_tile( cache_index );
145         t->mark_scheduled_for_use();
146
147         // register a load request
148         FGLoadRec request;
149         request.b = b;
150         request.cache_index = cache_index;
151         load_queue.push_back( request );
152     }
153
154     return cache_index;
155 }
156
157
158 // load a tile
159 void FGTileMgr::load_tile( const FGBucket& b, int cache_index) {
160
161     FG_LOG( FG_TERRAIN, FG_DEBUG, "Loading tile " << b );
162
163     global_tile_cache.fill_in(cache_index, b);
164
165     FG_LOG( FG_TERRAIN, FG_DEBUG, "Loaded for cache index: " << cache_index );
166 }
167
168
169 // Determine scenery altitude via ssg.  Normally this just happens
170 // when we render the scene, but we'd also like to be able to do this
171 // explicitely.  lat & lon are in radians.  view_pos in current world
172 // coordinate translated near (0,0,0) (in meters.)  Returns result in
173 // meters.
174
175 bool
176 FGTileMgr::current_elev_ssg( const Point3D& abs_view_pos, 
177                              const Point3D& view_pos )
178 {
179     sgdVec3 orig, dir;
180
181     sgdSetVec3(orig, view_pos.x(), view_pos.y(), view_pos.z() );
182     sgdSetVec3(dir, abs_view_pos.x(), abs_view_pos.y(), abs_view_pos.z() );
183
184     hit_list.Intersect( terrain, orig, dir );
185
186     int this_hit=0;
187     Point3D geoc;
188     double result = -9999;
189
190     int hitcount = hit_list.num_hits();
191     for ( int i = 0; i < hitcount; ++i ) {
192         geoc = fgCartToPolar3d( scenery.center + hit_list.get_point(i) );      
193         double lat_geod, alt, sea_level_r;
194         fgGeocToGeod(geoc.lat(), geoc.radius(), &lat_geod, 
195                      &alt, &sea_level_r);
196         if ( alt > result && alt < 10000 ) {
197             result = alt;
198             this_hit = i;
199         }
200     }
201
202     if ( result > -9000 ) {
203         scenery.cur_elev = result;
204         scenery.cur_radius = geoc.radius();
205         sgdCopyVec3(scenery.cur_normal, hit_list.get_normal(this_hit));
206         return true;
207     } else {
208         FG_LOG( FG_TERRAIN, FG_INFO, "no terrain intersection" );
209         scenery.cur_elev = 0.0;
210         float *up = current_view.local_up;
211         sgdSetVec3(scenery.cur_normal, up[0], up[1], up[2]);
212         return false;
213     }
214 }
215
216
217 FGBucket FGTileMgr::BucketOffset( int dx, int dy )
218 {
219     double clat, clon, span;
220     if( scroll_direction == SCROLL_INIT ) {
221         pending.set_bucket( longitude, latitude );
222         clat = pending.get_center_lat() + dy * FG_BUCKET_SPAN;
223
224         // walk dy units in the lat direction
225         pending.set_bucket( longitude, clat );
226
227         // find the lon span for the new latitude
228         span = bucket_span( clat );
229         
230         // walk dx units in the lon direction
231         clon = longitude + dx * span;
232     } else      {
233         pending.set_bucket( last_longitude, last_latitude );
234         clat = pending.get_center_lat() + dy * FG_BUCKET_SPAN;
235
236         // walk dy units in the lat direction
237         pending.set_bucket( last_longitude, clat );
238
239         // find the lon span for the new latitude
240         span = bucket_span( clat );
241
242         // walk dx units in the lon direction
243         clon = last_longitude + dx * span;
244     }    
245         
246     while ( clon < -180.0 ) clon += 360.0;
247     while ( clon >= 180.0 ) clon -= 360.0;
248     pending.set_bucket( clon, clat );
249
250     FG_LOG( FG_TERRAIN, FG_DEBUG, "    fgBucketOffset " << pending );
251     return pending;
252 }
253
254
255 // schedule a tile row(column) for loading
256 void FGTileMgr::scroll( void )
257 {
258     FG_LOG( FG_TERRAIN, FG_DEBUG, "schedule_row: Scrolling" );
259
260     int i, dw, dh;
261         
262     switch( scroll_direction ) {
263     case SCROLL_NORTH:
264         FG_LOG( FG_TERRAIN, FG_DEBUG, 
265                 "  (North) Loading " << tile_diameter << " tiles" );
266         dw = tile_diameter / 2;
267         dh = dw + 1;
268         for ( i = 0; i < tile_diameter; i++ ) {
269             sched_tile( BucketOffset( i - dw, dh) );
270         }
271         break;
272     case SCROLL_EAST:
273         FG_LOG( FG_TERRAIN, FG_DEBUG, 
274                 "  (East) Loading " << tile_diameter << " tiles" );
275         dh = tile_diameter / 2;
276         dw = dh + 1;
277         for ( i = 0; i < tile_diameter; i++ ) {
278             sched_tile( BucketOffset( dw, i - dh ) );
279         }
280         break;
281     case SCROLL_SOUTH:
282         dw = tile_diameter / 2;
283         dh = -dw - 1;
284         FG_LOG( FG_TERRAIN, FG_DEBUG, 
285                 "  (South) Loading " << tile_diameter << " tiles" );
286         for ( i = 0; i < tile_diameter; i++ ) {
287             sched_tile( BucketOffset( i - dw, dh) );
288         }
289         break;
290     case SCROLL_WEST:
291         dh = tile_diameter / 2;
292         dw = -dh - 1;
293         FG_LOG( FG_TERRAIN, FG_DEBUG, 
294                 "  (West) Loading " << tile_diameter << " tiles" );
295         for ( i = 0; i < tile_diameter; i++ ) {
296             sched_tile( BucketOffset( dw, i - dh ) );
297         }
298         break;
299     default:
300         FG_LOG( FG_TERRAIN, FG_WARN, "UNKNOWN SCROLL DIRECTION in schedule_row" );
301         ;
302     }
303     FG_LOG( FG_TERRAIN, FG_DEBUG, "\tschedule_row returns" );
304 }
305
306
307 void FGTileMgr::initialize_queue()
308 {
309     // First time through or we have teleported, initialize the
310     // system and load all relavant tiles
311
312     FG_LOG( FG_TERRAIN, FG_INFO, "Updating Tile list for " << current_bucket );
313     FG_LOG( FG_TERRAIN, FG_INFO, "  Updating Tile list for " << current_bucket );
314     FG_LOG( FG_TERRAIN, FG_INFO, "  Loading " 
315             << tile_diameter * tile_diameter << " tiles" );
316
317     int i;
318     scroll_direction = SCROLL_INIT;
319
320     // wipe/initialize tile cache
321     global_tile_cache.init();
322     previous_bucket.make_bad();
323
324     // build the local area list and schedule tiles for loading
325
326     // start with the center tile and work out in concentric
327     // "rings"
328
329     sched_tile( current_bucket );
330
331     for ( i = 3; i <= tile_diameter; i = i + 2 ) {
332         int j;
333         int span = i / 2;
334
335         // bottom row
336         for ( j = -span; j <= span; ++j ) {
337             sched_tile( BucketOffset( j, -span ) );
338         }
339
340         // top row
341         for ( j = -span; j <= span; ++j ) {
342             sched_tile( BucketOffset( j, span ) );
343         }
344
345         // middle rows
346         for ( j = -span + 1; j <= span - 1; ++j ) {
347             sched_tile( BucketOffset( -span, j ) );
348             sched_tile( BucketOffset( span, j ) );
349         }
350
351     }
352
353     // Now force a load of the center tile and inner ring so we
354     // have something to see in our first frame.
355     for ( i = 0; i < 9; ++i ) {
356         if ( load_queue.size() ) {
357             FG_LOG( FG_TERRAIN, FG_DEBUG, 
358                     "Load queue not empty, loading a tile" );
359
360             FGLoadRec pending = load_queue.front();
361             load_queue.pop_front();
362             load_tile( pending.b, pending.cache_index );
363         }
364     }
365 }
366
367
368 // given the current lon/lat (in degrees), fill in the array of local
369 // chunks.  If the chunk isn't already in the cache, then read it from
370 // disk.
371 int FGTileMgr::update( double lon, double lat ) {
372     // FG_LOG( FG_TERRAIN, FG_DEBUG, "FGTileMgr::update()" );
373
374     // FGInterface *f = current_aircraft.fdm_state;
375
376     // lonlat for this update 
377     // longitude = f->get_Longitude() * RAD_TO_DEG;
378     // latitude = f->get_Latitude() * RAD_TO_DEG;
379     longitude = lon;
380     latitude = lat;
381     // FG_LOG( FG_TERRAIN, FG_DEBUG, "lon "<< lonlat[LON] <<
382     //      " lat " << lonlat[LAT] );
383
384     current_bucket.set_bucket( longitude, latitude );
385     // FG_LOG( FG_TERRAIN, FG_DEBUG, "Updating Tile list for " << current_bucket );
386
387     tile_index = global_tile_cache.exists(current_bucket);
388     // FG_LOG( FG_TERRAIN, FG_DEBUG, "tile index " << tile_index );
389
390     if ( tile_index >= 0 ) {
391         current_tile = global_tile_cache.get_tile(tile_index);
392         scenery.next_center = current_tile->center;
393     } else {
394         FG_LOG( FG_TERRAIN, FG_WARN, "Tile not found (Ok if initializing)" );
395     }
396
397     if ( state == Running ) {
398         if( current_bucket == previous_bucket) {
399             FG_LOG( FG_TERRAIN, FG_DEBUG, "Same bucket as last time" );
400             scroll_direction = SCROLL_NONE;
401         } else {
402             // We've moved to a new bucket, we need to scroll our
403             // structures, and load in the new tiles
404             // CURRENTLY THIS ASSUMES WE CAN ONLY MOVE TO ADJACENT TILES.
405             // AT ULTRA HIGH SPEEDS THIS ASSUMPTION MAY NOT BE VALID IF
406             // THE AIRCRAFT CAN SKIP A TILE IN A SINGLE ITERATION.
407
408             if ( (current_bucket.get_lon() > previous_bucket.get_lon()) ||
409                  ( (current_bucket.get_lon() == previous_bucket.get_lon()) && 
410                    (current_bucket.get_x() > previous_bucket.get_x()) ) )
411                 {
412                     scroll_direction = SCROLL_EAST;
413                 }
414             else if ( (current_bucket.get_lon() < previous_bucket.get_lon()) ||
415                       ( (current_bucket.get_lon() == previous_bucket.get_lon()) && 
416                         (current_bucket.get_x() < previous_bucket.get_x()) ) )
417                 {   
418                     scroll_direction = SCROLL_WEST;
419                 }   
420
421             if ( (current_bucket.get_lat() > previous_bucket.get_lat()) ||
422                  ( (current_bucket.get_lat() == previous_bucket.get_lat()) && 
423                    (current_bucket.get_y() > previous_bucket.get_y()) ) )
424                 {   
425                     scroll_direction = SCROLL_NORTH;
426                 }
427             else if ( (current_bucket.get_lat() < previous_bucket.get_lat()) ||
428                       ( (current_bucket.get_lat() == previous_bucket.get_lat()) && 
429                         (current_bucket.get_y() < previous_bucket.get_y()) ) )
430                 {
431                     scroll_direction = SCROLL_SOUTH;
432                 }
433
434             scroll();
435         }
436
437     } else if ( state == Start || state == Inited ) {
438         initialize_queue();
439         state = Running;
440     }
441
442     if ( load_queue.size() ) {
443         FG_LOG( FG_TERRAIN, FG_DEBUG, "Load queue not empty, loading a tile" );
444
445         FGLoadRec pending = load_queue.front();
446         load_queue.pop_front();
447         load_tile( pending.b, pending.cache_index );
448     }
449
450     if ( scenery.center == Point3D(0.0) ) {
451         // initializing
452         // cout << "initializing ... " << endl;
453         Point3D geod_pos = Point3D( longitude * DEG_TO_RAD,
454                                     latitude * DEG_TO_RAD,
455                                     0.0);
456         Point3D tmp_abs_view_pos = fgGeodToCart( geod_pos );
457         scenery.center = tmp_abs_view_pos;
458         // cout << "abs_view_pos = " << tmp_abs_view_pos << endl;
459         prep_ssg_nodes();
460         current_elev_ssg( tmp_abs_view_pos,
461                           Point3D( 0.0 ) );
462     } else {
463         // cout << "abs view pos = " << current_view.abs_view_pos
464         //      << " view pos = " << current_view.view_pos << endl;
465         current_elev_ssg( current_view.abs_view_pos,
466                           current_view.view_pos );
467     }
468
469     // cout << "current elevation (ssg) == " << scenery.cur_elev << endl;
470
471     previous_bucket = current_bucket;
472     last_longitude = longitude;
473     last_latitude  = latitude;
474
475     return 1;
476 }
477
478 // Prepare the ssg nodes ... for each tile, set it's proper
479 // transform and update it's range selector based on current
480 // visibilty
481 void FGTileMgr::prep_ssg_node( int idx ) {
482 }
483
484 void FGTileMgr::prep_ssg_nodes( void ) {
485     FGTileEntry *t;
486     float ranges[2];
487     ranges[0] = 0.0f;
488     double vis = 0.0;
489
490 #ifndef FG_OLD_WEATHER
491     if ( WeatherDatabase != NULL ) {
492         vis = WeatherDatabase->getWeatherVisibility();
493     } else {
494         vis = 16000;
495     }
496 #else
497     vis = current_weather.get_visibility();
498 #endif
499     // cout << "visibility = " << vis << endl;
500
501     // traverse the potentially viewable tile list and update range
502     // selector and transform
503     for ( int i = 0; i < (int)global_tile_cache.get_size(); i++ ) {
504         t = global_tile_cache.get_tile( i );
505
506         if ( t->is_loaded() ) {
507             // set range selector (LOD trick) to be distance to center
508             // of tile + bounding radius
509
510             ranges[1] = vis + t->bounding_radius;
511             t->range_ptr->setRanges( ranges, 2 );
512
513             // calculate tile offset
514             t->SetOffset( scenery.center );
515
516             // calculate ssg transform
517             sgCoord sgcoord;
518             sgSetCoord( &sgcoord,
519                         t->offset.x(), t->offset.y(), t->offset.z(),
520                         0.0, 0.0, 0.0 );
521             t->transform_ptr->setTransform( &sgcoord );
522         }
523     }
524 }