Libevent R4: Working with events - Revision history

Pchero: /* Creating an event as its own callback argument */

2018-01-11T10:52:23Z

Creating an event as its own callback argument

← Older revision		Revision as of 10:52, 11 January 2018
Line 109:		Line 109:
	* Interface		* Interface
	<source lang=c>		<source lang=c>
	void *~~event_self_arg~~();		void *event_self_cbarg();
	</source>		</source>

Pchero at 14:45, 30 January 2015

2015-01-30T14:45:03Z

Show changes

Pchero at 10:25, 30 January 2015

2015-01-30T10:25:06Z

← Older revision		Revision as of 10:25, 30 January 2015
Line 269:		Line 269:
	Here’s the same example as above, but instead of relying on the size of struct event from event_struct.h, we use event_get_struct_size() to use the correct size at runtime.		Here’s the same example as above, but instead of relying on the size of struct event from event_struct.h, we use event_get_struct_size() to use the correct size at runtime.

			* Example
			<source lang=c>
			#include <event2/event.h>
			#include <stdlib.h>

			/* When we allocate an event_pair in memory, we'll actually allocate
			* more space at the end of the structure. We define some macros
			* to make accessing those events less error-prone. */
			struct event_pair {
			evutil_socket_t fd;
			};

			/* Macro: yield the struct event 'offset' bytes from the start of 'p' */
			#define EVENT_AT_OFFSET(p, offset) \
			((struct event) (((char)(p)) + (offset))
			/* Macro: yield the read event of an event_pair */
			#define READEV_PTR(pair) \
			EVENT_AT_OFFSET((pair), sizeof(struct event_pair))
			/* Macro: yield the write event of an event_pair */
			#define WRITEEV_PTR(pair) \
			EVENT_AT_OFFSET((pair), sizeof(struct event_pair) + event_get_struct_event_size())
			/* Macro: yield the actual size to allocate for an event_pair */
			#define EVENT_PAIR_SIZE() \
			(sizeof(struct event_pair) + 2 * event_get_struct_event_size())

			void readcb(evutil_socket_t, short, void *);
			void writecb(evutil_socket_t, short, void *);
			struct event_pair event_pair_new(struct event_base base, evutil_socket_t fd)
			{
			struct event_pair *p = malloc(EVENT_PAIR_SIZE());
			if (!p) return NULL;
			p->fd = fd;
			event_assign(READEV_PTR(p), base, fd, EV_READ\|EV_PERSIST, readcb, p);
			event_assign(WRITEEV_PTR(p), base, fd, EV_WRITE\|EV_PERSIST, writecb, p);

			return p;
			}
			</source>

			== Making events pending and non-pending ==
			한번 이벤트를 생성하면, 이벤트를 루프에 추가해서 pending 상태로 만들기 전까지는 아무것도 하지 않는다. 루프에 추가하기 위해서는 event_add() 를 사용한다.

			* Interface
			<source lang=c>
			int event_add(struct event ev, const struct timeval tv);
			</source>

			event_add() 를 호출하면 이벤트를 event_base 루프에 추가해서 pending 상태로 만들 수 있다. 성공시 0, 실패시 -1을 리턴한다. timeout 을 지정하고 싶지 않다면, tv를 NULL 로 입력하면 된다. timeout은 마이크로 초 단위까지 설정할 수 있다.

			만약 이미 pending 상태인 이벤으를 다시 event_add()로 추가한다면, pending 상태가 해제되고, 새로 설정된 timout 으로 다시 스케쥴링 된다. 만약 timeout 을 NULL 로 설정하여 재추가하게 되면, 아무런 일도 일어나지 않는다.

			* Note
			tv 변수에 timeout 목표 시간을 입력하면 안된다. 예를 들어 "tv->tv_sec = time(NULL)+10;"이라고 입력했다면 입력한 시간으로부터 10초 뒤가 아닌, 40년 뒤에 타이머가 작동될 것이다.

			* Interface
			<source lang=c>
			int event_remove_timer(struct event *ev);
			</source>
			드디어 타이머 이벤트를 삭제할 수 있는 함수가 나왔다. 만약 이벤트가 이벤트가 timeout pending 상태이며, IO 컴포넌트, 시그널 컴포넌트가 없는 상태일 때 사용가능하며, event_del() 함수와 같은 역할을 수행한다. 성공시 0, 실패시 -1을 리턴한다.

			== Events with priorities ==
			여러개의 이벤트들이 같이 trigger 되었을 때, Libevent는 어떤 콜백이 먼저 수행되어야 하는지 정해진 규칙이 없다. 하지만 중요한 콜백들이 실행 우선권을 가질 숭 씨도록 우선 순위를 지정할 수 있다.

			앞서 설명했듯이 event_base는 하나 이상의 우선순위를 설정할 수 있고, 초기화 직후, 이벤트를 추가하기 전에 설정 가능하다.

			* Interface
			<source lang =c>
			int event_priority_set(struct event *event, int priority);
			</source>
			이벤트에 부여 가능한 우선순위 번호는 0부터 event_base 에 설정한 우선순위 갯수 - 1 까지이다. 성공시 0, 실패시 -1을 리턴한다.

			여러개의 우선순위로 이루어진 이벤트들이 동작할때, 낮은 우선 순위를 가진 이벤트는 동작하지 않는다. 대신에, Libevent는 높은 우선 순위를 가진 이벤트를 실행시킨다. 그리고 다시 이벤트를 검색한다. active 상태인 높은 우선순위 이벤트가 없을때 낮은 우선순위의 이벤트를 실행시킨다.

			* Example
			<source lang=c>
			#include <event2/event.h>

			void read_cb(evutil_socket_t, short, void *);
			void write_cb(evutil_socket_t, short, void *);

			voie main_loop(evutil_socket_t fd)
			{
			struct event importatn, unimportant;
			struct event_base *base;

			base = event_base_new();
			event_base_priority_init(base, 2);

			/* Now base has priority 0, and priority 1 */
			important = event_new(base, fd, EV_WRITE\|EV_PERSIST, write_cb, NULL);
			unimportant = event_new(base, fd, EV_READ\|EV_PERSIST, read_cb, NULL);
			event_priority_set(important, 0);
			event_priority_set(unimportant, 1);

			/* Now, whenever the fd is ready for writing, the write callback will
			* happen before the read callback. The read callback won't happen at
			* all until the write callback is no longer active. */
			}
			</source>

			별도로 우선순위를 설정하지 않았다면, 기본값으로 event_base 에서 사용가능한 우선순위 갯수 / 2 가 된다.

			== Inspecting event status ==
			이벤트가 추가됐는지 혹은 이벤트가 어떤 상태인지 알고 싶을 때가 있다.

Pchero at 15:22, 29 January 2015

2015-01-29T15:22:31Z

Show changes

Pchero at 10:32, 29 January 2015

2015-01-29T10:32:17Z

@@ Line 1: / Line 1: @@
 == Overview ==
 원문은 이곳<ref>http://www.wangafu.net/~nickm/libevent-book/Ref4_event.html</ref>에서 확인할 수 있다.
 == References ==
 <references />
-[[category:Libevent]]
+[[category:libevent]]

Pchero: Created page with "== Overview == 원문은 이곳http://www.wangafu.net/~nickm/libevent-book/Ref4_event.html에서 확인할 수 있다. == References == category:..."

2015-01-29T09:55:59Z

Created page with "== Overview == 원문은 이곳<ref>http://www.wangafu.net/~nickm/libevent-book/Ref4_event.html</ref>에서 확인할 수 있다. == References == <references /> category:..."

New page

== Overview ==
원문은 이곳<ref>http://www.wangafu.net/~nickm/libevent-book/Ref4_event.html</ref>에서 확인할 수 있다.

== References ==
<references />

[[category:Libevent]]