Changed version up to 0.25.3

source/.version

@@ -1 +1 @@
-0.25.2
+0.25.3

source/bforce/daemon.c

@@ -178,7 +178,7 @@ static int daemon_sysentry_deinit(s_sysentry *sysent)
 	return 0;
 }
 
-static bool daemon_node_cancall_line(const s_node *node, const s_override *ovrd)
+static int daemon_node_cancall_line(const s_node *node, const s_override *ovrd)
 {
 	bool good_phone = FALSE;
 	bool good_host = FALSE;
@@ -208,6 +208,11 @@ static bool daemon_node_cancall_line(const s_node *node, const s_override *ovrd)
 		if( tcpip_isgood_host(ovrd->sIpaddr) )
 			good_host = TRUE;
 	}
+	else if ( node && *node->host )
+	{
+		if( tcpip_isgood_host(node->host) )
+			good_host = TRUE;
+	}
 	
 	/*
 	 * Check work time
@@ -231,6 +236,16 @@ static bool daemon_node_cancall_line(const s_node *node, const s_override *ovrd)
 			good_time = TRUE;
 	}
 	
+	
+	// Must be more complicated, i.e. call to IP even if modem is not good time
+	if ( good_host )
+	{
+		good_time = TRUE;
+	}
+	
+	DEB((D_DAEMON, "daemon: node_cancall_line good_phone: %d, good_time:%d, good_host:%d", 
+					good_phone, good_time, good_host));
+	
 	if( good_time )
 	{
 		if( good_host )
@@ -323,9 +338,23 @@ static bool daemon_node_cancall(s_sysentry *syst, bool ign_wtime, bool tcpip)
 			return FALSE;
 	}
 	
+	/* Make check for tcpip out */
+	if ( tcpip )
+	{
+		rc = daemon_node_cancall_line(&syst->node, NULL);
+		DEB((D_DAEMON, "daemon tcpip: node_cancall rc=%d", rc));
+		if ( rc == 2 )
+		{
+			syst->tcpip = TRUE;
+			return TRUE;
+		}
+	}
+	
+	
 	/* Make checks for all lines */
 	if( syst->overrides )
 	{
+		DEB((D_DAEMON, "daemon: node_cancall OVR-IN"));
 		if( syst->lineptr && syst->lineptr->hidden )
 		{
 			line = syst->line + 1;
@@ -363,11 +392,18 @@ static bool daemon_node_cancall(s_sysentry *syst, bool ign_wtime, bool tcpip)
 			}
 			line++;
 		}
+		
 	}
 	else /* Node without overriden parameters */
 	{
 		syst->line = line = 0;
-		return daemon_node_cancall_line(&syst->node, NULL);
+		rc = daemon_node_cancall_line(&syst->node, NULL);
+		DEB((D_DAEMON, "daemon: node_cancall rc=%d", rc));
+		if ( rc )
+		{
+			syst->tcpip = (rc == 2) ? TRUE : FALSE;
+			return TRUE;
+		}
 	}
 	
 	return FALSE;
@@ -687,6 +723,8 @@ int daemon_rescan_sysqueue(s_sysqueue *q, s_daemon_queue dqs[])
 	
 #ifdef DEBUG
 	log_sysqueue(q);
+	DEB((D_DAEMON, "daemon rescan_sysqueue daemon queue: MODEM: %d, %d; TCPIP: %d, %d",
+		dqs[MODEM_QUEUE].circle, dqs[MODEM_QUEUE].current, dqs[TCPIP_QUEUE].circle, dqs[TCPIP_QUEUE].current));
 #endif
 
 	return 0;
@@ -1010,10 +1048,17 @@ int daemon_run(const char *confname, const char *incname, bool quit)
 				timer_set(&timer_alive, DAEMON_ALIVE_TIMER);
 			}
 			
-			if( max_modem > 0 )
-				daemon_queue_do(&daemon_queues[MODEM_QUEUE]);
 			if( max_tcpip > 0 ) 
+			{
+				DEB((D_INFO,"daemon: daemon_tcpip_queue"));
 				daemon_queue_do(&daemon_queues[TCPIP_QUEUE]);
+			}
+			
+			if( max_modem > 0 )
+			{
+				DEB((D_INFO,"daemon: daemon_modem_queue"));
+				daemon_queue_do(&daemon_queues[MODEM_QUEUE]);
+			}
 			
 			(void)sleep(DAEMON_IDLE_SLEEP);
 			break;

source/bforce/daemon_call.c

@@ -54,7 +54,12 @@ static int daemon_call_branch(s_sysentry *syst, const char *lockdir, s_modemport
 
         s_bforce_opts opts;
         // TODO: add hiddenline round-robin
-        opts.hiddline=0;
+        memset(&opts, '\0', sizeof(s_bforce_opts));
+        
+        opts.hiddline = 0;
+        if ( syst->tcpip )
+			opts.runmode = MODE_CALL_IP;
+		else
 			opts.runmode = MODE_CALL_DEFAULT;
         opts.ipproto = NULL;
         opts.phone = NULL;
@@ -62,7 +67,7 @@ static int daemon_call_branch(s_sysentry *syst, const char *lockdir, s_modemport
         opts.inetd = 0;
         opts.connect = NULL;
         opts.device = NULL;
-
+    DEB((D_DAEMON, "daemon_call: calling call_system from branch"));
 //        log("doing call_system");
 	return call_system(syst->node.addr, &opts);
 }
@@ -88,7 +93,10 @@ int daemon_call(s_sysentry *syst)
 	 * Check whether this node is allready locked
 	 */
 	if( out_bsy_check(syst->node.addr) ) 
+	{
+		DEB((D_DAEMON, "daemon_call: node locked by .bsy file"));
 		return 0;
+	}
 	
 	/*
 	 * Set state structure to make expressions works properly now
@@ -101,6 +109,7 @@ int daemon_call(s_sysentry *syst)
 	
 	if( syst->tcpip == FALSE )
 	{
+		DEB((D_DAEMON, "daemon_call: tcpip false - prep modem line"));
 		if( (p_lockdir = conf_string(cf_uucp_lock_directory)) == NULL )
 			p_lockdir = BFORCE_LOCK_DIR;
 		
@@ -110,6 +119,9 @@ int daemon_call(s_sysentry *syst)
 			return 1;
 		}
 	}
+	DEB((D_DAEMON, "call %s line %d via %s",
+		ftn_addrstr(abuf, syst->node.addr), syst->line,
+		syst->tcpip ? "TCP/IP" : modemport->name));
 		
 	log("call %s line %d via %s",
 		ftn_addrstr(abuf, syst->node.addr), syst->line,
@@ -138,7 +150,7 @@ int daemon_call(s_sysentry *syst)
 	}
 	
 	/* Now we are in child process */
-	
+	DEB((D_DAEMON, "daemon_call: fork success - calling..."));
 	exit(daemon_call_branch(syst, p_lockdir, modemport));
 }
 

source/bforce/io_tcpip.c

@@ -54,7 +54,6 @@ static int tcpip_connect2(struct addrinfo *ai)
 		if ( fd == -1 ) 
 		{
 			DEB((D_INFO, "tcpip_connect2: socket error"));
-			continue;
 		}
 		else break;
 		

source/bforce/io_unix_tio.c

@@ -118,6 +118,9 @@ int tio_get(int fd, TIO *tio)
 {
 #ifdef HAVE_TERMIOS_H
 	return tcgetattr(fd, tio);
+#else
+	DEB(("io_unix_tio: TERMIOS not supported!"));
+	return -1;
 #endif
 }
 
@@ -127,6 +130,9 @@ int tio_set(int fd, TIO *tio)
 {
 #ifdef HAVE_TERMIOS_H
 	return tcsetattr(fd, TCSANOW, tio);
+#else
+	DEB(("io_unix_tio: TERMIOS not supported!"));
+	return -1;
 #endif
 }
 
@@ -177,7 +183,7 @@ int tio_get_speed(TIO *tio)
 			return speedtab[i].nspeed;
 	}
 	
-	return-1;
+	return -1;
 }
 
 int tio_set_flow_control(int fd, TIO *tio, int flow)

source/bforce/logger.c

@@ -106,11 +106,15 @@ int log_open(const char *logname, const char *ext, const char *tty)
 	
 	if( logname )
 	{
+		DEB((D_INFO,"log_open: Opening log file %s", logname));
+		
 		strnxcpy(log_name, logname, sizeof(log_name));
 		
+		// May be NULL, so check both
 		if( tty && *tty )
 			strnxcpy(log_ttyname, tty, sizeof(log_ttyname));
 		
+		// May be NULL, so check both
 		if( ext && *ext )
 		{
 			strnxcpy(log_extension, ext, sizeof(log_extension));
@@ -142,7 +146,9 @@ int log_close(void)
 	
 	if( log_fp )
 	{
-		rc = fclose(log_fp); log_fp = NULL;
+		rc = fclose(log_fp); 
+		DEB((D_INFO,"Closing log file."));
+		log_fp = NULL;
 	}
 	
 	return rc;	

source/bforce/nodelist.c

@@ -243,7 +243,7 @@ int nodelist_parsestring(s_node *node, char *str)
 	strnxcpy(node->phone, argv[NODELIST_POSPHONE], sizeof(node->phone));
 	strnxcpy(node->flags, argv[NODELIST_POSFLAGS], sizeof(node->flags));
 	node->speed = atoi(argv[NODELIST_POSSPEED]);
-	
+	DEB((D_NODELIST, "nodelist: Parsed common values SYS: %s, ZYZ: %s, LOC: %s, PHONE: %s", node->name, node->sysop, node->location, node->phone));
 	/*
 	 * Replace all '_' by space character
 	 */
@@ -291,8 +291,11 @@ int nodelist_parsestring(s_node *node, char *str)
 	node->do_ifcico = nodelist_checkflag(node->flags, "IFC") == 0;
 	node->do_telnet = nodelist_checkflag(node->flags, "ITN") == 0;
 	
+	//TODO: Add more INA flags to array
 	nodelist_flagvalue(node->flags, "INA", node->host);
 	
+	DEB((D_NODELIST, "nodelist: Parsed inet values IBN: %d, IFC: %d, ITN: %d, INA: %s", node->do_binkp, node->do_ifcico, node->do_telnet, node->host)); 
+	
 	return 0;
 }
 

source/bforce/prot_binkp.c

@@ -124,7 +124,7 @@ int binkp_loop(s_binkp_state *bstate) {
             bstate->continuesend = false;
         }
 
-        if (have_to_write==0 && (!no_more_to_send || bstate->extracmd[0]!=-1)) {
+        if (have_to_write==0 && (!no_more_to_send || bstate->extracmd[0]!=(char)-1)) {
             m = binkp_getforsend(bstate, writebuf+BINKP_HEADER, &block_type, &block_length);
             if(m==1 || m==3) {
                 //DEB((D_24554, "got block for sending %d %hu", block_type, block_length));
@@ -340,7 +340,7 @@ int binkp_getforsend(s_binkp_state *bstate, char *buf, int *block_type, unsigned
 {
     int my_sf, wr_pos;
     int n; // read file
-    if (bstate->extracmd[0]!=-1) {
+    if (bstate->extracmd[0]!=(char)-1) {
         DEB((D_24554, "Send cmd to remote %d %s", bstate->extracmd[0], bstate->extracmd+1));
         buf[0] = bstate->extracmd[0];
         strcpy(buf+1, bstate->extracmd+1);
@@ -668,12 +668,12 @@ case BPMSG_ADR:              /* List of addresses */
             if (bstate->address_established) {
                 PROTO_ERROR("remote tries to change address");
             }
-            if( bstate->extracmd[0] !=-1 ) return 0; // suspend !!!
+            if( bstate->extracmd[0] != (char)-1 ) return 0; // suspend !!!
             binkp_process_ADR(buf+1);
 
 	    if( !state.n_remoteaddr ) {
 	        log("error: remote did not supplied any addresses");
-	        if( bstate->extracmd[0] !=-1 ) return 0; // suspend
+	        if( bstate->extracmd[0] != (char)-1 ) return 0; // suspend
 	        bstate->extracmd[0] = BPMSG_BSY;
 	        strcpy(bstate->extracmd+1, "No addresses was presented");
 		bstate->extraislast = true;
@@ -788,7 +788,7 @@ case BPMSG_FILE:             /* File information */
 	        DEB((D_24554, "no, skipping; TODO: accept it"));
 		if( bstate->extracmd[0] != -1 ) return 0;
 		bstate->extracmd[0] = BPMSG_SKIP;
-		sprintf(bstate->extracmd+1, "%s %ld %ld %ld", recvfi.fn, recvfi.sz, recvfi.tm);
+		sprintf(bstate->extracmd+1, "%s %ld %ld %ld", recvfi.fn, recvfi.sz, recvfi.tm, recvfi.offs);
 		bstate->extraislast = false;
 		return 1;
 	    }
@@ -844,7 +844,7 @@ case BPMSG_OK:               /* Password was acknowleged (data ignored) */
             }
             if (session_addrs_lock(state.remoteaddrs, state.n_remoteaddr)) {
                 log("error: unable to lock");
-                if (bstate->extracmd[0]!=-1) return 0;
+                if (bstate->extracmd[0]!= (char)-1) return 0;
                 bstate->extracmd[0] = BPMSG_BSY;
                 strcpy(bstate->extracmd+1, "All addresses are busy");
 		bstate->extraislast = true;
@@ -954,7 +954,7 @@ case BPMSG_GET:              /* Get a file from offset */
             }
             DEB((D_24554, "M_GET file %s size %d time %d offset %d", getfi.fn, getfi.sz, getfi.tm, getfi.offs));
 
-            if (bstate->extracmd[0] != -1) return 0;
+            if (bstate->extracmd[0] != (char)-1) return 0;
 
             if (bstate->pi->send) if (p_compfinfo(bstate->pi->send, getfi.fn, getfi.sz, getfi.tm)==0) {
                 DEB((D_24554, "M_GET for currently transmitted file"));
@@ -1044,7 +1044,7 @@ case BINKP_BLK_DATA:
             return 1;
         }
 
-        if (bstate->extracmd[0] != -1) return 0;
+        if (bstate->extracmd[0] != (char)-1) return 0;
 
         long int n;
         n = p_rx_writefile(buf, block_length, bstate->pi);

source/bforce/sess_answ.c

@@ -22,8 +22,16 @@
 int answ_system(e_session type, char *connstr, int inetd)
 {
 	TIO oldtio;
-	struct sockaddr_in client;
+	union {
+                struct sockaddr a;
+                struct sockaddr_in in;
+                struct sockaddr_in6 in6;
+        } client;
+	//struct sockaddr_storage client;
 	int clientlen = sizeof(client);
+	char clienthost[NI_MAXHOST];
+	char clientport[NI_MAXSERV];
+	int clientres = 0;
 	int rc = 0;
 	char *p;
 	
@@ -74,18 +82,20 @@ int answ_system(e_session type, char *connstr, int inetd)
 		log("Answering TCPIP call...");
 		if( connstr && *connstr )
 			state.connstr = (char*)xstrcpy(connstr);
-		else if( getpeername(0, (struct sockaddr*)&client, &clientlen) == -1 )
-			logerr("can't get client address");
 		else 
 		{
-#ifdef IPV6
+			if(getpeername(0, &client.a, &clientlen)) 
-			>char addr_str[INET6_ADDRSTRLEN+1];
+				log("sess_answ: can't detrmine socket client");
-			state.peername = (char*)xstrcpy(inet_ntop(AF_INET6, client.sin6_addr, addr_str, INET6_ADDRSTRLEN));
+			clientres = getnameinfo( &client.a, clientlen,
-			state.peerport = (long)ntohs(client.sin6_port);
+					clienthost, sizeof(clienthost), clientport, 
-#else
+					sizeof(clientport), NI_NUMERICHOST | NI_NUMERICSERV);
-			state.peername = (char*)xstrcpy(inet_ntoa(client.sin_addr));
+			if ( clientres == 0 )
-			state.peerport = (long)ntohs(client.sin_port);
+			{
-#endif
+				state.peername = (char*)xstrcpy(clienthost);
+				state.peerport = (long)atol(clientport);
+			}
+			else
+				log("sess_answ: can't get client address: ", gai_strerror(clientres));
 		}
 	}
 	

source/bforce/sess_call.c

@@ -543,7 +543,7 @@ int call_system(s_faddr addr, const s_bforce_opts *opts)
 	char s[300];
 	snprintf(s, 299, "bforce calling system %d:%d/%d.%d", addr.zone, addr.net, addr.node, addr.point );
 	log(s);
-	
+	DEB((D_EVENT, s));
 	// find suitable way of connection and try to make session
 	
         int rc = 0;
@@ -568,12 +568,13 @@ int call_system(s_faddr addr, const s_bforce_opts *opts)
 	}
 	
 	state.listed    = state.node.listed;
+	DEB((D_EVENT, "Calling init, listed=%d", state.listed));
 	state.node.addr.domain[0] = '\0'; /* Discard domain for node address */
 
 	// 1. If call method specified in cmdline, do use it
 	// 2. If not, use nodelist data and overrides and call all available methods
 	//    If override contains Phone or IP flags, ignore nodelist connect methods (but save INA if not overrided)
-
+	DEB((D_EVENT, "Calling init, runmode=%d", opts->runmode));
 	// 1st - get all allowed call ways
 	// 2nd - gather information reqired to call and remove unavailable ways (no info, node does not support)
 
@@ -581,7 +582,7 @@ int call_system(s_faddr addr, const s_bforce_opts *opts)
 
 	if( opts->runmode == MODE_CALL_DEFAULT )
 	{
-		call_mayuse = CALL_MODEM | CALL_TCPIP_ANY;
+		call_mustuse = CALL_MODEM | CALL_TCPIP_ANY;
 	}
 	else if( opts->runmode == MODE_CALL_STDIO )
 	{
@@ -593,7 +594,14 @@ int call_system(s_faddr addr, const s_bforce_opts *opts)
 	}
 	else if( opts->runmode == MODE_CALL_IP )
 	{
-		if( strcasecmp(opts->ipproto, "binkp") == 0 )
+		DEB((D_EVENT, "Calling init, MODE_CALL_IP"));
+		if( !(opts->ipproto) ) // determine from nodelist/override
+		{
+			DEB((D_EVENT, "ipproto not set"));
+			call_mayuse = CALL_TCPIP_ANY;
+			call_mustuse = 0;
+		}
+		else if( strcasecmp(opts->ipproto, "binkp") == 0 )
 		{
 			call_mustuse = CALL_TCPIP_BINKP;
 		}
@@ -605,31 +613,29 @@ int call_system(s_faddr addr, const s_bforce_opts *opts)
 		{
 			call_mustuse = CALL_TCPIP_TELNET;
 		}
-		else if( opts->ipproto == NULL ) // determine from nodelist/override
-		{
-			call_mayuse = CALL_TCPIP_ANY;
-			call_mustuse = 0;
-		}
 		else
 		{
+			DEB((D_EVENT, "Unknown protocol %s", opts->ipproto));
 			log("Unknown protocol");
 			return -1;
 		}
 	}
 	else
 	{
-		log("Unknown protocol");
+		DEB((D_EVENT, "Unknown runmode %d", opts->runmode));
+		log("Unknown runmode");
 		return -1;
 	}
 	
 	call_mayuse |= call_mustuse; // it simplifies logics: all required is allowed
 
        //char s[300];
-       //snprintf(s, 299, "initial: may use %d must use %d", call_mayuse, call_mustuse);
+       snprintf(s, 299, "initial: may use %d must use %d", call_mayuse, call_mustuse);
-       //log(s);
+       log(s);
+       DEB((D_EVENT, s));
 
 
-	if( call_mayuse & CALL_MODEM )
+	if( (call_mayuse & CALL_MODEM) )
 	{
 		// 1. use phone from opts
 		// 2. use overrides
@@ -693,9 +699,9 @@ int call_system(s_faddr addr, const s_bforce_opts *opts)
 		}
 	}
 
-//       snprintf(s, 299, "after phone check: may use %d must use %d", call_mayuse, call_mustuse);
+       snprintf(s, 299, "after phone check: may use %d must use %d", call_mayuse, call_mustuse);
-//       log(s);
+       log(s);
-
+	   DEB((D_EVENT, s));
 	/*
 	 * Apply overrides to the node information
 	 */	
@@ -746,6 +752,8 @@ int call_system(s_faddr addr, const s_bforce_opts *opts)
 				state.override.sIpaddr, sizeof(state.node.host));
 	}
 	
+	DEB((D_EVENT, "Calling init, IPHOST", state.node.host));
+	
 	if( call_mayuse & CALL_TCPIP_ANY && !tcpip_isgood_host(state.node.host) ) {
 	    char *fidodnszone = conf_string(cf_fidodnszone);
 	    if (fidodnszone) {
@@ -765,13 +773,14 @@ int call_system(s_faddr addr, const s_bforce_opts *opts)
 	{
 		call_mayuse &= ~CALL_TCPIP_ANY;
 		log("bad host, exclude IP");
+		DEB((D_EVENT, "bad host %s, exclude IP", state.node.host));
 		if( call_mustuse & CALL_TCPIP_ANY )
 		{
 			errmsg = "don't know host name";
 			gotoexit(BFERR_PHONE_UNKNOWN);
 		}
 	}
-
+	DEB((D_EVENT,"sess_call: may use %d must use %d", call_mayuse, call_mustuse));
 //       snprintf(s, 299, "after IP check: may use %d must use %d", call_mayuse, call_mustuse);
 //       log(s);
 	
@@ -810,26 +819,31 @@ int call_system(s_faddr addr, const s_bforce_opts *opts)
 	
 	if( rc && call_mayuse & CALL_STDIO )
 	{
+		DEB((D_EVENT,"sess_call: calling stdio"));
 		rc = call_system_quiet(opts->connect, opts->inetd);
 	}
 
 	if( rc && call_mayuse & CALL_TCPIP_BINKP )
 	{
+		DEB((D_EVENT,"sess_call: calling binkp"));
 		rc = call_system_tcpip(CALL_TCPIP_BINKP);
 	}
 
 	if( rc && call_mayuse & CALL_TCPIP_IFCICO )
 	{
+		DEB((D_EVENT,"sess_call: calling ifcico"));
 		rc = call_system_tcpip(CALL_TCPIP_IFCICO);
 	}
 
 	if( rc && call_mayuse & CALL_TCPIP_TELNET )
 	{
+		DEB((D_EVENT,"sess_call: calling telnet"));
 		rc = call_system_tcpip(CALL_TCPIP_TELNET);
 	}
 
 	if( rc && call_mayuse & CALL_MODEM )
 	{
+		DEB((D_EVENT,"sess_call: calling MODEM"));
 		setproctitle("bforce calling %.32s, %.32s",
 			ftn_addrstr(abuf, state.node.addr), state.node.phone);
 		rc = -1;
@@ -850,6 +864,7 @@ int call_system(s_faddr addr, const s_bforce_opts *opts)
 		
 		    if( port_lock(p_lockdir, state.modemport) == 0 ) /* Successfuly locked port */
 		    {
+				DEB((D_EVENT,"sess_call: call_system_modem running"));
 		    	rc = call_system_modem();
 		    	port_unlock(p_lockdir, state.modemport);
 		    }

source/bforce/u_ftn.c

@@ -189,7 +189,8 @@ static int ftn_addrparse_fido(s_faddr *addr, const char *s, bool wildcard)
 	{
 		strnxcpy(addr->domain, string_printable(p), sizeof(addr->domain));
 	}
-	
+	DEB((D_INFO,"u_ftn: Parsed ftn address z:%d, net:%d, node:%d, point:%d",
+		addr->zone, addr->net, addr->node, addr->point));
 	return badaddr;
 }
 
@@ -326,6 +327,7 @@ int ftn_addrparse(s_faddr *addr, const char *s, bool wildcard)
 		addr->node  = DEFAULT_NODE;
 		addr->point = 0;
 		
+		DEB((D_INFO, "u_ftn: parsing ftnaddr %s", s));
 		if( addr->inetform )
 			badaddr = ftn_addrparse_inet(addr, s, wildcard);
 		else

source/bforce/u_misc.c

@@ -81,6 +81,7 @@ void *xrealloc(void *buf, size_t size)
 	else if( (tmp = (char*)(buf ? realloc(buf, size) : malloc(size))) == NULL )
 	{
 		log("failed to reallocate %ld bytes -> abort", size);
+		if( buf ) free(buf);
 		abort();
 	}