1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
|
/*
*
* $Id: k3bgrowisofshandler.cpp 619556 2007-01-03 17:38:12Z trueg $
* Copyright (C) 2003 Sebastian Trueg <trueg@k3b.org>
*
* This file is part of the K3b project.
* Copyright (C) 1998-2007 Sebastian Trueg <trueg@k3b.org>
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
* See the file "COPYING" for the exact licensing terms.
*/
#include "k3bgrowisofshandler.h"
#include <k3bjob.h>
#include <k3bcore.h>
#include <k3bglobalsettings.h>
#include <k3bdevice.h>
#include <k3bdevicehandler.h>
#include <klocale.h>
#include <kglobal.h>
#include <kdebug.h>
#include <tqtimer.h>
#include <errno.h>
#include <string.h>
class K3bGrowisofsHandler::Private
{
public:
int lastBuffer;
int lastDeviceBuffer;
};
K3bGrowisofsHandler::K3bGrowisofsHandler( TQObject* tqparent, const char* name )
: TQObject( tqparent, name )
{
d = new Private;
reset();
}
K3bGrowisofsHandler::~K3bGrowisofsHandler()
{
delete d;
}
void K3bGrowisofsHandler::reset( K3bDevice::Device* dev, bool dao )
{
m_device = dev;
m_error = ERROR_UNKNOWN;
m_dao = dao;
d->lastBuffer = 0;
d->lastDeviceBuffer = 0;
}
void K3bGrowisofsHandler::handleStart()
{
// TQTimer::singleShot( 2000, this, TQT_SLOT(slotCheckBuffertqStatus()) );
}
void K3bGrowisofsHandler::handleLine( const TQString& line )
{
int pos = 0;
if( line.startsWith( ":-[" ) ) {
// Error
if( line.contains( "ASC=30h" ) )
m_error = ERROR_MEDIA;
// :-[ PERFORM OPC failed with SK=3h/ASC=73h/ASCQ=03h
else if( line.startsWith( ":-[ PERFORM OPC failed" ) )
emit infoMessage( i18n("OPC failed. Please try writing speed 1x."), K3bJob::ERROR );
// :-[ attempt -blank=full or re-run with -dvd-compat -dvd-compat to engage DAO ]
else if( !m_dao &&
( line.contains( "engage DAO" ) || line.contains( "media is not formatted or unsupported" ) ) )
emit infoMessage( i18n("Please try again with writing mode DAO."), K3bJob::ERROR );
else if( line.startsWith( ":-[ Failed to change write speed" ) ) {
m_error = ERROR_SPEED_SET_FAILED;
}
}
else if( line.startsWith( ":-(" ) ) {
if( line.contains( "No space left on device" ) )
m_error = ERROR_OVERSIZE;
else if( line.contains( "blocks are free" ) && line.contains( "to be written" ) ) {
m_error = ERROR_OVERSIZE;
if( k3bcore->globalSettings()->overburn() )
emit infoMessage( i18n("Trying to write more than the official disk capacity"), K3bJob::WARNING );
}
else if( line.startsWith( ":-( unable to anonymously mmap" ) ) {
m_error = ERROR_MEMLOCK;
}
else if( line.startsWith( ":-( write failed" ) ) {
m_error = ERROR_WRITE_FAILED;
}
else
emit infoMessage( line, K3bJob::ERROR );
}
else if( line.startsWith( "PERFORM OPC" ) ) {
m_error = ERROR_OPC;
}
else if( line.contains( "flushing cache" ) ) {
// here is where we already should stop queriying the buffer fill
// since the device is only used there so far...
m_device = 0;
emit flushingCache();
emit newSubTask( i18n("Flushing Cache") );
emit infoMessage( i18n("Flushing the cache may take some time."), K3bJob::INFO );
}
// FIXME: I think this starts with dev->blockDeviceName() so we could improve parsing with:
// if( line.startsWith( dev->blockDeviceName() ) ) {
// line = line.mid( dev->blockDeviceName().length() );
// if( line.startsWith( "closing.....
else if( line.contains( "closing track" ) ) {
emit newSubTask( i18n("Closing Track") );
}
else if( line.contains( "closing disc" ) ) {
emit newSubTask( i18n("Closing Disk") );
}
else if( line.contains( "closing session" ) ) {
emit newSubTask( i18n("Closing Session") );
}
else if( line.contains( "updating RMA" ) ) {
emit newSubTask( i18n("Updating RMA") );
emit infoMessage( i18n("Updating RMA") + "...", K3bJob::INFO );
}
else if( line.contains( "closing session" ) ) {
emit newSubTask( i18n("Closing Session") );
emit infoMessage( i18n("Closing Session") + "...", K3bJob::INFO );
}
else if( line.contains( "writing lead-out" ) ) {
emit newSubTask( i18n("Writing Lead-out") );
emit infoMessage( i18n("Writing the lead-out may take some time."), K3bJob::INFO );
}
else if( line.contains( "Quick Grow" ) ) {
emit infoMessage( i18n("Removing reference to lead-out."), K3bJob::INFO );
}
else if( line.contains( "copying volume descriptor" ) ) {
emit infoMessage( i18n("Modifying ISO9660 volume descriptor"), K3bJob::INFO );
}
else if( line.contains( "FEATURE 21h is not on" ) ) {
if( !m_dao ) {
// FIXME: it's not only the writer. It may be the media: something like does not support it with this media
// da war was mit: wenn einmal formattiert, dann geht nur noch dao oder wenn einmal als overwrite
// formattiert, dann nur noch dao oder sowas
emit infoMessage( i18n("Writing mode Incremental Streaming not available"), K3bJob::WARNING );
emit infoMessage( i18n("Engaging DAO"), K3bJob::WARNING );
}
}
else if( ( pos = line.find( "Current Write Speed" ) ) > 0 ) {
// parse write speed
// /dev/sr0: "Current Write Speed" is 2.4x1385KBps
pos += 24;
int endPos = line.find( 'x', pos+1 );
bool ok = true;
double speed = line.mid( pos, endPos-pos ).toDouble(&ok);
if( ok )
emit infoMessage( i18n("Writing speed: %1 KB/s (%2x)")
.tqarg((int)(speed*1385.0))
.tqarg(KGlobal::locale()->formatNumber(speed)), K3bJob::INFO );
else
kdDebug() << "(K3bGrowisofsHandler) parsing error: '" << line.mid( pos, endPos-pos ) << "'" << endl;
}
else if( (pos = line.find( "RBU" )) > 0 ) {
// FIXME: use TQRegExp
// parse ring buffer fill for growisofs >= 6.0
pos += 4;
int endPos = line.find( '%', pos+1 );
bool ok = true;
double val = line.mid( pos, endPos-pos ).toDouble( &ok );
if( ok ) {
int newBuffer = (int)(val+0.5);
if( newBuffer != d->lastBuffer ) {
d->lastBuffer = newBuffer;
emit buffer( newBuffer );
}
// device buffer for growisofs >= 7.0
pos = line.find( "UBU", pos );
endPos = line.find( '%', pos+5 );
if( pos > 0 ) {
pos += 4;
val = line.mid( pos, endPos-pos ).toDouble( &ok );
if( ok ) {
int newBuffer = (int)(val+0.5);
if( newBuffer != d->lastDeviceBuffer ) {
d->lastDeviceBuffer = newBuffer;
emit deviceBuffer( newBuffer );
}
}
}
}
else
kdDebug() << "(K3bGrowisofsHandler) failed to parse ring buffer fill from '" << line.mid( pos, endPos-pos ) << "'" << endl;
}
else {
kdDebug() << "(growisofs) " << line << endl;
}
}
void K3bGrowisofsHandler::handleExit( int exitCode )
{
switch( m_error ) {
case ERROR_MEDIA:
emit infoMessage( i18n("K3b detected a problem with the media."), K3bJob::ERROR );
emit infoMessage( i18n("Please try another media brand, preferably one explicitly recommended by your writer's vendor."), K3bJob::ERROR );
emit infoMessage( i18n("Report the problem if it persists anyway."), K3bJob::ERROR );
break;
case ERROR_OVERSIZE:
if( k3bcore->globalSettings()->overburn() )
emit infoMessage( i18n("Data did not fit on disk."), K3bJob::ERROR );
else
emit infoMessage( i18n("Data does not fit on disk."), K3bJob::ERROR );
break;
case ERROR_SPEED_SET_FAILED:
emit infoMessage( i18n("Unable to set writing speed."), K3bJob::ERROR );
emit infoMessage( i18n("Please try again with the 'ignore speed' setting."), K3bJob::ERROR );
break;
case ERROR_OPC:
emit infoMessage( i18n("Optimum Power Calibration failed."), K3bJob::ERROR );
emit infoMessage( i18n("Try adding '-use-the-force-luke=noopc' to the "
"growisofs user parameters in the K3b settings."), K3bJob::ERROR );
break;
case ERROR_MEMLOCK:
emit infoMessage( i18n("Unable to allocate software buffer."), K3bJob::ERROR );
emit infoMessage( i18n("This error is caused by the low memorylocked resource limit."), K3bJob::ERROR );
emit infoMessage( i18n("It can be solved by issuing the command 'ulimit -l unlimited'..."), K3bJob::ERROR );
emit infoMessage( i18n("...or by lowering the used software buffer size in the advanced K3b settings."), K3bJob::ERROR );
break;
case ERROR_WRITE_FAILED:
emit infoMessage( i18n("Write error"), K3bJob::ERROR );
break;
default:
//
// The growisofs error codes:
//
// 128 + errno: fatal error upon program startup
// errno : fatal error during recording
//
if( exitCode > 128 ) {
// for now we just emit a message with the error
// in the future when I know more about what kinds of errors may occur
// we will enhance this
emit infoMessage( i18n("Fatal error at startup: %1").tqarg(strerror(exitCode-128)),
K3bJob::ERROR );
}
else if( exitCode == 1 ) {
// Doku says: warning at exit
// Example: mkisofs error
// unable to reload
// So basically this is just for mkisofs failure since we do not let growisofs reload the media
emit infoMessage( i18n("Warning at exit: (1)"), K3bJob::ERROR );
emit infoMessage( i18n("Most likely mkisofs failed in some way."), K3bJob::ERROR );
}
else {
emit infoMessage( i18n("Fatal error during recording: %1").tqarg(strerror(exitCode)),
K3bJob::ERROR );
}
}
reset();
}
void K3bGrowisofsHandler::slotCheckBuffertqStatus()
{
connect( K3bDevice::sendCommand( K3bDevice::DeviceHandler::BUFFER_CAPACITY, m_device ),
TQT_SIGNAL(finished(K3bDevice::DeviceHandler*)),
this,
TQT_SLOT(slotCheckBufferStatusDone(K3bDevice::DeviceHandler*)) );
}
void K3bGrowisofsHandler::slotCheckBufferStatusDone( K3bDevice::DeviceHandler* dh )
{
if( dh->success() && dh->bufferCapacity() > 0 ) {
emit deviceBuffer( 100 * (dh->bufferCapacity() - dh->availableBufferCapacity() ) / dh->bufferCapacity() );
TQTimer::singleShot( 500, this, TQT_SLOT(slotCheckBuffertqStatus()) );
}
else {
kdDebug() << "(K3bGrowisofsHandler) stopping buffer check." << endl;
}
}
#include "k3bgrowisofshandler.moc"
|
