Changeset 190


Ignore:
Timestamp:
Sep 22, 2009, 10:44:03 PM (16 years ago)
Author:
Dmitry A. Kuminov
Message:

corelib: QProcess: Implemented child termination/death detection using SIGCHILD and an auxiliary thread.

Location:
trunk/src/corelib/io
Files:
3 edited

Legend:

Unmodified
Added
Removed
  • trunk/src/corelib/io/qprocess.cpp

    r72 r190  
    437437    serial = 0;
    438438#endif
     439
     440
     441
    439442}
    440443
     
    443446QProcessPrivate::~QProcessPrivate()
    444447{
     448
     449
     450
    445451    if (stdinChannel.process)
    446452        stdinChannel.process->stdoutChannel.clear();
     
    744750    processError = QProcess::FailedToStart;
    745751    emit q->error(processError);
    746 #ifdef Q_OS_UNIX
     752#if
    747753    // make sure the process manager removes this entry
    748754    waitForDeadChild();
     
    801807        waitForFinished();
    802808    }
    803 #ifdef Q_OS_UNIX
     809#if
    804810    // make sure the process manager removes this entry
    805811    d->findExitCode();
  • trunk/src/corelib/io/qprocess_os2.cpp

    r181 r190  
    5151#include <ctype.h>
    5252
     53
     54
    5355/*
    5456    Returns a human readable representation of the first \a len
     
    122124    ::fcntl(pipe[0], F_SETFD, FD_CLOEXEC);
    123125    ::fcntl(pipe[1], F_SETFD, FD_CLOEXEC);
     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
     319
     320
     321
     322
     323
     324
     325
     326
     327
     328
     329
     330
     331
     332
     333
     334
     335
     336
     337
     338
     339
     340
     341
     342
     343
     344
     345
     346
     347
     348
     349
     350
     351
     352
     353
     354
     355
     356
     357
     358
    124359}
    125360
     
    372607        return;
    373608
     609
     610
    374611    // Start the process (platform dependent)
    375612    q->setProcessState(QProcess::Starting);
     
    424661                                       .arg(qPrintable(qt_error_string(errno))));
    425662        emit q->error(processError);
     663
    426664        cleanup();
    427665        return;
     
    452690        ::fcntl(stderrChannel.pipe[0], F_SETFL, ::fcntl(stderrChannel.pipe[0], F_GETFL) | O_NONBLOCK);
    453691
    454     q->setProcessState(QProcess::Running);
    455     // User can call kill()/terminate() from the stateChanged() slot
    456     // so check before proceeding
    457     if (!pid)
    458         return;
    459 
    460692    // give the process a chance to start ...
    461693    DosSleep(100);
     694
    462695    _q_startupNotification();
    463696}
     
    465698bool QProcessPrivate::processStarted()
    466699{
    467     return processState == QProcess::Running;
     700    // we don't actually wait for any notification from the child process
     701    // assuming it has been started as long as spawnvpe() returns success
     702    return processState == QProcess::Starting;
    468703}
    469704
     
    589824    Q_Q(QProcess);
    590825
    591     if (processStarted())
     826    if (processSta)
    592827        return true;
    593828
     
    8201055void QProcessPrivate::findExitCode()
    8211056{
     1057
     1058
     1059
     1060
     1061
     1062
     1063
     1064
    8221065}
    8231066
     
    8381081#if defined QPROCESS_DEBUG
    8391082    qDebug() << "QProcessPrivate::waitForDeadChild() not dead!";
     1083
     1084
    8401085#endif
    8411086    return false;
  • trunk/src/corelib/io/qprocess_p.h

    r72 r190  
    195195    qint64 pipeWriterBytesToWrite() const;
    196196#endif
     197
     198
     199
     200
    197201
    198202    static bool startDetached(const QString &program, const QStringList &arguments, const QString &workingDirectory = QString(),
Note: See TracChangeset for help on using the changeset viewer.