Changeset 3200 in kBuild for trunk/src/kmk

Timestamp:

Mar 28, 2018 8:32:11 PM (7 years ago)

Author:

bird

Message:

kmk,kWorker: Some fixes wrt output capture and ctrl-c.

Location:

trunk/src/kmk

Files:

• kmkbuiltin/kSubmit.c (modified) (3 diffs)
• output.c (modified) (1 diff)
• w32/winchildren.c (modified) (1 diff)
• w32/winchildren.h (modified) (1 diff)

trunk/src/kmk/kmkbuiltin/kSubmit.c

@@ -71 +71 @@
 
 #define TUPLE(a_sz)     a_sz, sizeof(a_sz) - 1
+
 
 /*********************************************************************************************************************************
@@ -1151 +1152 @@
 # else
         if (MkWinChildCreateSubmit((intptr_t)pWorker->OverlappedRead.hEvent, pWorker,
-                                   pWorker->pStdOut, pWorker->pStdErr, pPidSpawned) == 0)
+                                   pWorker->pStdOut, pWorker->pStdErr, pChild, pPidSpawned) == 0)
         { /* likely */ }
         else
@@ -1691 +1692 @@
                the kWorker process currently does not coordinate its output with
                the output.c mechanics. */
+#ifdef CONFIG_NEW_WIN_CHILDREN
+            if (pCtx->pOut && !pWorker->pStdOut)
+#else
             if (pCtx->pOut)
+#endif
                 output_dump(pCtx->pOut);
-
             rcExit = kSubmitSendJobMessage(pCtx, pWorker, pvMsg, cbMsg, 0 /*fNoRespawning*/, cVerbosity);
             if (rcExit == 0)

trunk/src/kmk/output.c

@@ -131 +131 @@
               const char *nl = (const char *)memchr (src, '\n', len);
               size_t line_len = nl ? nl - (const char *)src + 1 : len;
-              char *tmp = (char *)xmalloc (2 + line_len + 1);
-              tmp[0] = '>';
-              tmp[1] = ' ';
-              memcpy (&tmp[2], src, line_len);
+              char *tmp = (char *)xmalloc (1 + line_len + 1 + 1);
+              tmp[0] = '{';
+              memcpy (&tmp[1], src, line_len);
+              tmp[1 + line_len] = '}';
 #  ifdef KBUILD_OS_WINDOWS
-              maybe_con_fwrite (tmp, 2 + line_len, 1, dst);
+              maybe_con_fwrite (tmp, 1 + line_len + 1, 1, dst);
 #  else
-              fwrite (tmp, 2 + line_len, 1, dst);
+              fwrite (tmp, 1 + line_len + 1, 1, dst);
 #  endif
               free (tmp);

trunk/src/kmk/w32/winchildren.c

@@ -3118 +3118 @@
  * @param   hEvent          The event object handle to wait on.
  * @param   pvSubmitWorker  The argument to pass back to kSubmit to clean up.
- * @param   pPid            Where to return the pid.
  * @param   pStdOut         Standard output pipe for the worker. Optional.
  * @param   pStdErr         Standard error pipe for the worker. Optional.
- */
-int MkWinChildCreateSubmit(intptr_t hEvent, void *pvSubmitWorker, PWINCCWPIPE pStdOut, PWINCCWPIPE pStdErr, pid_t *pPid)
+ * @param   pMkChild        The make child structure.
+ * @param   pPid            Where to return the pid.
+ */
+int MkWinChildCreateSubmit(intptr_t hEvent, void *pvSubmitWorker, PWINCCWPIPE pStdOut, PWINCCWPIPE pStdErr,
+                           struct child *pMkChild, pid_t *pPid)
 {
     PWINCHILD pChild = mkWinChildNew(WINCHILDTYPE_SUBMIT);
+    pChild->pMkChild                = pMkChild;
     pChild->u.Submit.hEvent         = (HANDLE)hEvent;
     pChild->u.Submit.pvSubmitWorker = pvSubmitWorker;

trunk/src/kmk/w32/winchildren.h

@@ -75 +75 @@
                                struct child *pMkChild, pid_t *pPid);
 
-int     MkWinChildCreateSubmit(intptr_t hEvent, void *pvSubmitWorker, PWINCCWPIPE pStdOut, PWINCCWPIPE pStdErr, pid_t *pPid);
+int     MkWinChildCreateSubmit(intptr_t hEvent, void *pvSubmitWorker, PWINCCWPIPE pStdOut, PWINCCWPIPE pStdErr,
+                               struct child *pMkChild, pid_t *pPid);
 PWINCCWPIPE MkWinChildcareCreateWorkerPipe(unsigned iWhich, unsigned int idxWorker);
 void    MkWinChildcareWorkerDrainPipes(struct WINCHILD *pChild, PWINCCWPIPE pStdOut, PWINCCWPIPE pStdErr);