0025748: Parallel version of progress indicator
[occt.git] / src / ShapeProcess / ShapeProcess.cxx
1 // Created on: 2000-08-21
2 // Created by: Andrey BETENEV
3 // Copyright (c) 2000-2014 OPEN CASCADE SAS
4 //
5 // This file is part of Open CASCADE Technology software library.
6 //
7 // This library is free software; you can redistribute it and/or modify it under
8 // the terms of the GNU Lesser General Public License version 2.1 as published
9 // by the Free Software Foundation, with special exception defined in the file
10 // OCCT_LGPL_EXCEPTION.txt. Consult the file LICENSE_LGPL_21.txt included in OCCT
11 // distribution for complete text of the license and disclaimer of any warranty.
12 //
13 // Alternatively, this file may be used under the terms of Open CASCADE
14 // commercial license or contractual agreement.
15
16 #include <NCollection_DataMap.hxx>
17 #include <Message_Messenger.hxx>
18 #include <Message_Msg.hxx>
19 #include <Message_ProgressScope.hxx>
20 #include <ShapeProcess.hxx>
21 #include <ShapeProcess_Context.hxx>
22 #include <ShapeProcess_Operator.hxx>
23 #include <Standard_ErrorHandler.hxx>
24 #include <Standard_Failure.hxx>
25 #include <TCollection_AsciiString.hxx>
26 #include <TColStd_SequenceOfAsciiString.hxx>
27
28 static NCollection_DataMap<TCollection_AsciiString, Handle(ShapeProcess_Operator)> aMapOfOperators;
29 //=======================================================================
30 //function : RegisterOperator
31 //purpose  : 
32 //=======================================================================
33
34 Standard_Boolean ShapeProcess::RegisterOperator (const Standard_CString name,
35                                                  const Handle(ShapeProcess_Operator)& op)
36 {
37   if (aMapOfOperators.IsBound(name)) {
38 #ifdef OCCT_DEBUG
39     std::cout << "Warning: operator with name " << name << " is already registered!" << std::endl;
40 #endif
41     return Standard_False;
42   }
43   aMapOfOperators.Bind( name, op );
44   return Standard_True;
45 }
46
47 //=======================================================================
48 //function : FindOperator
49 //purpose  : 
50 //=======================================================================
51
52 Standard_Boolean ShapeProcess::FindOperator (const Standard_CString name,
53                                              Handle(ShapeProcess_Operator)& op)
54 {
55   if (!aMapOfOperators.IsBound(name)) {
56 #ifdef OCCT_DEBUG
57     std::cout << "Error: no operator with name " << name << " registered!" << std::endl;
58 #endif
59     return Standard_False;
60   }
61   op = aMapOfOperators.ChangeFind(name);
62   return !op.IsNull();
63 }
64
65 //=======================================================================
66 //function : Perform
67 //purpose  : 
68 //=======================================================================
69
70 Standard_Boolean ShapeProcess::Perform (const Handle(ShapeProcess_Context)& context,
71                                         const Standard_CString seq,
72                                         const Message_ProgressRange& theProgress)
73 {
74   context->SetScope ( seq );
75   
76   // get description of the sequence
77   TCollection_AsciiString sequence;
78   if ( ! context->GetString ( "exec.op", sequence ) ) {
79 #ifdef OCCT_DEBUG
80     std::cout << "Error: ShapeProcess_Performer::Perform: sequence not defined for " << seq << std::endl;
81 #endif
82     if ( context->TraceLevel() >0 ) {
83       Message_Msg SMSG3 ("SP.Sequence.Warn.NoSeq"); // Sequence %s not found
84       context->Messenger()->Send (SMSG3 << seq, Message_Warning);
85     }
86     context->UnSetScope();
87     return Standard_False;
88   }
89   TColStd_SequenceOfAsciiString sequenceOfOperators;
90   TCollection_AsciiString oper;
91   Standard_Integer i;
92   for ( i=1; ; i++ ) {
93     oper = sequence.Token ( " \t,;", i );
94     if ( oper.Length() <=0 ) break;
95     sequenceOfOperators.Append(oper);
96   }
97   
98   // put a message
99   if ( context->TraceLevel() >=2 ) {
100     Message_Msg SMSG0 ("SP.Sequence.Info.Seq"); //Sequence of operators: %s
101     TCollection_AsciiString Seq;
102     for ( Standard_Integer i1=1; i1 <= sequenceOfOperators.Length(); i1++ ) {
103       if (i1 > 1) Seq += ",";
104       Seq += sequenceOfOperators.Value(i1);
105     }
106     SMSG0.Arg (Seq.ToCString());
107     context->Messenger()->Send (SMSG0, Message_Info);
108   }
109
110   // iterate on operators in the sequence
111   Standard_Boolean isDone = Standard_False;
112   Message_ProgressScope aPS(theProgress, NULL, sequenceOfOperators.Length());
113   for (i = 1; i<=sequenceOfOperators.Length() && aPS.More(); i++)
114   {
115     oper = sequenceOfOperators.Value(i);
116     Message_ProgressRange aRange = aPS.Next();
117     
118     if ( context->TraceLevel() >=2 ) {
119       Message_Msg SMSG5 ("SP.Sequence.Info.Operator"); //Operator %d/%d: %s
120       SMSG5 << i << sequenceOfOperators.Length() << oper.ToCString();
121       context->Messenger()->Send (SMSG5, Message_Alarm);
122     }
123     
124     Handle(ShapeProcess_Operator) op;
125     if ( ! ShapeProcess::FindOperator ( oper.ToCString(), op ) ) {
126       if ( context->TraceLevel() >0 ) {
127         Message_Msg SMSG1 ("SP.Sequence.Error.NoOp"); //Operator %s not found
128         context->Messenger()->Send (SMSG1 << oper, Message_Alarm);
129       }
130       continue;
131     }
132     
133     context->SetScope ( oper.ToCString() );
134     try {
135       OCC_CATCH_SIGNALS
136       if (op->Perform(context, aRange))
137         isDone = Standard_True;
138     }
139     catch (Standard_Failure const& anException) {
140       Message_Msg SMSG2 ("SP.Sequence.Error.Except"); //Operator %s failed with exception %s
141       SMSG2 << oper << anException.GetMessageString();
142       context->Messenger()->Send (SMSG2, Message_Alarm);
143     }
144     context->UnSetScope();
145   }
146   
147   context->UnSetScope();
148   return isDone;
149 }