OK. I tried the following and it seems to work, Can someone comment on
whether this is bets practice.
uv_ip4_addr("127.0.0.1", PORT, &addr);
uv_tcp_init(uv_default_loop(), &lg_server);
uv_tcp_bind(&lg_server, (const struct sockaddr*) &addr, 0);
uv_listen((uv_stream_t*)&lg_server, 512, lg_connect);
uv_run(uv_default_loop(), UV_RUN_DEFAULT);
uv_close((uv_handle_t*) &lg_server, 0);
uv_run(uv_default_loop(), UV_RUN_DEFAULT);
uv_loop_close(uv_default_loop());
John
On Sunday, 18 May 2014 07:47:37 UTC-5, John Preston wrote:
>
> OK. So after the uv_run() I call
>
> uv_close((uv_handle_t*) &lg_server, 0);
>
> Now when I check with netstat the socket is closed. Thanks. One down.
> However this code is inside a .so library which does not get unloaded after
> the shutdown. Now when it gets called again to startup I get the following
> when the uv_run() is called again
>
> java: src/unix/core.c:178: uv__finish_close: Assertion `handle->flags &
> UV_CLOSING' failed.
>
> I suspect the default loop needs to be re initialised but when I tried to
> uv_delete_loop(uv_default_loop()) after shutting down the server I got the
> following:
>
> java: src/unix/loop.c:93: uv_loop_delete: Assertion `uv_loop_close(loop)
> == 0' failed.
>
> Both these cases caused other problems with the .so library code so some
> other memory is being touched.
>
> Any thoughts
>
> John
>
> On Sunday, 18 May 2014 06:26:41 UTC-5, Saúl Ibarra Corretgé wrote:
>>
>> -----BEGIN PGP SIGNED MESSAGE-----
>> Hash: SHA1
>>
>> On 05/18/2014 05:24 AM, John Preston wrote:
>> > I have a tcp server that I'm running in a separate thread to
>> > receive log messages and process them.
>> >
>> > /* server */ uv_ip4_addr("127.0.0.1", PORT, &addr);
>> >
>> > uv_tcp_init(uv_default_loop(), &lg_server);
>> >
>> > uv_tcp_bind(&lg_server, (const struct sockaddr*) &addr, 0);
>> >
>> > uv_listen((uv_stream_t*)&lg_server, 512, lg_connect);
>> >
>> > uv_run(uv_default_loop(), UV_RUN_DEFAULT);
>> >
>> >
>> > /*****/ void lg_connect(uv_stream_t* server, int status) { if
>> > (status == -1) { return; }
>> >
>> > uv_tcp_t *client = (uv_tcp_t*)malloc(sizeof(uv_tcp_t));
>> > uv_tcp_init(uv_default_loop(), client);
>> >
>> > if (uv_accept(server, (uv_stream_t*)client) == 0) {
>> > uv_read_start((uv_stream_t*)client, lg_alloc, lg_read); } else {
>> > uv_close((uv_handle_t*)client, lg_close); } }
>> >
>> >
>> > void lg_read(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf)
>> > { int msg_loop; struct MESSAGES *msg_buffer;
>> >
>> > if (nread != -1) { if (nread > 0) { msg_buffer = (struct MESSAGES
>> > *)buf->base;
>> >
>> > msg_loop = _process_message(msg_buffer);
>> >
>> > // If it was a shutdown message then close the queue if
>> > (msg_buffer->id == SHUTDOWN_MESSAGE) { uv_close((uv_handle_t*)tcp,
>> > lg_close); // stop run loop uv_stop(uv_default_loop()); } } } else
>> > { uv_close((uv_handle_t*)tcp, lg_close); }
>> >
>> > free(buf->base); }
>> >
>> > It seems to work ok but when I send a shutdown message, it is
>> > received inside the read callback and calls uv_close and uv_stop,
>> > the default loop is stoped and the code proceeds beyond the uv_run
>> > function. However if I run netstat -tln I still see the socket and
>> > port active. Does uv_close not close the socket.
>> >
>>
>> Yes, uv_close does close the socket. I had a quick look and I don't
>> see where you are closing the server, so that socket will remain open,
>> even if the loop is stopped.
>>
>>
>> Cheers,
>>
>> - --
>> Saúl Ibarra Corretgé
>> bettercallsaghul.com
>>
>> -----BEGIN PGP SIGNATURE-----
>> Version: GnuPG v1
>> Comment: Using GnuPG with Icedove - http://www.enigmail.net/
>>
>> iQIcBAEBAgAGBQJTeJjxAAoJEEEOVVOum8BZnM0P/2+Fzqn/WU9Nm7S0JnGJzYv1
>> 2ipm+z/cItQy0cfPn+0rF0NdlGAJfPOlJzSvqEohGrRegRXTukUI5rhF7o2INwr2
>> MXr5+UDQaYP7Ea9E/D9+wZMXccccgrKSIwHciGsrpw2G1DxFn8FrNinnWyTb5N+V
>> 2dVaSDolrUsXtzapZvyOzk2NaaD8kk6iXGKHUEWIq7jT5NOAbQIm63F9SivOkMMR
>> j4BeZMOx53aL+RdkiJn/8gLUqmyhd46FOVYkxLnj8X60k7VPJw4sttG6HA4oejWH
>> ebUFb2nNbRAztPUX11qsZtABk6TO4oxV6HpzOYjQ9gi83k/awEOLCglPMSW+NdJ8
>> brYfyrB71htlMSswsZKOmQoTgbKPedzeI77LpwqQe0RM2e0cE06MCtLu8qldccHe
>> o44Bof77YhwAqhHJQotb5o0nQtsceGvbmnu3l8TphVeKGZvJYjlvM1FyMdmMCWiS
>> wymJpG2wuokmqF2BaxyNN0Sw+etjEeLgjtFl8NWf4CYD1Tg3mf1+MRgZMP4QObIy
>> m/BRLqNCNSGUNfqOPRYg5NRKZDfetMTx3Q79MVF5x7Cw55C7uzgVqsI6j6LrDdWz
>> hInUjrCxEgSjsUuhMGlhpQZsFcSpNA23zo4bpC6jrIWh3jZh9aQLJePgRyYXyR8+
>> 6pBzBqB8rYTG8WOJ3DkH
>> =AvJj
>> -----END PGP SIGNATURE-----
>>
>
--
You received this message because you are subscribed to the Google Groups
"libuv" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/libuv.
For more options, visit https://groups.google.com/d/optout.
