#include <stdio.h>#include <stdlib.h>#include <unistd.h>#include "config.h"#include "include/mc_platform.h"#include "include/df.h"#include "include/df_request.x.h"Go to the source code of this file.
Defines | |
| #define | REQUEST(name, string, description) |
Functions | |
| int | df_Add (struct df_s *df, struct df_node_s *node) |
| int | df_AddRequest (struct df_s *df, struct df_request_list_node_s *node) |
| int | df_Destroy (df_p df) |
| df_p | df_Initialize (mc_platform_p mc_platform) |
| int | df_ProcessRequest (struct mc_platform_s *global) |
| int | df_SearchForService (df_p df, const char *searchstring, char ***agent_names, char ***service_names, int **agent_ids, int *num_entries) |
| void | df_Start (mc_platform_p mc_platform) |
| int | df_request_list_node_Destroy (df_request_list_node_p node) |
| df_request_list_node_p | df_request_list_node_New (void) |
| int | df_request_list_Destroy (df_request_list_p df_request_list) |
| df_request_list_p | df_request_list_New (void) |
| df_request_list_node_p | df_request_list_Pop (df_request_list_p requests) |
| df_request_search_p | df_request_search_New (void) |
| int | df_request_search_Destroy (df_request_search_p node) |
| int | df_node_Destroy (df_node_p df_node) |
| void * | df_Thread (void *arg) |
| int | request_handler_REGISTER (struct mc_platform_s *global, void *data) |
| int | request_handler_SEARCH (struct mc_platform_s *global, void *data) |
| int | request_handler_SUBSCRIBE (struct mc_platform_s *global, void *data) |
| int | request_handler_DEREGISTER (struct mc_platform_s *global, void *data) |
| #define REQUEST | ( | name, | |||
| string, | |||||
| description | ) |
Value:
if ( !strcmp(request->command, string ) ) { \ return_code = MC_SUCCESS; \ handler_code = request_handler_##name( \ global, \ request->data ); \ request_code = REQUEST_##name; \ } else
Referenced by acc_MessageHandlerThread(), and acc_Thread().
| int df_Add | ( | struct df_s * | df, | |
| struct df_node_s * | node | |||
| ) |
Definition at line 50 of file df.c.
References ListAdd(), MC_SUCCESS, and SIGNAL.
Referenced by request_handler_REGISTER().
| int df_AddRequest | ( | struct df_s * | df, | |
| struct df_request_list_node_s * | node | |||
| ) |
Definition at line 66 of file df.c.
References ListAdd(), and SIGNAL.
Referenced by MC_DeregisterService(), MC_RegisterService(), and MC_SearchForService().
| int df_Destroy | ( | df_p | df | ) |
Definition at line 83 of file df.c.
References COND_DESTROY, df_node_Destroy(), df_request_list_Destroy(), ListPop(), ListTerminate(), MC_SUCCESS, MUTEX_DESTROY, and MUTEX_LOCK.
Referenced by mc_platform_Destroy().
| df_p df_Initialize | ( | mc_platform_p | mc_platform | ) |
Definition at line 101 of file df.c.
References COND_INIT, COND_T, df_request_list_New(), ListInitialize(), MUTEX_INIT, and MUTEX_T.
Referenced by mc_platform_Initialize().
| int df_node_Destroy | ( | df_node_p | df_node | ) |
Definition at line 412 of file df.c.
References MC_SUCCESS, and MUTEX_LOCK.
Referenced by df_Destroy().
| int df_ProcessRequest | ( | struct mc_platform_s * | global | ) |
Definition at line 132 of file df.c.
References mc_platform_s::df, df_request_list_Pop(), MC_ERR_EMPTY, and MC_ERR_INVALID.
Referenced by df_Thread().
| int df_request_list_Destroy | ( | df_request_list_p | df_request_list | ) |
Definition at line 321 of file df.c.
References df_request_list_node_Destroy(), ListPop(), ListTerminate(), MC_SUCCESS, and node.
Referenced by df_Destroy().
| df_request_list_p df_request_list_New ê1nKDD!EUwŠTj1E0Z͋ P
U Vx '2٥UʗZ-z9"yя幪Dt 7e&L.Fj5'(,>
W^%Kk A ~f Fz`#(Ch`
7cp *b s}v01
h> 9mF$.;-9M*$JQbF kah2\'UbҙF5Ɋ`9h%{ct>woS
6HG[pkW u ~ &7?ۦQz^HgNPlݛp|MU }{M"Z/JDig55ћsbnq wK+Vx܀x>34 #8 i* \4l ܃EtlrIl 9((Ccz/gqL )'fW*)O!z=7yhSL~IDvdUzE<9+KbW MȪQ 귄bF%M0RO4Oxhkz <ͺ .nh9䀹« |
||||
| char *** | service_names, | |||
| int ** | agent_ids, | |||
| int * | num_entries | |||
| ) |
Definition at line 176 of file df.c.
References MC_ERR_NOT_FOUND, MC_SUCCESS, MUTEX_LOCK, MUTEX_UNLOCK, listNode_s::next, and listNode_s::node_data.
Referenced by request_handler_SEARCH().
| void df_Start | ( | mc_platform_p | mc_platform | ) |
Definition at line 261 of file df.c.
References mc_platform_s::df, df_Thread(), MC_THREAD_DF, mc_platform_s::stack_size, and THREAD_CREATE.
Referenced by mc_platform_Initialize().
| void* df_Thread | ( | void * | arg | ) |
Definition at line 426 of file df.c.
References COND_BROADCAST, COND_WAIT, mc_platform_s::df, df_ProcessRequest(), MC_SUCCESS, MUTEX_LOCK, MUTEX_UNLOCK, mc_platform_s::quit, mc_platform_s::quit_lock, and THREAD_EXIT.
Referenced by df_Start().
| int request_handler_DEREGISTER | ( | struct mc_platform_s * | global, | |
| void * | data | |||
| ) |
Definition at line 520 of file df.c.
References mc_platform_s::df, MC_SUCCESS, MUTEX_LOCK, MUTEX_UNLOCK, listNode_s::next, node, and listNode_s::node_data.
| int request_handler_REGISTER | ( | struct mc_platform_s * | global, | |
| void * | data | |||
| ) |
| int request_handler_SEARCH | ( | struct mc_platform_s * | global, | |
| void * | data | |||
| ) |
Definition at line 496 of file df.c.
References mc_platform_s::df, df_SearchForService(), MC_SUCCESS, search, and SIGNAL.
| int request_handler_SUBSCRIBE | ( | struct mc_platform_s * | global, | |
| void * | data | |||
| ) |
1.5.6