WebSVN – Kolibri OS – Diff – /kernel/trunk/gui/event.inc

-struc EVENT
-{  .code    rd 1
-            rd 5
-   .next    rd 1   ;+24
-   .prev    rd 1   ;+28
-}
-EVENT_SIZE  equ 32
-virtual at 0
-  EVENT EVENT
-end virtual
 align 4
-align 4
+init_events:
-init_events:
+           stdcall kernel_alloc, 512*EVENT_SIZE
-           stdcall kernel_alloc, 1024*EVENT_SIZE
+           mov [events], eax
-           mov [events], eax
+           xor eax, eax
+           mov [event_uid], eax
-           xor eax, eax
+           not eax
-           not eax
+           mov edi, event_map
-           mov edi, event_map
+           mov [event_start], edi
-           mov [event_start], edi
+           mov ecx, 64/4
-           mov ecx, 128/4
+           cld
-           cld
+           rep stosd
-           rep stosd
+           mov [event_end], edi
-           mov [event_end], edi
+           ret
-           xor eax,eax
+           ret
-           ret
+.found:
-.found:
+           btr [ebx], eax
-           btr [ebx], eax
+           mov [event_start],ebx
-           mov [event_start],ebx
+           inc [event_uid]
+           sub ebx, event_map
-           sub ebx, event_map
+           lea eax,[eax+ebx*8]
            lea eax,[eax+ebx*8]
+           lea ebx, [eax+eax*4]
+           shl eax,5
-           shl eax,5
+           lea eax,[eax+ebx*4]   ;eax*=52 (EVENT_SIZE)
+           add eax, [events]
-           add eax, [events]
+           mov ebx, [event_uid]
+           popfd
-           popfd
+           ret
-           xor ebx, ebx
-           mov [eax+EVENT.next], ebx
-           mov [eax+EVENT.prev], ebx
-           ret
+endp
 endp
 align 4
-align 4
+free_event:
-free_event:
-           pushfd
-           cli
+           sub eax, [events]
-           sub eax, [events]
+           mov ecx, EVENT_SIZE
-           shr eax, 5
+           mov ebx, event_map
+           cdq
+           div ecx
+           pushfd
+           cli
-           mov ebx, event_map
+           bts [ebx], eax
-           bts [ebx], eax
+           shr eax, 3
-           shr eax, 3
+           and eax, not 3
-           and eax, not 3
+           add eax, ebx
-           add eax, ebx
+           cmp [event_start], eax
-@@:
+           mov [event_start], eax
-           mov [event_start], eax
+           popfd
-           popfd
+           ret
            ret
+EVENT_WATCHED    equ 0x10000000
+EVENT_SIGNALED   equ 0x20000000
+MANUAL_RESET     equ 0x40000000
+MANUAL_DESTROY   equ 0x80000000
+; param
+;  eax= event data
+;  ebx= flags
+;
+; retval
+;  eax= event
+;  edx= id
+create_event:
+           .flags  equ  esp+4
+           .data   equ  esp
+           push ebx
+           push eax
+           call alloc_event
+           test eax, eax
+           jz .fail
+           mov [eax+APPOBJ.magic], 'EVNT'
+           mov [eax+APPOBJ.destroy], destroy_event
+           mov [eax+EVENT.id], ebx
+           mov ebx, [CURRENT_TASK]
+           shl ebx, 5
+           mov ebx, [0x3000+ebx+4]
+           mov [eax+APPOBJ.pid], ebx
+           mov edx, [.flags]
+           mov [eax+EVENT.state], edx
+           mov esi, [.data]
+           test esi, esi
+           jz @F
+           lea edi, [eax+EVENT.code]
+           mov ecx, 6
+           cld
+           rep movsd
+@@:
+           mov ecx, [CURRENT_TASK]
+           shl ecx,8
+           add ecx, PROC_BASE+APP_OBJ_OFFSET
+           pushfd
+           cli
+           mov edx, [ecx+APPOBJ.fd]
+           mov [eax+APPOBJ.fd], edx
+           mov [eax+APPOBJ.bk], ecx
+           mov [ecx+APPOBJ.fd], eax
+           mov [edx+APPOBJ.bk], eax
+           popfd
+           mov edx, [eax+EVENT.id]
+.fail:
+           add esp, 8
+           ret
+restore .flags
+restore .data
+; param
+;  eax= event
+;  ebx= id
+destroy_event:
+           cmp [eax+APPOBJ.magic], 'EVNT'
+           jne .fail
+           cmp [eax+EVENT.id], ebx
+           jne .fail
+           mov ebx, [eax+APPOBJ.fd]
+           mov ecx, [eax+APPOBJ.bk]
+           mov [ebx+APPOBJ.bk], ecx
+           mov [ecx+APPOBJ.fd], ebx
+.internal:
+           xor edx, edx             ;clear common header
+           mov [eax], edx
+           mov [eax+4], edx
+           mov [eax+8], edx
+           mov [eax+12], edx
+           mov [eax+16], edx
+           call free_event          ;release object memory
+.fail:
+           ret
 align 4
-align 4
+proc send_event stdcall pid:dword, event:dword
-proc send_event stdcall pid:dword, event:dword
+           locals
-           locals
+             slot     dd ?
-             slot     dd ?
+           endl
-           shl eax, 8
+           cmp [PROC_BASE+eax+APPDATA.ev_count], 32
-           cmp [PROC_BASE+eax+APPDATA.ev_count], 32
+           ja .fail
            ja .fail
            mov [slot], eax
-           mov [slot], eax
+           call alloc_event
-           call alloc_event
+           test eax, eax
-           test eax, eax
+           jz .fail
-           jz .fail
            lea edi, [eax+EVENT.code]
-           mov edi, eax
+           mov ecx, 6
-           mov ecx, 6
+           mov esi, [event]
-           mov esi, [event]
+           cld
-           cld
+           rep movsd
-           rep movsd
+           mov ecx, [slot]
+           add ecx, PROC_BASE+APP_EV_OFFSET
-           mov esi, eax
-           mov eax, [slot]
+           mov [eax+APPOBJ.magic], 'EVNT'
-           mov edi, [PROC_BASE+eax+APPDATA.ev_last]
+           mov [eax+APPOBJ.destroy], destroy_event
-           mov [esi+EVENT.prev], edi
+           mov ebx, [pid]
+           mov [eax+APPOBJ.pid], ebx
-           test edi, edi
+           mov [eax+EVENT.state], EVENT_SIGNALED
-           jz .set_last
+           pushfd
-           mov [edi+EVENT.next], esi
+           cli                         ;insert event into
-.set_last:
+           mov edx, [ecx+APPOBJ.fd]    ;events list
-           mov edx, [PROC_BASE+eax+APPDATA.ev_first]
+           mov [eax+APPOBJ.fd], edx    ;and set events flag
-           test edx, edx
-           jnz @F
+           mov [eax+APPOBJ.bk], ecx
-           mov [PROC_BASE+eax+APPDATA.ev_first], esi
+           mov [ecx+APPOBJ.fd], eax
-@@:
+           mov [edx+APPOBJ.bk], eax
+           inc [ecx+APPDATA.ev_count-APP_EV_OFFSET]
-           mov [PROC_BASE+eax+APPDATA.ev_last], esi
+           or  [ecx+APPDATA.event_mask-APP_EV_OFFSET], EVENT_EXTENDED
-           inc [PROC_BASE+eax+APPDATA.ev_count]
+           popfd
-           or  [PROC_BASE+eax+APPDATA.event_mask], EVENT_EXTENDED
+.fail:
+           ret
+endp
 .fail:
-           ret
+; timeout ignored
 endp
+align 4
-align 4
+proc get_event_ex stdcall, p_ev:dword, timeout:dword
-proc get_event_ex stdcall, p_ev:dword, timeout:dword
 .wait:
-.wait:
+           mov edx,[CURRENT_TASK]
+           shl edx,8
-           mov ebx,[CURRENT_TASK]
+           cmp [PROC_BASE+edx+APPDATA.ev_count], 0
-           shl ebx,8
-           cmp [PROC_BASE+ebx+APPDATA.ev_count], 0
+           je .switch
-           je .switch
-           mov esi, [PROC_BASE+ebx+APPDATA.ev_first]
-           mov edx, [esi+EVENT.next]
-           mov [PROC_BASE+ebx+APPDATA.ev_first], edx
-           test edx, edx
-           jz @F
-           mov [edx+EVENT.prev], 0
-@@:
-           jnz @F
+           add edx, PROC_BASE+APP_EV_OFFSET
-           mov [PROC_BASE+ebx+APPDATA.ev_last], edx
-           and dword [PROC_BASE+ebx+APPDATA.event_mask], not EVENT_EXTENDED
+           mov eax, [edx+EVENT.fd]
-@@:
+           cmp eax, edx
-           dec [PROC_BASE+ebx+APPDATA.ev_count]
+           je .switch
+           lea esi, [eax+EVENT.code]
+           mov edi, [p_ev]                ;copy event data
+           mov ecx, 6
+           cld
+           rep movsd
+           and dword [edi-24], 0xFF00FFFF ;clear priority field
+                                          ;
+           test [eax+EVENT.state], MANUAL_RESET
+           jnz .done
+           pushfd
+           cli                         ;remove event from events
+           mov ebx, [eax+APPOBJ.fd]    ;list (reset event)
+           mov ecx, [eax+APPOBJ.bk]    ;and clear events flag
+           mov [ebx+APPOBJ.bk], ecx    ;if no active events
+           mov [ecx+APPOBJ.fd], ebx
+           dec [edx+APPDATA.ev_count-APP_EV_OFFSET]
+           jnz @F
+           and [edx+APPDATA.event_mask-APP_EV_OFFSET], not EVENT_EXTENDED
+           popfd
+           test [eax+EVENT.state], MANUAL_DESTROY
+           jz .destroy
+           add edx, (APP_OBJ_OFFSET-APP_EV_OFFSET)
+           pushfd
+           cli
+           mov edx, [ecx+APPOBJ.fd]  ;insert event into
+           mov [eax+APPOBJ.fd], edx  ;objects list
+           mov [eax+APPOBJ.bk], ecx
+           mov [ecx+APPOBJ.fd], eax
+           mov [edx+APPOBJ.bk], eax
-           mov eax, esi
+           popfd
-           and dword [esi], 0xFF00FFFF
+.done:
-           mov edi, [p_ev]
+           ret
            mov ecx, 6
-           cld
+.destroy:
-           rep movsd
+           call destroy_event.internal
-           call free_event
+           ret
+.switch:
+           mov eax, [0x3010]
+           mov [eax+TASKDATA.state], byte 5
+	   call change_task
+	   jmp .wait
+endp
+; param
+;  eax= event
+;  ebx= id
+align 4
+wait_event:
+           .event equ esp
+           push eax
+.wait:
+           cmp [eax+APPOBJ.magic], 'EVNT'
+           jne .done
+           cmp [eax+EVENT.id], ebx
+           jne .done
+           test [eax+EVENT.state], EVENT_SIGNALED
+           jz .switch
+           test [eax+EVENT.state], MANUAL_RESET
+           jnz .done
+           mov edx,[CURRENT_TASK]
+           shl edx,8
+           add edx, PROC_BASE
+           pushfd
+           cli                         ;remove event from events
+           mov ebx, [eax+APPOBJ.fd]    ;list (reset event)
+           mov ecx, [eax+APPOBJ.bk]    ;and clear events flag
+           mov [ebx+APPOBJ.bk], ecx    ;if no active events
+           mov [ecx+APPOBJ.fd], ebx
+           dec [edx+APPDATA.ev_count]
+           jnz @F
+           and [edx+APPDATA.event_mask], not EVENT_EXTENDED
+@@:
+           and [eax+EVENT.state], not (EVENT_SIGNALED+EVENT_WATCHED)
+           popfd
+           test [eax+EVENT.state], MANUAL_DESTROY
+           jz .destroy
+           add edx, APP_OBJ_OFFSET
+           pushfd
+           cli
+           mov ecx, [edx+APPOBJ.fd]  ;insert event into
+           mov [eax+APPOBJ.fd], ecx  ;objects list
+           mov [eax+APPOBJ.bk], edx
+           mov [edx+APPOBJ.fd], eax
+           mov [ecx+APPOBJ.bk], eax
+           popfd
+.done:
+           add esp, 4
+           ret
+.destroy:
+           call destroy_event.internal
+           add esp, 4
+           ret
+.switch:
+           or [eax+EVENT.state], EVENT_WATCHED
+           mov eax, [0x3010]
+           mov [eax+TASKDATA.state], byte 5
+	   call change_task
+           mov eax, [.event]
+	   jmp .wait
+restore .event
+; param
+;  eax= event
+;  ebx= id
+;  ecx= flags
+raise_event:
+           .event equ esp
+           push eax
+           cmp [eax+APPOBJ.magic], 'EVNT'
+           jne .fail
+           cmp [eax+EVENT.id], ebx
+           jne .fail
+           mov eax, [eax+APPOBJ.pid]
+           call pid_to_slot
+           test eax, eax
+           jz .fail
+           mov edx, [.event]
+           test [edx+EVENT.state], EVENT_SIGNALED
+           jnz .done
+           test ecx, EVENT_WATCHED
+           jz @F
+           test [edx+EVENT.state], EVENT_WATCHED
+           jz .done
+@@:
+           shl eax, 8
+           add eax, PROC_BASE+APP_EV_OFFSET
+           pushfd
+           cli
+           mov ebx, [edx+APPOBJ.fd]
+           mov ecx, [edx+APPOBJ.bk]
+           mov [ebx+APPOBJ.bk], ecx
+           mov [ecx+APPOBJ.fd], ebx
+           mov ecx, [eax+APPOBJ.fd]
+           mov [edx+APPOBJ.fd], ecx
+           mov [edx+APPOBJ.bk], eax
+           mov [eax+APPOBJ.fd], edx
+           mov [ecx+APPOBJ.bk], edx
+           or [edx+EVENT.state], EVENT_SIGNALED
+           inc [eax+APPDATA.ev_count-APP_EV_OFFSET]
+           or  [eax+APPDATA.event_mask-APP_EV_OFFSET], EVENT_EXTENDED
-           ret
+           popfd
-.switch:
+.fail:
-           mov eax, [0x3010]
+.done:
-           mov [eax+TASKDATA.state], byte 5
+           add esp, 4
-     mov   eax,8
+     ret
-     ret
+   no_stack_event:
    no_stack_event:
      test  byte [edi+TASKDATA.event_mask+1], 1		; DEBUG
-     test  byte [edi+TASKDATA.event_mask+1], 1		; DEBUG
+     jz    .test_IRQ
-     jz    .test_ext
+     mov   eax, [0x3000]
-     mov   eax, [0x3000]
+     shl   eax, 8
-     shl   eax, 8
+     test  byte [eax+0x80000+APPDATA.event_mask+1], byte 1
-     test  byte [eax+0x80000+APPDATA.event_mask+1], byte 1
+     jz    .test_IRQ
-     jz    .test_ext
+     and   byte [eax+0x80000+APPDATA.event_mask+1], not 1
-     and   byte [eax+0x80000+APPDATA.event_mask+1], not 1
+     popad
-     popad
+     mov   eax, 9
-     mov   eax, 9
+     ret
-     ret
+;.test_ext:
-.test_ext:
+;     mov   eax, [0x3000]
-     mov   eax, [0x3000]
+;     shl   eax, 8
-     shl   eax, 8
+;     test  dword [eax+0x80000+APPDATA.event_mask], EVENT_EXTENDED
+;     jz .test_IRQ
-     test  dword [eax+0x80000+APPDATA.event_mask], EVENT_EXTENDED
+;     popad
-     jz .test_IRQ
+;     mov eax, 10
-     mov eax, 10
+;     ret
-     ret
 .test_IRQ:
 .test_IRQ:
      cmp   dword [edi+TASKDATA.event_mask], 0xFFFF
-     cmp   dword [edi+TASKDATA.event_mask], 0xFFFF
+     jbe   no_events

Subversion Repositories Kolibri OS

(root)/kernel/trunk/gui/event.inc – Rev 254 → 354