ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/Development/ray/src/util/rcomb.c
(Generate patch)

Comparing ray/src/util/rcomb.c (file contents):
Revision 2.11 by greg, Tue May 21 16:27:26 2024 UTC vs.
Revision 2.16 by greg, Thu May 23 15:48:44 2024 UTC

# Line 543 | Line 543 | output_headinfo(FILE *fp)
543   static int
544   spawned_children(int np)
545   {
546 +        long    inpwidth = 0;
547          int     i, rv;
548  
549   #if defined(_WIN32) || defined(_WIN64)
# Line 558 | Line 559 | spawned_children(int np)
559                  mop[i].imx.nrows = 1;
560                  if (!rmx_prepare(&mop[i].imx))
561                          goto memerror;
562 +                inpwidth += rmx_array_size(&mop[i].imx);
563                  if (mop[i].rmp != &mop[i].imx) {
564                          mop[i].rmp->nrows = 1;
565                          if (!rmx_prepare(mop[i].rmp))
566                                  goto memerror;
567 +                        inpwidth += rmx_array_size(mop[i].rmp);
568                  }
569          }
570                                  /* prep output row buffer */
# Line 598 | Line 601 | spawned_children(int np)
601                  cproc[i].pid = -1;
602                  rv = open_process(&cproc[i], NULL);
603                  if (rv <= 0) break;
604 +                if (!i && 2*rv >= inpwidth) {
605 +                        fputs("Problem too small for multi-processing\n",
606 +                                        stderr);
607 +                        exit(1);
608 +                }
609          }
610          if (rv > 0)
611                  return(1);      /* parent return value */
# Line 656 | Line 664 | parent_loop()
664                  break;
665              for (i = 0; i < nmats; i++)
666                  if (!rmx_write_data(mop[i].imx.mtx, mop[i].imx.ncomp,
667 <                                mop[i].imx.ncols, DTdouble, ofp))
667 >                                        mop[i].imx.ncols, DTdouble, ofp))
668                          return(0);
669              if (fflush(ofp) == EOF)
670                  return(0);
671          }
672 <        for (i = 0; i < nchildren; i++)
672 >        for (i = 0; i < nchildren; i++) {
673 >                sleep(2);                       /* try to maintain order */
674                  fclose(outfp[i]);
675 +        }
676          free(outfp);
677          i = close_processes(cproc, nchildren);
678          free(cproc); cproc = NULL;
# Line 708 | Line 718 | combine_input()
718                  set_c = varlookup("c") != NULL && !vardefined("c");
719          } else                          /* save a little time */
720                  set_r = set_c = 0;
721 +
722                                          /* read/process row-by-row */
723          for (cur_row = row0; (in_nrows <= 0) | (cur_row < in_nrows); cur_row += rstep) {
724              RMATRIX     *mres = NULL;
# Line 760 | Line 771 | combine_input()
771                          return(0);
772              }
773              rmx_free(mres); mres = NULL;
774 <            if (inchild >= 0) {
775 <                i = getc(stdin);        /* child waits for turn to output */
774 >            if (inchild >= 0) {         /* children share stdout */
775 >                i = getc(stdin);        /* signals it's our turn */
776                  if (i != EOF) ungetc(i, stdin);
777              }
778              if (!rmx_write_data(res->rmp->mtx, res->rmp->ncomp,
# Line 901 | Line 912 | main(int argc, char *argv[])
912                                  if (n && !isflt(argv[i+1])) {
913                                          mop[nmats].preop.csym = argv[++i];
914                                          mop[nmats].preop.clen = 0;
915 +                                        mcat_last = 0;
916                                          break;
917                                  }
918                                  if (n > MAXCOMP*MAXCOMP) n = MAXCOMP*MAXCOMP;

Diff Legend

– Removed lines
+ Added lines
< Changed lines (old)
> Changed lines (new)