Compare commits
	
		
			1 Commits
		
	
	
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| e2393d965a | 
| @ -53,10 +53,11 @@ module.exports.create = function (cli, dnsd) { | ||||
|         process.exit(0); | ||||
|       } | ||||
|       console.error("TCP Server Error:"); | ||||
|       console.error(err); | ||||
|       console.error(err.stack); | ||||
|       tcpServer.close(function () { | ||||
|         setTimeout(runTcp, 1000); | ||||
|       }); | ||||
|       //throw new Error(err);
 | ||||
|     }); | ||||
| 
 | ||||
|     tcpServer.listen(cli.port, function () { | ||||
|  | ||||
							
								
								
									
										16
									
								
								lib/udpd.js
									
									
									
									
									
								
							
							
						
						
									
										16
									
								
								lib/udpd.js
									
									
									
									
									
								
							| @ -1,6 +1,7 @@ | ||||
| 'use strict'; | ||||
| 
 | ||||
| module.exports.create = function (cli, dnsd) { | ||||
|   function runUdp() { | ||||
|     var server = require('dgram').createSocket({ | ||||
|       type: cli.udp6 ? 'udp6' : 'udp4' | ||||
|     , reuseAddr: true | ||||
| @ -19,8 +20,12 @@ module.exports.create = function (cli, dnsd) { | ||||
|         process.exit(123); | ||||
|         return; | ||||
|       } | ||||
|     console.error("error:", err.stack); | ||||
|     server.close(); | ||||
|       console.error("UDP Server Error:"); | ||||
|       console.error(err.stack); | ||||
|       server.close(function () { | ||||
|         setTimeout(runUdp, 1000); | ||||
|       }); | ||||
|       //throw new Error(err);
 | ||||
|     }; | ||||
| 
 | ||||
|     handlers.onMessage = function (nb, rinfo) { | ||||
| @ -29,9 +34,9 @@ module.exports.create = function (cli, dnsd) { | ||||
| 
 | ||||
|       dnsd.onMessage(nb, function (err, newAb, dbgmsg) { | ||||
|         // TODO send legit error message
 | ||||
|       if (err) { server.send(Buffer.from([0x00])); return; } | ||||
|         if (err) { server.send(Buffer.from([0x00]), rinfo.port, rinfo.address); return; } | ||||
|         server.send(newAb, rinfo.port, rinfo.address, function () { | ||||
|         console.log(dbgmsg, rinfo.port, rinfo.address); | ||||
|           console.log('[dnsd.onMessage] ' + dbgmsg, rinfo.port, rinfo.address); | ||||
|         }); | ||||
|       }); | ||||
|     }; | ||||
| @ -55,4 +60,7 @@ module.exports.create = function (cli, dnsd) { | ||||
|     server.on('listening', handlers.onListening); | ||||
| 
 | ||||
|     return server; | ||||
|   } | ||||
| 
 | ||||
|   return runUdp(); | ||||
| }; | ||||
|  | ||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user