##// END OF EJS Templates
ABS » abscontrol
RSS
imanay -
r45:46
parent child
Show More
Show file before | Show file after | Hide comments
@@ -0,0 +1,324
1 /*
2 * Servidor.c
3 *
4 * Created on: Nov 3, 2009
5 * Author: Jose Francisco Quenta
6 *
7 * Se implementa:
8 * -Carga en memoria los apuntes contenidos en un archivo de experimentos: apunte0 -> GPIO
9 * -Cambio de apunte.
10 * -Lectura del estado actual del apunte y grabado del mismo en un archivo
11 */
12
13 #include <stdio.h>
14 #include <stdlib.h>
15 #include <string.h>
16 #include <unistd.h>
17 #include <errno.h>
18
19 #include <sys/types.h>
20 #include <sys/socket.h>
21 #include <netinet/in.h>
22 #include <arpa/inet.h>
23 #include <netdb.h>
24
25 #include "./Librerias/AT91gpio_Funciones.h"
26 #include "./Librerias/Mensajes.h"
27
28 #define PUERTO_SERVIDOR 5500
29 #define TAM_BUFFER 100
30
31 #define maskc_out PC30+PC28+PC26+PC24+PC22+PC20 //MSB-UP-LSB MSB-DOWN-LSB //APUNTE
32
33 #define maskb_in PB16+PB18+PB20+PB30+PB24+PB22 //MSB-UP-LSB MSB-DOWN-LSB //VERIFICACION
34
35 #define bit_up_2 0x00010000 //Mascara de cada bit a revisar: bit_up_2 es MSB
36 #define bit_up_1 0x00040000
37 #define bit_up_0 0x00100000
38 #define bit_dow_2 0x40000000
39 #define bit_dow_1 0x01000000
40 #define bit_dow_0 0x00400000
41
42 #define MyID 11
43
44 char *buff_experimento= NULL;
45
46 AT91S_PIO *pioc;
47 AT91S_PIO *piob;
48
49 /*
50 * Zona de declaracion de cabeceras.
51 */
52 void inicializa_gpio();
53 int procesa_peticion(char *buff_peticion);
54 int cambia_apuntamiento(char *puntero_char);
55 int carga_experimento(char *nombre_archivo);
56 int chequeo_sistema(char *numero_muestras);
57
58 /*
59 *
60 */
61 int main(){
62
63 int conexion_servidorFd;
64 struct sockaddr_in inf_servidor;
65 struct sockaddr_storage inf_cliente;
66 int resultado;
67 int numbytes_recibidos;
68 int rpta;
69
70 char *buff_peticion = (char *) malloc(TAM_BUFFER);
71
72 size_t addr_len;
73
74 memset(&inf_servidor, 0, sizeof(inf_servidor));
75 inf_servidor.sin_family= AF_INET;
76 inf_servidor.sin_port= htons(PUERTO_SERVIDOR);
77 inf_servidor.sin_addr.s_addr= INADDR_ANY;
78
79 /* Se establece el socket */
80 conexion_servidorFd = socket(AF_INET,SOCK_DGRAM,0);
81 if (conexion_servidorFd == -1){
82 ERROR_FATAL("No se establecio correctamente el socket: socket()");
83 }
84
85 /* Se asocia el socket a un puerto y una IP */
86 resultado = bind(conexion_servidorFd,(struct sockaddr *)&inf_servidor,sizeof(inf_servidor));
87 if (resultado== -1){
88 ERROR_FATAL("No se establecio correctamente el socket: bind()");
89 }
90
91 /* Inicializamos el puerto GPIO del sistema embebido GSBC-9260S */
92 inicializa_gpio();
93
94 while(1){
95 LOG_SERVIDOR("Esperando solicitud de cliente...\n");
96
97 /* Se espera hasta que un cliente se conecte */
98 addr_len = sizeof(inf_cliente);
99 numbytes_recibidos = recvfrom(conexion_servidorFd, buff_peticion, TAM_BUFFER-1, 0, (struct sockaddr *)&inf_cliente, &addr_len);
100 if (numbytes_recibidos == -1){
101 ERROR_FATAL("Error en la recepcion de datos: recvfrom()");
102 }
103
104 /* Se procede a procesar los datos recibidos */
105 buff_peticion[numbytes_recibidos]= '\0';
106
107 /* procesamiento de la peticion */
108 rpta = procesa_peticion(buff_peticion);
109
110 //Respuesta del modulo de control
111 //
112
113
114 }
115 }
116
117
118
119 /*
120 * Esta funcion incializa el puerto GPIO
121 */
122 void inicializa_gpio(){
123
124 // Configuracion de los pines de APUNTE
125 pioc = pio_map(PIOC_BASE);
126 pio_enable(pioc, maskc_out);
127 pio_disable_irq(pioc, maskc_out);
128 pio_disable_multiple_driver(pioc, maskc_out);
129 pio_disable_pull_ups(pioc, maskc_out);
130 pio_synchronous_data_output(pioc, maskc_out);
131 pio_output_enable(pioc, maskc_out);
132
133 // Configuracion de los pines de VERIFICACION
134 piob = pio_map(PIOB_BASE);
135 pio_enable(piob, maskb_in);
136 pio_disable_irq(piob, maskb_in);
137 pio_disable_multiple_driver(piob, maskb_in);
138 pio_disable_pull_ups(piob, maskb_in);
139 pio_input_enable(piob, maskb_in);
140
141 }
142
143 /*
144 * Esta funcion procesa el mensaje de peticion y genera respuesta
145 */
146 int procesa_peticion(char *buff_peticion){
147 int rpta;
148 // char *header = strtok(buff_peticion, ":");
149 // char *ipSource = strtok(buff_peticion, ":");
150 // char *ipDestino = strtok(buff_peticion, ":");
151 char *comando = strtok(buff_peticion, ":");
152 char *valor = strtok(NULL, ":");
153
154 if ((comando == NULL) || (valor == NULL)){
155 ERROR("procesarPeticion: formato de mensaje incorrecto");
156 }
157 else{
158 if(strcmp(comando,"CARGA") == 0)
159 rpta = carga_experimento(valor);
160 else if(strcmp(comando,"CAMBIA") == 0)
161 rpta = cambia_apuntamiento(valor);
162 else if(strcmp(comando,"CHEQUEO") == 0)
163 rpta = chequeo_sistema(valor);
164 else
165 ERROR("procesa_peticion: comando no reconocido");
166 }
167
168 return rpta;
169 }
170
171
172 /*
173 * Esta funcion carga un archivo en un buffer que esta ubicado en memoria, luego
174 * este buffer es usado en la funcion "cambia_apuntamiento" para obtener el dato
175 * que sera usado en el cambio de apuntamiento.
176 */
177 int carga_experimento(char *nombre_archivo){
178
179 FILE *Archivo_Fd;
180
181 char *cadena = (char *) malloc(25);
182
183 int longitud_cadena;
184 int num_bytes= 0;
185 int num_filas= 0;
186
187 char ruta_archivo[50]; // Se crea la ruta para abrir el archivo
188 strcpy(ruta_archivo,"/mnt/sd/archivos/");
189 strcat(ruta_archivo,nombre_archivo);
190
191 Archivo_Fd = fopen(ruta_archivo,"r"); // Se procede a abrir el archivo, segun la ruta especificada
192 if(!Archivo_Fd){
193 ERROR("carga_archivo: No se pudo abrir el archivo!!! --> fopen()\n");
194 return -1;
195 }else{
196
197 while(!feof(Archivo_Fd)){ // Se procede a calcular la longitud del archivo para separar memoria
198 fgets(cadena,20,Archivo_Fd);
199 longitud_cadena= strlen(cadena);
200 cadena[longitud_cadena-1] = '\0';
201 num_bytes = num_bytes + longitud_cadena;
202 num_filas++;
203 }
204
205 rewind(Archivo_Fd); // Se reinicia el puntero del archivo
206
207 char *buffer_temporal = (char *) malloc(num_bytes+1); // Se separa espacio de memoria segun
208 // la longitud del archivo
209 fread(buffer_temporal, sizeof(char), num_bytes, Archivo_Fd);
210
211 char *puntero= strstr(buffer_temporal,".abs"); // Se procede a eliminar la cabecera del archivo
212 puntero= puntero + 12;
213
214 buff_experimento = (char *) malloc(7*(num_filas-3)); // num_bytes_fila*(num_filas-3);
215 strncpy(buff_experimento,puntero,7*(num_filas-3)); // Se carga en memoria la informacion del archivo
216
217 fclose(Archivo_Fd);
218
219 cambia_apuntamiento("0"); // Se apunta a la direccion 0
220
221 return 1;
222 }
223 }
224
225 /*
226 * Esta funcion recibe un numero en formato char, el dato se transforma a su equivalente en
227 * un numero entero, que sera usado para sacar un dato del buffer "buff_experimento", esta
228 * dato es el valor que se enviara al sistema de conmutacion RF para el cambio de apunte a
229 * traves del puerto GPIO.
230 */
231 int cambia_apuntamiento(char *puntero_char){
232
233 /*MSB-UP-LSB MSB-DOWN-LSB*/
234 int desplazamiento[6]={30,28,26,24,22,20}; // Defino los dezplazamientos que se aplicara
235 // al dato que ingresa para formar el número
236 // entero que se le pasara al puerto GPIO
237 // Estos números son los pines del puerto GPIO
238 // que se estan usando para el control
239
240 int puntero= atoi(puntero_char); // Se convierte a entero la direccion del puntero
241
242 int base= 7*puntero; // base= cantidad_bytes del dato x puntero
243 // cantidad de bytes es el numero de bytes que
244 printf("%i\n",puntero); // contiene cada dato, para este caso es 7
245 // porque es 6 bits de datos + 1 bit del cambio
246 // de linea.
247 char valor_char;
248 unsigned long valor;
249 unsigned long acumulado_ceros=0;
250 unsigned long acumulado_unos=0;
251
252 int offset; // Defino offset para el desplazamiento a traves
253 for(offset=0;offset<6;offset++){ // de cada dato que se obtiene del "buff_experimento"
254
255 valor_char= buff_experimento[base+offset]; // Obtengo el dato
256
257 if (valor_char == '0'){ // Obtengo el número acumulado segun sea un cero o un uno
258 valor= 0;
259 acumulado_ceros= acumulado_ceros + (1 << desplazamiento[offset]);
260 }else{
261 valor= 1;
262 acumulado_unos= acumulado_unos + (1 << desplazamiento[offset]);
263 }
264
265 }
266
267 pio_out(pioc, maskc_out, acumulado_unos, 1);
268 pio_out(pioc, maskc_out, acumulado_ceros, 0);
269
270 return 1;
271
272 }
273
274 /*
275 * Esta funcion lee "n" veces el estado del APUNTE actual y lo guarda en el
276 * archivo Verificacion.
277 */
278
279 int chequeo_sistema(char *numero_muestras){
280
281 char valor[7];
282 int i,cnt;
283 unsigned int entradac= 0;
284 FILE *fd;
285 fd=fopen("/mnt/sd/archivos/Verificacion","w");
286 fprintf(fd,"%s\n","Verificacion");
287 fprintf(fd,"%s\n","------------");
288 cnt=0;
289 do
290 {
291 //Inicializando arreglo
292 for(i=0;i<6;i++)
293 valor[i]='0';
294
295 valor[6]='\0';
296
297 //Lectura de puerto
298 entradac= pio_in(piob,maskb_in);
299
300 //Dandole formato al dato
301 if (!(entradac & bit_up_2))
302 valor[0] = '1';
303 if (!(entradac & bit_up_1))
304 valor[1] = '1';
305 if (!(entradac & bit_up_0))
306 valor[2] = '1';
307 if (!(entradac & bit_dow_2))
308 valor[3] = '1';
309 if (!(entradac & bit_dow_1))
310 valor[4] = '1';
311 if (!(entradac & bit_dow_0))
312 valor[5] = '1';
313
314 //Escribiendo en archivo
315 fprintf(fd,"%s\n",valor);
316 cnt=cnt+1;
317 usleep(1*1000*1000);
318
319 }while(cnt < atoi(numero_muestras));
320
321 fclose(fd);
322
323 return 1;
324 }
Show file before | Show file after | Hide comments
@@ -1,219 +1,224
1 1 <?xml version="1.0" encoding="UTF-8" standalone="no"?>
2 2 <?fileVersion 4.0.0?>
3 3
4 4 <cproject>
5 5 <storageModule moduleId="org.eclipse.cdt.core.settings">
6 6 <cconfiguration id="cdt.managedbuild.config.gnu.exe.release.1568263498">
7 7 <storageModule buildSystemId="org.eclipse.cdt.managedbuilder.core.configurationDataProvider" id="cdt.managedbuild.config.gnu.exe.release.1568263498" moduleId="org.eclipse.cdt.core.settings" name="Release">
8 8 <externalSettings/>
9 9 <extensions>
10 10 <extension id="org.eclipse.cdt.core.ELF" point="org.eclipse.cdt.core.BinaryParser"/>
11 11 <extension id="org.eclipse.cdt.core.MakeErrorParser" point="org.eclipse.cdt.core.ErrorParser"/>
12 12 <extension id="org.eclipse.cdt.core.GCCErrorParser" point="org.eclipse.cdt.core.ErrorParser"/>
13 13 <extension id="org.eclipse.cdt.core.GASErrorParser" point="org.eclipse.cdt.core.ErrorParser"/>
14 14 <extension id="org.eclipse.cdt.core.GLDErrorParser" point="org.eclipse.cdt.core.ErrorParser"/>
15 15 </extensions>
16 16 </storageModule>
17 17 <storageModule moduleId="cdtBuildSystem" version="4.0.0">
18 <configuration artifactName="Control_Module" buildArtefactType="org.eclipse.cdt.build.core.buildArtefactType.exe" buildProperties="org.eclipse.cdt.build.core.buildType=org.eclipse.cdt.build.core.buildType.release,org.eclipse.cdt.build.core.buildArtefactType=org.eclipse.cdt.build.core.buildArtefactType.exe" cleanCommand="rm -rf" description="" id="cdt.managedbuild.config.gnu.exe.release.1568263498" name="Release" parent="cdt.managedbuild.config.gnu.exe.release">
18 <configuration artifactName="Control_Module_v1_debug" buildArtefactType="org.eclipse.cdt.build.core.buildArtefactType.exe" buildProperties="org.eclipse.cdt.build.core.buildType=org.eclipse.cdt.build.core.buildType.release,org.eclipse.cdt.build.core.buildArtefactType=org.eclipse.cdt.build.core.buildArtefactType.exe" cleanCommand="rm -rf" description="" id="cdt.managedbuild.config.gnu.exe.release.1568263498" name="Release" parent="cdt.managedbuild.config.gnu.exe.release">
19 19 <folderInfo id="cdt.managedbuild.config.gnu.exe.release.1568263498." name="/" resourcePath="">
20 20 <toolChain id="cdt.managedbuild.toolchain.gnu.exe.release.785297601" name="Linux GCC" superClass="cdt.managedbuild.toolchain.gnu.exe.release">
21 21 <targetPlatform id="cdt.managedbuild.target.gnu.platform.exe.release.1008424557" name="Debug Platform" superClass="cdt.managedbuild.target.gnu.platform.exe.release"/>
22 22 <builder buildPath="${workspace_loc:/Control_Module/Release}" id="cdt.managedbuild.target.gnu.builder.exe.release.365458410" keepEnvironmentInBuildfile="false" managedBuildOn="true" name="Gnu Make Builder" superClass="cdt.managedbuild.target.gnu.builder.exe.release"/>
23 23 <tool id="cdt.managedbuild.tool.gnu.archiver.base.1343949145" name="GCC Archiver" superClass="cdt.managedbuild.tool.gnu.archiver.base"/>
24 24 <tool id="cdt.managedbuild.tool.gnu.cpp.compiler.exe.release.57926565" name="GCC C++ Compiler" superClass="cdt.managedbuild.tool.gnu.cpp.compiler.exe.release">
25 25 <option id="gnu.cpp.compiler.exe.release.option.optimization.level.35312113" name="Optimization Level" superClass="gnu.cpp.compiler.exe.release.option.optimization.level" value="gnu.cpp.compiler.optimization.level.most" valueType="enumerated"/>
26 26 <option id="gnu.cpp.compiler.exe.release.option.debugging.level.936269591" name="Debug Level" superClass="gnu.cpp.compiler.exe.release.option.debugging.level" value="gnu.cpp.compiler.debugging.level.none" valueType="enumerated"/>
27 27 </tool>
28 28 <tool command="arm-unknown-linux-gnu-gcc" id="cdt.managedbuild.tool.gnu.c.compiler.exe.release.1796829929" name="GCC C Compiler" superClass="cdt.managedbuild.tool.gnu.c.compiler.exe.release">
29 29 <option defaultValue="gnu.c.optimization.level.most" id="gnu.c.compiler.exe.release.option.optimization.level.499243164" name="Optimization Level" superClass="gnu.c.compiler.exe.release.option.optimization.level" valueType="enumerated"/>
30 30 <option id="gnu.c.compiler.exe.release.option.debugging.level.1960011250" name="Debug Level" superClass="gnu.c.compiler.exe.release.option.debugging.level" value="gnu.c.debugging.level.none" valueType="enumerated"/>
31 31 <inputType id="cdt.managedbuild.tool.gnu.c.compiler.input.1347535566" superClass="cdt.managedbuild.tool.gnu.c.compiler.input"/>
32 32 </tool>
33 33 <tool command="arm-unknown-linux-gnu-gcc" id="cdt.managedbuild.tool.gnu.c.linker.exe.release.1288648685" name="GCC C Linker" superClass="cdt.managedbuild.tool.gnu.c.linker.exe.release">
34 34 <inputType id="cdt.managedbuild.tool.gnu.c.linker.input.2046701530" superClass="cdt.managedbuild.tool.gnu.c.linker.input">
35 35 <additionalInput kind="additionalinputdependency" paths="$(USER_OBJS)"/>
36 36 <additionalInput kind="additionalinput" paths="$(LIBS)"/>
37 37 </inputType>
38 <outputType id="cdt.managedbuild.tool.gnu.c.linker.output.439510446" outputPrefix="" superClass="cdt.managedbuild.tool.gnu.c.linker.output"/>
38 39 </tool>
39 40 <tool id="cdt.managedbuild.tool.gnu.cpp.linker.exe.release.1068281678" name="GCC C++ Linker" superClass="cdt.managedbuild.tool.gnu.cpp.linker.exe.release"/>
40 41 <tool id="cdt.managedbuild.tool.gnu.assembler.exe.release.796779267" name="GCC Assembler" superClass="cdt.managedbuild.tool.gnu.assembler.exe.release">
41 42 <inputType id="cdt.managedbuild.tool.gnu.assembler.input.690094510" superClass="cdt.managedbuild.tool.gnu.assembler.input"/>
42 43 </tool>
43 44 </toolChain>
44 45 </folderInfo>
45 46 </configuration>
46 47 </storageModule>
48
49 <storageModule moduleId="org.eclipse.cdt.core.externalSettings"/>
50 <storageModule moduleId="org.eclipse.cdt.core.language.mapping"/>
51 <storageModule moduleId="org.eclipse.cdt.internal.ui.text.commentOwnerProjectMappings"/>
52 <storageModule moduleId="org.eclipse.cdt.make.core.buildtargets"/>
47 53 <storageModule moduleId="scannerConfiguration">
48 54 <autodiscovery enabled="true" problemReportingEnabled="true" selectedProfileId="org.eclipse.cdt.make.core.GCCStandardMakePerProjectProfile"/>
49 55 <profile id="org.eclipse.cdt.make.core.GCCStandardMakePerProjectProfile">
50 56 <buildOutputProvider>
51 57 <openAction enabled="true" filePath=""/>
52 58 <parser enabled="true"/>
53 59 </buildOutputProvider>
54 60 <scannerInfoProvider id="specsFile">
55 61 <runAction arguments="-E -P -v -dD ${plugin_state_location}/${specs_file}" command="gcc" useDefault="true"/>
56 62 <parser enabled="true"/>
57 63 </scannerInfoProvider>
58 64 </profile>
59 65 <profile id="org.eclipse.cdt.make.core.GCCStandardMakePerFileProfile">
60 66 <buildOutputProvider>
61 67 <openAction enabled="true" filePath=""/>
62 68 <parser enabled="true"/>
63 69 </buildOutputProvider>
64 70 <scannerInfoProvider id="makefileGenerator">
65 71 <runAction arguments="-f ${project_name}_scd.mk" command="make" useDefault="true"/>
66 72 <parser enabled="true"/>
67 73 </scannerInfoProvider>
68 74 </profile>
69 75 <profile id="org.eclipse.cdt.managedbuilder.core.GCCManagedMakePerProjectProfile">
70 76 <buildOutputProvider>
71 77 <openAction enabled="true" filePath=""/>
72 78 <parser enabled="true"/>
73 79 </buildOutputProvider>
74 80 <scannerInfoProvider id="specsFile">
75 81 <runAction arguments="-E -P -v -dD ${plugin_state_location}/${specs_file}" command="gcc" useDefault="true"/>
76 82 <parser enabled="true"/>
77 83 </scannerInfoProvider>
78 84 </profile>
79 85 <profile id="org.eclipse.cdt.managedbuilder.core.GCCManagedMakePerProjectProfileCPP">
80 86 <buildOutputProvider>
81 87 <openAction enabled="true" filePath=""/>
82 88 <parser enabled="true"/>
83 89 </buildOutputProvider>
84 90 <scannerInfoProvider id="specsFile">
85 91 <runAction arguments="-E -P -v -dD ${plugin_state_location}/specs.cpp" command="g++" useDefault="true"/>
86 92 <parser enabled="true"/>
87 93 </scannerInfoProvider>
88 94 </profile>
89 95 <profile id="org.eclipse.cdt.managedbuilder.core.GCCManagedMakePerProjectProfileC">
90 96 <buildOutputProvider>
91 97 <openAction enabled="true" filePath=""/>
92 98 <parser enabled="true"/>
93 99 </buildOutputProvider>
94 100 <scannerInfoProvider id="specsFile">
95 101 <runAction arguments="-E -P -v -dD ${plugin_state_location}/specs.c" command="gcc" useDefault="true"/>
96 102 <parser enabled="true"/>
97 103 </scannerInfoProvider>
98 104 </profile>
99 105 <profile id="org.eclipse.cdt.managedbuilder.core.GCCWinManagedMakePerProjectProfile">
100 106 <buildOutputProvider>
101 107 <openAction enabled="true" filePath=""/>
102 108 <parser enabled="true"/>
103 109 </buildOutputProvider>
104 110 <scannerInfoProvider id="specsFile">
105 111 <runAction arguments="-E -P -v -dD ${plugin_state_location}/${specs_file}" command="gcc" useDefault="true"/>
106 112 <parser enabled="true"/>
107 113 </scannerInfoProvider>
108 114 </profile>
109 115 <profile id="org.eclipse.cdt.managedbuilder.core.GCCWinManagedMakePerProjectProfileCPP">
110 116 <buildOutputProvider>
111 117 <openAction enabled="true" filePath=""/>
112 118 <parser enabled="true"/>
113 119 </buildOutputProvider>
114 120 <scannerInfoProvider id="specsFile">
115 121 <runAction arguments="-E -P -v -dD ${plugin_state_location}/specs.cpp" command="g++" useDefault="true"/>
116 122 <parser enabled="true"/>
117 123 </scannerInfoProvider>
118 124 </profile>
119 125 <profile id="org.eclipse.cdt.managedbuilder.core.GCCWinManagedMakePerProjectProfileC">
120 126 <buildOutputProvider>
121 127 <openAction enabled="true" filePath=""/>
122 128 <parser enabled="true"/>
123 129 </buildOutputProvider>
124 130 <scannerInfoProvider id="specsFile">
125 131 <runAction arguments="-E -P -v -dD ${plugin_state_location}/specs.c" command="gcc" useDefault="true"/>
126 132 <parser enabled="true"/>
127 133 </scannerInfoProvider>
128 134 </profile>
129 135 <scannerConfigBuildInfo instanceId="cdt.managedbuild.config.gnu.exe.release.1568263498;cdt.managedbuild.config.gnu.exe.release.1568263498.;cdt.managedbuild.tool.gnu.c.compiler.exe.release.1796829929;cdt.managedbuild.tool.gnu.c.compiler.input.1347535566">
130 136 <autodiscovery enabled="true" problemReportingEnabled="true" selectedProfileId="org.eclipse.cdt.managedbuilder.core.GCCManagedMakePerProjectProfileC"/>
131 137 <profile id="org.eclipse.cdt.make.core.GCCStandardMakePerProjectProfile">
132 138 <buildOutputProvider>
133 139 <openAction enabled="true" filePath=""/>
134 140 <parser enabled="true"/>
135 141 </buildOutputProvider>
136 142 <scannerInfoProvider id="specsFile">
137 143 <runAction arguments="-E -P -v -dD ${plugin_state_location}/${specs_file}" command="gcc" useDefault="true"/>
138 144 <parser enabled="true"/>
139 145 </scannerInfoProvider>
140 146 </profile>
141 147 <profile id="org.eclipse.cdt.make.core.GCCStandardMakePerFileProfile">
142 148 <buildOutputProvider>
143 149 <openAction enabled="true" filePath=""/>
144 150 <parser enabled="true"/>
145 151 </buildOutputProvider>
146 152 <scannerInfoProvider id="makefileGenerator">
147 153 <runAction arguments="-f ${project_name}_scd.mk" command="make" useDefault="true"/>
148 154 <parser enabled="true"/>
149 155 </scannerInfoProvider>
150 156 </profile>
151 157 <profile id="org.eclipse.cdt.managedbuilder.core.GCCManagedMakePerProjectProfile">
152 158 <buildOutputProvider>
153 159 <openAction enabled="true" filePath=""/>
154 160 <parser enabled="true"/>
155 161 </buildOutputProvider>
156 162 <scannerInfoProvider id="specsFile">
157 163 <runAction arguments="-E -P -v -dD ${plugin_state_location}/${specs_file}" command="gcc" useDefault="true"/>
158 164 <parser enabled="true"/>
159 165 </scannerInfoProvider>
160 166 </profile>
161 167 <profile id="org.eclipse.cdt.managedbuilder.core.GCCManagedMakePerProjectProfileCPP">
162 168 <buildOutputProvider>
163 169 <openAction enabled="true" filePath=""/>
164 170 <parser enabled="true"/>
165 171 </buildOutputProvider>
166 172 <scannerInfoProvider id="specsFile">
167 173 <runAction arguments="-E -P -v -dD ${plugin_state_location}/specs.cpp" command="g++" useDefault="true"/>
168 174 <parser enabled="true"/>
169 175 </scannerInfoProvider>
170 176 </profile>
171 177 <profile id="org.eclipse.cdt.managedbuilder.core.GCCManagedMakePerProjectProfileC">
172 178 <buildOutputProvider>
173 179 <openAction enabled="true" filePath=""/>
174 180 <parser enabled="true"/>
175 181 </buildOutputProvider>
176 182 <scannerInfoProvider id="specsFile">
177 183 <runAction arguments="-E -P -v -dD ${plugin_state_location}/specs.c" command="gcc" useDefault="true"/>
178 184 <parser enabled="true"/>
179 185 </scannerInfoProvider>
180 186 </profile>
181 187 <profile id="org.eclipse.cdt.managedbuilder.core.GCCWinManagedMakePerProjectProfile">
182 188 <buildOutputProvider>
183 189 <openAction enabled="true" filePath=""/>
184 190 <parser enabled="true"/>
185 191 </buildOutputProvider>
186 192 <scannerInfoProvider id="specsFile">
187 193 <runAction arguments="-E -P -v -dD ${plugin_state_location}/${specs_file}" command="gcc" useDefault="true"/>
188 194 <parser enabled="true"/>
189 195 </scannerInfoProvider>
190 196 </profile>
191 197 <profile id="org.eclipse.cdt.managedbuilder.core.GCCWinManagedMakePerProjectProfileCPP">
192 198 <buildOutputProvider>
193 199 <openAction enabled="true" filePath=""/>
194 200 <parser enabled="true"/>
195 201 </buildOutputProvider>
196 202 <scannerInfoProvider id="specsFile">
197 203 <runAction arguments="-E -P -v -dD ${plugin_state_location}/specs.cpp" command="g++" useDefault="true"/>
198 204 <parser enabled="true"/>
199 205 </scannerInfoProvider>
200 206 </profile>
201 207 <profile id="org.eclipse.cdt.managedbuilder.core.GCCWinManagedMakePerProjectProfileC">
202 208 <buildOutputProvider>
203 209 <openAction enabled="true" filePath=""/>
204 210 <parser enabled="true"/>
205 211 </buildOutputProvider>
206 212 <scannerInfoProvider id="specsFile">
207 213 <runAction arguments="-E -P -v -dD ${plugin_state_location}/specs.c" command="gcc" useDefault="true"/>
208 214 <parser enabled="true"/>
209 215 </scannerInfoProvider>
210 216 </profile>
211 217 </scannerConfigBuildInfo>
212 218 </storageModule>
213 <storageModule moduleId="org.eclipse.cdt.core.externalSettings"/>
214 219 </cconfiguration>
215 220 </storageModule>
216 221 <storageModule moduleId="cdtBuildSystem" version="4.0.0">
217 222 <project id="Control_Module.cdt.managedbuild.target.gnu.exe.1941602615" name="Executable" projectType="cdt.managedbuild.target.gnu.exe"/>
218 223 </storageModule>
219 224 </cproject>
Show file before | Show file after | Hide comments
@@ -1,322 +1,339
1 1 /*
2 2 * Servidor.c
3 3 *
4 4 * Created on: Nov 3, 2009
5 5 * Author: Jose Francisco Quenta
6 6 *
7 7 * Se implementa:
8 8 * -Carga en memoria los apuntes contenidos en un archivo de experimentos: apunte0 -> GPIO
9 9 * -Cambio de apunte.
10 10 * -Lectura del estado actual del apunte y grabado del mismo en un archivo
11 11 */
12 12
13 13 #include <stdio.h>
14 14 #include <stdlib.h>
15 15 #include <string.h>
16 16 #include <unistd.h>
17 17 #include <errno.h>
18 18
19 19 #include <sys/types.h>
20 20 #include <sys/socket.h>
21 21 #include <netinet/in.h>
22 22 #include <arpa/inet.h>
23 23 #include <netdb.h>
24 24
25 25 #include "./Librerias/AT91gpio_Funciones.h"
26 26 #include "./Librerias/Mensajes.h"
27 27
28 28 #define PUERTO_SERVIDOR 5500
29 29 #define TAM_BUFFER 100
30 30
31 31 #define maskc_out PC30+PC28+PC26+PC24+PC22+PC20 //MSB-UP-LSB MSB-DOWN-LSB //APUNTE
32 32
33 33 #define maskb_in PB16+PB18+PB20+PB30+PB24+PB22 //MSB-UP-LSB MSB-DOWN-LSB //VERIFICACION
34 34
35 35 #define bit_up_2 0x00010000 //Mascara de cada bit a revisar: bit_up_2 es MSB
36 36 #define bit_up_1 0x00040000
37 37 #define bit_up_0 0x00100000
38 38 #define bit_dow_2 0x40000000
39 39 #define bit_dow_1 0x01000000
40 40 #define bit_dow_0 0x00400000
41 41
42 42 #define MyID 11
43 43
44 44 char *buff_experimento= NULL;
45 45
46 46 AT91S_PIO *pioc;
47 47 AT91S_PIO *piob;
48 48
49 49 /*
50 50 * Zona de declaracion de cabeceras.
51 51 */
52 52 void inicializa_gpio();
53 int procesa_peticion(char *buff_peticion);
54 int cambia_apuntamiento(char *puntero_char);
55 int carga_experimento(char *nombre_archivo);
56 int chequeo_sistema(char *numero_muestras);
53 //int procesa_peticion(char *buff_peticion);
54 void procesa_peticion(char *buff_peticion);
55 //int cambia_apuntamiento(char *puntero_char);
56 void cambia_apuntamiento(char *puntero_char);
57 //int carga_experimento(char *nombre_archivo);
58 void carga_experimento(char *nombre_archivo);
59 //int chequeo_sistema(char *numero_muestras);
60 void chequeo_sistema(char *numero_muestras);
57 61
58 62 /*
59 63 *
60 64 */
61 65 int main(){
62 66
63 67 int conexion_servidorFd;
64 68 struct sockaddr_in inf_servidor;
65 69 struct sockaddr_storage inf_cliente;
66 70 int resultado;
67 71 int numbytes_recibidos;
68 int rpta;
72 //int rpta;
69 73
70 74 char *buff_peticion = (char *) malloc(TAM_BUFFER);
71 75
72 76 size_t addr_len;
73 77
74 78 memset(&inf_servidor, 0, sizeof(inf_servidor));
75 79 inf_servidor.sin_family= AF_INET;
76 80 inf_servidor.sin_port= htons(PUERTO_SERVIDOR);
77 81 inf_servidor.sin_addr.s_addr= INADDR_ANY;
78 82
79 83 /* Se establece el socket */
80 84 conexion_servidorFd = socket(AF_INET,SOCK_DGRAM,0);
81 85 if (conexion_servidorFd == -1){
82 86 ERROR_FATAL("No se establecio correctamente el socket: socket()");
83 87 }
84 88
85 89 /* Se asocia el socket a un puerto y una IP */
86 90 resultado = bind(conexion_servidorFd,(struct sockaddr *)&inf_servidor,sizeof(inf_servidor));
87 91 if (resultado== -1){
88 92 ERROR_FATAL("No se establecio correctamente el socket: bind()");
89 93 }
90 94
91 95 /* Inicializamos el puerto GPIO del sistema embebido GSBC-9260S */
92 96 inicializa_gpio();
93 97
94 98 while(1){
95 99 LOG_SERVIDOR("Esperando solicitud de cliente...\n");
96 100
97 101 /* Se espera hasta que un cliente se conecte */
98 102 addr_len = sizeof(inf_cliente);
99 103 numbytes_recibidos = recvfrom(conexion_servidorFd, buff_peticion, TAM_BUFFER-1, 0, (struct sockaddr *)&inf_cliente, &addr_len);
100 104 if (numbytes_recibidos == -1){
101 105 ERROR_FATAL("Error en la recepcion de datos: recvfrom()");
102 }
106 }else
107 printf("Recibidos: %i\n",numbytes_recibidos);
103 108
104 109 /* Se procede a procesar los datos recibidos */
105 110 buff_peticion[numbytes_recibidos]= '\0';
111 printf("%s\n",buff_peticion);
106 112
107 113 /* procesamiento de la peticion */
108 rpta = procesa_peticion(buff_peticion);
114 //rpta = procesa_peticion(buff_peticion);
115 procesa_peticion(buff_peticion);
109 116
110 117 //Respuesta del modulo de control
111 118 //
112 119
113 120
114 121 }
115 122 }
116 123
117 124 /*
118 125 * Esta funcion incializa el puerto GPIO
119 126 */
120 127 void inicializa_gpio(){
121 128
122 129 // Configuracion de los pines de APUNTE
123 130 pioc = pio_map(PIOC_BASE);
124 131 pio_enable(pioc, maskc_out);
125 132 pio_disable_irq(pioc, maskc_out);
126 133 pio_disable_multiple_driver(pioc, maskc_out);
127 134 pio_disable_pull_ups(pioc, maskc_out);
128 135 pio_synchronous_data_output(pioc, maskc_out);
129 136 pio_output_enable(pioc, maskc_out);
130 137
131 138 // Configuracion de los pines de VERIFICACION
132 139 piob = pio_map(PIOB_BASE);
133 140 pio_enable(piob, maskb_in);
134 141 pio_disable_irq(piob, maskb_in);
135 142 pio_disable_multiple_driver(piob, maskb_in);
136 143 pio_disable_pull_ups(piob, maskb_in);
137 144 pio_input_enable(piob, maskb_in);
138 145
139 146 }
140 147
141 148 /*
142 149 * Esta funcion procesa el mensaje de peticion y genera respuesta
143 150 */
144 int procesa_peticion(char *buff_peticion){
145 int rpta;
151 //int procesa_peticion(char *buff_peticion){
152 void procesa_peticion(char *buff_peticion){
153 //int rpta = 0;
154
146 155 // char *header = strtok(buff_peticion, ":");
147 156 // char *ipSource = strtok(buff_peticion, ":");
148 157 // char *ipDestino = strtok(buff_peticion, ":");
149 158 char *comando = strtok(buff_peticion, ":");
150 159 char *valor = strtok(NULL, ":");
151 160
161 printf("Testpoint_1\n");
152 162 if ((comando == NULL) || (valor == NULL)){
153 163 ERROR("procesarPeticion: formato de mensaje incorrecto");
154 164 }
155 165 else{
156 166 if(strcmp(comando,"CARGA") == 0)
157 rpta = carga_experimento(valor);
167 //rpta = carga_experimento(valor);
168 carga_experimento(valor);
158 169 else if(strcmp(comando,"CAMBIA") == 0)
159 rpta = cambia_apuntamiento(valor);
170 //rpta = cambia_apuntamiento(valor);
171 cambia_apuntamiento(valor);
160 172 else if(strcmp(comando,"CHEQUEO") == 0)
161 rpta = chequeo_sistema(valor);
173 //rpta = chequeo_sistema(valor);
174 chequeo_sistema(valor);
162 175 else
163 176 ERROR("procesa_peticion: comando no reconocido");
164 177 }
165 178
166 return rpta;
179 //return rpta;
167 180 }
168 181
169 182
170 183 /*
171 184 * Esta funcion carga un archivo en un buffer que esta ubicado en memoria, luego
172 185 * este buffer es usado en la funcion "cambia_apuntamiento" para obtener el dato
173 186 * que sera usado en el cambio de apuntamiento.
174 187 */
175 int carga_experimento(char *nombre_archivo){
188 //int carga_experimento(char *nombre_archivo){
189 void carga_experimento(char *nombre_archivo){
176 190
177 191 FILE *Archivo_Fd;
178 192
179 193 char *cadena = (char *) malloc(25);
180 194
181 195 int longitud_cadena;
182 196 int num_bytes= 0;
183 197 int num_filas= 0;
184 198
185 199 char ruta_archivo[50]; // Se crea la ruta para abrir el archivo
186 200 strcpy(ruta_archivo,"/mnt/sd/archivos/");
187 201 strcat(ruta_archivo,nombre_archivo);
188 202
189 203 Archivo_Fd = fopen(ruta_archivo,"r"); // Se procede a abrir el archivo, segun la ruta especificada
190 204 if(!Archivo_Fd){
191 205 ERROR("carga_archivo: No se pudo abrir el archivo!!! --> fopen()\n");
192 return -1;
206 // return -1;
193 207 }else{
194
208 printf("Testpoint_2\n");
195 209 while(!feof(Archivo_Fd)){ // Se procede a calcular la longitud del archivo para separar memoria
196 210 fgets(cadena,20,Archivo_Fd);
197 211 longitud_cadena= strlen(cadena);
198 212 cadena[longitud_cadena-1] = '\0';
199 213 num_bytes = num_bytes + longitud_cadena;
200 214 num_filas++;
201 215 }
202 216
203 217 rewind(Archivo_Fd); // Se reinicia el puntero del archivo
204 218
205 219 char *buffer_temporal = (char *) malloc(num_bytes+1); // Se separa espacio de memoria segun
206 220 // la longitud del archivo
207 221 fread(buffer_temporal, sizeof(char), num_bytes, Archivo_Fd);
208 222
209 char *puntero= strstr(buffer_temporal,".abs"); // Se procede a eliminar la cabecera del archivo
223 printf("Testpoint_3\n");
224 char *puntero= strstr(buffer_temporal,".ab1"); // Se procede a eliminar la cabecera del archivo
210 225 puntero= puntero + 12;
211 226
212 227 buff_experimento = (char *) malloc(7*(num_filas-3)); // num_bytes_fila*(num_filas-3);
213 228 strncpy(buff_experimento,puntero,7*(num_filas-3)); // Se carga en memoria la informacion del archivo
214 229
215 230 fclose(Archivo_Fd);
216 231
217 cambia_apuntamiento("0"); // Se apunta a la direccion 0
218
219 return 1;
232 //cambia_apuntamiento("0"); // Se apunta a la direccion 0
233
234 // return 1;
220 235 }
221 236 }
222 237
223 238 /*
224 239 * Esta funcion recibe un numero en formato char, el dato se transforma a su equivalente en
225 240 * un numero entero, que sera usado para sacar un dato del buffer "buff_experimento", esta
226 241 * dato es el valor que se enviara al sistema de conmutacion RF para el cambio de apunte a
227 242 * traves del puerto GPIO.
228 243 */
229 int cambia_apuntamiento(char *puntero_char){
244 //int cambia_apuntamiento(char *puntero_char){
245 void cambia_apuntamiento(char *puntero_char){
230 246
231 247 /*MSB-UP-LSB MSB-DOWN-LSB*/
232 248 int desplazamiento[6]={30,28,26,24,22,20}; // Defino los dezplazamientos que se aplicara
233 249 // al dato que ingresa para formar el número
234 250 // entero que se le pasara al puerto GPIO
235 251 // Estos números son los pines del puerto GPIO
236 252 // que se estan usando para el control
237 253
238 254 int puntero= atoi(puntero_char); // Se convierte a entero la direccion del puntero
239 255
240 256 int base= 7*puntero; // base= cantidad_bytes del dato x puntero
241 257 // cantidad de bytes es el numero de bytes que
242 258 printf("%i\n",puntero); // contiene cada dato, para este caso es 7
243 259 // porque es 6 bits de datos + 1 bit del cambio
244 260 // de linea.
245 261 char valor_char;
246 262 unsigned long valor;
247 263 unsigned long acumulado_ceros=0;
248 264 unsigned long acumulado_unos=0;
249 265
250 266 int offset; // Defino offset para el desplazamiento a traves
251 267 for(offset=0;offset<6;offset++){ // de cada dato que se obtiene del "buff_experimento"
252 268
253 269 valor_char= buff_experimento[base+offset]; // Obtengo el dato
254 270
255 271 if (valor_char == '0'){ // Obtengo el número acumulado segun sea un cero o un uno
256 272 valor= 0;
257 273 acumulado_ceros= acumulado_ceros + (1 << desplazamiento[offset]);
258 274 }else{
259 275 valor= 1;
260 276 acumulado_unos= acumulado_unos + (1 << desplazamiento[offset]);
261 277 }
262 278
263 279 }
264 280
265 281 pio_out(pioc, maskc_out, acumulado_unos, 1);
266 282 pio_out(pioc, maskc_out, acumulado_ceros, 0);
267 283
268 return 1;
284 //return 1;
269 285
270 286 }
271 287
272 288 /*
273 289 * Esta funcion lee "n" veces el estado del APUNTE actual y lo guarda en el
274 290 * archivo Verificacion.
275 291 */
276 292
277 int chequeo_sistema(char *numero_muestras){
293 //int chequeo_sistema(char *numero_muestras){
294 void chequeo_sistema(char *numero_muestras){
278 295
279 296 char valor[7];
280 297 int i,cnt;
281 298 unsigned int entradac= 0;
282 299 FILE *fd;
283 300 fd=fopen("/mnt/sd/archivos/Verificacion","w");
284 301 fprintf(fd,"%s\n","Verificacion");
285 302 fprintf(fd,"%s\n","------------");
286 303 cnt=0;
287 304 do
288 305 {
289 306 //Inicializando arreglo
290 307 for(i=0;i<6;i++)
291 308 valor[i]='0';
292 309
293 310 valor[6]='\0';
294 311
295 312 //Lectura de puerto
296 313 entradac= pio_in(piob,maskb_in);
297 314
298 315 //Dandole formato al dato
299 316 if (!(entradac & bit_up_2))
300 317 valor[0] = '1';
301 318 if (!(entradac & bit_up_1))
302 319 valor[1] = '1';
303 320 if (!(entradac & bit_up_0))
304 321 valor[2] = '1';
305 322 if (!(entradac & bit_dow_2))
306 323 valor[3] = '1';
307 324 if (!(entradac & bit_dow_1))
308 325 valor[4] = '1';
309 326 if (!(entradac & bit_dow_0))
310 327 valor[5] = '1';
311 328
312 329 //Escribiendo en archivo
313 330 fprintf(fd,"%s\n",valor);
314 331 cnt=cnt+1;
315 332 usleep(1*1000*1000);
316 333
317 }while(cnt < atoi(numero_muestras));
334 }while(cnt < (atoi(numero_muestras)+1));
318 335
319 336 fclose(fd);
320 337
321 return 1;
322 }
338 //return 1;
339 }
Show file before | Show file after | Hide comments
1 NO CONTENT: file was removed
General Comments 0
You need to be logged in to leave comments. Login now