Clair.Event_Loop 구현 완료함. ㅋㅋ 현재 손적화 중

나르시 · 2025.11.26 17:46:06

최적화란.. 최씨 무인정권이 적화통일하는 거라는

우스게소리.. 웃기긴 하다.

소스코드는 다음과 같습니다.

.ads 파일은 c언어에 비유하자면 .h 같은 성격의 파일입니다.

외부에 노출되는 API죠.

변수 관련하여 한가지 최적화하고..

구글 제미니, MS 코파일럿에 소스코드 입력하여

조언 받아 인공 최적화하고 있습니다. ㅋㅋㅋ

최상의 결과물이 나오고 있습니다.

0 오버헤드라는 것이 특징입니다.

이벤트 추가 삭제에 O(1) 시간 소요됩니다.

해시맵이나 순서맵 등 맵을 사용하지 않았습니다.

링크드리스트 방식인데 링크가 Idle Source 객체 안에 들어 있습니다.

그 결과 idle 이벤트들을 줄줄히 실행 가능하고 삽입/삭제시 O(1) 시간이 걸립니다.

이론적으로 최상의 속도.

이러한 방식이 해시맵보다 빠릅니다. 해시맵도 이론적으로 O(1)이지만

메모리 소비, 리해싱, 해시 함수 때문에 방금 애기한 침입형 링크드리스트 방식보다는

상대적으로 느립니다.

그러면 등록한 이벤트를 어떻게 찾느냐? 그것은 kqueue 및 epoll이 알아서 해줍니다.

이벤트를 등록할 때 kqueue의 udata (사용자 데이터)에 Source 포인터를 넘깁니다. ㅎㅎ

source 레코드에 ident, event mask, callback, user_data 등이 들어 있지요.

그에 대핸 포인터를 kqueue의 udata로 넘긴거지요.

-- clair-event_loop.ads
-- Copyright (c) 2021-2025 Hodong Kim <hodong@nimfsoft.art>
--
-- Permission to use, copy, modify, and/or distribute this software for any
-- purpose with or without fee is hereby granted.
--
-- THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
-- WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
-- MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
-- ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
-- WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
-- ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
-- OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
--

with Clair.File;
with Interfaces.C;
with System;

package Clair.Event_Loop is
  use type Interfaces.C.int;

  -----------------------------------------------------------------------------
  -- [Time Definitions] 64-bit Milliseconds
  -----------------------------------------------------------------------------
  type Milliseconds is new Interfaces.C.long_long;

  INFINITE  : constant Milliseconds := -1;
  IMMEDIATE : constant Milliseconds :=  0;

  -----------------------------------------------------------------------------
  -- [Handle & Context] Opaque Types
  -----------------------------------------------------------------------------
  type Context is limited private;

  -- 사용자는 Handle이 무엇인지(포인터인지 정수인지) 모릅니다.
  type Handle is private;
  NULL_HANDLE : constant Handle;

  -----------------------------------------------------------------------------
  -- [Callbacks] Type Safety
  -----------------------------------------------------------------------------
  -- 1. I/O 감시용
  type Event_Mask is new Interfaces.C.unsigned;

  EVENT_INPUT   : constant Event_Mask := 16#001#; -- same as EPOLLIN
  EVENT_OUTPUT  : constant Event_Mask := 16#004#; -- same as EPOLLOUT
  EVENT_ERROR   : constant Event_Mask := 16#008#; -- same as EPOLLERR
  EVENT_HANG_UP : constant Event_Mask := 16#010#; -- same as EPOLLHUP

  -- 1. I/O 감시용
  type IO_Callback is access procedure (
    fd        : Clair.File.Descriptor;
    events    : Event_Mask;
    user_data : System.Address
  ) with convention => c;

  -- 2. 타이머용 (자신의 핸들을 받아 삭제 가능)
  type Timer_Callback is access procedure (
    timer     : Handle;
    user_data : System.Address
  ) with convention => c;

  -- 아이들 전용 콜백
  type Idle_Callback is access procedure (
    idle      : Handle;
    user_data : System.Address
  ) with convention => c;

  -- 시그널 콜백
  -- signum: 발생한 시그널 번호 (예: SIGINT=2, SIGTERM=15)
  type Signal_Callback is access procedure (
    signum    : Interfaces.C.int;
    user_data : System.Address
  ) with convention => c;
  -----------------------------------------------------------------------------
  -- [Public API]
  -----------------------------------------------------------------------------
  function  create return Context;
  procedure destroy (self : in out Context);

  procedure run  (self : in out Context);
  procedure stop (self : in out Context);

  -- 루프의 한 사이클을 실행
  -- 이벤트를 확인하고, 준비된 이벤트가 있다면 콜백을 실행한 뒤 복귀합니다.
  -- timeout: 밀리초 단위. 음수면 무한 대기.
  procedure iterate (self    : in out Context;
                     timeout : Milliseconds := INFINITE);


  function add_watch (
    self      : in out Context;
    fd        : Clair.File.Descriptor;
    events    : Event_Mask;
    callback  : IO_Callback;
    user_data : System.Address := System.NULL_ADDRESS
  ) return Handle;

  function add_timer (
    self      : in out Context;
    interval  : Milliseconds;
    callback  : Timer_Callback;
    user_data : System.Address := System.NULL_ADDRESS;
    one_shot  : Boolean := False
  ) return Handle;

  -- Idle 추가: 루프가 돌 때마다 실행됩니다.
  function add_idle (
    self      : in out Context;
    callback  : Idle_Callback;
    user_data : System.Address := System.NULL_ADDRESS
  ) return Handle;

  procedure remove (
    self   : in out Context;
    target : Handle
  );

  procedure modify_watch (
    self   : in out Context;
    watch  : Handle;
    events : Event_Mask
  );


  function add_unix_signal (
    self      : in out Context;
    signum    : Interfaces.C.int;
    callback  : Signal_Callback;
    user_data : System.Address := System.NULL_ADDRESS
  ) return Handle;

private

  -----------------------------------------------------------------------------
  -- [Internal Data Structures] Pointer + RefCount + Variant Record
  -----------------------------------------------------------------------------
  -- 1. 리소스의 종류를 식별하는 열거형
  type Source_Kind is (KIND_WATCH, KIND_TIMER, KIND_IDLE, KIND_SIGNAL);
  type Source; -- Forward declaration
  type Source_Access is access all Source;
  pragma convention (c, Source_Access);

  type Handle is new Source_Access;
  NULL_HANDLE : constant Handle := null;

  -- 2. 가변 레코드 (variant record)
  -- kind(판별자)에 따라 구조가 변합니다.
  type Source (kind : Source_Kind := KIND_WATCH) is record
    -- [공통 필드] 모든 종류가 공유하는 데이터
    ref_count : Integer := 1;     -- 참조 카운트 (0이 되면 free)
    is_closed : Boolean := False; -- 논리적 삭제 여부 (zombie check)
    user_data : System.Address;
    -- [가변 필드] Kind에 따라 달라지는 데이터
    case kind is
      when KIND_WATCH =>
        fd     : Clair.File.Descriptor; -- 파일 디스크립터
        events : Event_Mask;            -- 감시 중인 이벤트 마스크
        io_cb  : IO_Callback;           -- I/O 전용 콜백

      when KIND_TIMER =>
        timer_cb : Timer_Callback;     -- 타이머 전용 콜백
        -----------------------------------------------------------------------
        -- [Platform-Specific Identifier] 플랫폼별 타이머 식별자
        -----------------------------------------------------------------------
        -- 이 필드는 운영체제 커널이 타이머를 구별하고 제어(삭제)하기 위해
        -- 요구하는 고유 값을 저장합니다. OS 구현 방식에 따라 용도가 다릅니다.
        --
        -- 1. Linux (epoll + timerfd):
        --    'timerfd_create'가 반환한 **파일 디스크립터(FD)**를 반드시 저장해야 합니다.
        --    (삭제 시 close(Ident) 호출 필요)
        --
        -- 2. BSD (kqueue):
        --    'kevent' 구조체의 **'ident'** 필드 값을 저장하는 용도입니다.
        --
        --    [구현 노트 - 최적화]
        --    구현 전략에 따라, 별도의 ID를 발급하지 않고 **Source 객체의 메모리 주소(Handle)**
        --    그 자체를 정수로 변환하여 kqueue의 ident로 사용할 수 있습니다.
        --    이 경우, **본 필드(Ident)는 사용되지 않거나(Unused)**,
        --    주소값을 중복 저장하는 용도로 사용될 수 있습니다.
        --
        -- * 타입 선정: 64비트 포인터 주소값 저장을 보장하기 위해 unsigned_long_long 사용.
        -----------------------------------------------------------------------
        ident : Interfaces.C.unsigned_long_long;

      when KIND_IDLE =>
        idle_cb   : Idle_Callback;      -- 아이들 전용 콜백
        idle_next : Handle;
        idle_prev : Handle; -- 삭제 편의를 위해 이중 연결 리스트 추천

      when KIND_SIGNAL =>
        sig_num : Interfaces.C.int;     -- 시그널 번호
        sig_cb  : Signal_Callback;      -- 콜백
        -- [Linux 호환성]
        -- kqueue는 필요 없지만, epoll은 signalfd로 만든 FD를 저장해야 삭제(close) 가능
        sig_fd  : Clair.File.Descriptor := Clair.File.INVALID_DESCRIPTOR; -- -1
    end case;
  end record;


  type Timespec is record
    tv_sec  : Interfaces.C.long;
    tv_nsec : Interfaces.C.long;
  end record;
  pragma convention (c, Timespec);

  type Context is limited record
    fd              : Clair.File.Descriptor;
    is_running      : Boolean  := False;
    -- 캐싱된 타임아웃 (비교용, 64비트 정수)
    cached_timeout  : Milliseconds := INFINITE;
    cached_timespec : Timespec     := (others => 0);
    -- idle 관리
    call_depth      : Natural := 0;
    idle_head       : Handle  := NULL_HANDLE; -- 리스트의 시작
    idle_tail       : Handle  := NULL_HANDLE; -- 리스트의 끝 (빠른 추가용)
    idle_count      : Natural := 0;
  end record;

end Clair.Event_Loop;

번호	제목	글쓴이	작성일	조회	추천
설문	뛰어난 운동 신경으로 남자와 싸워도 이길 것 같은 여자 스타는?	운영자	25/11/24	-	-
이슈	[디시人터뷰] 충무로가 주목하는 신예, '세계의 주인' 서수빈	운영자	25/11/24	-	-
AD	따뜻한 겨울나기! 방한용품 SALE	운영자	25/11/27	-	-
2905102	@.@	재현	16:51	22	0
2905101	오드로이드 중간평가 [5]	에이도비	16:18	87	1
2905100	[연구주제] 저출산의 배경	1급시크릿공문(121.172)	16:04	17	0
2905099	나님 끙야즁❤+	♥냥덩이의우웅한하룽♥	16:01	38	0
2905097	[대한민국] 저출산과 저출생과 출생아 단어 차이 [1]	1급시크릿공문(121.172)	15:53	21	0
2905095	냥덩이 발도잡 감성지능 0인듯	ㅇㅇ(182.231)	15:08	29	2
2905094	❤✨☀⭐⚡☘⛩☃나님 시작합니당☃⛩☘⚡⭐☀✨❤	♥냥덩이의우웅한하룽♥	14:53	30	0
2905093	부동산 아저씨가 집 보러 안 오시네요. [1]	넥도리아(220.74)	14:43	25	0
2905091	식빵이랑 커피 샀어	넥도리아(223.38)	14:22	26	0
2905090	[한국전파진흥협회] 2026년 상반기 클라우드 아키텍처 전문가 양성과정 [1]	프갤러(14.32)	13:54	41	0
2905089	미국영어보단 영국영어발음이 쉽고 멋지지않냐? [5]	헬마스터	13:28	67	0
2905088	나님 왤케 특별하실깡? [1]	♥냥덩이의우웅한하룽♥	13:15	50	0
2905082	12개 핫딜 사이트 북마크해놨던 과거의 나 ㅂㅅ	프갤러(117.111)	11:58	60	0
2905081	이재명이 잘하고있긴함	타이밍뒷.통수한방(1.213)	11:46	49	1
2905080	[대한민국] 차이나인에 대한 답글	1급시크릿공문(121.172)	11:42	20	0
2905079	❤✨☀⭐⚡☘⛩☃나님 시작합니당☃⛩☘⚡⭐☀✨❤	♥냥덩이의우웅한하룽♥	11:02	39	0
2905078	[대한민국] FBI 부정선거 조사 착수와 메인 뉴스에 나오는 법조인들	1급시크릿공문(121.172)	10:57	31	0
2905077	이태원모욕죄로 벌금 100만원이면 싸게쳤다 vs 억울하다 [8]	ㅇㅇ(203.232)	10:38	59	0
2905076	회사에 다른오퍼를 빌미로 연봉협상 시도하는거 [13]	프갤러(112.219)	10:22	79	0
2905075	33세 남성 벌레인생 나같은 성욕부시레기도 결혼 가능하려나	ㅇㅇ(203.232)	10:08	67	0
2905073	이재명 대통령님 전자정부프레임워크를 러스트 기반으로 이전해주십 [4]	프갤러(110.8)	09:47	59	0
2905072	[대한민국] 이재명 때문에- [1]	1급시크릿공문(121.172)	09:22	42	1
2905070	개발자 새끼들이 씹덕 애니 프사 하는 이유는? [2]	ㅇㅇ(211.235)	09:07	52	0
2905069	졸라 피곤하네..ㅇㅅㅇ	헤르 미온느	08:52	26	0
2905067	오늘은 에러처리 패키지 구조를 잡아야겠어요 [2]	나르시	08:47	23	0
2905066	산책로 다리 ㅇㅅㅇ [2]	헤르 미온느	08:42	30	0
2905065	태연 ㅇㅅㅇ	헤르 미온느	08:39	25	0
2905064	하루 한 번 헤르미온느 찬양	헤르 미온느	08:38	41	0
2905063	찬반논란인데 너희 생각은?	ㅇㅇ(203.232)	08:28	48	0
2905061	❤✨☀⭐⚡☘⛩☃나님 시작합니당☃⛩☘⚡⭐☀✨❤	♥냥덩이의우웅한하룽♥	07:03	65	0
2905060	이재명이 잘 하고 잇다는 증거.jpg [4]	야옹아저씨	06:52	72	1
2905058	죽은 인터넷 이론	발명도둑잡기(118.216)	04:54	35	0
2905057	음기 충전	발명도둑잡기(118.216)	04:31	64	0
2905056	북한학자 조희승의 가야사- 임나는 한반도가 아닌 일본 서부지역에	발명도둑잡기(118.216)	04:00	20	0
2905053	영화 <프랑스> 인기래서 생각나는 예전 글	발명도둑잡기(118.216)	03:40	26	0
2905047	내가 예술계 새 트렌드 알려준다	발명도둑잡기(118.216)	03:22	40	0
2905042	지금 분위기가	프갤러(49.165)	03:07	59	0
2905041	Le Solitaire. Theo Mercier	발명도둑잡기(118.216)	02:56	25	0
2905040	DB는 조인을 안하는게 걍 최선인듯 [2]	프갤러(58.29)	02:53	65	0
2905038	책사풍후의 게임 엔진 개발 일지_프로젝트 삼국사기	책사풍후	02:46	47	0
2905036	씨발국가 완전 중국 다 되었네 이딴 병신같은걸로 전과 ㅋㅋㅋㅋ	ㅇㅇ(39.7)	02:30	89	0
2905034	ai는 코드를 낳고	ㅇㅇ	02:18	41	1
2905033	노력한 보상을 갈취당하고 주식이란 도박에 몰두하는 시민들	발명도둑잡기(118.216)	02:12	30	0
2905027	위성 쏘는 이유가 나오는 영화 <에너미 오브 더스테이츠> [1]	발명도둑잡기(118.216)	01:59	47	0
2905025	국내에 외국계 기업 특 ) 짱깨랑 양키랑 좇본 인도 대기업들 몰렸는데	타이밍뒷.통수한방(1.213)	01:54	42	0
2905023	윤도현-타잔	발명도둑잡기(118.216)	01:47	28	0
2905022	위성 싸서 좋은점은 짱깨들밖에없잖누 ㅋㅋㅋㅋㅋ	타이밍뒷.통수한방(1.213)	01:41	33	0
2905021	위성 쏘는 이유 중 하나가 야당 감시다	발명도둑잡기(118.216)	01:33	31	0
2905017	내일 또 클리앙새끼를 누리호 ㅇㅈㄹ하면서 난리치겠누 [1]	타이밍뒷.통수한방(1.213)	01:23	48	0
2905015	냥덩이 잡아다가 누리호에 묶어서 쏴올렸다는데?	발명도둑잡기(118.216)	01:17	34	0

최근 방문

즐겨찾기

즐겨찾기 갤러리

이미지 올리기 이용안내

갤러리 이슈박스, 최근방문 갤러리

연관 갤러리

개념글 리스트

차단하기

[프로그래밍 갤러리]

갤러리 본문 영역

추천 비추천

댓글 영역

① NFT 발행

② NFT 구매

파워링크 광고

하단 갤러리 리스트 영역

왼쪽 컨텐츠 영역

갤러리 리스트 영역

페이지 이동

오른쪽 컨텐츠 영역

알림 설정

알림

디시콘 리스트

디시콘

디시콘 검색결과(0)

인기 디시콘