4 * Copyright 1995 Alexandre Julliard
26 #include "selectors.h"
27 #include "stackframe.h"
40 /* Min. number of thunks allocated when creating a new segment */
43 /* Pointer to function to switch to a larger stack */
44 int (*IF1632_CallLargeStack)( int (*func)(), void *arg ) = NULL;
47 static THHOOK DefaultThhook = { 0 };
48 THHOOK *pThhook = &DefaultThhook;
50 #define hCurrentTask (pThhook->CurTDB)
51 #define hFirstTask (pThhook->HeadTDB)
52 #define hLockedTask (pThhook->LockTDB)
54 static HTASK16 hTaskToKill = 0;
55 static UINT16 nTaskCount = 0;
57 static void TASK_YieldToSystem(TDB*);
59 extern BOOL32 THREAD_InitDone;
62 /***********************************************************************
65 void TASK_InstallTHHook( THHOOK *pNewThhook )
67 THHOOK *pOldThhook = pThhook;
69 pThhook = pNewThhook? pNewThhook : &DefaultThhook;
71 *pThhook = *pOldThhook;
74 /***********************************************************************
77 HTASK16 TASK_GetNextTask( HTASK16 hTask )
79 TDB* pTask = (TDB*)GlobalLock16(hTask);
81 if (pTask->hNext) return pTask->hNext;
82 return (hFirstTask != hTask) ? hFirstTask : 0;
85 /***********************************************************************
88 static void TASK_LinkTask( HTASK16 hTask )
93 if (!(pTask = (TDB *)GlobalLock16( hTask ))) return;
94 prevTask = &hFirstTask;
97 TDB *prevTaskPtr = (TDB *)GlobalLock16( *prevTask );
98 if (prevTaskPtr->priority >= pTask->priority) break;
99 prevTask = &prevTaskPtr->hNext;
101 pTask->hNext = *prevTask;
107 /***********************************************************************
110 static void TASK_UnlinkTask( HTASK16 hTask )
115 prevTask = &hFirstTask;
116 while (*prevTask && (*prevTask != hTask))
118 pTask = (TDB *)GlobalLock16( *prevTask );
119 prevTask = &pTask->hNext;
123 pTask = (TDB *)GlobalLock16( *prevTask );
124 *prevTask = pTask->hNext;
131 /***********************************************************************
134 * Create a thunk free-list in segment 'handle', starting from offset 'offset'
135 * and containing 'count' entries.
137 static void TASK_CreateThunks( HGLOBAL16 handle, WORD offset, WORD count )
143 pThunk = (THUNKS *)((BYTE *)GlobalLock16( handle ) + offset);
145 pThunk->magic = THUNK_MAGIC;
146 pThunk->free = (int)&pThunk->thunks - (int)pThunk;
148 for (i = 0; i < count-1; i++)
150 free += 8; /* Offset of next thunk */
151 pThunk->thunks[4*i] = free;
153 pThunk->thunks[4*i] = 0; /* Last thunk */
157 /***********************************************************************
160 * Allocate a thunk for MakeProcInstance().
162 static SEGPTR TASK_AllocThunk( HTASK16 hTask )
168 if (!(pTask = (TDB *)GlobalLock16( hTask ))) return 0;
169 sel = pTask->hCSAlias;
170 pThunk = &pTask->thunks;
171 base = (int)pThunk - (int)pTask;
172 while (!pThunk->free)
175 if (!sel) /* Allocate a new segment */
177 sel = GLOBAL_Alloc( GMEM_FIXED, sizeof(THUNKS) + (MIN_THUNKS-1)*8,
178 pTask->hPDB, TRUE, FALSE, FALSE );
179 if (!sel) return (SEGPTR)0;
180 TASK_CreateThunks( sel, 0, MIN_THUNKS );
183 pThunk = (THUNKS *)GlobalLock16( sel );
186 base += pThunk->free;
187 pThunk->free = *(WORD *)((BYTE *)pThunk + pThunk->free);
188 return PTR_SEG_OFF_TO_SEGPTR( sel, base );
192 /***********************************************************************
195 * Free a MakeProcInstance() thunk.
197 static BOOL32 TASK_FreeThunk( HTASK16 hTask, SEGPTR thunk )
203 if (!(pTask = (TDB *)GlobalLock16( hTask ))) return 0;
204 sel = pTask->hCSAlias;
205 pThunk = &pTask->thunks;
206 base = (int)pThunk - (int)pTask;
207 while (sel && (sel != HIWORD(thunk)))
210 pThunk = (THUNKS *)GlobalLock16( sel );
213 if (!sel) return FALSE;
214 *(WORD *)((BYTE *)pThunk + LOWORD(thunk) - base) = pThunk->free;
215 pThunk->free = LOWORD(thunk) - base;
220 /***********************************************************************
223 * 32-bit entry point for a new task. This function is responsible for
224 * setting up the registers and jumping to the 16-bit entry point.
226 static void TASK_CallToStart(void)
228 TDB *pTask = (TDB *)GlobalLock16( GetCurrentTask() );
229 NE_MODULE *pModule = NE_GetPtr( pTask->hModule );
230 SEGTABLEENTRY *pSegTable = NE_SEG_TABLE( pModule );
232 SET_CUR_THREAD( pTask->thdb );
235 /* Terminate the stack frame chain */
236 memset(THREAD_STACK16( pTask->thdb ), '\0', sizeof(STACK16FRAME));
238 if (pModule->flags & NE_FFLAGS_WIN32)
240 /* FIXME: all this is an ugly hack */
242 LPTHREAD_START_ROUTINE entry = (LPTHREAD_START_ROUTINE)
243 RVA_PTR(pModule->module32, OptionalHeader.AddressOfEntryPoint);
244 DWORD size = PE_HEADER(pModule->module32)->OptionalHeader.SizeOfStackReserve;
248 pTask->userhandler = (USERSIGNALPROC)&USER_SignalProc;
249 if (pModule->heap_size)
250 LocalInit( pTask->hInstance, 0, pModule->heap_size );
252 InitApp( pTask->hModule );
253 PE_InitializeDLLs( PROCESS_Current(), DLL_PROCESS_ATTACH, (LPVOID)-1 );
254 TRACE(relay, "(entryproc=%p)\n", entry );
257 ExitProcess( entry(NULL) );
259 CreateThread( NULL, size, entry, NULL, 0, &id );
260 thdb = THREAD_ID_TO_THDB( id );
262 while ( thdb->exit_code == 0x103 )
265 QUEUE_Signal( pTask->hSelf );
268 ExitProcess( thdb->exit_code );
271 else if (pModule->dos_image)
278 /* Registers at initialization must be:
280 * bx stack size in bytes
281 * cx heap size in bytes
282 * si previous app instance
283 * di current app instance
285 * es selector to the PSP
286 * ds dgroup of the application
288 * sp top of the stack
292 memset( &context, 0, sizeof(context) );
293 CS_reg(&context) = pSegTable[pModule->cs - 1].selector;
294 DS_reg(&context) = pSegTable[pModule->dgroup - 1].selector;
295 ES_reg(&context) = pTask->hPDB;
296 EIP_reg(&context) = pModule->ip;
297 EBX_reg(&context) = pModule->stack_size;
298 ECX_reg(&context) = pModule->heap_size;
299 EDI_reg(&context) = context.SegDs;
301 TRACE(task, "Starting main program: cs:ip=%04lx:%04x ds=%04lx ss:sp=%04x:%04x\n",
302 CS_reg(&context), IP_reg(&context), DS_reg(&context),
303 SELECTOROF(pTask->thdb->cur_stack),
304 OFFSETOF(pTask->thdb->cur_stack) );
306 Callbacks->CallRegisterShortProc( &context, 0 );
307 /* This should never return */
308 ERR( task, "Main program returned! (should never happen)\n" );
314 /***********************************************************************
317 * NOTE: This routine might be called by a Win32 thread. We don't have
318 * any real problems with that, since we operated merely on a private
319 * TDB structure that is not yet linked into the task list.
321 HTASK16 TASK_Create( THDB *thdb, NE_MODULE *pModule, HINSTANCE16 hInstance,
322 HINSTANCE16 hPrevInstance, UINT16 cmdShow)
330 STACK16FRAME *frame16;
331 STACK32FRAME *frame32;
332 PDB32 *pdb32 = thdb->process;
333 SEGTABLEENTRY *pSegTable = NE_SEG_TABLE( pModule );
335 /* Allocate the task structure */
337 hTask = GLOBAL_Alloc( GMEM_FIXED | GMEM_ZEROINIT, sizeof(TDB),
338 pModule->self, FALSE, FALSE, FALSE );
339 if (!hTask) return 0;
340 pTask = (TDB *)GlobalLock16( hTask );
342 /* Fill the task structure */
344 pTask->nEvents = 1; /* So the task can be started */
345 pTask->hSelf = hTask;
348 if (pModule->flags & NE_FFLAGS_WIN32)
349 pTask->flags |= TDBF_WIN32;
350 if (pModule->lpDosTask)
351 pTask->flags |= TDBF_WINOLDAP;
353 pTask->version = pModule->expected_version;
354 pTask->hInstance = hInstance;
355 pTask->hPrevInstance = hPrevInstance;
356 pTask->hModule = pModule->self;
357 pTask->hParent = GetCurrentTask();
358 pTask->magic = TDB_MAGIC;
359 pTask->nCmdShow = cmdShow;
361 pTask->curdrive = DRIVE_GetCurrentDrive() | 0x80;
362 strcpy( pTask->curdir, "\\" );
363 lstrcpyn32A( pTask->curdir + 1, DRIVE_GetDosCwd( DRIVE_GetCurrentDrive() ),
364 sizeof(pTask->curdir) - 1 );
366 /* Create the thunks block */
368 TASK_CreateThunks( hTask, (int)&pTask->thunks - (int)pTask, 7 );
370 /* Copy the module name */
372 GetModuleName( pModule->self, name, sizeof(name) );
373 strncpy( pTask->module_name, name, sizeof(pTask->module_name) );
375 /* Allocate a selector for the PDB */
377 pTask->hPDB = GLOBAL_CreateBlock( GMEM_FIXED, &pTask->pdb, sizeof(PDB),
378 pModule->self, FALSE, FALSE, FALSE, NULL );
382 pTask->pdb.int20 = 0x20cd;
383 pTask->pdb.dispatcher[0] = 0x9a; /* ljmp */
384 PUT_DWORD(&pTask->pdb.dispatcher[1], (DWORD)NE_GetEntryPoint(
385 GetModuleHandle16("KERNEL"), 102 )); /* KERNEL.102 is DOS3Call() */
386 pTask->pdb.savedint22 = INT_GetHandler( 0x22 );
387 pTask->pdb.savedint23 = INT_GetHandler( 0x23 );
388 pTask->pdb.savedint24 = INT_GetHandler( 0x24 );
389 pTask->pdb.fileHandlesPtr =
390 PTR_SEG_OFF_TO_SEGPTR( GlobalHandleToSel(pTask->hPDB),
391 (int)&((PDB *)0)->fileHandles );
392 pTask->pdb.hFileHandles = 0;
393 memset( pTask->pdb.fileHandles, 0xff, sizeof(pTask->pdb.fileHandles) );
394 pTask->pdb.environment = pdb32->env_db->env_sel;
395 pTask->pdb.nbFiles = 20;
397 /* Fill the command line */
399 cmd_line = pdb32->env_db->cmd_line;
400 while (*cmd_line && (*cmd_line != ' ') && (*cmd_line != '\t')) cmd_line++;
401 while ((*cmd_line == ' ') || (*cmd_line == '\t')) cmd_line++;
402 lstrcpyn32A( pTask->pdb.cmdLine+1, cmd_line, sizeof(pTask->pdb.cmdLine)-1);
403 pTask->pdb.cmdLine[0] = strlen( pTask->pdb.cmdLine + 1 );
405 /* Get the compatibility flags */
407 pTask->compat_flags = GetProfileInt32A( "Compatibility", name, 0 );
409 /* Allocate a code segment alias for the TDB */
411 pTask->hCSAlias = GLOBAL_CreateBlock( GMEM_FIXED, (void *)pTask,
412 sizeof(TDB), pTask->hPDB, TRUE,
413 FALSE, FALSE, NULL );
415 /* Set the owner of the environment block */
417 FarSetOwner( pTask->pdb.environment, pTask->hPDB );
419 /* Default DTA overwrites command-line */
421 pTask->dta = PTR_SEG_OFF_TO_SEGPTR( pTask->hPDB,
422 (int)&pTask->pdb.cmdLine - (int)&pTask->pdb );
424 /* Create the 16-bit stack frame */
426 if (!(sp = pModule->sp))
427 sp = pSegTable[pModule->ss-1].minsize + pModule->stack_size;
429 pTask->thdb->cur_stack = PTR_SEG_OFF_TO_SEGPTR( pTask->hInstance, sp );
430 pTask->thdb->cur_stack -= 2*sizeof(STACK16FRAME);
431 frame16 = (STACK16FRAME *)PTR_SEG_TO_LIN( pTask->thdb->cur_stack );
432 frame16->ebp = sp + (int)&((STACK16FRAME *)0)->bp;
433 frame16->bp = LOWORD(frame16->ebp);
434 frame16->ds = frame16->es = pTask->hInstance;
436 frame16->entry_point = 0;
437 frame16->entry_cs = 0;
438 frame16->mutex_count = 1; /* TASK_Reschedule is called from 16-bit code */
439 /* The remaining fields will be initialized in TASK_Reschedule */
441 /* Create the 32-bit stack frame */
443 stack32Top = (char*)pTask->thdb->teb.stack_top;
444 frame16->frame32 = frame32 = (STACK32FRAME *)stack32Top - 1;
445 frame32->frame16 = pTask->thdb->cur_stack + sizeof(STACK16FRAME);
451 frame32->retaddr = (DWORD)TASK_CallToStart;
452 /* The remaining fields will be initialized in TASK_Reschedule */
454 if (!THREAD_Current()->cur_stack)
455 THREAD_Current()->cur_stack = pTask->thdb->cur_stack;
458 TRACE(task, "module='%s' cmdline='%s' task=%04x\n",
459 name, cmd_line, hTask );
464 /***********************************************************************
467 * NOTE: This routine might be called by a Win32 thread. Thus, we need
468 * to be careful to protect global data structures. We do this
469 * by entering the Win16Lock while linking the task into the
472 void TASK_StartTask( HTASK16 hTask )
474 /* Add the task to the linked list */
476 SYSLEVEL_EnterWin16Lock();
477 TASK_LinkTask( hTask );
478 SYSLEVEL_LeaveWin16Lock();
480 TRACE(task, "linked task %04x\n", hTask );
482 /* Get the task up and running. If we ourselves are a 16-bit task,
483 we simply Yield(). If we are 32-bit however, we need to signal
484 the main process somehow (NOT YET IMPLEMENTED!) */
486 if ( GetCurrentTask() )
487 if ( THREAD_IsWin16( THREAD_Current() ) )
490 FIXME(task, "Don't know how to start 16-bit task from 32-bit thread. Move the mouse!\n");
494 /***********************************************************************
497 static void TASK_DeleteTask( HTASK16 hTask )
502 if (!(pTask = (TDB *)GlobalLock16( hTask ))) return;
505 pTask->magic = 0xdead; /* invalidate signature */
507 /* Delete the Win32 part of the task */
509 K32OBJ_DecCount( &pTask->thdb->process->header );
510 K32OBJ_DecCount( &pTask->thdb->header );
512 /* Free the task module */
514 FreeModule16( pTask->hModule );
516 /* Free the selector aliases */
518 GLOBAL_FreeBlock( pTask->hCSAlias );
519 GLOBAL_FreeBlock( pTask->hPDB );
521 /* Free the task structure itself */
523 GlobalFree16( hTask );
525 /* Free all memory used by this task (including the 32-bit stack, */
526 /* the environment block and the thunk segments). */
528 GlobalFreeAll( hPDB );
532 /***********************************************************************
533 * TASK_KillCurrentTask
535 * Kill the currently running task. As it's not possible to kill the
536 * current task like this, it is simply marked for destruction, and will
537 * be killed when either TASK_Reschedule or this function is called again
538 * in the context of another task.
540 void TASK_KillCurrentTask( INT16 exitCode )
542 TDB* pTask = (TDB*) GlobalLock16( GetCurrentTask() );
543 NE_MODULE* pModule = NE_GetPtr( pTask->hModule );
544 if (!pTask) USER_ExitWindows(); /* No current task yet */
546 if ( !THREAD_IsWin16( THREAD_Current() ) )
548 FIXME(task, "called for Win32 thread (%04x)!\n", THREAD_Current()->teb_sel);
552 /* Enter the Win16Lock to protect global data structures
553 NOTE: We never explicitly leave it again. This shouldn't matter
554 though, as it will be released in TASK_Reschedule and this
555 task won't ever get scheduled again ... */
557 SYSLEVEL_EnterWin16Lock();
559 assert(hCurrentTask == GetCurrentTask());
561 TRACE(task, "Killing task %04x\n", hCurrentTask );
563 /* Delete active sockets */
566 WINSOCK_DeleteTaskWSI( pTask, pTask->pwsi );
569 /* Kill DOS VM task */
570 if ( pModule->lpDosTask )
571 MZ_KillModule( pModule->lpDosTask );
574 /* Perform USER cleanup */
576 if (pTask->userhandler)
577 pTask->userhandler( hCurrentTask, USIG_TERMINATION, 0,
578 pTask->hInstance, pTask->hQueue );
580 if (hTaskToKill && (hTaskToKill != hCurrentTask))
582 /* If another task is already marked for destruction, */
583 /* we can kill it now, as we are in another context. */
584 TASK_DeleteTask( hTaskToKill );
589 TRACE(task, "this is the last task, exiting\n" );
593 /* Remove the task from the list to be sure we never switch back to it */
594 TASK_UnlinkTask( hCurrentTask );
597 TDB* p = (TDB *)GlobalLock16( hFirstTask );
600 if( p->hYieldTo == hCurrentTask ) p->hYieldTo = 0;
601 p = (TDB *)GlobalLock16( p->hNext );
605 hTaskToKill = hCurrentTask;
609 TASK_YieldToSystem(pTask);
611 /* We should never return from this Yield() */
613 ERR(task,"Return of the living dead %04x!!!\n", hCurrentTask);
617 /***********************************************************************
620 * This is where all the magic of task-switching happens!
622 * Note: This function should only be called via the TASK_YieldToSystem()
623 * wrapper, to make sure that all the context is saved correctly.
625 * It must not call functions that may yield control.
627 void TASK_Reschedule(void)
629 TDB *pOldTask = NULL, *pNewTask;
631 STACK16FRAME *newframe16;
633 /* NOTE: As we are entered from 16-bit code, we hold the Win16Lock.
634 We hang onto it thoughout most of this routine, so that accesses
635 to global variables (most notably the task list) are protected. */
636 assert(hCurrentTask == GetCurrentTask());
638 TRACE(task, "entered with hTask %04x (pid %d)\n", hCurrentTask, getpid());
641 /* FIXME: What about the Win16Lock ??? */
644 /* First check if there's a task to kill */
646 if (hTaskToKill && (hTaskToKill != hCurrentTask))
648 TASK_DeleteTask( hTaskToKill );
652 /* Find a task to yield to */
654 pOldTask = (TDB *)GlobalLock16( hCurrentTask );
655 if (pOldTask && pOldTask->hYieldTo)
657 /* check for DirectedYield() */
659 hTask = pOldTask->hYieldTo;
660 pNewTask = (TDB *)GlobalLock16( hTask );
661 if( !pNewTask || !pNewTask->nEvents) hTask = 0;
662 pOldTask->hYieldTo = 0;
665 /* extract hardware events only! */
667 if (!hTask) EVENT_WaitNetEvent( FALSE, TRUE );
671 /* Find a task that has an event pending */
676 pNewTask = (TDB *)GlobalLock16( hTask );
678 TRACE(task, "\ttask = %04x, events = %i\n", hTask, pNewTask->nEvents);
680 if (pNewTask->nEvents) break;
681 hTask = pNewTask->hNext;
683 if (hLockedTask && (hTask != hLockedTask)) hTask = 0;
686 /* No task found, wait for some events to come in */
688 /* NOTE: We release the Win16Lock while waiting for events. This is to enable
689 Win32 threads to thunk down to 16-bit temporarily. Since Win16
690 tasks won't execute and Win32 threads are not allowed to enter
691 TASK_Reschedule anyway, there should be no re-entrancy problem ... */
693 SYSLEVEL_ReleaseWin16Lock();
694 EVENT_WaitNetEvent( TRUE, TRUE );
695 SYSLEVEL_RestoreWin16Lock();
698 if (hTask == hCurrentTask)
700 TRACE(task, "returning to the current task(%04x)\n", hTask );
701 return; /* Nothing to do */
703 pNewTask = (TDB *)GlobalLock16( hTask );
704 TRACE(task, "Switching to task %04x (%.8s)\n",
705 hTask, pNewTask->module_name );
707 /* Make the task the last in the linked list (round-robin scheduling) */
709 pNewTask->priority++;
710 TASK_UnlinkTask( hTask );
711 TASK_LinkTask( hTask );
712 pNewTask->priority--;
714 /* Finish initializing the new task stack if necessary */
716 newframe16 = THREAD_STACK16( pNewTask->thdb );
717 if (!newframe16->entry_cs)
719 STACK16FRAME *oldframe16 = CURRENT_STACK16;
720 STACK32FRAME *oldframe32 = oldframe16->frame32;
721 STACK32FRAME *newframe32 = newframe16->frame32;
722 newframe16->entry_ip = oldframe16->entry_ip;
723 newframe16->entry_cs = oldframe16->entry_cs;
724 newframe16->ip = oldframe16->ip;
725 newframe16->cs = oldframe16->cs;
726 newframe32->ebp = oldframe32->ebp;
727 newframe32->restore_addr = oldframe32->restore_addr;
728 newframe32->codeselector = oldframe32->codeselector;
731 /* Switch to the new stack */
733 /* NOTE: We need to release/restore the Win16Lock, as the task
734 switched to might be at another recursion level than
737 SYSLEVEL_ReleaseWin16Lock();
739 hCurrentTask = hTask;
740 SET_CUR_THREAD( pNewTask->thdb );
741 pNewTask->ss_sp = pNewTask->thdb->cur_stack;
743 SYSLEVEL_RestoreWin16Lock();
747 /***********************************************************************
750 * Scheduler interface, this way we ensure that all "unsafe" events are
751 * processed outside the scheduler.
753 void TASK_YieldToSystem(TDB* pTask)
757 if ( !THREAD_IsWin16( THREAD_Current() ) )
759 FIXME(task, "called for Win32 thread (%04x)!\n", THREAD_Current()->teb_sel);
763 Callbacks->CallTaskRescheduleProc();
767 pQ = (MESSAGEQUEUE*)GlobalLock16(pTask->hQueue);
768 if( pQ && pQ->flags & QUEUE_FLAG_XEVENT &&
769 !(pQ->wakeBits & (QS_SENDMESSAGE | QS_SMRESULT)) )
771 pQ->flags &= ~QUEUE_FLAG_XEVENT;
772 EVENT_WaitNetEvent( FALSE, FALSE );
778 /***********************************************************************
779 * InitTask (KERNEL.91)
781 * Called by the application startup code.
783 void WINAPI InitTask( CONTEXT *context )
787 SEGTABLEENTRY *pSegTable;
788 INSTANCEDATA *pinstance;
789 LONG stacklow, stackhi;
791 if (context) EAX_reg(context) = 0;
792 if (!(pTask = (TDB *)GlobalLock16( GetCurrentTask() ))) return;
793 if (!(pModule = NE_GetPtr( pTask->hModule ))) return;
795 /* This is a hack to install task USER signal handler before
796 * implicitly loaded DLLs are initialized (see windows/user.c) */
798 pTask->userhandler = (USERSIGNALPROC)&USER_SignalProc;
800 /* Initialize implicitly loaded DLLs */
801 NE_InitializeDLLs( pTask->hModule );
805 /* Registers on return are:
806 * ax 1 if OK, 0 on error
807 * cx stack limit in bytes
808 * dx cmdShow parameter
809 * si instance handle of the previous instance
810 * di instance handle of the new task
811 * es:bx pointer to command-line inside PSP
813 * 0 (=%bp) is pushed on the stack
815 SEGPTR ptr = STACK16_PUSH( pTask->thdb, sizeof(WORD) );
816 *(WORD *)PTR_SEG_TO_LIN(ptr) = 0;
817 SP_reg(context) -= 2;
819 EAX_reg(context) = 1;
821 if (!pTask->pdb.cmdLine[0]) EBX_reg(context) = 0x80;
824 LPBYTE p = &pTask->pdb.cmdLine[1];
825 while ((*p == ' ') || (*p == '\t')) p++;
826 EBX_reg(context) = 0x80 + (p - pTask->pdb.cmdLine);
828 ECX_reg(context) = pModule->stack_size;
829 EDX_reg(context) = pTask->nCmdShow;
830 ESI_reg(context) = (DWORD)pTask->hPrevInstance;
831 EDI_reg(context) = (DWORD)pTask->hInstance;
832 ES_reg (context) = (WORD)pTask->hPDB;
835 /* Initialize the local heap */
836 if ( pModule->heap_size )
838 LocalInit( pTask->hInstance, 0, pModule->heap_size );
841 /* Initialize the INSTANCEDATA structure */
842 pSegTable = NE_SEG_TABLE( pModule );
843 stacklow = pSegTable[pModule->ss - 1].minsize;
844 stackhi = stacklow + pModule->stack_size;
845 if (stackhi > 0xffff) stackhi = 0xffff;
846 pinstance = (INSTANCEDATA *)PTR_SEG_OFF_TO_LIN(CURRENT_DS, 0);
847 pinstance->stackbottom = stackhi; /* yup, that's right. Confused me too. */
848 pinstance->stacktop = stacklow;
849 pinstance->stackmin = OFFSETOF( pTask->thdb->cur_stack );
853 /***********************************************************************
854 * WaitEvent (KERNEL.30)
856 BOOL16 WINAPI WaitEvent( HTASK16 hTask )
860 if (!hTask) hTask = GetCurrentTask();
861 pTask = (TDB *)GlobalLock16( hTask );
863 if ( !THREAD_IsWin16( THREAD_Current() ) )
865 FIXME(task, "called for Win32 thread (%04x)!\n", THREAD_Current()->teb_sel);
869 if (pTask->nEvents > 0)
874 TASK_YieldToSystem(pTask);
876 /* When we get back here, we have an event */
878 if (pTask->nEvents > 0) pTask->nEvents--;
883 /***********************************************************************
884 * PostEvent (KERNEL.31)
886 void WINAPI PostEvent( HTASK16 hTask )
890 if (!hTask) hTask = GetCurrentTask();
891 if (!(pTask = (TDB *)GlobalLock16( hTask ))) return;
893 if ( !THREAD_IsWin16( THREAD_Current() ) )
895 FIXME(task, "called for Win32 thread (%04x)!\n", THREAD_Current()->teb_sel);
904 /***********************************************************************
905 * SetPriority (KERNEL.32)
907 void WINAPI SetPriority( HTASK16 hTask, INT16 delta )
912 if (!hTask) hTask = GetCurrentTask();
913 if (!(pTask = (TDB *)GlobalLock16( hTask ))) return;
914 newpriority = pTask->priority + delta;
915 if (newpriority < -32) newpriority = -32;
916 else if (newpriority > 15) newpriority = 15;
918 pTask->priority = newpriority + 1;
919 TASK_UnlinkTask( hTask );
920 TASK_LinkTask( hTask );
925 /***********************************************************************
926 * LockCurrentTask (KERNEL.33)
928 HTASK16 WINAPI LockCurrentTask( BOOL16 bLock )
930 if (bLock) hLockedTask = GetCurrentTask();
931 else hLockedTask = 0;
936 /***********************************************************************
937 * IsTaskLocked (KERNEL.122)
939 HTASK16 WINAPI IsTaskLocked(void)
945 /***********************************************************************
946 * OldYield (KERNEL.117)
948 void WINAPI OldYield(void)
950 TDB *pCurTask = (TDB *)GlobalLock16( GetCurrentTask() );
952 if ( !THREAD_IsWin16( THREAD_Current() ) )
954 FIXME(task, "called for Win32 thread (%04x)!\n", THREAD_Current()->teb_sel);
958 if (pCurTask) pCurTask->nEvents++; /* Make sure we get back here */
959 TASK_YieldToSystem(pCurTask);
960 if (pCurTask) pCurTask->nEvents--;
964 /***********************************************************************
965 * DirectedYield (KERNEL.150)
967 void WINAPI DirectedYield( HTASK16 hTask )
969 TDB *pCurTask = (TDB *)GlobalLock16( GetCurrentTask() );
971 if ( !THREAD_IsWin16( THREAD_Current() ) )
973 FIXME(task, "called for Win32 thread (%04x)!\n", THREAD_Current()->teb_sel);
977 pCurTask->hYieldTo = hTask;
982 /***********************************************************************
983 * UserYield (USER.332)
985 void WINAPI UserYield(void)
987 TDB *pCurTask = (TDB *)GlobalLock16( GetCurrentTask() );
988 MESSAGEQUEUE *queue = (MESSAGEQUEUE *)GlobalLock16( pCurTask->hQueue );
990 if ( !THREAD_IsWin16( THREAD_Current() ) )
992 FIXME(task, "called for Win32 thread (%04x)!\n", THREAD_Current()->teb_sel);
996 /* Handle sent messages */
997 while (queue && (queue->wakeBits & QS_SENDMESSAGE))
998 QUEUE_ReceiveMessage( queue );
1002 queue = (MESSAGEQUEUE *)GlobalLock16( pCurTask->hQueue );
1003 while (queue && (queue->wakeBits & QS_SENDMESSAGE))
1004 QUEUE_ReceiveMessage( queue );
1008 /***********************************************************************
1009 * Yield16 (KERNEL.29)
1011 void WINAPI Yield16(void)
1013 TDB *pCurTask = (TDB *)GlobalLock16( GetCurrentTask() );
1015 if ( !THREAD_IsWin16( THREAD_Current() ) )
1017 FIXME(task, "called for Win32 thread (%04x)!\n", THREAD_Current()->teb_sel);
1021 if (pCurTask) pCurTask->hYieldTo = 0;
1022 if (pCurTask && pCurTask->hQueue) UserYield();
1027 /***********************************************************************
1028 * MakeProcInstance16 (KERNEL.51)
1030 FARPROC16 WINAPI MakeProcInstance16( FARPROC16 func, HANDLE16 hInstance )
1035 if (!hInstance) hInstance = CURRENT_DS;
1036 thunkaddr = TASK_AllocThunk( GetCurrentTask() );
1037 if (!thunkaddr) return (FARPROC16)0;
1038 thunk = PTR_SEG_TO_LIN( thunkaddr );
1039 lfunc = PTR_SEG_TO_LIN( func );
1041 TRACE(task, "(%08lx,%04x): got thunk %08lx\n",
1042 (DWORD)func, hInstance, (DWORD)thunkaddr );
1043 if (((lfunc[0]==0x8c) && (lfunc[1]==0xd8)) ||
1044 ((lfunc[0]==0x1e) && (lfunc[1]==0x58))
1046 FIXME(task,"thunk would be useless for %p, overwriting with nop;nop;\n", func );
1047 lfunc[0]=0x90; /* nop */
1048 lfunc[1]=0x90; /* nop */
1051 *thunk++ = 0xb8; /* movw instance, %ax */
1052 *thunk++ = (BYTE)(hInstance & 0xff);
1053 *thunk++ = (BYTE)(hInstance >> 8);
1054 *thunk++ = 0xea; /* ljmp func */
1055 *(DWORD *)thunk = (DWORD)func;
1056 return (FARPROC16)thunkaddr;
1060 /***********************************************************************
1061 * FreeProcInstance16 (KERNEL.52)
1063 void WINAPI FreeProcInstance16( FARPROC16 func )
1065 TRACE(task, "(%08lx)\n", (DWORD)func );
1066 TASK_FreeThunk( GetCurrentTask(), (SEGPTR)func );
1070 /**********************************************************************
1071 * GetCodeHandle (KERNEL.93)
1073 HANDLE16 WINAPI GetCodeHandle( FARPROC16 proc )
1076 BYTE *thunk = (BYTE *)PTR_SEG_TO_LIN( proc );
1078 /* Return the code segment containing 'proc'. */
1079 /* Not sure if this is really correct (shouldn't matter that much). */
1081 /* Check if it is really a thunk */
1082 if ((thunk[0] == 0xb8) && (thunk[3] == 0xea))
1083 handle = GlobalHandle16( thunk[6] + (thunk[7] << 8) );
1085 handle = GlobalHandle16( HIWORD(proc) );
1091 /**********************************************************************
1092 * DefineHandleTable16 (KERNEL.94)
1094 BOOL16 WINAPI DefineHandleTable16( WORD wOffset )
1096 return TRUE; /* FIXME */
1100 /***********************************************************************
1101 * SetTaskQueue (KERNEL.34)
1103 HQUEUE16 WINAPI SetTaskQueue( HTASK16 hTask, HQUEUE16 hQueue )
1108 if (!hTask) hTask = GetCurrentTask();
1109 if (!(pTask = (TDB *)GlobalLock16( hTask ))) return 0;
1111 hPrev = pTask->hQueue;
1112 pTask->hQueue = hQueue;
1114 TIMER_SwitchQueue( hPrev, hQueue );
1120 /***********************************************************************
1121 * GetTaskQueue (KERNEL.35)
1123 HQUEUE16 WINAPI GetTaskQueue( HTASK16 hTask )
1127 if (!hTask) hTask = GetCurrentTask();
1128 if (!(pTask = (TDB *)GlobalLock16( hTask ))) return 0;
1129 return pTask->hQueue;
1133 /***********************************************************************
1134 * SwitchStackTo (KERNEL.108)
1136 void WINAPI SwitchStackTo( WORD seg, WORD ptr, WORD top )
1139 STACK16FRAME *oldFrame, *newFrame;
1140 INSTANCEDATA *pData;
1143 if (!(pTask = (TDB *)GlobalLock16( GetCurrentTask() ))) return;
1144 if (!(pData = (INSTANCEDATA *)GlobalLock16( seg ))) return;
1145 TRACE(task, "old=%04x:%04x new=%04x:%04x\n",
1146 SELECTOROF( pTask->thdb->cur_stack ),
1147 OFFSETOF( pTask->thdb->cur_stack ), seg, ptr );
1149 /* Save the old stack */
1151 oldFrame = THREAD_STACK16( pTask->thdb );
1152 /* pop frame + args and push bp */
1153 pData->old_ss_sp = pTask->thdb->cur_stack - sizeof(STACK16FRAME)
1155 *(WORD *)PTR_SEG_TO_LIN(pData->old_ss_sp) = oldFrame->bp;
1156 pData->stacktop = top;
1157 pData->stackmin = ptr;
1158 pData->stackbottom = ptr;
1160 /* Switch to the new stack */
1162 /* Note: we need to take the 3 arguments into account; otherwise,
1163 * the stack will underflow upon return from this function.
1165 copySize = oldFrame->bp - OFFSETOF(pData->old_ss_sp);
1166 copySize += 3 * sizeof(WORD) + sizeof(STACK16FRAME);
1167 pTask->thdb->cur_stack = PTR_SEG_OFF_TO_SEGPTR( seg, ptr - copySize );
1168 newFrame = THREAD_STACK16( pTask->thdb );
1170 /* Copy the stack frame and the local variables to the new stack */
1172 memmove( newFrame, oldFrame, copySize );
1174 *(WORD *)PTR_SEG_OFF_TO_LIN( seg, ptr ) = 0; /* clear previous bp */
1178 /***********************************************************************
1179 * SwitchStackBack (KERNEL.109)
1181 void WINAPI SwitchStackBack( CONTEXT *context )
1184 STACK16FRAME *oldFrame, *newFrame;
1185 INSTANCEDATA *pData;
1187 if (!(pTask = (TDB *)GlobalLock16( GetCurrentTask() ))) return;
1188 if (!(pData = (INSTANCEDATA *)GlobalLock16(SELECTOROF(pTask->thdb->cur_stack))))
1190 if (!pData->old_ss_sp)
1192 WARN( task, "No previous SwitchStackTo\n" );
1195 TRACE(task, "restoring stack %04x:%04x\n",
1196 SELECTOROF(pData->old_ss_sp), OFFSETOF(pData->old_ss_sp) );
1198 oldFrame = THREAD_STACK16( pTask->thdb );
1200 /* Pop bp from the previous stack */
1202 BP_reg(context) = *(WORD *)PTR_SEG_TO_LIN(pData->old_ss_sp);
1203 pData->old_ss_sp += sizeof(WORD);
1205 /* Switch back to the old stack */
1207 pTask->thdb->cur_stack = pData->old_ss_sp - sizeof(STACK16FRAME);
1208 SS_reg(context) = SELECTOROF(pData->old_ss_sp);
1209 ESP_reg(context) = OFFSETOF(pData->old_ss_sp) - sizeof(DWORD); /*ret addr*/
1210 pData->old_ss_sp = 0;
1212 /* Build a stack frame for the return */
1214 newFrame = THREAD_STACK16( pTask->thdb );
1215 newFrame->frame32 = oldFrame->frame32;
1216 if (TRACE_ON(relay))
1218 newFrame->entry_ip = oldFrame->entry_ip;
1219 newFrame->entry_cs = oldFrame->entry_cs;
1224 /***********************************************************************
1225 * GetTaskQueueDS (KERNEL.118)
1227 void WINAPI GetTaskQueueDS( CONTEXT *context )
1229 DS_reg(context) = GlobalHandleToSel( GetTaskQueue(0) );
1233 /***********************************************************************
1234 * GetTaskQueueES (KERNEL.119)
1236 void WINAPI GetTaskQueueES( CONTEXT *context )
1238 ES_reg(context) = GlobalHandleToSel( GetTaskQueue(0) );
1242 /***********************************************************************
1243 * GetCurrentTask (KERNEL.36)
1245 HTASK16 WINAPI GetCurrentTask(void)
1247 return THREAD_InitDone? PROCESS_Current()->task : 0;
1250 DWORD WINAPI WIN16_GetCurrentTask(void)
1252 /* This is the version used by relay code; the first task is */
1253 /* returned in the high word of the result */
1254 return MAKELONG( GetCurrentTask(), hFirstTask );
1258 /***********************************************************************
1259 * GetCurrentPDB (KERNEL.37)
1261 HANDLE16 WINAPI GetCurrentPDB(void)
1265 if (!(pTask = (TDB *)GlobalLock16( GetCurrentTask() ))) return 0;
1270 /***********************************************************************
1271 * GetInstanceData (KERNEL.54)
1273 INT16 WINAPI GetInstanceData( HINSTANCE16 instance, WORD buffer, INT16 len )
1275 char *ptr = (char *)GlobalLock16( instance );
1276 if (!ptr || !len) return 0;
1277 if ((int)buffer + len >= 0x10000) len = 0x10000 - buffer;
1278 memcpy( (char *)GlobalLock16(CURRENT_DS) + buffer, ptr + buffer, len );
1283 /***********************************************************************
1284 * GetExeVersion (KERNEL.105)
1286 WORD WINAPI GetExeVersion(void)
1290 if (!(pTask = (TDB *)GlobalLock16( GetCurrentTask() ))) return 0;
1291 return pTask->version;
1295 /***********************************************************************
1296 * SetErrorMode16 (KERNEL.107)
1298 UINT16 WINAPI SetErrorMode16( UINT16 mode )
1303 if (!(pTask = (TDB *)GlobalLock16( GetCurrentTask() ))) return 0;
1304 oldMode = pTask->error_mode;
1305 pTask->error_mode = mode;
1306 pTask->thdb->process->error_mode = mode;
1311 /***********************************************************************
1312 * SetErrorMode32 (KERNEL32.486)
1314 UINT32 WINAPI SetErrorMode32( UINT32 mode )
1316 return SetErrorMode16( (UINT16)mode );
1320 /***********************************************************************
1321 * GetDOSEnvironment (KERNEL.131)
1323 SEGPTR WINAPI GetDOSEnvironment(void)
1327 if (!(pTask = (TDB *)GlobalLock16( GetCurrentTask() ))) return 0;
1328 return PTR_SEG_OFF_TO_SEGPTR( pTask->pdb.environment, 0 );
1332 /***********************************************************************
1333 * GetNumTasks (KERNEL.152)
1335 UINT16 WINAPI GetNumTasks(void)
1341 /***********************************************************************
1342 * GetTaskDS (KERNEL.155)
1344 * Note: this function apparently returns a DWORD with LOWORD == HIWORD.
1345 * I don't think we need to bother with this.
1347 HINSTANCE16 WINAPI GetTaskDS(void)
1351 if (!(pTask = (TDB *)GlobalLock16( GetCurrentTask() ))) return 0;
1352 return pTask->hInstance;
1356 /***********************************************************************
1357 * IsTask (KERNEL.320)
1359 BOOL16 WINAPI IsTask( HTASK16 hTask )
1363 if (!(pTask = (TDB *)GlobalLock16( hTask ))) return FALSE;
1364 if (GlobalSize16( hTask ) < sizeof(TDB)) return FALSE;
1365 return (pTask->magic == TDB_MAGIC);
1369 /***********************************************************************
1370 * SetTaskSignalProc (KERNEL.38)
1372 * Real 16-bit interface is provided by the THUNK_SetTaskSignalProc.
1374 FARPROC16 WINAPI SetTaskSignalProc( HTASK16 hTask, FARPROC16 proc )
1379 if (!hTask) hTask = GetCurrentTask();
1380 if (!(pTask = (TDB *)GlobalLock16( hTask ))) return NULL;
1381 oldProc = (FARPROC16)pTask->userhandler;
1382 pTask->userhandler = (USERSIGNALPROC)proc;
1387 /***********************************************************************
1388 * SetSigHandler (KERNEL.140)
1390 WORD WINAPI SetSigHandler( FARPROC16 newhandler, FARPROC16* oldhandler,
1391 UINT16 *oldmode, UINT16 newmode, UINT16 flag )
1393 FIXME(task,"(%p,%p,%p,%d,%d), unimplemented.\n",
1394 newhandler,oldhandler,oldmode,newmode,flag );
1396 if (flag != 1) return 0;
1397 if (!newmode) newhandler = NULL; /* Default handler */
1402 if (!(pTask = (TDB *)GlobalLock16( GetCurrentTask() ))) return 0;
1403 if (oldmode) *oldmode = pTask->signal_flags;
1404 pTask->signal_flags = newmode;
1405 if (oldhandler) *oldhandler = pTask->sighandler;
1406 pTask->sighandler = newhandler;
1412 /***********************************************************************
1413 * GlobalNotify (KERNEL.154)
1415 VOID WINAPI GlobalNotify( FARPROC16 proc )
1419 if (!(pTask = (TDB *)GlobalLock16( GetCurrentTask() ))) return;
1420 pTask->discardhandler = proc;
1424 /***********************************************************************
1425 * GetExePtr (KERNEL.133)
1427 static HMODULE16 GetExePtrHelper( HANDLE16 handle, HTASK16 *hTask )
1432 /* Check for module handle */
1434 if (!(ptr = GlobalLock16( handle ))) return 0;
1435 if (((NE_MODULE *)ptr)->magic == IMAGE_OS2_SIGNATURE) return handle;
1437 /* Search for this handle inside all tasks */
1439 *hTask = hFirstTask;
1442 TDB *pTask = (TDB *)GlobalLock16( *hTask );
1443 if ((*hTask == handle) ||
1444 (pTask->hInstance == handle) ||
1445 (pTask->hQueue == handle) ||
1446 (pTask->hPDB == handle)) return pTask->hModule;
1447 *hTask = pTask->hNext;
1450 /* Check the owner for module handle */
1452 owner = FarGetOwner( handle );
1453 if (!(ptr = GlobalLock16( owner ))) return 0;
1454 if (((NE_MODULE *)ptr)->magic == IMAGE_OS2_SIGNATURE) return owner;
1456 /* Search for the owner inside all tasks */
1458 *hTask = hFirstTask;
1461 TDB *pTask = (TDB *)GlobalLock16( *hTask );
1462 if ((*hTask == owner) ||
1463 (pTask->hInstance == owner) ||
1464 (pTask->hQueue == owner) ||
1465 (pTask->hPDB == owner)) return pTask->hModule;
1466 *hTask = pTask->hNext;
1472 HMODULE16 WINAPI GetExePtr( HANDLE16 handle )
1475 return GetExePtrHelper( handle, &dummy );
1478 void WINAPI WIN16_GetExePtr( CONTEXT *context )
1480 WORD *stack = PTR_SEG_OFF_TO_LIN(SS_reg(context), SP_reg(context));
1481 HANDLE16 handle = (HANDLE16)stack[2];
1485 hModule = GetExePtrHelper( handle, &hTask );
1487 AX_reg(context) = CX_reg(context) = hModule;
1488 if (hTask) ES_reg(context) = hTask;
1491 /***********************************************************************
1492 * TaskFirst (TOOLHELP.63)
1494 BOOL16 WINAPI TaskFirst( TASKENTRY *lpte )
1496 lpte->hNext = hFirstTask;
1497 return TaskNext( lpte );
1501 /***********************************************************************
1502 * TaskNext (TOOLHELP.64)
1504 BOOL16 WINAPI TaskNext( TASKENTRY *lpte )
1507 INSTANCEDATA *pInstData;
1509 TRACE(toolhelp, "(%p): task=%04x\n", lpte, lpte->hNext );
1510 if (!lpte->hNext) return FALSE;
1511 pTask = (TDB *)GlobalLock16( lpte->hNext );
1512 if (!pTask || pTask->magic != TDB_MAGIC) return FALSE;
1513 pInstData = (INSTANCEDATA *)PTR_SEG_OFF_TO_LIN( pTask->hInstance, 0 );
1514 lpte->hTask = lpte->hNext;
1515 lpte->hTaskParent = pTask->hParent;
1516 lpte->hInst = pTask->hInstance;
1517 lpte->hModule = pTask->hModule;
1518 lpte->wSS = SELECTOROF( pTask->thdb->cur_stack );
1519 lpte->wSP = OFFSETOF( pTask->thdb->cur_stack );
1520 lpte->wStackTop = pInstData->stacktop;
1521 lpte->wStackMinimum = pInstData->stackmin;
1522 lpte->wStackBottom = pInstData->stackbottom;
1523 lpte->wcEvents = pTask->nEvents;
1524 lpte->hQueue = pTask->hQueue;
1525 strncpy( lpte->szModule, pTask->module_name, 8 );
1526 lpte->szModule[8] = '\0';
1527 lpte->wPSPOffset = 0x100; /*??*/
1528 lpte->hNext = pTask->hNext;
1533 /***********************************************************************
1534 * TaskFindHandle (TOOLHELP.65)
1536 BOOL16 WINAPI TaskFindHandle( TASKENTRY *lpte, HTASK16 hTask )
1538 lpte->hNext = hTask;
1539 return TaskNext( lpte );
1543 /***********************************************************************
1544 * GetAppCompatFlags16 (KERNEL.354)
1546 DWORD WINAPI GetAppCompatFlags16( HTASK16 hTask )
1548 return GetAppCompatFlags32( hTask );
1552 /***********************************************************************
1553 * GetAppCompatFlags32 (USER32.206)
1555 DWORD WINAPI GetAppCompatFlags32( HTASK32 hTask )
1559 if (!hTask) hTask = GetCurrentTask();
1560 if (!(pTask=(TDB *)GlobalLock16( (HTASK16)hTask ))) return 0;
1561 if (GlobalSize16(hTask) < sizeof(TDB)) return 0;
1562 return pTask->compat_flags;