Eventos, Conc, file, streams

jquemada · jquemada · commit b3c3821ea88a · 2013-01-20T20:02:38.000+01:00
diff --git a/e50-timeout.js b/e50-timeout.js
@@ -0,0 +1,8 @@
+setTimeout(function() {  // callback
+		      console.log('world');
+           },
+           2000  // evento ocurre 2000
+);               // miliseg. despues
+
+
+console.log('hello');
diff --git a/e52-file.js b/e52-file.js
@@ -0,0 +1,8 @@
+var fs = require('fs');
+
+fs.readFile('file.js', 
+	        'ascii',
+	        function(err, data) {
+		       console.log(data) 
+            }
+);
diff --git a/e53-file-bin.js b/e53-file-bin.js
@@ -0,0 +1,5 @@
+var fs = require('fs');
+var filehandle = fs.readFile('e04-file-bin.js', 
+	function(err, data) {
+		console.log(data) 
+});
diff --git a/e55-argv.js b/e55-argv.js
@@ -0,0 +1,4 @@
+var i;
+for(i = 0; i < process.argv.length; i++) {
+    console.log('Parametro ' + i + " = " + process.argv[i]) ;
+}
diff --git a/e56-argv.js b/e56-argv.js
@@ -0,0 +1,9 @@
+var i;
+for(i = 0; i < process.argv.length; i++) {
+    console.log('Parametro ' + i + " = " + process.argv[i]) ;
+}
+
+// programa equivalente con método de JavaScript 1.5
+process.argv.forEach(function (val, index, array) {
+  console.log('Parametro ' + index + ': ' + val);
+});
diff --git a/e57-uncaughtException.js b/e57-uncaughtException.js
@@ -0,0 +1,11 @@
+// define manejador de evento
+process.on('uncaughtException', function(err) {
+  console.log('EXCEPCION CAPTURADA: \n  -> ' + err);
+});
+
+console.log('Este mensaje saldra por consola');
+
+// No estar definida, disparará uncaughtException
+funcionIndefinida();
+
+console.log('Este mensaje NO saldra por consola');
diff --git a/e60-nextTick.js b/e60-nextTick.js
@@ -0,0 +1,6 @@
+setTimeout(function() { console.log('Evento A');}, 2);
+setTimeout(function() { console.log('Evento B');}, 0);
+
+process.nextTick(function() { console.log('Tick D');});
+process.nextTick(function() { console.log('Tick E');});
+console.log('Fin de Programa Principal');
diff --git a/e61-deadlock.js b/e61-deadlock.js
@@ -0,0 +1,7 @@
+var i, fact = 1;
+for(i = 1; i == 10; i=i+2) { // error: bucle infinito
+    fact = fact*i;          // bloquea procesador
+    console.log(i + "! = " + fact) ;
+}
+
+// no se ejecutarian nunca los eventos
diff --git a/e65-mutual_exclusion.js b/e65-mutual_exclusion.js
@@ -0,0 +1,17 @@
+var tiempo = 6000;  // variable compartida
+
+setInterval(function() { 
+	         tiempo = tiempo - 1000;
+	         console.log('A consume: 1000');
+	         if (tiempo < 1) {process.exit()};
+           }, 
+           1000
+);
+
+setInterval(function() { 
+	         tiempo = tiempo - 1000;
+	         console.log('B consume: 1000');
+	         if (tiempo < 1) {process.exit()};
+           }, 
+           1000
+);
diff --git a/e70-copy.js b/e70-copy.js
@@ -0,0 +1,20 @@
+var fs = require('fs');     // importa modulo file system
+
+if (process.argv.length != 4){  // parametros mal?
+  console.log('   syntax: "node copy <orig> <dest>"');
+  process.exit()            // finaliza proceso node
+}
+
+fs.readFile(
+  process.argv[2],          // fichero <orig>
+  function(err, data) {     // callback de finalización
+    fs.writeFile(
+      process.argv[3],      // fichero <dest>
+      data,                 // contenido de <orig>
+      function (err) {      // callback de finalización
+        if (err) throw err;
+        console.log('file copied');
+      }
+    );
+  }
+);
diff --git a/e75-copy.js b/e75-copy.js
@@ -0,0 +1,20 @@
+var fs = require('fs');     // importa modulo file system
+
+if (process.argv.length != 4){  // parametros mal?
+  console.log('   syntax: "node copy <orig> <dest>"');
+  process.exit()            // finaliza proceso node
+}
+
+fs.readFile(
+  process.argv[2],          // fichero <orig>
+  function(err, data) {     // callback de finalización
+    fs.writeFile(
+      process.argv[3],      // fichero <dest>
+      data,                 // contenido de <orig>
+      function (err) {      // callback de finalización
+        if (err) throw err;
+        console.log('file copied');
+      }
+    );
+  }
+);
diff --git a/e75-copy_pump.js b/e75-copy_pump.js
@@ -0,0 +1,13 @@
+var fs = require('fs'),
+    util = require('util');
+
+if (process.argv.length != 4){  // parametros mal?
+  console.log('   syntax: "node copy <orig> <dest>"');
+  process.exit()            // finaliza proceso node
+}
+
+//Open files as readable streams
+var readStream = fs.createReadStream(process.argv[2]);
+var writeStream = fs.createWriteStream(process.argv[3]);
+
+util.pump(readStream, writeStream);
diff --git a/e80-append.js b/e80-append.js
@@ -0,0 +1,20 @@
+var fs = require('fs');   // importa modulo file system
+
+if (process.argv.length != 4){  // parametros mal?
+  console.log('   syntax: "node append <orig> <dest>"');
+  process.exit()            // finaliza proceso node
+}
+
+fs.readFile(
+  process.argv[2],          // fichero <orig>
+  function(err, data) {     // callback de finalización
+    fs.appendFile(
+      process.argv[3],      // fichero <dest>
+      data,                 // contenido de <orig>
+      function (err) {      // callback de finalización
+        if (err) throw err;
+        console.log('files appended');
+      }
+    );
+  }
+);
diff --git a/e90-stdin_out.js b/e90-stdin_out.js
@@ -0,0 +1,11 @@
+ // arranca stream
+process.stdin.resume();
+
+ // Configura entrada ASCII (sino buffer binario)
+process.stdin.setEncoding('ascii');
+
+ // Manejador de evento 'data'
+ //  -> bucle de lectura de lineas
+process.stdin.on('data', function(line) {
+  process.stdout.write(line);
+});
diff --git a/e91-stdin.js b/e91-stdin.js
@@ -0,0 +1,11 @@
+ // arranca stream
+process.stdin.resume();
+
+ // Configura entrada ASCII (sino buffer binario)
+process.stdin.setEncoding('ascii');
+
+ // Manejador de evento 'data'
+ //  -> bucle de lectura de lineas
+process.stdin.on('data', function(line) {
+  console.log(line);
+});
diff --git a/e93-copy_stream.js b/e93-copy_stream.js
@@ -0,0 +1,19 @@
+var fs = require('fs');
+
+//Open a file as a readable stream
+var readStream = fs.ReadStream("e10-copy.js");
+readStream.setEncoding('ascii'); // This is key; otherwise we'd be using buffers
+
+var writeStream = fs.createWriteStream("out.txt");
+
+// every time "data" is read, this event fires
+readStream.on('data', function(textData) {
+  console.log("Found some text!");
+  writeStream.write(textData);
+});
+
+// the reading is finished...
+readStream.on('close', function () {
+  writeStream.end(); // ...close up the write, too!
+  console.log("I finished.");
+});
diff --git a/e94-copy_stream1.js b/e94-copy_stream1.js
@@ -0,0 +1,18 @@
+var fs = require('fs'), orig, dest;
+
+// Open either stdin or 'argv[2]' as a readable stream
+if (!(process.argv[2])) { process.stdin.resume(); orig = process.stdin; } 
+else { orig = fs.createReadStream(process.argv[2]); } // open file as stream
+
+// Open either stdout or 'argv[3]' as a readable stream
+if (!(process.argv[3])) { dest = process.stdout; } 
+else { dest = fs.createWriteStream(process.argv[3]); } // open file as stream
+
+// The "data" event fires, when data is read from a file or from stdin
+orig.on('data', function(data) { dest.write(data); });
+
+// When reading finishes clean-up
+orig.on('close', function () {
+  if (process.argv[3]) { dest.end();} // close output file
+  console.log("Finished.");
+});

-Original file line number
+Diff line change
@@ @@ -0,0 +1,4 @@ @@
 +var i;
 +for(i = 0; i < process.argv.length; i++) {
 +    console.log('Parametro ' + i + " = " + process.argv[i]) ;
 +}