workbench/libs/datatypes/doasynclayout.c

   1 /*
   2     Copyright © 1995-2015, The AROS Development Team. All rights reserved.
   3     $Id$
   4
   5     Desc:
   6     Lang: English
   7 */
   8
   9 #define USE_BOOPSI_STUBS
  10 #include <utility/tagitem.h>
  11 #include <dos/dostags.h>
  12 #include <dos/dosextens.h>
  13 #include <proto/dos.h>
  14 #include <proto/intuition.h>
  15 #include <intuition/intuition.h>
  16 #include <intuition/gadgetclass.h>
  17 #include <intuition/cghooks.h>
  18 #include <clib/boopsistubs.h>
  19 #include "datatypes_intern.h"
  20
  21 struct LayoutMessage
  22 {
  23     struct Message        lm_Msg;
  24     struct DataTypesBase *lm_dtb;
  25     Object               *lm_object;
  26     struct Window        *lm_window;
  27     struct gpLayout       lm_gplayout;
  28     struct GadgetInfo     lm_ginfo;
  29 };
  30
  31
  32 void AsyncLayouter(void)
  33 {
  34     struct DataTypesBase *dtb;
  35     struct LayoutMessage *lm;
  36     struct DTSpecialInfo *dtsi;
  37     Object *object;
  38     BOOL done = FALSE;
  39
  40     struct Process *MyProc = (struct Process *)FindTask(NULL);
  41
  42     WaitPort(&MyProc->pr_MsgPort);
  43     lm = (struct LayoutMessage *)GetMsg(&MyProc->pr_MsgPort);
  44
  45     dtb = lm->lm_dtb;
  46
  47     object = lm->lm_object;
  48     dtsi = ((struct Gadget *)object)->SpecialInfo;
  49
  50     ObtainSemaphore(&dtsi->si_Lock);
  51
  52     lm->lm_gplayout.MethodID = DTM_ASYNCLAYOUT;
  53
  54     while (!done)
  55     {
  56         DoMethodA(object, (Msg)&lm->lm_gplayout);
  57
  58         ObtainSemaphore(&(GPB(dtb)->dtb_Semaphores[SEM_ASYNC]));
  59         if (dtsi->si_Flags & DTSIF_NEWSIZE)
  60         {
  61             /* Ensure the method is only called once more unless there's
  62                another request to restart it */
  63             dtsi->si_Flags &= ~DTSIF_NEWSIZE;
  64
  65             /* Ensure Ctrl-C is cleared in case it was set again after the
  66                method saw it, or the method finished without seeing it */
  67             CheckSignal(SIGBREAKF_CTRL_C);
  68         }
  69         else
  70         {
  71             /* Prepare to exit */
  72             dtsi->si_Flags &= ~DTSIF_LAYOUT;
  73             setattrs((struct Library *)dtb, object, DTA_LayoutProc, NULL,
  74                 TAG_DONE);
  75             done = TRUE;
  76         }
  77         ReleaseSemaphore(&(GPB(dtb)->dtb_Semaphores[SEM_ASYNC]));
  78     }
  79
  80     ReleaseSemaphore(&dtsi->si_Lock);
  81
  82     DoGad_OM_NOTIFY((struct Library *)dtb, object, lm->lm_window, NULL, 0,
  83                     GA_ID, (ULONG)((struct Gadget *)object)->GadgetID,
  84                     DTA_Data,         object,
  85                     DTA_TopVert,      dtsi->si_TopVert,
  86                     DTA_VisibleVert,  dtsi->si_VisVert,
  87                     DTA_TotalVert,    dtsi->si_TotVert,
  88                     DTA_TopHoriz,     dtsi->si_TopHoriz,
  89                     DTA_VisibleHoriz, dtsi->si_VisHoriz,
  90                     DTA_TotalHoriz,   dtsi->si_TotHoriz,
  91                     DTA_Sync,         TRUE,
  92                     DTA_Busy,         FALSE,
  93                     TAG_DONE);
  94
  95     Forbid();
  96
  97     dtsi->si_Flags &= ~DTSIF_LAYOUTPROC;
  98
  99     FreeVec(lm);
 100 }
 101
 102
 103 /*****************************************************************************
 104
 105     NAME */
 106 #include <proto/datatypes.h>
 107
 108         AROS_LH2(ULONG, DoAsyncLayout,
 109
 110 /*  SYNOPSIS */
 111         AROS_LHA(Object *         , object, A0),
 112         AROS_LHA(struct gpLayout *, gpl   , A1),
 113
 114 /*  LOCATION */
 115         struct Library *, DataTypesBase, 14, DataTypes)
 116
 117 /*  FUNCTION
 118
 119     Perform an object's DTM_ASYNCLAYOUT method -- doing it asynchronously
 120     off loads the input.device. The method should exit when a SIGBREAK_CTRL_C
 121     is received; this signal means that the data is obsolete and the
 122     method will be called again.
 123
 124     INPUTS
 125
 126     object  --  pointer to data type object
 127     gpl     --  gpLayout message pointer
 128
 129     RESULT
 130
 131     NOTES
 132
 133     EXAMPLE
 134
 135     BUGS
 136
 137     SEE ALSO
 138
 139     INTERNALS
 140
 141 *****************************************************************************/
 142 {
 143     AROS_LIBFUNC_INIT
 144
 145     ULONG retval = FALSE;
 146     struct DTSpecialInfo *dtsi=((struct Gadget *)object)->SpecialInfo;
 147     struct Process *LayoutProc;
 148
 149     ObtainSemaphore(&(GPB(DataTypesBase)->dtb_Semaphores[SEM_ASYNC]));
 150
 151     if(dtsi->si_Flags & DTSIF_LAYOUT)
 152     {
 153         dtsi->si_Flags |= DTSIF_NEWSIZE;
 154
 155         if(GetAttr(DTA_LayoutProc, object, (IPTR *)&LayoutProc))
 156         {
 157             if(LayoutProc != NULL)
 158                 Signal((struct Task *)LayoutProc, SIGBREAKF_CTRL_C);
 159         }
 160
 161         retval = TRUE;
 162     }
 163     else
 164     {
 165         struct LayoutMessage *lm;
 166
 167         dtsi->si_Flags |= (DTSIF_LAYOUT | DTSIF_LAYOUTPROC);
 168
 169         Do_OM_NOTIFY(DataTypesBase, object, gpl->gpl_GInfo, 0, DTA_Data, NULL,
 170                      TAG_DONE);
 171
 172         if((lm = AllocVec(sizeof(struct LayoutMessage),
 173                          MEMF_PUBLIC | MEMF_CLEAR)))
 174         {
 175             struct TagItem Tags[5];
 176
 177             lm->lm_Msg.mn_Node.ln_Type = NT_MESSAGE;
 178             lm->lm_Msg.mn_Length = sizeof(struct LayoutMessage);
 179             lm->lm_dtb = (struct DataTypesBase *)DataTypesBase;
 180             lm->lm_object = object;
 181             lm->lm_window = gpl->gpl_GInfo->gi_Window;
 182             lm->lm_gplayout = *gpl;
 183             lm->lm_ginfo= *gpl->gpl_GInfo;
 184             lm->lm_gplayout.gpl_GInfo= &lm->lm_ginfo;
 185
 186             Tags[0].ti_Tag  = NP_StackSize;
 187             Tags[0].ti_Data = AROS_STACKSIZE;
 188             Tags[1].ti_Tag  = NP_Entry;
 189             Tags[1].ti_Data = (IPTR)&AsyncLayouter;
 190             Tags[2].ti_Tag  = NP_Priority;
 191             Tags[2].ti_Data = 0;
 192             Tags[3].ti_Tag  = NP_Name;
 193             Tags[3].ti_Data = (IPTR)"AsyncLayoutDaemon";
 194             Tags[4].ti_Tag  = TAG_DONE;
 195
 196             if((LayoutProc = CreateNewProc(Tags)))
 197             {
 198                 PutMsg(&LayoutProc->pr_MsgPort, &lm->lm_Msg);
 199
 200                 setattrs(DataTypesBase, object, DTA_LayoutProc, LayoutProc, TAG_DONE);
 201                 retval = TRUE;
 202             }
 203             else
 204                 FreeVec(lm);
 205         }
 206
 207         if (!retval) dtsi->si_Flags &= ~(DTSIF_LAYOUT | DTSIF_LAYOUTPROC);
 208     }
 209
 210     ReleaseSemaphore(&(GPB(DataTypesBase)->dtb_Semaphores[SEM_ASYNC]));
 211
 212     return retval;
 213
 214     AROS_LIBFUNC_EXIT
 215
 216 } /* DoAsyncLayout */