forked from tboox/tbox
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
5 changed files
with
178 additions
and
14 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,162 @@ | ||
| /* ////////////////////////////////////////////////////////////////////////////////////// | ||
| * includes | ||
| */ | ||
| #include "../demo.h" | ||
|
|
||
| /* ////////////////////////////////////////////////////////////////////////////////////// | ||
| * macros | ||
| */ | ||
|
|
||
| // port | ||
| #define TB_DEMO_PORT (9090) | ||
|
|
||
| /* ////////////////////////////////////////////////////////////////////////////////////// | ||
| * types | ||
| */ | ||
|
|
||
| // the client type | ||
| typedef struct __tb_demo_client_t | ||
| { | ||
| // the pipe file | ||
| tb_pipe_file_ref_t pipe; | ||
|
|
||
| // the read size | ||
| tb_hize_t size; | ||
|
|
||
| // the read data | ||
| tb_byte_t data[8192]; | ||
|
|
||
| // wait event | ||
| tb_bool_t wait; | ||
|
|
||
| }tb_demo_client_t, *tb_demo_client_ref_t; | ||
|
|
||
| /* ////////////////////////////////////////////////////////////////////////////////////// | ||
| * implementation | ||
| */ | ||
| static tb_void_t tb_demo_session_exit(tb_demo_client_ref_t client, tb_poller_ref_t poller) | ||
| { | ||
| if (client) | ||
| { | ||
| // trace | ||
| tb_trace_d("[%p]: read %llu", client->pipe, client->size); | ||
|
|
||
| // remove pipe from poller | ||
| // tb_poller_remove(poller, client->pipe); | ||
|
|
||
| // exit pipe file | ||
| if (client->pipe) tb_pipe_file_exit(client->pipe); | ||
| client->pipe = tb_null; | ||
|
|
||
| // exit client | ||
| tb_free(client); | ||
| } | ||
| } | ||
| static tb_long_t tb_demo_session_read(tb_demo_client_ref_t client) | ||
| { | ||
| while (1) | ||
| { | ||
| tb_long_t real = tb_pipe_file_read(client->pipe, client->data, sizeof(client->data)); | ||
| if (real > 0) | ||
| { | ||
| client->size += real; | ||
| client->wait = tb_false; | ||
| } | ||
| else if (!real && !client->wait) | ||
| { | ||
| client->wait = tb_true; | ||
| break; | ||
| } | ||
| else return -1; | ||
| } | ||
| return 0; | ||
| } | ||
| static tb_int_t tb_demo_session_writ(tb_cpointer_t priv) | ||
| { | ||
| tb_pipe_file_ref_t pipe = (tb_pipe_file_ref_t)priv; | ||
| tb_byte_t data[8192 * 16]; | ||
| tb_size_t count = 100; | ||
| tb_usleep(50000); | ||
| while (count--) | ||
| { | ||
| tb_trace_d("[%p]: write %llu", pipe, sizeof(data)); | ||
| if (!tb_pipe_file_bwrit(pipe, data, sizeof(data))) break; | ||
| } | ||
| return 0; | ||
| } | ||
| static tb_void_t tb_demo_session_start(tb_poller_ref_t poller, tb_pipe_file_ref_t pipe) | ||
| { | ||
| // trace | ||
| tb_trace_d("[%p]: recving ..", pipe); | ||
|
|
||
| // init client | ||
| tb_demo_client_ref_t client = tb_malloc0_type(tb_demo_client_t); | ||
| if (client) | ||
| { | ||
| client->pipe = pipe; | ||
| client->wait = tb_false; | ||
| if (!tb_demo_session_read(client)) | ||
| { | ||
| tb_size_t events = TB_POLLER_EVENT_RECV; | ||
| if (tb_poller_support(poller, TB_POLLER_EVENT_CLEAR)) | ||
| events |= TB_POLLER_EVENT_CLEAR; | ||
| //tb_poller_insert(poller, pipe, events, client); | ||
| } | ||
| else tb_demo_session_exit(client, poller); | ||
| } | ||
| } | ||
| static tb_void_t tb_demo_poller_open(tb_poller_ref_t poller) | ||
| { | ||
| tb_pipe_file_ref_t pair[2]; | ||
| if (tb_pipe_file_init_pair(pair, 4096)) | ||
| { | ||
| tb_demo_session_start(poller, pair[0]); | ||
| tb_thread_init(tb_null, tb_demo_session_writ, pair[1], 0); | ||
| } | ||
| } | ||
| static tb_void_t tb_demo_poller_event(tb_poller_ref_t poller, tb_socket_ref_t pipe, tb_size_t events, tb_cpointer_t priv) | ||
| { | ||
| switch (events) | ||
| { | ||
| case TB_POLLER_EVENT_RECV | TB_POLLER_EVENT_EOF: | ||
| case TB_POLLER_EVENT_RECV: | ||
| { | ||
| tb_demo_client_ref_t client = (tb_demo_client_ref_t)priv; | ||
| if (tb_demo_session_read(client) || (events & TB_POLLER_EVENT_EOF)) | ||
| tb_demo_session_exit(client, poller); | ||
| } | ||
| break; | ||
| default: | ||
| break; | ||
| } | ||
| } | ||
|
|
||
| /* ////////////////////////////////////////////////////////////////////////////////////// | ||
| * main | ||
| */ | ||
| tb_int_t tb_demo_platform_poller_pipe_main(tb_int_t argc, tb_char_t** argv) | ||
| { | ||
| // start file client | ||
| tb_poller_ref_t poller = tb_null; | ||
| do | ||
| { | ||
| // init poller | ||
| poller = tb_poller_init(tb_null); | ||
| tb_assert_and_check_break(poller); | ||
|
|
||
| // attach poller to the current thread | ||
| tb_poller_attach(poller); | ||
|
|
||
| // attempt to open clients | ||
| tb_demo_poller_open(poller); | ||
|
|
||
| // wait events | ||
| while (tb_poller_wait(poller, tb_demo_poller_event, -1) > 0) ; | ||
|
|
||
| } while (0); | ||
|
|
||
| // exit poller | ||
| if (poller) tb_poller_exit(poller); | ||
| poller = tb_null; | ||
| return 0; | ||
| } |