/home/mesh/mesh/include/mesh_comm.h
Go to the documentation of this file.
00001 /************************************************************************* 00002 This file is part of MESH. 00003 00004 MESH is free software: you can redistribute it and/or modify 00005 it under the terms of the GNU General Public License as published by 00006 the Free Software Foundation, either version 3 of the License, or 00007 (at your option) any later version. 00008 00009 MESH is distributed in the hope that it will be useful, 00010 but WITHOUT ANY WARRANTY; without even the implied warranty of 00011 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 00012 GNU General Public License for more details. 00013 00014 You should have received a copy of the GNU General Public License 00015 along with MESH. If not, see <http://www.gnu.org/licenses/>. 00016 **************************************************************************/ 00021 #ifndef MESH_COMM_H 00022 #define MESH_COMM_H 00023 00024 //define states of shared data 00025 #define SD_INACTIVE 0 00026 #define SD_SHARED 1 00027 #define SD_EXCLUSIVE 2 00028 #define SD_EXCLUSIVE_REQ 3 00029 #define SD_EXCLUSIVE_RDY 4 00030 00031 //define blocking modes 00032 #define NO_BLOCKING 0 00033 #define BLOCK_THREAD 1 00034 #define BLOCK_RESOURCE 2 00035 00036 //define read or write access 00037 #define READ_ACCESS 0 00038 #define WRITE_ACCESS 1 00039 00052 void mesh_comm_write(gchar *comm_thread, 00053 void* arg, 00054 mesh_shared_data *msd, 00055 gint blocking_mode); 00056 00063 void mesh_comm_write_delayed(gchar *comm_thread, 00064 void* arg, 00065 mesh_shared_data *msd, 00066 gint blocking_mode); 00067 00079 void mesh_comm_read(gchar *comm_thread, 00080 void* arg, 00081 mesh_shared_data *msd, 00082 gint blocking_mode); 00083 00089 void mesh_comm_read_delayed(gchar *comm_thread, 00090 void* arg, 00091 mesh_shared_data *msd, 00092 gint blocking_mode); 00093 00105 void mesh_create_comm_thread(gchar *name, 00106 mesh_scheduler *cs, 00107 void*(*thread)(void*)); 00108 00109 mesh_scheduler* mesh_create_comm_scheduler(gchar *name); 00110 00111 //sets exclusive access to a shared data in order to perform a write 00112 void mesh_shared_set_write(mesh_shared_data *msd); 00113 00114 //releases exclusive ownership of a variable after a write 00115 void mesh_shared_end_write(mesh_shared_data *msd); 00116 00117 //sets shared data state when read is performed 00118 void mesh_shared_set_read(mesh_shared_data *msd); 00119 00120 //ends the read state of a shared piece of data 00121 void mesh_shared_end_read(mesh_shared_data *msd); 00122 00123 //creates a mesh_shared_data structure and initializes all the 00124 //neccessary synchronization variables 00125 mesh_shared_data* 00126 mesh_create_shared_data(void *data); 00127 00128 //finds the appropriate comm comm_thread, creates a comm untimed thread, 00129 //and blocks if necessary 00130 void 00131 mesh_comm_read_write_helper(mesh_thread *calling_thread, 00132 gchar *comm_thread, 00133 mesh_comm_thread_data *mctd, 00134 gchar *thread_name, 00135 gboolean blocking); 00136 #endif
