AI한테 일시키니까.. 이렇게 코드도 작성해 줌. ㅋㅋ
with System;
package Clair.IO.Poller is
-- ----------------------------------------------------------------------
-- 타입 정의
-- ----------------------------------------------------------------------
-- Poller 인스턴스를 나타내는 불투명 타입입니다.
-- Limited Private으로 선언하여 할당 및 복사를 제한합니다.
type Context is limited private;
-- 감시할 이벤트의 종류를 정의합니다.
type Event_Condition is (Input, Output, Error, Hang_Up);
-- 여러 이벤트를 동시에 지정하기 위한 배열 타입입니다.
type Event_Flags is array (Event_Condition) of Boolean;
pragma pack (Event_Flags);
-- ----------------------------------------------------------------------
-- Poller API
-- ----------------------------------------------------------------------
-- [create]
-- 새로운 Poller 인스턴스를 생성하고 초기화합니다.
-- 반환값: 초기화된 Poller Context
function create return Context;
-- [destroy]
-- 사용이 완료된 Poller 인스턴스를 파기하고 리소스를 해제합니다.
-- self: 파기할 Context
procedure destroy (self : in out Context);
-- [add]
-- 감시할 파일 디스크립터(fd)와 이벤트를 Poller에 등록합니다.
-- self: Poller Context
-- fd : 감시 대상 파일 디스크립터
-- events: 감시할 이벤트 목록
procedure add (self : in out Context;
fd : Clair.File.Descriptor;
events : Event_Flags);
-- [modify]
-- 이미 등록된 파일 디스크립터의 감시 이벤트를 변경합니다.
-- self: Poller Context
-- fd : 대상 파일 디스크립터
-- events: 변경할 새로운 이벤트 목록
procedure modify (self : in out Context;
fd : Clair.File.Descriptor;
events : Event_Flags);
-- [delete]
-- 특정 파일 디스크립터를 감시 목록에서 제거합니다.
-- self: Poller Context
-- fd : 제거할 파일 디스크립터
procedure delete (self : in out Context;
fd : Clair.File.Descriptor);
-- [wait]
-- 등록된 이벤트가 발생할 때까지 대기합니다.
-- self : Poller Context
-- timeout_ms : 대기 시간 (밀리초). -1인 경우 무한 대기.
-- Count : 발생한 이벤트의 수 (output)
procedure wait (self : in out Context;
results : out Result_Array; -- [핵심] 커널이 여기에 씀
count : out Natural;
timeout_ms : Integer);
private
-- 내부 구현 상세 (운영체제 의존적 데이터 저장)
-- 예시를 위해 간단한 레코드로 정의하며, 실제 구현부는 Body에 작성됩니다.
type Context is record
Handle : System.Address := System.NULL_ADDRESS;
end record;
end Clair.IO.Poller;
내부 구현은 kqueue 및 epoll 겸용으로 할 건데,
Result_Array는 kevent, epoll_event을 추상화한 타입이지.
그런데 wait에서 results가 있는데 그게 루프 돌면서 kevent를 복사해와야하는 것임.
성능 저하가 발생됨.
그래서 gg치고...
API는 똑같게할 것임.
예전에 설계한 Clair.Event_Loop라고 있는데,
Clair.IO.Poller를 제거하고,
Clair.Event_Loop를 kqueue, epoll로 구현할 것임.
API는 다음과 같음.
with Clair.File;
with Clair.IO;
package Clair.Event_Loop is
type Context is limited private;
type Context_Access is access all Context;
type Watch_Condition is (Input_Ready, Output_Ready, Error_Occurred);
type Handle_Id is new Interfaces.C.int;
Invalid_Handle : constant Handle_Id := -1;
type Event_Callback is access procedure (
fd : Clair.File.Descriptor;
events : Clair.IO.Event_Mask;
user_data : System.Address
) with convention => c;
procedure run (self : in out Context);
procedure stop (self : in out Context);
-- 루프의 한 사이클(Step)을 실행
-- 이벤트를 확인하고, 준비된 이벤트가 있다면 콜백을 실행한 뒤 복귀합니다.
-- Timeout: 대기 시간 (초). 0.0이면 즉시 리턴(Polling).
procedure iterate (self : Context);
-- io_wait -- polling
function add_watch (
self : in out Context;
fd : Clair.File.Descriptor;
events : Clair.IO.Event_Mask;
callback : Event_Callback;
user_data : System.Address := System.NULL_ADDRESS
) return Handle_Id;
procedure remove_watch (
self : in out Context;
id : Handle_Id
);
procedure modify_watch (
self : in out Context;
fd : Clair.File.Descriptor;
events : Clair.IO.Event_Mask
);
private
type Context is limited record
is_running : Boolean := False;
end record;
end Clair.Event_Loop;
외부에 kqueue, epoll 관련한 것들을 노출하지 않지.
원래는 Clair.IO.Poller에서 kqueue, epoll을 래핑 후,
Clair.Event_Loop를 Clair.IO.Poller로 구현하려 했는데
오버헤드가 미세하게 추가되기 때문에,
오버헤드 0으로 만들기 위해,
Clair.IO.Poller 추상화 API를 제거하고
Clair.Event_Loop를 kqueue, epoll로 직접 구현하기로 함.
ㅋㅋㅋ
이거 때문에 설레어 잠을 못 이루는 중 ㅎㅎ
미쳤어 정말~~
댓글 영역
획득법
① NFT 발행
작성한 게시물을 NFT로 발행하면 일주일 동안 사용할 수 있습니다. (최초 1회)
② NFT 구매
다른 이용자의 NFT를 구매하면 한 달 동안 사용할 수 있습니다. (구매 시마다 갱신)
사용법
디시콘에서지갑연결시 바로 사용 가능합니다.