Allow PasteCanvas layers with unset canvas parameters to be exported.
[synfig.git] / synfig-studio / trunk / src / gtkmm / asyncrenderer.cpp
1 /* === S Y N F I G ========================================================= */
2 /*!     \file asyncrenderer.cpp
3 **      \brief Template File
4 **
5 **      $Id$
6 **
7 **      \legal
8 **      Copyright (c) 2002-2005 Robert B. Quattlebaum Jr., Adrian Bentley
9 **      Copyright (c) 2007 Chris Moore
10 **
11 **      This package is free software; you can redistribute it and/or
12 **      modify it under the terms of the GNU General Public License as
13 **      published by the Free Software Foundation; either version 2 of
14 **      the License, or (at your option) any later version.
15 **
16 **      This package is distributed in the hope that it will be useful,
17 **      but WITHOUT ANY WARRANTY; without even the implied warranty of
18 **      MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
19 **      General Public License for more details.
20 **      \endlegal
21 */
22 /* ========================================================================= */
23
24 /* === H E A D E R S ======================================================= */
25
26 #ifdef USING_PCH
27 #       include "pch.h"
28 #else
29 #ifdef HAVE_CONFIG_H
30 #       include <config.h>
31 #endif
32
33 #include "asyncrenderer.h"
34 #include "app.h"
35 #include <glibmm/thread.h>
36 #include <glibmm/dispatcher.h>
37
38 #ifdef HAVE_UNISTD_H
39 #include <unistd.h>
40 #endif
41
42 #ifdef HAVE_SYS_TYPES_H
43 #include <sys/types.h>
44 #endif
45
46 #ifdef HAVE_SYS_WAIT_H
47 #include <sys/wait.h>
48 #endif
49
50 #ifdef HAVE_SIGNAL_H
51 #include <signal.h>
52 #endif
53
54 #include <synfig/general.h>
55 #include <ETL/clock>
56
57 #include "general.h"
58
59 #endif
60
61 /* === U S I N G =========================================================== */
62
63 using namespace std;
64 using namespace etl;
65 using namespace synfig;
66 using namespace studio;
67
68 #define BOREDOM_TIMEOUT         50
69
70 #define REJOIN_ON_STOP  1
71
72 // The Glib::Dispatcher class is broken as of Glibmm 2.4.5.
73 // Defining this macro enables the workaround.
74 #define GLIB_DISPATCHER_BROKEN 1
75
76 /* === C L A S S E S ======================================================= */
77
78 class AsyncTarget_Tile : public synfig::Target_Tile
79 {
80 public:
81         etl::handle<synfig::Target_Tile> warm_target;
82
83         struct tile_t
84         {
85                 Surface surface;
86                 int x,y;
87                 tile_t(const Surface& surface,int x, int y):
88                         surface(surface),
89                         x(x),y(y)
90                 {
91                 }
92         };
93         std::list<tile_t> tile_queue;
94         Glib::Mutex mutex;
95
96 #ifndef GLIB_DISPATCHER_BROKEN
97         Glib::Dispatcher tile_ready_signal;
98 #endif
99         Glib::Cond cond_tile_queue_empty;
100         bool alive_flag;
101
102         sigc::connection ready_connection;
103
104 public:
105         AsyncTarget_Tile(etl::handle<synfig::Target_Tile> warm_target):
106                 warm_target(warm_target)
107         {
108                 set_avoid_time_sync(warm_target->get_avoid_time_sync());
109                 set_tile_w(warm_target->get_tile_w());
110                 set_tile_h(warm_target->get_tile_h());
111                 set_canvas(warm_target->get_canvas());
112                 set_quality(warm_target->get_quality());
113                 set_remove_alpha(warm_target->get_remove_alpha());
114                 set_threads(warm_target->get_threads());
115                 set_clipping(warm_target->get_clipping());
116                 set_rend_desc(&warm_target->rend_desc());
117                 alive_flag=true;
118 #ifndef GLIB_DISPATCHER_BROKEN
119                 ready_connection=tile_ready_signal.connect(sigc::mem_fun(*this,&AsyncTarget_Tile::tile_ready));
120 #endif
121         }
122
123         ~AsyncTarget_Tile()
124         {
125                 ready_connection.disconnect();
126         }
127         void set_dead()
128         {
129                 Glib::Mutex::Lock lock(mutex);
130                 alive_flag=false;
131         }
132
133         virtual int total_tiles()const
134         {
135                 return warm_target->total_tiles();
136         }
137
138         virtual int next_tile(int& x, int& y)
139         {
140                 if(!alive_flag)
141                         return 0;
142
143                 return warm_target->next_tile(x,y);
144         }
145
146         virtual int next_frame(Time& time)
147         {
148                 if(!alive_flag)
149                         return 0;
150                 return warm_target->next_frame(time);
151         }
152
153         virtual bool start_frame(synfig::ProgressCallback *cb=0)
154         {
155                 if(!alive_flag)
156                         return false;
157                 return warm_target->start_frame(cb);
158         }
159
160         virtual bool add_tile(const synfig::Surface &surface, int gx, int gy)
161         {
162                 assert(surface);
163                 if(!alive_flag)
164                         return false;
165                 Glib::Mutex::Lock lock(mutex);
166                 tile_queue.push_back(tile_t(surface,gx,gy));
167                 if(tile_queue.size()==1)
168                 {
169 #ifdef GLIB_DISPATCHER_BROKEN
170                 ready_connection=Glib::signal_timeout().connect(
171                         sigc::bind_return(
172                                 sigc::mem_fun(*this,&AsyncTarget_Tile::tile_ready),
173                                 false
174                         )
175                         ,0
176                 );
177 #else
178                 tile_ready_signal();
179 #endif
180                 }
181
182                 return alive_flag;
183         }
184
185         void tile_ready()
186         {
187                 Glib::Mutex::Lock lock(mutex);
188                 if(!alive_flag)
189                 {
190                         tile_queue.clear();
191                         cond_tile_queue_empty.signal();
192                         return;
193                 }
194                 while(!tile_queue.empty() && alive_flag)
195                 {
196                         tile_t& tile(tile_queue.front());
197
198                         if (getenv("SYNFIG_SHOW_TILE_OUTLINES"))
199                         {
200                                 Color red(1,0,0);
201                                 tile.surface.fill(red, 0, 0, 1, tile.surface.get_h());
202                                 tile.surface.fill(red, 0, 0, tile.surface.get_w(), 1);
203                         }
204
205                         alive_flag=warm_target->add_tile(tile.surface,tile.x,tile.y);
206
207                         tile_queue.pop_front();
208                 }
209                 cond_tile_queue_empty.signal();
210         }
211
212         virtual void end_frame()
213         {
214 #ifdef SINGLE_THREADED
215                 if (!single_threaded())
216                 {
217 #endif
218                         while(alive_flag)
219                         {
220                                 Glib::Mutex::Lock lock(mutex);
221                                 if(!tile_queue.empty() && alive_flag)
222                                 {
223                                         if(cond_tile_queue_empty.timed_wait(mutex,Glib::TimeVal(0,BOREDOM_TIMEOUT)))
224                                                 break;
225                                 }
226                                 else
227                                         break;
228                         }
229 #ifdef SINGLE_THREADED
230                 }
231 #endif
232                 Glib::Mutex::Lock lock(mutex);
233                 if(!alive_flag)
234                         return;
235                 return warm_target->end_frame();
236         }
237 };
238
239
240
241 class AsyncTarget_Scanline : public synfig::Target_Scanline
242 {
243 public:
244         etl::handle<synfig::Target_Scanline> warm_target;
245
246         int scanline_;
247         Surface surface;
248
249         Glib::Mutex mutex;
250
251 #ifndef GLIB_DISPATCHER_BROKEN
252         Glib::Dispatcher frame_ready_signal;
253 #endif
254         Glib::Cond cond_frame_queue_empty;
255         bool alive_flag;
256         bool ready_next;
257         sigc::connection ready_connection;
258
259
260 public:
261         AsyncTarget_Scanline(etl::handle<synfig::Target_Scanline> warm_target):
262                 warm_target(warm_target)
263         {
264                 set_avoid_time_sync(warm_target->get_avoid_time_sync());
265                 set_canvas(warm_target->get_canvas());
266                 set_quality(warm_target->get_quality());
267                 set_remove_alpha(warm_target->get_remove_alpha());
268                 set_threads(warm_target->get_threads());
269                 set_rend_desc(&warm_target->rend_desc());
270                 alive_flag=true;
271 #ifndef GLIB_DISPATCHER_BROKEN
272                 ready_connection=frame_ready_signal.connect(sigc::mem_fun(*this,&AsyncTarget_Scanline::frame_ready));
273 #endif
274                 surface.set_wh(warm_target->rend_desc().get_w(),warm_target->rend_desc().get_h());
275         }
276
277         ~AsyncTarget_Scanline()
278         {
279                 ready_connection.disconnect();
280         }
281
282         virtual int next_frame(Time& time)
283         {
284                 if(!alive_flag)
285                         return 0;
286                 return warm_target->next_frame(time);
287
288         }
289
290         void set_dead()
291         {
292                 Glib::Mutex::Lock lock(mutex);
293                 alive_flag=false;
294         }
295
296         virtual bool start_frame(synfig::ProgressCallback */*cb*/=0)
297         {
298                 return alive_flag;
299         }
300
301         virtual void end_frame()
302         {
303                 {
304                         Glib::Mutex::Lock lock(mutex);
305
306                         if(!alive_flag)
307                                 return;
308                         ready_next=false;
309
310 #ifdef GLIB_DISPATCHER_BROKEN
311                 ready_connection=Glib::signal_timeout().connect(
312                         sigc::bind_return(
313                                 sigc::mem_fun(*this,&AsyncTarget_Scanline::frame_ready),
314                                 false
315                         )
316                         ,0
317                 );
318 #else
319                         frame_ready_signal();
320 #endif
321                 }
322
323 #ifdef SINGLE_THREADED
324                 if (single_threaded())
325                         signal_progress()();
326                 else
327 #endif
328                         while(alive_flag && !ready_next)
329                         {
330                                 Glib::Mutex::Lock lock(mutex);
331                                 if(cond_frame_queue_empty.timed_wait(mutex,Glib::TimeVal(0,BOREDOM_TIMEOUT)))
332                                         break;
333                         }
334         }
335
336
337         virtual Color * start_scanline(int scanline)
338         {
339                 Glib::Mutex::Lock lock(mutex);
340
341                 return surface[scanline];
342         }
343
344         virtual bool end_scanline()
345         {
346                 return alive_flag;
347         }
348
349         void frame_ready()
350         {
351                 Glib::Mutex::Lock lock(mutex);
352                 if(alive_flag)
353                         alive_flag=warm_target->add_frame(&surface);
354 #ifdef SINGLE_THREADED
355                 if (!single_threaded())
356 #endif
357                         cond_frame_queue_empty.signal();
358                 ready_next=true;
359         }
360 };
361
362 /* === G L O B A L S ======================================================= */
363
364 /* === P R O C E D U R E S ================================================= */
365
366 /* === M E T H O D S ======================================================= */
367
368 AsyncRenderer::AsyncRenderer(etl::handle<synfig::Target> target_,synfig::ProgressCallback *cb):
369         error(false),
370         success(false),
371         cb(cb)
372 #ifdef SINGLE_THREADED
373         , updating(false)
374 #endif
375 {
376         render_thread=0;
377         if(etl::handle<synfig::Target_Tile>::cast_dynamic(target_))
378         {
379                 etl::handle<AsyncTarget_Tile> wrap_target(
380                         new AsyncTarget_Tile(etl::handle<synfig::Target_Tile>::cast_dynamic(target_))
381                 );
382
383                 signal_stop_.connect(sigc::mem_fun(*wrap_target,&AsyncTarget_Tile::set_dead));
384
385                 target=wrap_target;
386         }
387         else if(etl::handle<synfig::Target_Scanline>::cast_dynamic(target_))
388         {
389                 etl::handle<AsyncTarget_Scanline> wrap_target(
390                         new AsyncTarget_Scanline(
391                                 etl::handle<synfig::Target_Scanline>::cast_dynamic(target_)
392                         )
393                 );
394
395                 signal_stop_.connect(sigc::mem_fun(*wrap_target,&AsyncTarget_Scanline::set_dead));
396
397                 target=wrap_target;
398         }
399 }
400
401 AsyncRenderer::~AsyncRenderer()
402 {
403         stop();
404 }
405
406 void
407 AsyncRenderer::stop()
408 {
409         if(target)
410         {
411                 Glib::Mutex::Lock lock(mutex);
412                 done_connection.disconnect();
413
414                 if(render_thread)
415                 {
416                         signal_stop_();
417
418 #if REJOIN_ON_STOP
419 #ifdef SINGLE_THREADED
420                         if (!single_threaded())
421 #endif
422                                 render_thread->join();
423 #endif
424
425                         // Make sure all the dispatch crap is cleared out
426                         //Glib::MainContext::get_default()->iteration(false);
427
428                         if(success)
429                                 signal_success_();
430
431                         signal_finished_();
432
433                         target=0;
434                         render_thread=0;
435                 }
436         }
437 }
438
439 void
440 AsyncRenderer::pause()
441 {
442 }
443
444 void
445 AsyncRenderer::resume()
446 {
447 }
448
449 void
450 AsyncRenderer::start()
451 {
452         done_connection=Glib::signal_timeout().connect(
453                 sigc::bind_return(
454                         mem_fun(*this,&AsyncRenderer::start_),
455                         false
456                 )
457                 ,50
458         );
459 }
460
461 #ifdef SINGLE_THREADED
462 void
463 AsyncRenderer::rendering_progress()
464 {
465         updating = true;
466         while(studio::App::events_pending()) studio::App::iteration(false);
467         updating = false;
468 }
469 #endif
470
471 void
472 AsyncRenderer::start_()
473 {
474         error=false;success=false;
475         if(target)
476         {
477 #ifndef GLIB_DISPATCHER_BROKEN
478                 done_connection=signal_done_.connect(mem_fun(*this,&AsyncRenderer::stop));
479 #endif
480
481 #ifdef SINGLE_THREADED
482                 if (single_threaded())
483                 {
484                         synfig::info("%s:%d rendering in the same thread", __FILE__, __LINE__);
485                         target->signal_progress().connect(sigc::mem_fun(this,&AsyncRenderer::rendering_progress));
486                         render_thread = (Glib::Thread*)1;
487                         render_target();
488                 }
489                 else
490 #endif
491                 {
492                         render_thread=Glib::Thread::create(
493                                 sigc::mem_fun(*this,&AsyncRenderer::render_target),
494 #if REJOIN_ON_STOP
495                                 true
496 #else
497                                 false
498 #endif
499                                 );
500                         assert(render_thread);
501                 }
502         }
503         else
504         {
505                 stop();
506         }
507 }
508
509 void
510 AsyncRenderer::render_target()
511 {
512         etl::handle<Target> target(AsyncRenderer::target);
513
514         if(target && target->render())
515         {
516                 success=true;
517         }
518         else
519         {
520                 error=true;
521 #ifndef REJOIN_ON_STOP
522                 return;
523 #endif
524         }
525
526         if(mutex.trylock())
527         {
528 #ifdef GLIB_DISPATCHER_BROKEN
529                 done_connection=Glib::signal_timeout().connect(
530                         sigc::bind_return(
531                                 mem_fun(*this,&AsyncRenderer::stop),
532                                 false
533                         )
534                         ,0
535                 );
536 #else
537                 signal_done_.emit();
538 #endif
539                 mutex.unlock();
540         }
541 }