add function sf_socket_close

fstore_storage_engine
YuQing 2023-05-10 20:29:14 +08:00
parent 7c6673f78a
commit 32706b6275
2 changed files with 16 additions and 0 deletions

View File

@ -400,6 +400,19 @@ int sf_socket_server_ex(SFContext *sf_context)
return 0; return 0;
} }
void sf_socket_close_ex(SFContext *sf_context)
{
if (sf_context->inner_sock >= 0) {
close(sf_context->inner_sock);
sf_context->inner_sock = -1;
}
if (sf_context->outer_sock >= 0) {
close(sf_context->outer_sock);
sf_context->outer_sock = -1;
}
}
static void accept_run(struct accept_thread_context *accept_context) static void accept_run(struct accept_thread_context *accept_context)
{ {
int incomesock; int incomesock;

View File

@ -86,6 +86,9 @@ void sf_set_current_time();
int sf_socket_server_ex(SFContext *sf_context); int sf_socket_server_ex(SFContext *sf_context);
#define sf_socket_server() sf_socket_server_ex(&g_sf_context) #define sf_socket_server() sf_socket_server_ex(&g_sf_context)
void sf_socket_close_ex(SFContext *sf_context);
#define sf_socket_close() sf_socket_close_ex(&g_sf_context)
void sf_accept_loop_ex(SFContext *sf_context, const bool block); void sf_accept_loop_ex(SFContext *sf_context, const bool block);
#define sf_accept_loop() sf_accept_loop_ex(&g_sf_context, true) #define sf_accept_loop() sf_accept_loop_ex(&g_sf_context, true)