--- ansh/src/utils.c 2012/01/23 10:34:13 1.3 +++ ansh/src/utils.c 2012/07/22 22:41:33 1.4 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ - * $Id: utils.c,v 1.3 2012/01/23 10:34:13 misho Exp $ + * $Id: utils.c,v 1.4 2012/07/22 22:41:33 misho Exp $ * ************************************************************************* The ELWIX and AITNET software is distributed under the following @@ -12,7 +12,7 @@ terms: All of the documentation and software included in the ELWIX and AITNET Releases is copyrighted by ELWIX - Sofia/Bulgaria -Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011 +Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012 by Michael Pounov . All rights reserved. Redistribution and use in source and binary forms, with or without @@ -307,7 +307,7 @@ _pkt_Send(int s, u_int seq, char flg, u_int crypted, u str = cryptBuffer(pos, datlen, Crypted); if (str) { memcpy(pos, str, datlen); - free(str); + io_free(str); } } @@ -419,7 +419,7 @@ _pkt_Recv(u_char * __restrict buf, int rlen, u_int * _ if (str) { memcpy(buf + bpf->bh_hdrlen + ETHER_HDR_LEN + sizeof(struct ansh_hdr), str, *datlen); - free(str); + io_free(str); } } @@ -446,7 +446,7 @@ pktRecv(int s, u_int * __restrict seq, u_int * __restr else memset(data, 0, *datlen); - if (!(buf = malloc(*datlen))) { + if (!(buf = io_malloc(*datlen))) { ERR("malloc() #%d - %s", errno, strerror(errno)); return ANSH_FLG_ERR; } @@ -454,7 +454,7 @@ pktRecv(int s, u_int * __restrict seq, u_int * __restr rlen = read(s, buf, *datlen); if (rlen == -1) { ERR("Receive packet() #%d - %s", errno, strerror(errno)); - free(buf); + io_free(buf); return ANSH_FLG_ERR; } else VERB(4) LOG("Get packet with len=%d", rlen); @@ -462,7 +462,7 @@ pktRecv(int s, u_int * __restrict seq, u_int * __restr /* check header len */ if (rlen < (sizeof(struct bpf_hdr) + ETHER_HDR_LEN + sizeof(struct ansh_hdr))) { VERB(1) LOG("Discard packet too short %d ...", rlen); - free(buf); + io_free(buf); return ANSH_FLG_ERR; } else { bpf = (struct bpf_hdr*) buf; @@ -473,7 +473,7 @@ pktRecv(int s, u_int * __restrict seq, u_int * __restr ptr = next = buf; ptrlen = nextlen = rlen; if ((flg = _pkt_Recv(ptr, ptrlen, seq, crypted, pos, &buflen, &next, &nextlen)) == -1) { - free(buf); + io_free(buf); return ANSH_FLG_ERR; } else { pos += buflen; @@ -492,7 +492,7 @@ pktRecv(int s, u_int * __restrict seq, u_int * __restr ptrlen = nextlen; } - free(buf); + io_free(buf); return flg; } @@ -534,33 +534,4 @@ cryptBuffer(u_char *buf, int rlen, u_int ctr) return NULL; return str; -} - -int -stopProcess(sched_root_task_t * __restrict root, proc_head_t * __restrict h, pid_t pid, sched_task_func_t func) -{ - struct tagProc *p; - - FTRACE(3); - - SLIST_FOREACH(p, h, proc_next) - if (p->proc_pid == pid) { - break; - } - VERB(3) LOG("pid=%d found=%p\n", pid, p); - if (!p) - return 1; - - ioFreePTY(p->proc_pty, p->proc_ttyname); - if (p->proc_pty) - schedCancelby(root, NULL, CRITERIA_FD, (void*) ((intptr_t) p->proc_pty), NULL); - - p->proc_pty = 0; - p->proc_pid = 0; - p->proc_seq = 0; - p->proc_flg = ANSH_FLG_EOF; - p->proc_rlen_[FD2NET] = 0; - - schedCallOnce(root, func, p, p->proc_sock); - return 0; }