Feda /dev/ - No Javascript allowed | Página 275

MisKo #8221 Jul '20

Pues yo recuerdo q de lo primero que hice, fue una especie de 'radio online' para los colegas con VB6.

Unos colegas se conectaban a emitir vía winamp o alguna mierda del estilo (no recuerdo nada) y, con el programa que hice yo, se escuchaba (conectandose a winamp desde el programa) y se podían pedir canciones para q lo vieran los que emitian.

De esto hace facilmente más de 15 años xDD

Fyn4r #8222 Jul '20 Inocente

#8217 creo que el primer proyecto que intente fue un clon de ogame

1 respuesta

eXtreM3 #8223 Jul '20

Pero queremos código, no mierdas de descripciones.

1 respuesta

Fyn4r #8224 Jul '20 Inocente

#8223 igual te crees que conservo código de cuando tenía 18 años xd

1 1 respuesta

MisKo #8225 Jul '20

No tengo un código de hace más de 15 años xD, pero horrible sería poco

eXtreM3 #8226 Jul '20

#8224 btw lo del clon de ogame... hace no mucho un chaval vino por aquí queriéndolo hacer no?

Eso es una puta movida, es muy muy complejo.

2 respuestas

Markitos_182 #8227 Jul '20

#8226 #8222 Todo el mundo ha intentado o conoce a alguien que ha intentado hacer un clon del ogame

1

Fyn4r #8228 Jul '20 Inocente

#8226 lo es, pero es lo típico que conoces bien y piensas "lo hago más simple" (pensando que no es una locura igualmente xd) porque obviamente no tienes ni puta idea de estimar ni de analizar ni de nada xd

Lo siguiente que hice creo que ya fue alguna cosa para Arduino y similares de lo cual si debería tener código por GitHub . Luego miro

Markitos_182 #8229 Jul '20

¿Alguien se acuerda de Google Code?

1 respuesta

desu #8230 Jul '20

Yo tengo codigo practica de primero de carrera, primera asignatura... no programaba en espa;ol lo hacia en catalan xd

Screen en 3, 2, 1...

spoiler

Me cago en mis putos muertos xd xq no esta bien identado? decir que nos hacian picar en vim y no usar ide pero joder que asco doy

no tengo codigo mas viejo que este, noviembre 2014, llevaba programando 1mes.

Lecherito #8231 Jul '20 A toda leche

Pues yo si tengo algo de codigo de cuando empece:

on *:DIALOG:chan.err:init:0: { did -a $dname 1 %chan.mensaje }
dialog chan.err {
  title "ChanEdit - Error"
  size -1 -1 160 30
  option dbu
  text "", 1, 0 1 160 28
  button "",2,-20 -20 0 0,cancel
}
alias -l chan.mensaje {
  set %chan.mensaje $$1-
  if ($dialog(chan.err)) { dialog -x chan.err}
  dialog -m chan.err chan.err
  dialog -v chan.err
  halt
}
on *:DIALOG:channedit:init:0: {
  set %numtochan 1
  while (%numtochan <= $chan(0) {
    did -a channedit 1 $chan(%numtochan)
    inc %numtochan
  }
}
on *:DIALOG:channedit:sclick:1: {
  set %ai 1
  while (%ai <= $nick($did(channedit,1).seltext)) {
    did -a channedit 2 $nick($did(channedit,1).seltext),%ai)
    inc %ai
  }
}
on *:DIALOG:channedit:sclick:3: {
  set %nick1 $did(channedit,2).seltext
  did -d channedit 2 $didwm(channedit,2,%nick1) 
}

alias sorteos { dialog -m sorteobot sorteobot }
dialog sorteobot {
  title "Sorteos"
  size -1 -1 199 188
  option dbu
  list 1, 11 13 69 150, size
  box " Lista de Apuntados ", 2, 4 4 83 164
  box " Acciones Sorteo ", 3, 89 4 100 163
  button "Expulsar", 4, 100 88 37 12
  button "Actualizar", 5, 140 72 37 12
  button "Empezar", 6, 100 72 37 12
  button "Agregar", 7, 140 87 37 12
  button "Limite", 8, 100 102 37 12
  button "Poner Premio", 9, 140 102 37 12
  button "Editar Expul.", 10, 140 116 37 12
  button "Borrar Lista", 11, 100 116 37 12
  edit "", 12, 135 17 50 10
  button "Parar", 13, 100 131 37 12
  button "Cerrar", 14, 140 131 37 12
  text "Canal", 15, 96 18 25 8
  text "Premio", 16, 96 31 25 8
  text "Limite", 17, 96 43 25 8
  edit "", 18, 135 29 50 10
  edit "", 19, 135 41 50 10
}
on *:DIALOG:sorteobot:sclick:8: { set %~~sorteo.lim $$?="Pon un limite de personas" }
on *:DIALOG:sorteobot:sclick:11: {
  write -c sorteos.txt
  did -r sorteobot 2
}
on *:DIALOG:gatherbot:sclick:4: {
  set %~~sorteo.kick.nick $did(gatherbot,2).seltext
  did -d $didwm(sorteobot,2,%~~sorteo.kick.nick)
}
on *:TEXT:!add:%~~sorteo.chan: {
  if (%~~sorteo.stat == on) {
    write sorteos.txt $nick
    did -a sorteobot 2 $nick
  }
  elseif ($read(sorteos.txt, w, * $+ $nick $+ *)) && (%~~sorteo.stat == on) {
    msg %~~sorteo.chan $nick ya estas apuntado al sorteo, no te puedes añadir dos veces.
  }
}
on *:DIALOG:sorteobot:sclick:6: {
  if ($did(gatherbot,12).text != $null) && ($did(gatherbot,18).text != $null) && ($did(gatherbot,19).text != $null) {
    set %~~sorteo.lim $did(gatherbot,19).text
    set %~~sorteo.chan $did(gatherbot,12).text
    msg %~~sorteo.chan Acaba de empezar un sorteo, poned !add para añadirse o !remove para quitarse.
    msg %~~sorteo.chan Como premio, esta $did(gatherbot,18).text
    msg %~~sorteo.chan El limite de personas es %~~sorteo.lim $+ .
  }
}

Joder, que recuerdos aquellos del mIRC scripting

2 2 respuestas

Wei-Yu #8232 Jul '20

> escribir en narniano

1 respuesta

desu #8233 Jul '20

#8232 Mucho peor seria escribir en javascript.

isvidal #8234 Jul '20

#8231 Cuantos a;os tenias cuando hacías eso

Lecherito #8235 Jul '20 A toda leche

Pues tendria 14 o 15. Recuerdo que imprimi 100 paginas de tutorial de mirc scripting y me lo lleve a un intercambio que tuve en UK. Me baje el mIRC en la casa donde estaba y programaba ahi xddddd

1

Wei-Yu #8236 Jul '20

NSFW

LLoid #8237 Jul '20

Un día rularé el código de mi proyecto de final de carrera. Era una app que servía para medir el CMMI en organizaciones (tela).

Creo que ha sido la mierda más gorda que he hecho en mi vida. Todavía tengo pesadillas.

r2d2rigo #8238 Jul '20 Inocente

#8229 veo y subo: alguien se acuerda de CodePlex?

3

B

[Borrado] #8239 Jul '20

#8231 Que mitico! yo también empece a picar con mIRC Scripting (antes había trasteado con algún diskette de DOS para mi amiga 500):

En general la comunidad de "eScripting.tk" era la mejor de todas!! MijT era un adelantado a su tiempo, a saber que ha sido de muchos de esa comunidad...

1

Ranthas #8240 Jul '20

A ver si encuentro mis prácticas de sistemas operativos...el espagueti code de la práctica de los fork / mutex no lo ves ni Everis xDDDDDDDDDD

2 respuestas

Fyn4r #8241 Jul '20 Inocente

#8240 buf, esas prácticas y las de algoritmos las perdí fijo pero estaría bien revisitarlas xddd

1 respuesta

Lecherito #8242 Jul '20 A toda leche

#8240 #8241 yo recuerdo la practica de los barberos (forks y concurrencia)

manager.c

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <signal.h>
#include <sys/wait.h>

#include <memoriaI.h>
#include <semaforoI.h>
#include <constants.h>

void esperar(int senhal); void controlador(int senhal);

int main(int argc, char *argv[]) {
	//Definicion de las variables
	int i, numClientes,numSillas, numSalaEspera, maxClientes;
  srand((int)getpid());

	//Declaracion de variables
	numClientes = atoi(argv[1]);
	numSillas = atoi(argv[2]);
	maxClientes = atoi(argv[3]);
	numSalaEspera = (maxClientes-numSillas>0)?:10;

  pid_t procesos[numClientes+BARBEROS];

  //Creacion de semaforos
	crear_sem(S_SILLON,BARBEROS);
	crear_sem(S_SILLA,numClientes);
  crear_sem(B_RAPIDO,1); crear_sem(B_MEDIO,1); crear_sem(B_LENTO,1);
  crear_sem(S_VMC_BARBEROS,1);
  crear_sem(S_VMC_CAJA,1);
  crear_sem(S_VMC_SALA,1);
  crear_sem(S_FINAL_RAPIDO,0); crear_sem(S_FINAL_MEDIO,0); crear_sem(S_FINAL_LENTO,0);


  //Creacion de variables de memoria compartida
	crear_var(VMC_CAJA,0);
	crear_var(VMC_SALA_ESPERA,numSalaEspera);
	crear_var(VMC_BARBEROS,7);

	//Se espera la terminacion de los procesos
	if (signal(SIGCHLD,esperar) == SIG_ERR) {
		fprintf(stderr,"Didnt wait for a child.\n"); exit(1);
	}

	//Manejo de control+c
	if (signal(SIGINT,controlador) == SIG_ERR) {
		fprintf(stderr, "Abrupt termination.\n"); exit(1);
	}
  //Los 3 primeros son los barberos.
	for (i=0;i<BARBEROS;i++) {
		switch(procesos[i] = fork()) {
			case 0:
				switch(i) {
					case 0:
						execl("./exec/barbero","barbero",B_LENTO,S_FINAL_LENTO,1,NULL);
						break;
					case 1:
						execl("./exec/barbero","barbero",B_MEDIO,S_FINAL_MEDIO,2,NULL);
						break;
					case 2:
						execl("./exec/barbero","barbero",B_RAPIDO,S_FINAL_RAPIDO,3,NULL);
						break;
				}
		}
	}
	//Lanzamiento de procesos
	for (i=BARBEROS;i<numClientes;i++) {
		switch(procesos[i] = fork()) {
			case 0:
				execl("./exec/cliente","cliente",NULL);
				break;
		}
    sleep(rand() % MAX_TIEMPO +1);
	}
	while(1) pause();
	return 0;
}

void esperar(int senhal) {
	int i; while(wait3(&i, WNOHANG, NULL) > 0);
}

void controlador(int senhal) {
	printf("\nCtrl+c capturada.\n");
	printf("Finalizando...\n\n");
	destruir_sem(S_SILLON);
	destruir_sem(S_SILLA);
  destruir_sem(B_RAPIDO); destruir_sem(B_MEDIO); destruir_sem(B_LENTO);
  destruir_sem(S_VMC_BARBEROS);
  destruir_sem(S_VMC_CAJA);
  destruir_sem(S_VMC_SALA);
  destruir_sem(S_FINAL_RAPIDO); destruir_sem(S_FINAL_MEDIO); destruir_sem(S_FINAL_LENTO);

	destruir_var(VMC_CAJA);
	destruir_var(VMC_SALA_ESPERA);
	destruir_var(VMC_BARBEROS);
	sleep(1); printf("OK!\n");
	exit(0);
}

cliente.c

#include <sys/types.h>
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <sys/wait.h>

#include <semaforoI.h>
#include <memoriaI.h>
#include <constants.h>

//TODO FALTA COMPROBAR SI HAY ESPACIO EN LA SALA DE ESPERA PARA QUEDARNOS.
char* traducirBarbero(int barberos);
int escogerBarbero(int barbs);
char* traducirFinal(int barberos);

int main(int argc, char *argv[]) {
	int BarberoAescoger, escogido, salaEspera, dineroCaja;

  printf("[Cliente %d] entra. \n",getpid());

	//Semaforos 
	sem_t *s_pSilla, *s_pSillon, *s_pCaja, *s_pSala; //Inicializacion de los semaforos
  sem_t *s_pBarberos, *s_pFinalcortado, *s_pBarberoescogido;
	
	s_pSilla 	 = get_sem(S_SILLA);  //Dar valores a los semaforos
	s_pSillon	 = get_sem(S_SILLON);
	s_pCaja		 = get_sem(S_VMC_CAJA);
  s_pBarberos = get_sem(S_VMC_BARBEROS);

  //VMC
  int iCaja, iBarberos;

  iCaja = obtener_var(VMC_CAJA);
  iBarberos = obtener_var(VMC_BARBEROS);


	wait_sem(s_pSilla);														//Esperamos a que haya una silla libre
  printf("[Cliente %d] se sienta en una silla libre. \n",getpid());
	wait_sem(s_pSillon);													//Esperamos a que haya un sillón libre
  printf("[Cliente %d] se sienta en un sillon libre. \n",getpid());
	signal_sem(s_pSilla);													//Liberamos la silla de la que nos acabamos de levantar
  printf("[Cliente %d] se levanta de la silla. \n",getpid());

	/*La variable compartida de los barberos, nunca será menor que 0, ya que el semaforo contador
	 *con nombre s_pSillon, controla los sillones que hay libre, con la variable de memoria compartida
	 *sabemos que sillones son los que estan libres y entonces escogemos el mejor.
	 */

	wait_sem(s_pBarberos);									//Esperamos al semaforo controlador la escritura de la VMC_BARBERO
	consultar_var(iBarberos, &BarberoAescoger);	//Consultamos la variable 
	escogido = escogerBarbero(BarberoAescoger);			//Escogemos el mejor barbero
	BarberoAescoger -= escogido;										//Quitamos el barbero escogido de la lista de disponibles
	modificar_var(iBarberos, BarberoAescoger);		//Lo modificamos en la variable compartida
	signal_sem(s_pBarberos);												  	//Liberamos el mutex de la VMC_BARBERO
  printf("[Cliente %d] escoge a: %s. \n",getpid(),traducirBarbero(escogido));

	char *barberoAutilizar = traducirBarbero(escogido); //Traducimos el barbero a una string
  printf("Barbero a utilizar: %s\n",barberoAutilizar);
  s_pBarberoescogido = get_sem(barberoAutilizar);     //Creamos el semaforo correspondiente
  s_pFinalcortado = get_sem(traducirFinal(escogido)); //Creamos el semaforo para el final del cortado
	signal_sem(s_pBarberoescogido); 												//Despertamos al barbero que vamos a utilizar
	wait_sem(s_pFinalcortado);    		  						    		//Esperamos al final del corte
  printf("[Cliente %d] se levanta de la sillon, fin del corte. \n",getpid());

  signal_sem(s_pSillon);										       		//Liberamos el sillon despues del cortado

	wait_sem(s_pBarberos);														  //Devolvemos el valor que tenia la variable compartida
	consultar_var(iBarberos, &BarberoAescoger);	//De qué barberos hay disponibles.
	BarberoAescoger += escogido;                    //Se añade el barbero a los disponibles
	modificar_var(iBarberos, BarberoAescoger);   //Modificamos la variable
	signal_sem(s_pBarberos);                            //La liberamos

	wait_sem(s_pCaja);                                  //Cogemos el semaforo de la variable caja para pagar
	consultar_var(iCaja, &dineroCaja);           //Sacamos el valor de la variable a usar
  dineroCaja+=CONSTANTE_PAGAR+rand() % 10 + 1;    //Calculamos cuanto vamos a pagar y se suma
  modificar_var(iCaja, dineroCaja);            //Ponemos el valor nuevo de la variable
  signal_sem(s_pCaja);                                //Liberamos el semaforo de la variable de caja

	return 0;
}

char* traducirFinal(int barberos) {
	if (barberos == 4) return S_FINAL_RAPIDO;
	if (barberos == 2) return S_FINAL_MEDIO;
	if (barberos == 1) return S_FINAL_LENTO;
  return "NULL";
}

char* traducirBarbero(int barberos) {
	if (barberos == 4) return B_RAPIDO;
	if (barberos == 2) return B_MEDIO;
	if (barberos == 1) return B_LENTO;
  return "NULL";
}

int escogerBarbero(int barbs) {
  int devolver=-1;
	if (barbs >= 1) devolver = 1;
	if (barbs >= 2) devolver = 2;
	if (barbs >= 4) devolver = 4;
  return devolver;
}

memoria.c

#include <stdio.h>
#include <errno.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/mman.h>
#include <sys/stat.h>
#include <sys/types.h>

#include <memoriaI.h>

int crear_var(const char *name, int valor) {
	int shm_fd;
	int *p;

	//Abre el objeto de memoria compartida
	shm_fd = shm_open(name, O_CREAT | O_RDWR, 0666);
	if (shm_fd == -1) {
		fprintf(stderr, "Error al crear la variable: %s\n",strerror(errno));
		exit(1);
	}

	//Establecer el tamaño
	if (ftruncate(shm_fd, sizeof(int)) == -1) {
		fprintf(stderr, "Error al truncar la variable: %s\n",strerror(errno));
		exit(1);
	}

	//Mapeo del objeto de la memoria compartida
	p = mmap(NULL, sizeof(int), PROT_READ | PROT_WRITE, MAP_SHARED, shm_fd, 0);
	if (p == MAP_FAILED) {
		fprintf(stderr, "Error al truncar la variable: %s\n",strerror(errno));
		exit(1);
	}

	*p = valor;
	munmap(p, sizeof(int));

	return shm_fd;
}

int obtener_var(const char *name) {
	int shm_fd;
	
	//Abre el objeto de memoria compartida
	shm_fd = shm_open(name, O_RDWR,0666);
	if (shm_fd == -1) {
		fprintf(stderr, "Error al obtener la variable: %s\n",strerror(errno));
		exit(1);
	}

	return shm_fd;
}

void destruir_var (const char *name) {
	int shm_fd = obtener_var(name);

	if (close(shm_fd) == -1) {
		fprintf(stderr, "Error al destruir la variable: %s\n",strerror(errno));
		exit(1);
	}

	if (shm_unlink(name) == -1) {
		fprintf(stderr, "Error al destruir la variable: %s\n",strerror(errno));
		exit(1);
	}
}

void modificar_var (int shm_fd, int valor) {
	int *p;

	//Mapeo del objeto de la memoria compartida
	p = mmap(NULL, sizeof(int), PROT_READ | PROT_WRITE, MAP_SHARED, shm_fd, 0);
	if (p == MAP_FAILED) {
		fprintf(stderr, "Error al truncar la variable: %s\n",strerror(errno));
		exit(1);
	}
	
	*p = valor;
	munmap(p, sizeof(int));
}

void consultar_var(int shm_fd, int *valor) {
	int *p;

	//Mapeo del objeto de la memoria compartida
	p = mmap(NULL, sizeof(int), PROT_READ | PROT_WRITE, MAP_SHARED, shm_fd, 0);
	if (p == MAP_FAILED) {
		fprintf(stderr, "Error al truncar la variable: %s\n",strerror(errno));
		exit(1);
	}
	
	*valor = *p;
	munmap(p,sizeof(int));
}

semaforo.c

#include <stdio.h>
#include <errno.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/mman.h>
#include <sys/stat.h> 
#include <semaforoI.h>

sem_t *crear_sem(const char *name, unsigned int valor) {
	sem_t *sem;

	sem = sem_open(name, O_CREAT, 0644, valor);
	if (sem == SEM_FAILED) {
		fprintf(stderr, "Error al crear el sem.: %s\n",strerror(errno));
		exit(1);
	}
	
	return sem;
}

sem_t *get_sem(const char *name) {
	sem_t *sem;

	sem = sem_open(name, O_RDWR);
	if (sem == SEM_FAILED) {
		fprintf(stderr, "Error al obtener el sem.: %s\n",strerror(errno));
		exit(1);
	}

	return sem;
}

void destruir_sem(const char *name) {
	sem_t *sem = get_sem(name);

	//Se cierra el semaforo
	if ((sem_close(sem)) == -1) {
		fprintf(stderr, "Error al cerrar el sem.: %s\n",strerror(errno));
		exit(1);
	}

	//Se elimina el semaforo
	if ((sem_unlink(name)) == -1) {
		fprintf(stderr, "Error al destruir el sem.: %s\n",strerror(errno));
		exit(1);
	}
}

void signal_sem(sem_t *sem) {
	if ((sem_post(sem)) == -1) {
		fprintf(stderr, "Error al modificar el sem.: %s\n",strerror(errno));
		exit(1);
	}
}

void wait_sem(sem_t *sem) {
	if ((sem_wait(sem)) == -1) {
		fprintf(stderr, "Error al esperar el sem.: %s\n",strerror(errno));
		exit(1);
	}
}

barbero.c

#include <sys/types.h>
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <sys/wait.h>

#include <semaforoI.h>
#include <memoriaI.h>
#include <constants.h>

int main(int argc, char *argv[]) {
  srand(getpid());
  sem_t *s_pBarbero, *s_pFinal;

  printf("[Barbero %d] arranca soy <%s>. \n",getpid(),argv[1]);
  
  s_pBarbero = get_sem(argv[1]);  // Semaforo para saber que barbero es
  s_pFinal   = get_sem(argv[2]);  // Semaforo para el final del cortado segun barbero

  wait_sem(s_pBarbero);
  printf("[Barbero %d] se pone a cortar. \n",getpid());
  int esperar = (rand() % MAX_TIEMPO + 1)*atoi(argv[3]);
  sleep(esperar);
  signal_sem(s_pFinal);
  printf("[Barbero %d] termina de cortar. \n",getpid());

	return 0;
}

Vaya recuerdos macho xDDD, estoy sacando todas las mierdas que he hecho desde entonces lol

3 1 respuesta

JuAn4k4 #8243 Jul '20

#8242 Es una maravilla. Yo tenia un tetris multijugador... espagueti puro y una casa de apuestas cliente servidor. No me quiero imaginar la mierda de código que debe haber ahí. Una pena que lo haya perdido todo, no usaba ningún control de versiones, iba con vi por ssh y ahi se quedó... en los servers de la universidad todo.

Tengo impreso el código del PFC....

Fyn4r #8244 Jul '20 Inocente

Tengo prácticamente todas la prácticas de la carrera en dropbox, luego subo cosas desde el pc xd

1

B

[Borrado] #8245 Jul '20

En mis tiempos todo esto era campo y el primer año de carrera te lo comías con Modula 2 o Ada.

1 respuesta

JuAn4k4 #8246 Jul '20

#8245 Recuerdo pasarlo bastante mal para que compilase Ada, solo por las definiciones de los tipos, y debía ser sencillo... pero por no parar a entenderlo...

desu #8247 Jul '20

kek tomad a los de fp/uni aqui teneis una practica de 10 gratis de 1 o 2. el map reduce siempre sale.

// main

WordCount.java

public class WordCount
{

public static void main(String[] args) 
{

	WordCountMR wc = new WordCountMR(args);

	wc.Run();

	System.exit(0);
}

}

// Word Count Map reduce

WordCountMR.java

import java.util.Collection;

public class WordCountMR extends MapReduce
{

public WordCountMR(String[] args) 
{
	// Procesar argumentos.
	if (args.length!=2)
		throw new IllegalArgumentException("Illegal command line argument: WordCount <input dir> <ouput dir>.\n");

	SetInputPath(args[0]);
	SetOutputPath(args[1]);
	SetReducers(1);
}

// Word Count Map.
@Override
public Error Map(Map map, MapInputTuple tuple)
{
	String value = tuple.getValue();

	if (MapReduce.DEBUG) System.err.println("DEBUG::MapWordCount procesing tuple " + tuple.getKey() + " -> "+ tuple.getValue());
	
	
	// Convertir todos los posibles separadores de palabras a espacios.
	value = value.replace(":", " ");
	value = value.replace(".", " ");
	value = value.replace(";", " ");
	value = value.replace(",", " ");
	value = value.replace("\"", " ");
	value = value.replace("\\", " ");
	value = value.replace("(", " ");
	value = value.replace(")", " ");
	value = value.replace("[", " ");
	value = value.replace("]", " ");
	value = value.replace("?", " ");
	value = value.replace("¿", " ");
	value = value.replace("!", " ");
	value = value.replace("¡", " ");
	value = value.replace("%", " ");
	value = value.replace("<", " ");
	value = value.replace(">", " ");
	value = value.replace("-", " ");
	value = value.replace("_", " ");
	value = value.replace("#", " ");
	value = value.replace("*", " ");
	value = value.replace("/", " ");

	// Emit map result (word,'1').
	for (String word : value.split("\\s+")) 
    	map.EmitResult(word,1);

	return(Error.COk);
}


// Word Count Reduce.
@Override
public Error Reduce(Reduce reduce, String key, Collection<Integer> values)
{
	int totalCount=0;

	if (MapReduce.DEBUG) System.err.print("DEBUG::ReduceWordCount key " + key +"s -> ");

	// Procesar todas los valores para esta clave.
	for(int number : values)
	{
		if (MapReduce.DEBUG) System.err.print(" " + number);
		totalCount +=  number;
	}

	if (MapReduce.DEBUG) System.err.println(" ==> " + totalCount);

	reduce.EmitResult(key, totalCount);

	return(Error.COk);
}

}

Error.java

public enum Error {
COk, CError, CErrorOpenInputDir, CErrorOpenInputFile, CErrorReadingFile,
CErrorOpenOutputFile;

public static void showError(String message) 
{ 
	System.err.println(message); 
	System.exit(1); 
}

}

Reduce.java

import java.io.FileNotFoundException;
import java.io.PrintWriter;
import java.util.Collection;
import java.util.Iterator;

import com.google.common.collect.ArrayListMultimap;
import com.google.common.collect.ListMultimap;
import com.google.common.collect.Multimaps;

class Reduce
{
private MapReduce mapReduce;
PrintWriter OutputFile;
private ListMultimap<String, Integer> Input = Multimaps.synchronizedListMultimap(ArrayListMultimap.<String, Integer> create());

	
// Constructor para una tarea Reduce, se le pasa la función que reducción que tiene que 
// ejecutar para cada tupla de entrada y el nombre del fichero de salida en donde generará 
// los resultados.

public Reduce(MapReduce mapr, String OutputPath)
{
	mapReduce = mapr;
	try {
		OutputFile = new PrintWriter(OutputPath);
	} 
	catch (FileNotFoundException e) 
	{
		System.err.println("Reduce::ERROR Open output file " + OutputPath + ".");
		e.printStackTrace();
	} 
}


// Finish: cierra fichero salida.
public void Finish()
{
	OutputFile.close();
}


// Función para añadir las tuplas de entrada para la función de redución en forma de lista de 
// tuplas (key,value).
public void AddInputKeys(String key, Collection<Integer> values)
{
	for (Integer value : values)
		AddInput(key, value);
}


private void AddInput(String key, Integer value)
{
	if (MapReduce.DEBUG) System.err.println("DEBUG::Reduce add input "+ key + "-> " + value);
	Input.put(key,value);
}


// Función de ejecución de la tarea Reduce: por cada tupla de entrada invoca a la función 
// especificada por el programador, pasandolo el objeto Reduce, la clave y la lista de 
// valores.
public Error Run() 
{
	Iterator<String> keyIterator = Input.keySet().iterator();
	while(keyIterator.hasNext())
	{
		String key = keyIterator.next();
		
		Error err = mapReduce.Reduce(this, key, Input.get(key));
		if (err!=Error.COk)
			return(err);
		
		keyIterator.remove();
	}
	
	Finish();
	
	return(Error.COk);
}


// Función para escribir un resulta en el fichero de salida.
public void EmitResult(String key, int value)
{
	OutputFile.write(key + " " + value + "\n");
}

}

Map.java

import java.io.;
import java.util.List;
import java.util.Vector;
import com.google.common.collect.;

class MapInputTuple
{
long Key;
String Value;

public MapInputTuple(long key, String value) 
{
	setKey(key);
	setValue(value);
}
	
public long getKey() { return(Key); }
public void setKey(long key) { Key = key; }

public String getValue() { return(Value); }
public void setValue(String value) { Value=value; }

}

public class Map
{
private MapReduce mapReduce;
private Vector<MapInputTuple> Input = new Vector<MapInputTuple>();
private ListMultimap<String, Integer> Output = Multimaps.synchronizedListMultimap(ArrayListMultimap.<String, Integer> create());


public Map(MapReduce mapr)
{	
	mapReduce=mapr;
}


public ListMultimap<String, Integer> GetOutput()
{
	return(Output);
}


public void PrintOutputs()
{
	for (String key : Output.keySet())
	{
		List<Integer> ocurrences = Output.get(key);
		System.out.println("Map " + this + " Output: key: "+ key + " -> " + ocurrences);
	}
}
	
// Lee fichero de entrada (split) línea a línea y lo guarda en una cola del Map en forma de
// tuplas (key,value).
public Error ReadFileTuples(String fileName)
{
	long Offset=0;
	FileInputStream fis;
	
	try {
		fis = new FileInputStream(fileName);
	} catch (FileNotFoundException e) {
		System.err.println("Map::ERROR File "+fileName+" not found.");
		e.printStackTrace();
		return(Error.CErrorOpenInputFile);
	}
	 
	//Construct BufferedReader from InputStreamReader
	BufferedReader br = new BufferedReader(new InputStreamReader(fis));
 
	String line = null;
	try {
		while ((line = br.readLine())!=null) 
		{
			if (MapReduce.DEBUG) System.err.println("DEBUG::Map input " + Offset + " -> " + line);
			AddInput(new MapInputTuple(Offset, line));
		    Offset+=line.length();
		}
	} catch (IOException e) {
		System.err.println("Map::ERROR Reading file "+fileName+".");
		e.printStackTrace();
		return(Error.CErrorReadingFile);
	}
	try {
		br.close();
	} catch (IOException e) {
		e.printStackTrace();
		return(Error.CErrorReadingFile);
	}

	return(Error.COk);
}


public void AddInput(MapInputTuple tuple)
{
	Input.add(tuple);
}


// Ejecuta la tarea de Map: recorre la cola de tuplas de entrada y para cada una de ellas
// invoca a la función de Map especificada por el programador.
public Error Run() 
{
	Error err;

	while (!Input.isEmpty())
	{
		if (MapReduce.DEBUG) System.err.println("DEBUG::Map process input tuple " + Input.get(0).getKey() +" -> " + Input.get(0).getValue());
		err = mapReduce.Map(this, Input.get(0));
		if (err!=Error.COk)
			return(err);

		Input.remove(0);
	}

	return(Error.COk);
}



// Función para escribir un resultado parcial del Map en forma de tupla (key,value)
public void EmitResult(String key, int value)
{
	if (MapReduce.DEBUG) System.err.println("DEBUG::Map emit result " + key + " -> " + value);
	Output.put(key,new Integer(value));
}

}

MapReduce.java

import java.io.File;
import java.util.Collection;
import java.util.Vector;

abstract class MapReduce
{
public static final boolean DEBUG = false;

private String 	InputPath;
private String 	OutputPath;
	
private Vector<Map> Mappers =  new Vector<Map>();
private Vector<Reduce> Reducers =  new Vector<Reduce>();

public MapReduce()
{
	SetInputPath("");
	SetOutputPath("");
}
	
// Constructor MapReduce: número de reducers a utilizar. Los parámetros de directorio/fichero entrada 
// y directorio salida se inicilizan mediante Set* y las funciones Map y reduce sobreescribiendo los
// métodos abstractos.

public MapReduce(String input, String output, int nReducers)
{
	SetInputPath(input);
	SetOutputPath(output);
	SetReducers(nReducers);
}


private void AddMap(Map map) 
{ 
	Mappers.add(map); 
}

private void AddReduce(Reduce reducer) 
{ 
	Reducers.add(reducer); 
}
	

public void SetInputPath(String path) {
	InputPath = path;
}

public void SetOutputPath(String path) {
	OutputPath = path;
}

public void SetReducers(int nReducers)
{
	for(int x=0;x<nReducers;x++)
	{
		AddReduce(new Reduce(this, OutputPath+"/result.r"+(x+1)));
	}
}


// Procesa diferentes fases del framework mapreduc: split, map, suffle/merge, reduce.
public Error Run()
{
	if (Split(InputPath)!=Error.COk)
		Error.showError("MapReduce::Run-Error Split");

	if (Maps()!=Error.COk)
		Error.showError("MapReduce::Run-Error Map");

	if (Suffle()!=Error.COk)
		Error.showError("MapReduce::Run-Error Merge");

	if (Reduces()!=Error.COk)
		Error.showError("MapReduce::Run-Error Reduce");

	return(Error.COk);
}


// Genera y lee diferentes splits: 1 split por fichero.
// Versión secuencial: asume que un único Map va a procesar todos los splits.
private Error Split(String input)
{
	File folder = new File(input);

	Map map = new Map(this);
	AddMap(map);
	
	if (folder.isDirectory()) 
	{
		File[] listOfFiles = folder.listFiles();
	
		/* Read all the files and directories within directory */
	    for (int i = 0; i < listOfFiles.length; i++) 
	    {
	    	if (listOfFiles[i].isFile()) 
	    	{
	    		System.out.println("Processing input file " + listOfFiles[i].getAbsolutePath() + ".");
	    		map.ReadFileTuples(listOfFiles[i].getAbsolutePath());
	    	}
	    	else if (listOfFiles[i].isDirectory()) {
	    		System.out.println("Directory " + listOfFiles[i].getName());
	    	}
	    }
	}
	else 
	{
		System.out.println("Processing input file " + folder.getAbsolutePath() + ".");
		map.ReadFileTuples(folder.getAbsolutePath());
	}
	
	return(Error.COk);
}


// Ejecuta cada uno de los Maps.
private Error Maps()
{	
	for(Map map : Mappers)
	{
		if (MapReduce.DEBUG) System.err.println("DEBUG::Running Map "+ map);
		if (map.Run()!=Error.COk)
			Error.showError("MapReduce::Map Run error.\n");
	}
	
	return(Error.COk);
}


public Error Map(Map map, MapInputTuple tuple)
{
	System.err.println("MapReduce::Map -> ERROR map must be override.");
	return(Error.CError);
}



// Ordena y junta todas las tuplas de salida de los maps. Utiliza una función de hash como 
// función de partición, para distribuir las claves entre los posibles reducers.
// Utiliza un multimap para realizar la ordenación/unión.
private Error Suffle()
{
	for(Map map : Mappers)
	{
		if (MapReduce.DEBUG) map.PrintOutputs();

		for (String key : map.GetOutput().keySet())
		{		    
		    // Calcular a que reducer le corresponde está clave:
			int r = key.hashCode()%Reducers.size();

			if (MapReduce.DEBUG) System.err.println("DEBUG::MapReduce::Suffle merge key " + key +" to reduce " + r);

			// Añadir todas las tuplas de la clave al reducer correspondiente.
			Reducers.get(r).AddInputKeys(key, map.GetOutput().get(key));			
		}
		
		// Eliminar todas las salidas.
		map.GetOutput().clear();
	}
	
	return(Error.COk);
}


// Ejecuta cada uno de los Reducers.
private Error Reduces()
{
	for(Reduce reduce : Reducers)
	{
		if (reduce.Run()!=Error.COk)
			Error.showError("MapReduce::Reduce Run error.\n");
	}
	return(Error.COk);
}

	

public Error Reduce(Reduce reduce, String key, Collection<Integer> values)
{
	System.err.println("MapReduce::Reduce  -> ERROR Reduce must be override.");
	return(Error.CError);
}

}

Voy a bajarme todas mis practicas y en septiembre se las voy a pasar por whastapp/discord lo que sea del grupo de primero.

Los que no sois dinosaurios, hasta donde hicisteis de la practica de pacman de berkeley? esa es mitica xddd

Ranthas #8248 Jul '20

import java.util.Vector

Virgen queridísima, luego los dinosaurios somos nosotros xDDDDDDDDDDDDDDDDDDDDDDDDDDD

1 1 respuesta

r2d2rigo #8249 Jul '20 Inocente

Codigo en ingles y comentarios en espa;ol, para que quede claro que lo has sacado del rincon del vago.

1 1 respuesta

desu #8250 Jul '20

#8249 #8248 Los comentarios para el profe. El vector es porque es syncronized no?

Plot twist, ese codigo lo entregue yo (por eso lo tengo) pero lo pico mi comp;aero que suele hacer c# por eso las mayusculas... xddd de ese codigo he picado 0 lineas ni lo mire antes de entregar.

como haciais las practicas en vuestra epoca? se hacia lo de repartiros las asignaturas? o como lo haciais?

2 respuestas

Feda /dev/ - No Javascript allowed

Normas basicas de convivencia:

Memes Feda/dev

Usuarios habituales