Added stop-semaphore-file support (data/newslink.stop).

exec/newslink.js

@@ -216,6 +216,9 @@ if(slave) {
 	readln();
 }
 
+var stop_semaphore=system.data_dir+"newslink.stop";
+file_remove(stop_semaphore);
+
 /******************************/
 /* Export and Import Messages */
 /******************************/
@@ -230,6 +233,9 @@ for(i in area) {
 		break;
 	}
 
+	if(file_exists(stop_semaphore))
+		break;
+
 //	printf("%s\r\n",area[i].toString());
 	
 	sub = area[i][1];
@@ -288,7 +294,7 @@ for(i in area) {
 	if(debug)
 		print("exporting local messages");
 	last_msg=msgbase.last_msg;
-	for(;socket.is_connected && ptr<=last_msg;ptr++) {
+	for(;socket.is_connected && ptr<=last_msg && !file_exists(stop_semaphore);ptr++) {
 		console.line_counter = 0;
 		hdr = msgbase.get_msg_header(
 			/* retrieve by offset? */	false,
@@ -433,7 +439,7 @@ for(i in area) {
 		ptr++;
 	}
 
-	for(;socket.is_connected && ptr<=last_msg;ptr++) {
+	for(;socket.is_connected && ptr<=last_msg && !file_exists(stop_semaphore);ptr++) {
 		console.line_counter = 0;
 		writeln(format("ARTICLE %lu",ptr));
 		rsp = readln();
@@ -546,6 +552,9 @@ for(i in area) {
 	}
 	delete ptr_file;
 	delete msgbase;
+
+//	if(flags.indexOf('b')>=0)	// binary newsgroup
+//		load("binarydecoder.js",sub);
 }
 
 writeln("quit");