Index: trunk/Basic.java =================================================================== --- trunk/Basic.java (revision 26) +++ (revision ) @@ -1,34 +1,0 @@ -class ClasseAttiva extends Thread{ - public void run(){ - while (true) { - try { - Thread.sleep(100); - } - catch(InterruptedException e){ - System.err.println(e); - } - System.out.println(this.getName()); - } - } -} - -public class Basic { - public static final void main(final String[] args) { - ClasseAttiva o1 = new ClasseAttiva(); - ClasseAttiva o2 = new ClasseAttiva(); - o1.start(); - o2.start(); - while (true){ - try { - Thread.sleep(100); - } - catch(InterruptedException e){ - System.err.println(e); - } - - System.out.println("Main thread"); - } - - } -} - Index: trunk/Boot.s =================================================================== --- trunk/Boot.s (revision 26) +++ (revision ) @@ -1,109 +1,0 @@ -/* set to 16 bit mode (80x86 begin in real mode) text section to 0 */ -.code16 -.text -.org 0x00 - -.global _start -_start: - mov $0x07C0,%ax - mov %ax,%ds - - call booting - xor %dx,%dx /* test if dx == 0 */ - call working - call idleloop - ret - -booting: - mov $boot,%si - call message - call nl - ret - -message: - cld /* set direction to increment */ - lodsb - or %al,%al - jz done - mov $0xE,%ah - mov $7,%bx - int $0x10 - jmp message - -done: - ret - -nl: - mov $newline,%si - call message - ret - -working: - call nl - call nl - mov $device,%si - call message - call waitenter - inc %dx - cmp $3,%dx - je keyboard - jmp working - -waitenter: - call nl - movw $cont,%si - call message - xor %ax,%ax /* Sets AH=0 and AL=0 */ - int $0x16 /* Wait for keypress */ - cmp 'T',%al - jz taz - cmp 't',%al - jz taz - cmp $13,%al - jnz waitenter - ret - -keyboard: - call nl - call nl - movw $kbd,%si - call message - call nl - movw cont,%si - call message - ret - -taz: - call nl - call nl - movw tazq,%si - call message - jmp waitenter - -idleloop: - hlt - jmp idleloop - -boot: - .ascii "Loading UniOS 1.1 Beta..." -newline: - .byte 10, 13, 0 -device: - .ascii "Device not responding to SCSI command." -cont: - .ascii "Hit ENTER to continue..." -kbd: - .ascii "Keyboard not responding to SCSI command." -tazq: - .ascii "Yes, TazQ is an Internet crack monkey on wheels." - -/* Fill with zero until boottag */ -padlen: - .byte boottag - . - -.fill 10,1,0 -/* times 510-($-$$) db 0 */ - -.org 510 -boottag: - .word 0xAA55 Index: trunk/Makefile =================================================================== --- trunk/Makefile (revision 26) +++ (revision ) @@ -1,49 +1,0 @@ -TARGET_ARCH=-m32 -ASM=nasm -CFLAGS=-masm=intel -Wall - -mioboot: mioboot.asm - $(ASM) -l $@.lst -o $@ $< - -mioboot-nobios: mioboot-nobios.asm - $(ASM) -l $@.lst -o $@ $< - -mioboot-nobios-simple: mioboot-nobios-simple.asm - $(ASM) -l $@.lst -o $@ $< - - -esercizio.o: esercizio.asm - $(ASM) -felf $< - -esercizio: esercizio.o - -pthreads-pc rw rw-nosync rw-mutex rw-rlotto: LDFLAGS=-lpthread - -pthreads-pc: pthreads-pc.c - -fork-pc: fork-pc.c - -tsl.o: tsl.asm - $(ASM) -felf tsl.asm - -tsl: tsl.o - -enter.o: enter.asm - $(ASM) -felf enter.asm - -threads-tsl: threads-tsl.o enter.o - -threads-tsl-new: threads-tsl-new.c - -%.tex : %.nw - noweave -delay -filter btdefn -index -filter "awk -f lst.awk|tee debug" $< > $@ - -%.c : %.nw - notangle -R$@ -filter btdefn $< > $@ - -%.pdf : %.tex - pdflatex $< && pdflatex $< && pdflatex $< - -.PHONY: clean -clean: - rm -f mioboot mioboot-nobios mioboot-nobios-simple *.lst *~ semantic.cache esegui forca Index: trunk/PC.java =================================================================== --- trunk/PC.java (revision 26) +++ (revision ) @@ -1,124 +1,0 @@ -/** - * Describe class PC here. - * - * - * Created: Fri Jun 8 14:32:29 2007 - * - * @author Mattia Monga - * @version 1.0 - */ - -class Actor extends Thread -{ - public Actor(String nome){ - super(nome); - } - - private Magazzino shared; - public final Magazzino getShared() { - return shared; - } - public final void setShared(final Magazzino newShared) { - this.shared = newShared; - } - -} - - -class Produttore extends Actor { - public Produttore(String nome, Magazzino b) { - super(nome); - setShared(b); - } - - public void run(){ - int i = 0; - while(true){ - System.out.println(getName() + ": Inserisco " + i + " nel buffer"); - getShared().put(i); - i += 1; - } - } -} - -class Consumatore extends Actor{ - public Consumatore(String nome, Magazzino b) { - super(nome); - setShared(b); - } - public void run(){ - while(true){ - int i = getShared().get(); - System.out.println(getName() + ": Estraggo " + i + " dal buffer"); - - } - } -} - -class Magazzino{ - public final static int SIZE = 10; - private int[] memory = new int[SIZE]; - private int quanti = 0; - - public final int get() { - String n = Thread.currentThread().getName(); - synchronized(syncPC){ - while(isVuoto()){ - System.out.println(n + " ha tentato di leggere"); - try { - syncPC.wait(); - } catch (InterruptedException e) { - System.err.println(e); - } - } - int ris = memory[--quanti]; - if (quanti == SIZE - 1) syncPC.notifyAll(); - System.out.println(n + " ha letto"); - return ris; - } - } - - public final void put(final int newMemory) { - String n = Thread.currentThread().getName(); - synchronized(syncPC){ - while (isPieno()){ - System.out.println(n + " ha tentato di scrivere"); - try { - syncPC.wait(); - } catch (InterruptedException e) { - e.printStackTrace(System.err); - } - } - memory[quanti++] = newMemory; - if (quanti == 1) syncPC.notifyAll(); - System.out.println(n + " ha scritto"); - } - } - - public final boolean isVuoto() { - return quanti == 0; - } - - public final boolean isPieno() { - return quanti == SIZE; - } - - private Object syncPC = new Object(); -} - - -public class PC { - - public static final void main(final String[] args) { - Magazzino x = new Magazzino(); - Produttore a1 = new Produttore("Aldo", x); - Produttore a2 = new Produttore("Alberto", x); - Consumatore b = new Consumatore("Barbara", x); - a1.start(); - b.start(); - a2.start(); - } - -} - - Index: trunk/PCMon.java =================================================================== --- trunk/PCMon.java (revision 26) +++ (revision ) @@ -1,133 +1,0 @@ -/** - * Describe class PC here. - * - * - * Created: Fri Jun 8 14:32:29 2007 - * - * @author Mattia Monga - * @version 1.0 - */ -import java.util.concurrent.locks.*; - -class Actor extends Thread -{ - public Actor(String nome){ - super(nome); - } - - private Magazzino shared; - public final Magazzino getShared() { - return shared; - } - public final void setShared(final Magazzino newShared) { - this.shared = newShared; - } - -} - - -class Produttore extends Actor { - public Produttore(String nome, Magazzino b) { - super(nome); - setShared(b); - } - - public void run(){ - int i = 0; - while(true){ - System.out.println(getName() + ": Inserisco " + i + " nel buffer"); - getShared().put(i); - i += 1; - } - } -} - -class Consumatore extends Actor{ - public Consumatore(String nome, Magazzino b) { - super(nome); - setShared(b); - } - public void run(){ - while(true){ - int i = getShared().get(); - System.out.println(getName() + ": Estraggo " + i + " dal buffer"); - - } - } -} - -class Magazzino{ - public final static int SIZE = 10; - private int[] memory = new int[SIZE]; - private int quanti = 0; - - public final int get() { - monitor.lock(); - int ris = -1; - try{ - String n = Thread.currentThread().getName(); - while (isVuoto()){ - System.out.println(n + " ha tentato di leggere"); - empty.await(); - } - ris = memory[--quanti]; - if (quanti == SIZE - 1) full.signal(); - System.out.println(n + " ha letto"); - } catch (InterruptedException e){ - System.err.println(e); - } finally { - monitor.unlock(); - return ris; - } - } - - public final void put(final int newMemory) { - monitor.lock(); - try{ - String n = Thread.currentThread().getName(); - while (isPieno()){ - System.out.println(n + " ha tentato di scrivere"); - full.await(); - } - memory[quanti++] = newMemory; - if (quanti == 1) empty.signal(); - System.out.println(n + " ha scritto"); - } catch (InterruptedException e){ - System.err.println(e); - } finally { - monitor.unlock(); - } - } - - public final boolean isVuoto() { - return quanti == 0; - } - - public final boolean isPieno() { - return quanti == SIZE; - } - - - private static final Lock monitor = new ReentrantLock(); - private static final Condition empty = monitor.newCondition(); - private static final Condition full = monitor.newCondition(); - - -} - - -public class PCMon { - - public static final void main(final String[] args) { - Magazzino x = new Magazzino(); - Produttore a1 = new Produttore("Aldo", x); - Produttore a2 = new Produttore("Alberto", x); - Consumatore b = new Consumatore("Barbara", x); - a1.start(); - b.start(); - a2.start(); - } - -} - - Index: trunk/PCSem.java =================================================================== --- trunk/PCSem.java (revision 26) +++ (revision ) @@ -1,117 +1,0 @@ -/** - * Describe class PC here. - * - * - * Created: Fri Jun 8 14:32:29 2007 - * - * @author Mattia Monga - * @version 1.0 - */ - -import java.util.concurrent.Semaphore; - -class Actor extends Thread -{ - public Actor(String nome){ - super(nome); - } - - private Magazzino shared; - public final Magazzino getShared() { - return shared; - } - public final void setShared(final Magazzino newShared) { - this.shared = newShared; - } - -} - - -class Produttore extends Actor { - public Produttore(String nome, Magazzino b) { - super(nome); - setShared(b); - } - - public void run(){ - int i = 0; - while(true){ - System.out.println(getName() + ": Inserisco " + i + " nel buffer"); - getShared().put(i); - i += 1; - } - } -} - -class Consumatore extends Actor{ - public Consumatore(String nome, Magazzino b) { - super(nome); - setShared(b); - } - public void run(){ - while(true){ - int i = getShared().get(); - System.out.println(getName() + ": Estraggo " + i + " dal buffer"); - - } - } -} - -class Magazzino{ - public final static int SIZE = 10; - private int[] memory = new int[SIZE]; - private int quanti = 0; - - public final int get() { - try{ - String n = Thread.currentThread().getName(); - pieno.acquire(); - mutex.acquire(); - int ris = memory[--quanti]; - mutex.release(); - vuoto.release(); - - System.out.println(n + " ha letto"); - return ris; - } - catch(InterruptedException e){ - System.err.println(e); - return -1; - } - } - - public final void put(final int newMemory) { - try{ - String n = Thread.currentThread().getName(); - vuoto.acquire(); - mutex.acquire(); - memory[quanti++] = newMemory; - mutex.release(); - pieno.release(); - System.out.println(n + " ha scritto"); - } - catch(InterruptedException e){ - System.err.println(e); - } - } - - private static final Semaphore mutex = new Semaphore(1); - private static final Semaphore pieno = new Semaphore(0); - private static final Semaphore vuoto = new Semaphore(SIZE); - -} - - -public class PCSem { - - public static final void main(final String[] args) { - Magazzino x = new Magazzino(); - Produttore a1 = new Produttore("Aldo", x); - Produttore a2 = new Produttore("Alberto", x); - Consumatore b = new Consumatore("Barbara", x); - a1.start(); - b.start(); - a2.start(); - } - -} Index: trunk/SemPC.java =================================================================== --- trunk/SemPC.java (revision 26) +++ (revision ) @@ -1,73 +1,0 @@ -import java.util.Vector; -import java.util.concurrent.Semaphore; - -public class SemPC{ - public static final int N = 10; - public static final void main(final String[] args) { - Vector shared = new Vector(N); - Semaphore mutex = new Semaphore(1); - Semaphore empty = new Semaphore(N); - Semaphore full = new Semaphore(0); - Producer p = new Producer(shared, mutex, empty, full); - Consumer c = new Consumer(shared, mutex, empty, full); - p.start(); c.start(); - } -} - -class Agent extends Thread{ - protected Vector buf; - protected Semaphore mutex; - protected Semaphore empty; - protected Semaphore full; - public Agent(String name, Vector b, - Semaphore _mutex, Semaphore _empty, Semaphore _full){ - super(name); - this.buf = b; - this.mutex = _mutex; - this.full = _full; - this.empty = _empty; - } -} - -class Producer extends Agent{ - public Producer(Vector b, - Semaphore _mutex, Semaphore _empty, Semaphore _full) { - super("Producer", b, _mutex, _empty, _full); - } - public void run(){ - while (true){ - Object o = new Object(); - System.out.println("Ho prodotto " + o); - try { - this.empty.acquire(); - this.mutex.acquire(); - this.buf.add(o); - this.mutex.release(); - this.full.release(); - } catch (InterruptedException e) { - System.err.println(e); - } - } - } -} - -class Consumer extends Agent{ - public Consumer(Vector b, - Semaphore _mutex, Semaphore _empty, Semaphore _full) { - super("Consumer", b, _mutex, _empty, _full); } - public void run(){ - while (true){ - try { - this.full.acquire(); - this.mutex.acquire(); - Object o = this.buf.remove(0); - System.out.println("Ho consumato " + o); - this.mutex.release(); - this.empty.release(); - } catch (InterruptedException e) { - System.out.println(e); - } - } - } -} - Index: trunk/Shared.java =================================================================== --- trunk/Shared.java (revision 26) +++ (revision ) @@ -1,46 +1,0 @@ -class ClasseAttiva extends Thread{ - protected static int shared = 0; - public void run() { - while (true) { - if (shared >= 10) break; - try { - Thread.sleep(1000); - } - catch(InterruptedException e){ - System.err.println(e); - } - if (shared >= 10){ - throw new Error("Corsa critica!!!"); - } - System.out.print(this.getName()); - System.out.print(" s = "); - System.out.println(this.shared); - shared += 1; - } - } -} - - - -public class Shared { - public static final void main(final String[] args) { - ClasseAttiva o1 = new ClasseAttiva(); - ClasseAttiva o2 = new ClasseAttiva(); - o1.start(); - o2.start(); - while (true){ - try { - Thread.sleep(1000); - } - catch(InterruptedException e){ - System.err.println(e); - } - - System.out.println("Main thread"); - } - - } -} - - - Index: trunk/Shared2.java =================================================================== --- trunk/Shared2.java (revision 26) +++ (revision ) @@ -1,50 +1,0 @@ -class ClasseAttiva extends Thread{ - protected static int shared = 0; - protected static Object lock = new Object(); - public void run() { - while (true) { - synchronized(lock){ - if (shared >= 10) break; - try { - Thread.sleep(1000); - } - catch(InterruptedException e){ - System.err.println(e); - } - if (shared >= 10){ - throw new Error("Corsa critica!!!"); - } - System.out.print(this.getName()); - System.out.print(" s = "); - System.out.println(this.shared); - shared += 1; - } - Thread.yield(); // non necessaria, ma favorisce lo scheduling di entrambi - } - } -} - - - -public class Shared2 { - public static final void main(final String[] args) { - ClasseAttiva o1 = new ClasseAttiva(); - ClasseAttiva o2 = new ClasseAttiva(); - o1.start(); - o2.start(); - while (true){ - try { - Thread.sleep(1000); - } - catch(InterruptedException e){ - System.err.println(e); - } - - System.out.println("Main thread"); - } - - } -} - - - Index: trunk/alea.sh =================================================================== --- trunk/alea.sh (revision 26) +++ (revision ) @@ -1,26 +1,0 @@ -SHARED_MEM=lock -echo 0 > $SHARED_MEM - -processo(){ # name - for i in $(seq 1000); do - while grep 1 $SHARED_MEM >/dev/null ; do true; done - echo 1 > $SHARED_MEM - critical_session $1 - echo 0 > $SHARED_MEM - io - done -} -critical_session(){ - for i in 1 2 3; do - echo -n $1 - io - done - echo . -} - -io(){ - dd if=/dev/zero of=/dev/null count=1000 2>/dev/null -} - -processo pippo & processo pluto & -wait Index: trunk/alternanza.sh =================================================================== --- trunk/alternanza.sh (revision 26) +++ (revision ) @@ -1,29 +1,0 @@ -SHARED_MEM=turn -echo pippo > $SHARED_MEM - -processo(){ # name - for i in $(seq 100); do - while grep -v $1 $SHARED_MEM >/dev/null ; do true; done - critical_session $1 - if test "$1" = "pippo"; then - echo "pluto" > $SHARED_MEM; - else - echo "pippo" > $SHARED_MEM; - fi - io - done -} -critical_session(){ - for i in 1 2 3; do - echo -n $1 - io - done - echo . -} - -io(){ - dd if=/dev/zero of=/dev/null count=1000 2>/dev/null -} - -processo pippo & processo pluto & -wait Index: trunk/dekker1.sh =================================================================== --- trunk/dekker1.sh (revision 26) +++ (revision ) @@ -1,32 +1,0 @@ -#! /bin/bash - -turno=1 - -function p1(){ - for i in $(seq 1 10); do - local ddone=$(false) - while ! [ $ddone ]; do - while [ $turno -eq 2 ]; do - echo $i - ddone=$(true) - turno=2 - done - done - done -} - -function p2(){ - for i in $(seq 11 20); do - local ddone=$(false) - while ! [ $ddone ]; do - while [ $turno -eq 1 ]; do - echo $i - ddone=$(true) - turno=1 - done - done - done -} - -p1 & p2 & -wait %1 %2 Index: trunk/enter.asm =================================================================== --- trunk/enter.asm (revision 26) +++ (revision ) @@ -1,17 +1,0 @@ -section .text -global enter_section - -enter_section: - enter 0, 0 ; 0 bytes of local stack space - mov ebx,[ebp+8] ; first parameter to function - - -;; bts bitbase bitoffset -;; selects the bitoffset bit in bitbase, -;; stores the value in the CF flag, and sets the bit to 1 -spin: lock bts dword [ebx], 0 - jc spin - - leave ; mov esp,ebp / pop ebp - ret - Index: trunk/enter2.asm =================================================================== --- trunk/enter2.asm (revision 26) +++ (revision ) @@ -1,19 +1,0 @@ -section .text -global enter_section -extern printf - -enter_section: - enter 0, 0 ; 0 bytes of local stack space - mov ebx,[ebp+8] ; first parameter to function - - -spin: push busy - call printf - lock bts dword [ebx], 0 - jc spin - - leave ; mov esp,ebp / pop ebp - ret - -section .rodata -busy: db "Busy waiting!",10,0 Index: trunk/esegui.c =================================================================== --- trunk/esegui.c (revision 26) +++ (revision ) @@ -1,24 +1,0 @@ -#include -#include -#include - -int main(){ - int x = fork(); - if (x < 0){ - perror("Errore nella fork:"); - exit(1); - } else { - if (x != 0){ - printf("Processo padre\n"); - } else { - char* argv[] = {"/bin/ls", "/usr", 0}; - execv("/bin/ls",argv ); - perror("Errore nella exec:"); - } - } - return 0; -} - - - - Index: trunk/esercizio.asm =================================================================== --- trunk/esercizio.asm (revision 26) +++ (revision ) @@ -1,27 +1,0 @@ - ;; uguale all'esame..... - -segment .text - global main - extern printf,exit - -main: push dword 3 - push dword 5 - mov ebp,esp - mov eax,[esp] - mov ebx,[ebp] - add eax, ebx - add esp, 4 - mov ebx,[esp] - push ebx - push eax - push dword format - call printf - add esp, 4*3 - push dword 0 - call exit - hlt - -segment .rodata -format: db "EAX %d, EBX %d",0x0a,0 ; 0x0a -> a capo - - Index: trunk/filefigli.c =================================================================== --- trunk/filefigli.c (revision 26) +++ (revision ) @@ -1,83 +1,0 @@ -/* Copyright (C) 2012 by Mattia Monga */ -/* $Id$ */ - -#include -#include -#include -#include -#include -#include -#include -#include - -void lsofd(const char* name){ - int i; - for (i=0; i<_POSIX_OPEN_MAX; i++){ - struct stat buf; - if (fstat(i, &buf) == 0){ - printf("%s fd:%d i-node: %d\n", name, i, buf.st_ino); - } - } -} - -main(){ - pid_t pid; - int f, off; - char string[] = "Hello, world!\n"; - - lsofd("padre (senza figli)"); - printf("padre (senza figli) pipe *\n"); - f = open("provaxxx.dat", O_CREAT|O_WRONLY|O_TRUNC, S_IRWXU); - if (f == -1){ - perror("pipe"); - exit(1); - } - lsofd("padre (senza figli)"); - if (write(f, string, (strlen(string))) != (strlen(string)) ){ - perror("write"); - exit(1); - } - - off = lseek(f, 0, SEEK_CUR); - printf("padre (senza figli) seek: %d\n", off); - - printf("padre (senza figli) fork *\n"); - if ( (pid = fork()) < 0){ - perror("fork"); - exit(1); - } - if (pid > 0){ - lsofd("padre"); - printf("padre close *\n"); - printf("padre write *\n"); - off = lseek(f, 0, SEEK_CUR); - printf("padre seek prima: %d\n", off); - if (write(f, string, (strlen(string))) != (strlen(string)) ){ - perror("write"); - exit(1); - } - lsofd("padre"); - off = lseek(f, 0, SEEK_CUR); - printf("padre seek dopo: %d\n", off); - exit(0); - } - else { - lsofd("figlio"); - printf("figlio close *\n"); - printf("figlio write *\n"); - off = lseek(f, 0, SEEK_CUR); - printf("figlio seek prima: %d\n", off); - if (write(f, string, (strlen(string))) != (strlen(string)) ){ - perror("write"); - exit(1); - } - lsofd("figlio"); - off = lseek(f, 0, SEEK_CUR); - printf("figlio seek dopo: %d\n", off); - exit(0); - } -} - -/* Local Variables: */ -/* compile-command: "make -k " */ -/* End: */ Index: trunk/forca.c =================================================================== --- trunk/forca.c (revision 26) +++ (revision ) @@ -1,18 +1,0 @@ -#include -#include -#include - -int main(void){ - int x = fork(); - if (x < 0){ - perror("Errore nella fork:"); - exit(1); - } - if (x != 0){ - while(1) printf("Processo padre (x == %d)\n", x); - } - else { // x == 0 - while(1) printf("Processo figlio (x == %d)\n", x); - } - return 0; -} Index: trunk/fork-pc.c =================================================================== --- trunk/fork-pc.c (revision 26) +++ (revision ) @@ -1,81 +1,0 @@ -/* Copyright (C) 2008 by Mattia Monga */ -/* $Id$ */ -#include -#include -#include -#include - -void b_insert(char*); -void b_remove(char**); - - -void producer(void) -{ - while (1){ - char* o = (char*)malloc(sizeof(char)); - printf("Ho prodotto %x\n", o); - b_insert(o); - } -} - -void consumer(void) -{ - while (1){ - char* o; - b_remove(&o); - free(o); - printf("Ho consumato %x\n", o); - } -} - -int main(void){ - - int p, c; - - p = fork(); - if (p == 0) producer(); - c = fork(); - if (c == 0) consumer(); - - waitpid(-1, NULL, 0); - - return 0; -} - -#define N 10 -char* buffer[N]; -int count = 0; - -pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER; -pthread_cond_t full = PTHREAD_COND_INITIALIZER; -pthread_cond_t empty = PTHREAD_COND_INITIALIZER; - -void b_insert(char* o) -{ - pthread_mutex_lock(&lock); - - if (count == N) pthread_cond_wait(&full, &lock); - buffer[count++] = o; - if (count == 1) pthread_cond_signal(&empty); - - pthread_mutex_unlock(&lock); -} - -/* passaggio per indirizzo per evitare di fare la return fuori dai lock */ -void b_remove(char** result) -{ - pthread_mutex_lock(&lock); - - if (count == 0) pthread_cond_wait(&empty, &lock); - *result = buffer[--count]; - if (count == N-1) pthread_cond_signal(&full); - - pthread_mutex_unlock(&lock); -} - - -/* Local Variables: */ -/* compile-command: "make -k " */ -/* End: */ - - Index: trunk/globale.sh =================================================================== --- trunk/globale.sh (revision 26) +++ (revision ) @@ -1,20 +1,0 @@ - - -globale=0 - -function primo(){ - globale=1; - echo "Primo ha finito" -} - -function secondo(){ - echo "Secondo ha iniziato" - sleep 10 - echo $globale; - echo "Secondo ha finito" -} - - -primo ; secondo ; -primo & secondo & -wait %1 %2 Index: trunk/guardiano.c =================================================================== --- trunk/guardiano.c (revision 26) +++ (revision ) @@ -1,87 +1,0 @@ -/* Copyright (C) 2009 by Mattia Monga */ -/* $Id$ */ - -#include -#include -#include -#include - -pthread_t p1,p2,p3; - -pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER; -pthread_cond_t dodici = PTHREAD_COND_INITIALIZER; -int contatore = 0; - - - -void* guardiano(void* x){ - pthread_mutex_lock(&lock); - while ( contatore < 12){ - printf("Going to block...........\n"); - pthread_cond_wait(&dodici, &lock); - printf("Watcher alive...........\n"); - } - pthread_mutex_unlock(&lock); - printf("Dodici!!!!!\n"); - return NULL; -} - -// Il corpo del ciclo viene eseguito mantenendo il lock -void* incrementatore1(void* x){ - while(pthread_mutex_lock(&lock), contatore < 12){ - contatore += 1; - printf("Sono pippo e sto incrementando: %d\n ", - contatore); - if (contatore == 12) { - printf("Sveglia da pippo!!!!!\n"); - pthread_cond_signal(&dodici); - } - pthread_mutex_unlock(&lock); - pthread_yield(); - } - pthread_mutex_unlock(&lock); - return NULL; -} - -// come il precedente ma scritto con do-while forse e` piu` chiaro -void* incrementatore2(void* x){ - do { - pthread_mutex_lock(&lock); - contatore += 1; - printf("Sono pluto e sto incrementando: %d\n ", - contatore); - if (contatore == 12){ - printf("Sveglia da pluto!!!!!\n"); - pthread_cond_signal(&dodici); - } - pthread_mutex_unlock(&lock); - pthread_yield(); - } while (contatore < 12); - return NULL; -} - - - - -int main(void){ - - pthread_create(&p1, NULL, incrementatore1, NULL); - pthread_create(&p2, NULL, incrementatore2, NULL); - pthread_create(&p3, NULL, guardiano, NULL); - - pthread_join(p1, NULL); - pthread_join(p2, NULL); - pthread_join(p3, NULL); - - return 0; -} - - - - - - - -/* Local Variables: */ -/* compile-command: "make -k " */ -/* End: */ Index: trunk/hello-mod.s =================================================================== --- trunk/hello-mod.s (revision 26) +++ (revision ) @@ -1,49 +1,0 @@ - .section .rodata -.LC0: - .string "Hello world! (%d)\n" -formato: /* la stringa di formato per la scanf */ - .string "%d" - - .data -x: /* una variabile x */ - .int - - .text - .globl main - .type main, @function -main: -.LFB0: - .cfi_startproc - pushl %ebp - .cfi_def_cfa_offset 8 - .cfi_offset 5, -8 - movl %esp, %ebp - .cfi_def_cfa_register 5 - andl $-16, %esp - subl $32, %esp - push $x /* oppure: movl $x, 4(%esp) */ - push $formato /* oppure: movl $formato, (%esp) */ - call scanf - subl $1, (x) /* da 0 a x-1 */ - movl $0, 28(%esp) - jmp .L2 -.L3: - movl 28(%esp), %eax - addl $1, %eax - movl %eax, 4(%esp) - movl $.LC0, (%esp) - call printf - movl $1, (%esp) - call sleep - addl $1, 28(%esp) -.L2: - movl (x), %eax /* compara con x */ - cmpl %eax, 28(%esp) - jle .L3 - movl $0, (%esp) - call exit - .cfi_endproc -.LFE0: - .size main, .-main - .ident "GCC: (Debian 4.7.2-5) 4.7.2" - .section .note.GNU-stack,"",@progbits Index: trunk/hello.c =================================================================== --- trunk/hello.c (revision 26) +++ (revision ) @@ -1,14 +1,0 @@ -/* Copyright (C) 2014 by Mattia Monga */ -/* $Id$ */ - -#include - -int main(){ - printf("Ciao %d %s", 5, "mamma"); - asm("mov eax, 0"); - return 0; -} - -/* Local Variables: */ -/* compile-command: "make -k " */ -/* End: */ Index: trunk/hello.s =================================================================== --- trunk/hello.s (revision 26) +++ (revision ) @@ -1,39 +1,0 @@ - .file "hello.c" - .intel_syntax noprefix - .section .rodata -.LC0: - .string "mamma" -.LC1: - .string "Ciao %d %s" - .text - .globl main - .type main, @function -main: -.LFB0: - .cfi_startproc - push ebp - .cfi_def_cfa_offset 8 - .cfi_offset 5, -8 - mov ebp, esp - .cfi_def_cfa_register 5 - and esp, -16 - sub esp, 16 - mov DWORD PTR [esp+8], OFFSET FLAT:.LC0 - mov DWORD PTR [esp+4], 5 - mov DWORD PTR [esp], OFFSET FLAT:.LC1 - call printf -#APP -# 8 "hello.c" 1 - mov eax, 0 -# 0 "" 2 -#NO_APP - mov eax, 0 - leave - .cfi_restore 5 - .cfi_def_cfa 4, 4 - ret - .cfi_endproc -.LFE0: - .size main, .-main - .ident "GCC: (Debian 4.8.2-18) 4.8.2" - .section .note.GNU-stack,"",@progbits Index: trunk/lamport.sh =================================================================== --- trunk/lamport.sh (revision 26) +++ (revision ) @@ -1,67 +1,0 @@ -#! /bin/bash - -N=2 - -function assegna(){ - echo $2 >> $1 -} - -function leggi(){ - tail -1 $1 -} - - -for j in $(seq 1 $N); do - echo "0">choosing$j - echo "0">number$j -done -echo "1">alternanza - -function max(){ - local m=$(leggi number1) - for j in $(seq 1 $N); do - m=$(( $m > $(leggi number$j) ? $m : $(leggi number$j) )) - done - echo $m -} - - -function p(){ - local p - for p in $(seq $(( $1 * 10 )) $(( $1 * 10 + 9 )) ); do - while true; do - # doorway - assegna choosing$1 "1" - assegna number$1 "$(( 1 + max ))" - # bakery - assegna choosing$1 "0" - local j - for j in $(seq 1 $N); do - while [ $(leggi choosing$j) -ne 0 ]; do - sleep 0.01 - done - while [ \( $(leggi number$j) -ne 0 \) -a \ - \( \( $(leggi number$j) -lt $(leggi number$1) \) -o \ - \( $(leggi number$j) -eq $(leggi number$1) \) -a \ - \( $j -lt $1 \) \) ]; do - sleep 0.01 - done - done - # critical section - if [ $(leggi alternanza) -eq $1 ]; then - echo $p - assegna alternanza "$(( ( $(leggi alternanza) % 2 ) + 1))" - assegna number$1 "0" - break - else - assegna number$1 "0" - fi - # non critical section - done - done -} - -p 1 & -p 2 & - -wait %1 %2 Index: trunk/mioboot-nobios-simple.asm =================================================================== --- trunk/mioboot-nobios-simple.asm (revision 26) +++ (revision ) @@ -1,20 +1,0 @@ -;Copyright (C) 2008, 2009 by Mattia Monga -bits 16 ; 16 bit real mode -org 0x7C00 ; origine indirizzo 0000:7C00 - -start: - mov ax, 0xb800 ; text video memory - mov ds, ax ; ds non accessibile direttamente - mov bx, 10 -write: - cmp bx, 0 - jz end - mov byte [ds:bx], 'm' ; indirizzamento relativo a ds - mov byte [ds:bx+1], 0x0F ; attrib = white on black - sub bx, 2 - jmp write -end: - hlt - -times 510-($-$$) db 0 ; 0-padding -dw 0xAA55 Index: trunk/mioboot-nobios.asm =================================================================== --- trunk/mioboot-nobios.asm (revision 26) +++ (revision ) @@ -1,28 +1,0 @@ -;Copyright (C) 2007 by Mattia Monga -bits 16 ; 16 bit real mode -org 0x7C00 ; origine indirizzo 0000:7C00 - -start: - mov ax, 0xb800 ; text video memory dest array index [ES:DI] - mov es, ax - mov di, 0 ; start of video memory - - cld ; clears direction flag (index regs incremented) - mov ah, 0x0F ; attrib = white on black - mov si, msg - call message - hlt - -message: - lodsb ; carica un byte da [DS:SI] in AL e inc SI - cmp al, 0 - jz done - stosw ; memorizza una word da [ES:DI] in AL e inc SI - jmp message -done: ret - - -msg db "Hello world from the bare machine!!!", 0 - - times 510-($-$$) db 0 - dw 0xAA55 Index: trunk/mioboot.asm =================================================================== --- trunk/mioboot.asm (revision 26) +++ (revision ) @@ -1,49 +1,0 @@ -;Copyright (C) 2008 by Mattia Monga -bits 16 ; 16 bit real mode -org 0x7C00 ; origine indirizzo 0000:7C00 - -start: - cld ; clears direction flag (index regs incremented) - mov si, boot - call message -working: - mov si, work - call message - - call waitenter - jmp working - -message: - lodsb ; carica un byte da [DS:SI] in AL e inc SI - cmp al, 0 - jz done - mov ah, 0x0E ; write char to screen in text mode - mov bx, 0 ; BH page number BL foreground color - int 0x10 ; write AL to screen (BIOS) - jmp message -done: ret - -boot: db "Loading unuseful system...." , 10, 13, 0 -work: db "I've done my unuseful stuff!" , 10, 13, 0 -cont: db "Hit ENTER to continue...", 10, 13, 0 -wow: db "Great! Hello world!" , 10, 13, 0 - -waitenter: mov si, cont - call message - mov ah, 0 - int 0x16 ; Wait for keypress (BIOS) - cmp al, 'm' - jz egg - cmp al, 'b' - jz basic - cmp al, 13 - jnz waitenter - ret -egg: mov si, wow - call message - jmp waitenter -basic: int 0x18 ; basic (BIOS) - hlt - - times 510-($-$$) db 0 - dw 0xAA55 Index: trunk/peterson.sh =================================================================== --- trunk/peterson.sh (revision 26) +++ (revision ) @@ -1,38 +1,0 @@ -SHARED_MEM=turno -echo pippo > $SHARED_MEM - -processo(){ # name other - for i in $(seq 100); do - enter_region $1 $2 - critical_session $1 - leave_region $1 - io - done -} -critical_session(){ - for i in 1 2 3; do - echo -n $1 - io - done - echo . -} - -io(){ - dd if=/dev/zero of=/dev/null count=1000 2>/dev/null -} - -enter_region() { # process other - echo "true" > interested_$1 - echo $1 > $SHARED_MEM - while grep $1 $SHARED_MEM >/dev/null && - grep true interested_$2 >/dev/null ; - do - true; - done -} -leave_region() { # process - echo "false" > interested_$1 -} - -processo pippo pluto & processo pluto pippo & -wait Index: trunk/processi.sh =================================================================== --- trunk/processi.sh (revision 26) +++ (revision ) @@ -1,16 +1,0 @@ -#! /bin/bash - -function p1(){ - for i in $(seq 1 10); do - echo $i - done -} - -function p2(){ - for i in $(seq 11 20); do - echo $i - done -} - -p1 & p2 & -wait %1 %2 Index: trunk/pthreads-counter.c =================================================================== --- trunk/pthreads-counter.c (revision 26) +++ (revision ) @@ -1,114 +1,0 @@ -/****************************************************************************** -* FILE: condvar.c -* DESCRIPTION: -* Example code for using Pthreads condition variables. The main thread -* creates three threads. Two of those threads increment a "count" variable, -* while the third thread watches the value of "count". When "count" -* reaches a predefined limit, the waiting thread is signaled by one of the -* incrementing threads. The waiting thread "awakens" and then modifies -* count. The program continues until the incrementing threads reach -* TCOUNT. The main program prints the final value of count. -* SOURCE: Adapted from example code in "Pthreads Programming", B. Nichols -* et al. O'Reilly and Associates. -* LAST REVISED: 07/16/09 Blaise Barney -******************************************************************************/ -#include -#include -#include - -#define NUM_THREADS 3 -#define TCOUNT 10 -#define COUNT_LIMIT 12 - -int count = 0; -pthread_mutex_t count_mutex; -pthread_cond_t count_threshold_cv; - -void *inc_count(void *t) -{ - int i; - long my_id = (long)t; - - for (i=0; i < TCOUNT; i++) { - pthread_mutex_lock(&count_mutex); - count++; - - /* - Check the value of count and signal waiting thread when condition is - reached. Note that this occurs while mutex is locked. - */ - if (count == COUNT_LIMIT) { - printf("inc_count(): thread %ld, count = %d Threshold reached. ", - my_id, count); - pthread_cond_signal(&count_threshold_cv); - printf("Just sent signal.\n"); - } - printf("inc_count(): thread %ld, count = %d, unlocking mutex\n", - my_id, count); - pthread_mutex_unlock(&count_mutex); - - /* Do some work so threads can alternate on mutex lock */ - sleep(1); - } - pthread_exit(NULL); -} - -void *watch_count(void *t) -{ - long my_id = (long)t; - - printf("Starting watch_count(): thread %ld\n", my_id); - - /* - Lock mutex and wait for signal. Note that the pthread_cond_wait routine - will automatically and atomically unlock mutex while it waits. - Also, note that if COUNT_LIMIT is reached before this routine is run by - the waiting thread, the loop will be skipped to prevent pthread_cond_wait - from never returning. - */ - pthread_mutex_lock(&count_mutex); - while (count < COUNT_LIMIT) { - printf("watch_count(): thread %ld going into wait...\n", my_id); - pthread_cond_wait(&count_threshold_cv, &count_mutex); - } - - printf("watch_count(): thread %ld Condition signal received.\n", my_id); - count += 125; - printf("watch_count(): thread %ld count now = %d.\n", my_id, count); - - pthread_mutex_unlock(&count_mutex); - pthread_exit(NULL); -} - -int main(int argc, char *argv[]) -{ - int i, rc; - long t1=1, t2=2, t3=3; - pthread_t threads[3]; - pthread_attr_t attr; - - /* Initialize mutex and condition variable objects */ - pthread_mutex_init(&count_mutex, NULL); - pthread_cond_init (&count_threshold_cv, NULL); - - /* For portability, explicitly create threads in a joinable state */ - pthread_attr_init(&attr); - pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE); - pthread_create(&threads[0], &attr, watch_count, (void *)t1); - pthread_create(&threads[1], &attr, inc_count, (void *)t2); - pthread_create(&threads[2], &attr, inc_count, (void *)t3); - - /* Wait for all threads to complete */ - for (i = 0; i < NUM_THREADS; i++) { - pthread_join(threads[i], NULL); - } - printf ("Main(): Waited on %d threads. Final value of count = %d. Done.\n", - NUM_THREADS, count); - - /* Clean up and exit */ - pthread_attr_destroy(&attr); - pthread_mutex_destroy(&count_mutex); - pthread_cond_destroy(&count_threshold_cv); - pthread_exit (NULL); - -} Index: trunk/pthreads-pc.c =================================================================== --- trunk/pthreads-pc.c (revision 26) +++ (revision ) @@ -1,83 +1,0 @@ -/* Copyright (C) 2008, 2014 by Mattia Monga */ -/* $Id$ */ -#include -#include -#include - -void b_insert(char*); -void b_remove(char**); - - -void* producer(void* args) -{ - while (1){ - char* o = (char*)malloc(sizeof(char)); - printf("Ho prodotto %p\n", o); - b_insert(o); - } - return NULL; -} - -void* consumer(void* args) -{ - while (1){ - char* o; - b_remove(&o); - free(o); - printf("Ho consumato %p\n", o); - } - return NULL; -} - -int main(void){ - - pthread_t p, c; - - - pthread_create(&p, NULL, &producer, NULL); - pthread_create(&c, NULL, &consumer, NULL); - - pthread_join(p, NULL); - pthread_join(c, NULL); - return 0; -} - -#define N 10 -char* buffer[N]; -int count = 0; - -pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER; -pthread_cond_t full = PTHREAD_COND_INITIALIZER; -pthread_cond_t empty = PTHREAD_COND_INITIALIZER; - -void b_insert(char* o) -{ - pthread_mutex_lock(&lock); - - while (count == N) pthread_cond_wait(&full, &lock); - printf("Buffer a %d\n", count); - buffer[count++] = o; - if (count == 1) pthread_cond_signal(&empty); - - pthread_mutex_unlock(&lock); -} - -/* passaggio per indirizzo per evitare di fare la return fuori dai lock */ -void b_remove(char** result) -{ - pthread_mutex_lock(&lock); - - while (count == 0) pthread_cond_wait(&empty, &lock); - printf("Buffer a %d\n", count); - *result = buffer[--count]; - if (count == N-1) pthread_cond_signal(&full); - - pthread_mutex_unlock(&lock); -} - - -/* Local Variables: */ -/* compile-command: "make -k " */ -/* End: */ - - Index: trunk/semafori.sh =================================================================== --- trunk/semafori.sh (revision 26) +++ (revision ) @@ -1,39 +1,0 @@ -N=2 - -function assegna(){ - echo $2 >> $1 -} - -function leggi(){ - tail -1 $1 -} - - -echo "1">alternanza - -TMP=$(mktemp semafori.sh.XXXXXX) -trap "rm -f $TMP* 2>/dev/null" 0 -rm $TMP - -function p(){ - local p - for p in $(seq $(( $1 * 10 )) $(( $1 * 10 + 9 )) ); do - while true; do - lockfile $TMP - if [ $(leggi alternanza) -eq $1 ]; then - echo $p - assegna alternanza "$(( ( $(leggi alternanza) % 2 ) + 1))" - rm -f $TMP - break - else - rm -f $TMP - fi - sleep 0.01 - done - done -} - -p 1 & -p 2 & - -wait %1 %2 Index: trunk/syscall.asm =================================================================== --- trunk/syscall.asm (revision 26) +++ (revision ) @@ -1,17 +1,0 @@ -segment .text - global main - -main: mov ecx, msg ; stringa - mov edx, msg_size ; dimensione stringa - mov ebx, 1 ; file descriptor (stdout) - mov eax, 4 ; syscall 4 (write) - int 0x80 - - mov eax, 1 ; syscall 1 (exit) - int 0x80 - - -segment .rodata -msg db 'Ciao solabbisti!',10,0 -msg_size equ $ - msg - Index: trunk/threads-isolated.c =================================================================== --- trunk/threads-isolated.c (revision 26) +++ (revision ) @@ -1,67 +1,0 @@ -/* Copyright (C) 2009 by Mattia Monga */ -/* $Id$ */ - -#include -#include -#include -#include -#include - -int run(void* s) -{ - int* shared = (int*)s; // alias per comodit\`a - while (shared[0] < 10) { - sleep(1); - printf("Processo figlio (%d). s = %d\n", - getpid(), shared[0]); - if (!(shared[0] < 10)){ - printf("Corsa critica!!!!\n"); - abort(); - } - shared[0] += 1; - } - return 0; -} - - -int main(void){ - - int shared[2] = {0 , 0}; - /* int clone(int (*fn)(void *), - * void *child_stack, - * int flags, - * void *arg); - * crea una copia del chiamante (con le caratteristiche - * specificate da flags) e lo esegue partendo da fn */ - if (clone(run, /* il nuovo - * processo esegue run(shared), vedi quarto - * parametro */ - malloc(4096)+4096, /* lo stack del nuovo processo - * (cresce verso il basso!) */ - SIGCHLD, // in questo caso la clone \`e analoga alla fork - shared) < 0){ - perror("Errore nella creazione");exit(1); - } - if (clone(run, malloc(4096)+4096, SIGCHLD, shared) < 0){ - perror("Errore nella creazione");exit(1); - } - - /* Isolati: ciascuno dei figli esegue 10 volte. */ - // Per il padre shared[0] \`e \textbf{sempre} 0 */ - - while(shared[0] == 0) { - sleep(1); - printf("Processo padre. s = %d\n", shared[0]); - } - return 0; -} - - - - - - - -/* Local Variables: */ -/* compile-command: "make -k " */ -/* End: */ Index: trunk/threads-peterson.c =================================================================== --- trunk/threads-peterson.c (revision 26) +++ (revision ) @@ -1,98 +1,0 @@ -/* Copyright (C) 2009 by Mattia Monga */ -/* $Id$ */ -#define _GNU_SOURCE -#include -#include -#include -#include -#include - - -void enter_section(int process, int* turn, int* interested) -{ - int other = 1 - process; - interested[process] = 1; - *turn = process; - while (*turn == process && interested[other]){ - printf("Busy waiting di %d\n", process); - } -} - -void leave_section(int process, int* interested) -{ - interested[process] = 0; -} - -int run(const int p, void* s) -{ - int* shared = (int*)s; // alias per comodit\`a - while (enter_section(p, &shared[1], &shared[2]), shared[0] < 10) { - sleep(1); - printf("Processo figlio (%d). s = %d\n", - getpid(), shared[0]); - if (!(shared[0] < 10)){ - printf("Corsa critica!!!!\n"); - abort(); - } - shared[0] += 1; - leave_section(p, &shared[2]); - } - leave_section(p, &shared[2]);// il test nel while \`e dopo enter\_section - - return 0; -} - -int run0(void*s){ return run(0, s); } -int run1(void*s){ return run(1, s); } - - -int main(void){ - - int shared[4] = {0 , 0, 0, 0}; - - /* int clone(int (*fn)(void *), - * void *child_stack, - * int flags, - * void *arg); - * crea una copia del chiamante (con le caratteristiche - * specificate da flags) e lo esegue partendo da fn */ - if (clone(run0, /* il nuovo - * processo esegue run(shared), vedi quarto - * parametro */ - malloc(4096)+4096, /* lo stack del nuovo processo - * (cresce verso il basso!) */ - CLONE_VM | SIGCHLD, /* la (virtual) memory \`e condivisa */ - shared) < 0){ - perror("Errore nella creazione"); - exit(1); - } - - if (clone(run1, malloc(4096)+4096, CLONE_VM | SIGCHLD, shared) < 0){ - perror("Errore nella creazione"); - exit(1); - } - - /* Memoria condivisa: i due figli nell'insieme eseguono 10 o - * 11 volte con possibili corse critiche. Il padre - * condivide shared[0] con i figli */ - - while(shared[0] < 10) { - sleep(1); - printf("Processo padre. s = %d %d %d %d\n", - shared[0], - shared[1], - shared[2], - shared[3]); - } - return 0; -} - - - - - - - -/* Local Variables: */ -/* compile-command: "make -k " */ -/* End: */ Index: trunk/threads-sem.c =================================================================== --- trunk/threads-sem.c (revision 26) +++ (revision ) @@ -1,78 +1,0 @@ -/* Copyright (C) 2009 by Mattia Monga */ -/* $Id$ */ - -#include -#include -#include -#include -#include -#include - -void down(sem_t *s){ - if (sem_wait(s) < 0){ - perror("Errore semaforo (down)"); - exit(1); - } -} - -void up(sem_t *s){ - if (sem_post(s) < 0){ - perror("Errore semaforo (up)"); - exit(1); - } -} - -int shared = 0; -pthread_t p1, p2; -sem_t ss; - -void* run(void* s){ - while (down(&ss), - shared < 10) { - sleep(1); - printf("Processo thread (%p). s = %d\n", - pthread_self(), shared); - if (!(shared < 10)){ - printf("Corsa critica!!!!\n"); - abort(); - } - shared += 1; - up(&ss); - pthread_yield(); - } - up(&ss); - return NULL; -} - - - -int main(void){ - - if (sem_init(&ss, - 0 /* thread local semaphore */, - 1 /* init value */ - ) < 0){ - perror("Errore semaforo"); - exit(1); - } - - pthread_create(&p1, NULL, run, NULL); - pthread_create(&p2, NULL, run, NULL); - - pthread_join(p1, NULL); - pthread_join(p2, NULL); - - sem_destroy(&ss); - - return 0; -} - - - - - - - -/* Local Variables: */ -/* compile-command: "make -k " */ -/* End: */ Index: trunk/threads-shared.c =================================================================== --- trunk/threads-shared.c (revision 26) +++ (revision ) @@ -1,69 +1,0 @@ -/* Copyright (C) 2009 by Mattia Monga */ -/* $Id$ */ -#define _GNU_SOURCE -#include -#include -#include -#include -#include - -int run(void* s) -{ - int* shared = (int*)s; // alias per comodit\`a - while (shared[0] < 10) { - sleep(1); - printf("Processo figlio (%d). s = %d\n", - getpid(), shared[0]); - if (!(shared[0] < 10)){ - printf("Corsa critica!!!!\n"); - abort(); - } - shared[0] += 1; - } - return 0; -} - - -int main(void){ - - int shared[2] = {0 , 0}; - /* int clone(int (*fn)(void *), - * void *child_stack, - * int flags, - * void *arg); - * crea una copia del chiamante (con le caratteristiche - * specificate da flags) e lo esegue partendo da fn */ - if (clone(run, /* il nuovo - * processo esegue run(shared), vedi quarto - * parametro */ - malloc(4096)+4096, /* lo stack del nuovo processo - * (cresce verso il basso!) */ - CLONE_VM | SIGCHLD, // (virtual) memory condivisa - shared) < 0){ - perror("Errore nella creazione");exit(1); - } - - if (clone(run, malloc(4096)+4096, CLONE_VM | SIGCHLD, shared) < 0){ - perror("Errore nella creazione");exit(1); - } - - /* Memoria condivisa: i due figli nell'insieme eseguono 10 o - * 11 volte: \`e possibile una corsa critica. Il padre - * condivide shared[0] con i figli */ - - while(shared[0] < 10) { - sleep(1); - printf("Processo padre. s = %d\n", shared[0]); - } - return 0; -} - - - - - - - -/* Local Variables: */ -/* compile-command: "make -k " */ -/* End: */ Index: trunk/threads-tsl.c =================================================================== --- trunk/threads-tsl.c (revision 26) +++ (revision ) @@ -1,89 +1,0 @@ -/* Copyright (C) 2009 by Mattia Monga */ -/* $Id$ */ -#define _GNU_SOURCE - -#include -#include -#include -#include -#include - - -void enter_section(int *s); /* in enter.asm */ -void leave_section(int *s){ *s = 0; } - -int run(const int p, void* s){ - int* shared = (int*)s; // alias per comodit\`a - while (enter_section(&shared[1]), shared[0] < 10) { - sleep(1); - printf("Processo figlio (%d). s = %d\n", - getpid(), shared[0]); - fflush(stdout); - if (!(shared[0] < 10)){ - printf("Corsa critica!!!!\n"); - abort(); - } - shared[0] += 1; - leave_section(&shared[1]); - sched_yield(); - usleep(50); - } - leave_section(&shared[1]); // il test nel while \`e dopo enter\_section - return 0; -} - -int run0(void*s){ return run(0, s); } -int run1(void*s){ return run(1, s); } - - -int main(void){ - - int shared[4] = {0 , 0, 0, 0}; - - /* int clone(int (*fn)(void *), - * void *child_stack, - * int flags, - * void *arg); - * crea una copia del chiamante (con le caratteristiche - * specificate da flags) e lo esegue partendo da fn */ - if (clone(run0, /* il nuovo - * processo esegue run(shared), vedi quarto - * parametro */ - malloc(4096)+4096, /* lo stack del nuovo processo - * (cresce verso il basso!) */ - CLONE_VM | SIGCHLD, /* la (virtual) memory \`e condivisa */ - shared) < 0){ - perror("Errore nella creazione"); - exit(1); - } - - if (clone(run1, malloc(4096)+4096, CLONE_VM | SIGCHLD, shared) < 0){ - perror("Errore nella creazione"); - exit(1); - } - - /* Memoria condivisa: i due figli nell'insieme eseguono 10 o - * 11 volte: \`e possibile una corsa critica. Il padre - * condivide shared[0] con i figli */ - - while(shared[0] < 10) { - sleep(1); - printf("Processo padre. s = %d %d %d %d\n", - shared[0], - shared[1], - shared[2], - shared[3]); - fflush(stdout); - } - return 0; -} - - - - - - - -/* Local Variables: */ -/* compile-command: "make -k " */ -/* End: */ Index: trunk/threads.c =================================================================== --- trunk/threads.c (revision 26) +++ (revision ) @@ -1,56 +1,0 @@ -/* Copyright (C) 2009 by Mattia Monga */ -/* $Id$ */ - -#include -#include -#include -#include -#include -#include - -int run(void* s) -{ - int* shared = (int*)s; /* alias per comodita` */ - while (shared[0] < 10) { - sleep(1); - printf("Processo figlio (%d). s = %d\n", - getpid(), shared[0]); - if (!(shared[0] < 10)){ - printf("Corsa critica!!!!\n"); - abort(); - } - shared[0] += 1; - } - return 0; -} - - -int main(void){ - - int shared[2] = {0 , 0}; - if (clone(run, malloc(4096)+4096, SIGCHLD, shared) < 0){ - perror("Errore nella creazione"); - exit(1); - } - - if (clone(run, malloc(4096)+4096, SIGCHLD, shared) < 0){ - perror("Errore nella creazione"); - exit(1); - } - - while(1) { - sleep(1); - printf("Processo padre. s = %d\n", shared[0]); - } - return 0; -} - - - - - - - -/* Local Variables: */ -/* compile-command: "make -k " */ -/* End: */ Index: trunk/trap.sh =================================================================== --- trunk/trap.sh (revision 26) +++ (revision ) @@ -1,12 +1,0 @@ -#!/bin/sh - -trap "echo Ho ricevuto il segnale USR1" 10 -trap "echo Ho ricevuto il segnale USR2" 12 -trap "echo Ho ricevuto il segnale INT" 2 - -while true ; do - sleep 1 - echo "ciao: sono $(id)" -done - - Index: trunk/tsl.asm =================================================================== --- trunk/tsl.asm (revision 26) +++ (revision ) @@ -1,32 +1,0 @@ - -segment .text - global main -extern printf - -main: mov eax, 0 - call stampa - lock bts dword [x], 0 - jc salta ; gi\`a settato - call stampa -salta: lock bts dword [x], 0 - jnc _end - call stampa - jmp _end - -stampa: push dword [x] - push dword fmt - call printf - add esp, 8 - ret - - -_end: mov eax, 1 ; call syscall exit - xor ebx, ebx ; exit status 0 - int 0x80 - hlt - -segment .data -x: dd 0 - -segment .rodata -fmt: db "Il valore di x e` %x",0x0a,0 ; 0x0a -> a capo Index: trunk/unios.asm =================================================================== --- trunk/unios.asm (revision 26) +++ (revision ) @@ -1,113 +1,0 @@ -; Redistribution and use in source and binary forms, with or without modification, are -; permitted provided that the following conditions are met: -; -; Redistributions of source code must retain the above copyright notice, this list of -; conditions and the following disclaimer. -; -; Redistributions in binary form must reproduce the above copyright notice, this list of -; conditions and the following disclaimer in the documentation and/or other materials -; provided with the distribution. -; -; The name of the author may not be used to endorse or promote products derived from this -; software without specific prior written permission. -; -; THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, -; INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR -; A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, -; INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT -; LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; -; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN -; CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY -; OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. -; -; Version: 1.1.1 Beta - -bits 16 -org 0h - - mov ax, 0x7C0 - mov ds, ax - - call booting - xor dx,dx - call working - call idleloop - -nl: - mov si, newline - call message - ret - -booting: - mov si, boot - call message - call nl - ret - -working: - call nl - call nl - mov si, device - call message - call waitenter; - inc dx - cmp dx, 3 - je keyboard - jmp working - -keyboard: - call nl - call nl - mov si, kbd - call message - call nl - mov si, cont - call message - ret - -waitenter: - call nl - mov si, cont - call message - xor ax,ax ; Sets AH=0 and AL=0 - int 16h ; Wait for keypress - cmp al, 'T' - jz taz - cmp al, 't' - jz taz - cmp al, 13 - jnz waitenter - ret - -taz: - call nl - call nl - mov si, tazq - call message - jmp waitenter - -idleloop: - hlt - jmp idleloop - -message: - lodsb - or al, al - jz done - mov ah, 0Eh - mov bx, 7 - int 10h - jmp message - -done: - ret - -boot: db 'Loading UniOS 1.1 Beta...' , 0 -newline: db 10, 13, 0 -device: db 'Device not responding to SCSI command.' , 0 -cont: db 'Hit ENTER to continue...', 0 -kbd: db 'Keyboard not responding to SCSI command.' , 0 -tazq: db 'Yes, TazQ is an Internet crack monkey on wheels.' , 0 - - times 510-($-$$) db 0 - dw 0xAA55