Changeset 3641


Ignore:
Timestamp:
May 18, 2008, 2:11:03 PM (17 years ago)
Author:
bird
Message:

Moved the spawn wait hack into spm and made it a passive wait.

Location:
trunk/libc
Files:
3 edited

Legend:

Unmodified
Added
Removed

  • TabularUnified trunk/libc/include/InnoTekLIBC/sharedpm.h

    r2937 r3641  
    697697
    698698/**
     699 * Wait for a embryo to become a live process and complete
     700 * inheriting (file handles / sockets issues).
     701 *
     702 * @returns non-zero if the process has started.
     703 * @param   pEmbryo         The embry process.
     704 */
     705int __libc_spmWaitForChildToBecomeAlive(__LIBC_PSPMPROCESS pEmbryo);
     706
     707/**
    699708 * Searches for a process given by pid.
    700709 *

  • TabularUnified trunk/libc/src/kNIX/os2/__spawnve.c

    r3635 r3641  
    531531                 * If we figure that it's a libc child, we can wait a good deal longer.
    532532                 */
    533                 /** @todo add a SPM notification for when inherit is completed. */
    534                 __LIBC_SPMLOADAVG LoadAvg;
    535                 unsigned uLoadAvgTS;
    536                 int fDoneInherit;
    537                 ULONG ulStart = fibGetMsCount();
    538                 rc = 0;
    539                 while (     (fDoneInherit = pEmbryo->enmState >= __LIBC_PROCSTATE_ALIVE
    540                                          || (pEmbryo->pInherit == NULL && pEmbryo->pInheritLocked == NULL)
    541                             ) == 0
    542                        &&   fibGetMsCount() - ulStart <= 8)
    543                 {
    544                     DosSleep(rc++ > 4);
    545                     __libc_spmGetLoadAvg(&LoadAvg, &uLoadAvgTS); /* SMP HACK */
    546                 }
    547                 if (    !fDoneInherit
    548                     &&  pEmbryo->enmState == __LIBC_PROCSTATE_ALIVE)
    549                 {
    550                     LIBCLOG_MSG("libc child - wait some more (rc=%d)\n", rc);
    551                     rc = 0;
    552                     __libc_spmGetLoadAvg(&LoadAvg, &uLoadAvgTS); /* SMP HACK */
    553                     while (     (fDoneInherit = pEmbryo->enmState >= __LIBC_PROCSTATE_ALIVE
    554                                              || (pEmbryo->pInherit == NULL && pEmbryo->pInheritLocked == NULL)
    555                                 ) == 0
    556                            &&   fibGetMsCount() - ulStart <= 100)
    557                     {
    558                         DosSleep(rc++ > 4);
    559                         __libc_spmGetLoadAvg(&LoadAvg, &uLoadAvgTS); /* SMP HACK */
    560                     }
    561                 }
    562                 LIBCLOG_MSG("fDoneInherit=%d rc=%d enmState=%d inh=%p,%p - waited %d ms\n",
    563                             fDoneInherit, rc, pEmbryo->enmState, pEmbryo->pInherit, pEmbryo->pInheritLocked, fibGetMsCount() - ulStart);
     533                int fDoneInherit = __libc_spmWaitForChildToBecomeAlive(pEmbryo);
     534                LIBCLOG_MSG("fDoneInherit=%d enmState=%d inh=%p,%p\n",
     535                            fDoneInherit, pEmbryo->enmState, pEmbryo->pInherit, pEmbryo->pInheritLocked);
    564536
    565537                /*
    … …  
    634606                        {
    635607                            LIBCLOG_MSG("waiting some more...\n");
    636                             do
    637                             {
    638                                 DosSleep(!(rc++ % 3));
    639                                 __libc_spmGetLoadAvg(&LoadAvg, &uLoadAvgTS); /* SMP HACK */
    640                                 fDoneInherit = pEmbryo->enmState > __LIBC_PROCSTATE_ALIVE
    641                                             || (pEmbryo->pInherit == NULL && pEmbryo->pInheritLocked == NULL);
    642                             } while (!fDoneInherit
    643                                   && fibGetMsCount() - ulStart <= 200);
    644                             LIBCLOG_MSG("fDoneInherit=%d rc=%d enmState=%d inh=%p,%p - waited %d ms\n",
    645                                         fDoneInherit, rc, pEmbryo->enmState, pEmbryo->pInherit, pEmbryo->pInheritLocked, fibGetMsCount() - ulStart);
     608                            fDoneInherit = __libc_spmWaitForChildToBecomeAlive(pEmbryo);
     609                            LIBCLOG_MSG("fDoneInherit=%d enmState=%d inh=%p,%p\n",
     610                                        fDoneInherit, pEmbryo->enmState, pEmbryo->pInherit, pEmbryo->pInheritLocked);
    646611                        }
    647612

  • TabularUnified trunk/libc/src/kNIX/os2/sharedpm.c

    r3373 r3641  
    2525 *
    2626 */
     27
    2728
    2829/** @todo
    … …  
    461462            LIBC_ASSERTM(!gpSPMSelf->pInheritLocked, "Trying to free a locked inherit struct!\n");
    462463
    463             spmReleaseMutex(&RegRec);
     464            LIBCLOG_MSG("posting %#lx\n", gpSPMHdr->hevNotify);
     465            APIRET rc2 = DosPostEventSem(gpSPMHdr->hevNotify);
     466            spmReleaseMutex(&RegRec);
     467            LIBC_ASSERTM(!rc2, "rc2=%ld!\n", rc2); rc2 = rc2;
    464468        }
    465469    }
    … …  
    596600
    597601/**
     602 * Wait for a embryo to become a live process and complete
     603 * inheriting (file handles / sockets issues).
     604 *
     605 * @returns non-zero if the process has started.
     606 * @param   pEmbryo         The embry process.
     607 */
     608int __libc_spmWaitForChildToBecomeAlive(__LIBC_PSPMPROCESS pEmbryo)
     609{
     610    LIBCLOG_ENTER("pEmbryo=%p\n", pEmbryo);
     611    int                     cLoops;
     612    __LIBC_SPMXCPTREGREC    RegRec;
     613    ULONG                   ulIgnored;
     614    int                     fAlive = 0;
     615    APIRET                  rc = 0;
     616    ULONG                   ulStart = 0;
     617    DosQuerySysInfo(QSV_MS_COUNT, QSV_MS_COUNT, &ulStart, sizeof(ulStart));
     618
     619    /*
     620     * Wait for the process to become ready, 8 ms max.
     621     * However, if it becomes alive in that period we know it's a libc
     622     * process and will wait a bit more (130 ms) for it to finishing
     623     * initialization and inheritance.
     624     */
     625    for (cLoops = 0; ; cLoops++)
     626    {
     627        /*
     628         * Reset the notification event sem.
     629         */
     630        spmRequestMutex(&RegRec);
     631        fAlive = pEmbryo->enmState > __LIBC_PROCSTATE_ALIVE
     632              || (   pEmbryo->pInherit == NULL
     633                  && pEmbryo->pInheritLocked == NULL
     634                  && pEmbryo->enmState == __LIBC_PROCSTATE_ALIVE);
     635        if (!fAlive)
     636            DosResetEventSem(gpSPMHdr->hevNotify, &ulIgnored);
     637        spmReleaseMutex(&RegRec);
     638        if (fAlive)
     639            break; /* done */
     640
     641        /*
     642         * Calc the time we should sleep.
     643         */
     644        ULONG ulNow = 0;
     645        DosQuerySysInfo(QSV_MS_COUNT, QSV_MS_COUNT, &ulNow, sizeof(ulNow));
     646        ULONG ulSleep = ulNow - ulStart;
     647        if (ulSleep < 8)
     648        {
     649            ulSleep = 8 - ulSleep;
     650            LIBCLOG_MSG("wait %lu ms (cLoops=%d rc=%ld)\n", ulSleep, cLoops, rc);
     651        }
     652        else if (pEmbryo->enmState != __LIBC_PROCSTATE_ALIVE)
     653            break; /* giving up */
     654        else if (ulSleep < 130)
     655        {
     656            ulSleep = 130 - ulSleep;
     657            if (ulSleep > 8)
     658                ulSleep = 8; /* reset race protection */
     659            LIBCLOG_MSG("libc child - wait %lu ms (cLoops=%d rc=%ld)\n", ulSleep, cLoops, rc);
     660        }
     661        else
     662            break; /* giving up */
     663
     664        /*
     665         * Recheck before going to sleep on the event sem.
     666         */
     667        fAlive = pEmbryo->enmState > __LIBC_PROCSTATE_ALIVE
     668              || (   pEmbryo->pInherit == NULL
     669                  && pEmbryo->pInheritLocked == NULL
     670                  && pEmbryo->enmState == __LIBC_PROCSTATE_ALIVE);
     671        if (fAlive)
     672            break; /* done */
     673
     674        if (    gpSPMHdr->hevNotify
     675            &&  (rc == NO_ERROR || rc == ERROR_TIMEOUT || rc == ERROR_SEM_TIMEOUT))
     676            rc = DosWaitEventSem(gpSPMHdr->hevNotify, ulSleep);
     677        else
     678        {
     679            /* fallback if the sem is busted or for old libc initializing spm. */
     680            DosSleep(cLoops > 8);
     681
     682            __LIBC_SPMLOADAVG LoadAvg; /* SPM hack */
     683            __libc_spmSetLoadAvg(&LoadAvg);
     684        }
     685    }
     686    LIBCLOG_RETURN_INT(fAlive);
     687}
     688
     689
     690/**
    598691 * Searches for a process given by pid.
    599692 *
    … …  
    22822375            if (!gpSPMHdr->cSigMaxActive)
    22832376                gpSPMHdr->cSigMaxActive = 1024;
     2377            if (gpSPMHdr->hevNotify)
     2378                rc = DosOpenEventSem(NULL, &gpSPMHdr->hevNotify);
     2379            else
     2380                rc = DosCreateEventSem(NULL, &gpSPMHdr->hevNotify, DC_SEM_SHARED, FALSE);
    22842381        }
    22852382        else
    … …  
    23432440        {
    23442441            /*
    2345              * Register the current process and increment open counter.
     2442             * Register the current process, increment open counter,
     2443             * and notify everyone that spm data has changed.
    23462444             */
    23472445            PLINFOSEG pLIS = GETLINFOSEG();
    23482446            spmRegisterSelf(pPib->pib_ulpid, pPib->pib_ulppid, pLIS->sgCurrent);
    23492447            if (gpSPMSelf)
     2448            {
    23502449                gpSPMSelf->cSPMOpens++;
     2450
     2451                LIBCLOG_MSG("posting %#lx\n", gpSPMHdr->hevNotify);
     2452                APIRET rc2 = DosPostEventSem(gpSPMHdr->hevNotify);
     2453                LIBC_ASSERTM(!rc2, "rc2=%ld!\n", rc2); rc2 = rc2;
     2454            }
    23512455
    23522456            /*
    … …  
    25292633                    *pParent->ppChildNotifyTail = pTerm;
    25302634                    pParent->ppChildNotifyTail = &pTerm->pNext;
    2531                     DosPostEventSem(gpSPMHdr->hevNotify);
     2635                   
     2636                    LIBCLOG_MSG("posting %#lx\n", gpSPMHdr->hevNotify);
     2637                    APIRET rc2 = DosPostEventSem(gpSPMHdr->hevNotify);
     2638                    LIBC_ASSERTM(!rc2, "rc2=%ld!\n", rc2); rc2 = rc2;
    25322639                }
    25332640                else
    … …  
    31513258
    31523259                /* post notification sem. */
    3153                 DosPostEventSem(gpSPMHdr->hevNotify);
     3260                LIBCLOG_MSG("posting %#lx\n", gpSPMHdr->hevNotify);
     3261                APIRET rc2 = DosPostEventSem(gpSPMHdr->hevNotify);
     3262                LIBC_ASSERTM(!rc2, "rc2=%ld!\n", rc2); rc2 = rc2;
    31543263            }
    31553264            else
    … …  
    33533462                    spmFreeProcess(pProcess);
    33543463                    pProcess = pProcessNext;
     3464                   
     3465                    /* Wake up the embryo waiters (paranoia). */
     3466                    LIBCLOG_MSG("posting %#lx\n", gpSPMHdr->hevNotify);
     3467                    APIRET rc2 = DosPostEventSem(gpSPMHdr->hevNotify);
     3468                    LIBC_ASSERTM(!rc2, "rc2=%ld!\n", rc2); rc2 = rc2;
    33553469                    continue;
    33563470                }
    … …  
    34443558                        spmFreeProcess(pProcess);
    34453559                        pProcess = pProcessNext;
     3560                       
     3561                        /* Wake up the embryo waiters (paranoia). */
     3562                        LIBCLOG_MSG("posting %#lx\n", gpSPMHdr->hevNotify);
     3563                        APIRET rc2 = DosPostEventSem(gpSPMHdr->hevNotify);
     3564                        LIBC_ASSERTM(!rc2, "rc2=%ld!\n", rc2); rc2 = rc2;
    34463565                        continue;
    34473566                    }
Note: See TracChangeset for help on using the changeset viewer.