Text  |   XML   |   Visible Warnings:

pvm3.4.6 : pvm3.4.6 analysis 2 : Null Pointer Dereference  at pvmd.c:1927

Categories: LANG.MEM.NPD CWE:476
Warning ID: 98.28691
Procedure: work
Trace: view
Modified: Thu Nov 26 11:27:24 2009   show details
 
Priority: None
State: None
Finding: None
Owner: None
  edit properties

Legend [ X ]
Warning Location
Contributes
Parse Error
Other Warning
Two or More Loop Iterations
On Execution Path
Comment
Macro
Preprocessor
Include
Keyword
Preprocessed Away
Legend
Warning Location Contributes Parse Error
Other Warning Two or More Loop Iterations On Execution Path
Comment Macro Preprocessor
Include Keyword Preprocessed Away

Source  |  Language: C Hide Legend     
ProblemLineSource
   /kat0/fletcher/SATE/2010/pvm3/src/pvmd.c
   Enter work
 1696 work() 
 1697 {
 1698         static int lastpinged = 0;      /* host that got last keepalive msg */ 
 1699 #ifdef FDSETNOTSTRUCT 
 1700         fd_set rfds, wfds;                      /* result of select */ 
 1701         /* fd_set efds; */ 
 1702 #else 
 1703         struct fd_set rfds, wfds;       /* result of select */ 
 1704         /* struct fd_set efds; */ 
 1705 #endif 
 1706         int nrdy;                                       /* number of fds ready after select */ 
   ...
 1718         double tbpl;                            /* time at beginning of probe loop */ 
 1719         double toutpl;                          /* timeout in the probe loop */ 
 1720         int timed_out;
 1721         extern double dclock();
 1722 #endif 
 1723 #endif 
 1724 #ifdef  SHMEM 
 1725         int someclosed; 
 1726 #endif 
 1727  
 1728         gettimeofday(&tnow, (struct timezone*)0);
 1729         if (pvmdebmask || myhostpart) {
 1730                 PVM_TIMET time_temp;
 1731                 pvmlogprintf("%s (%s) %s %s\n",
 1732                                 hosts->ht_hosts[hosts->ht_local]->hd_name,
 1733                                 inadport_decimal(&hosts->ht_hosts[hosts->ht_local]->hd_sad),   /* Buffer Overrun (ID: 22089.28936) */  /* Buffer Underrun (ID: 22088.28935) */
 1734                                 myarchname,
 1735                                 PVM_VER);
 1736                 pvmlogprintf("ready ");
 1737                 time_temp = (PVM_TIMET) tnow.tv_sec;
 1738                 pvmlogprintf(ctime(&time_temp));   /* Format String (ID: 22201.29376) */
 1739         }
 1740  
 1741         /*
 1742         * check for default plug-in modules (& start them)
 1743         * (only if pvmd, not for pvmd'...)
 1744         */ 
 1745  
 1746         if ( myhostpart ) {
 1747                 char *av[5];
 1748                 char *buf;
 1749                 char *cmd;
 1750                 int ac;
 1751                 int i;
 1752  
 1753                 for ( i=0 ; modulenames[i] ; i++ ) {
 1754                         cmd = getenv( modulenames[i] );
 1755                         if ( cmd != NULL )
 1756                         {
   ...
 1765                                 }
 1766                                 if (buf) PVM_FREE( buf );
 1767                         }
 1768                 }
 1769         }
 1770  
 1771         /*
 1772         * remind myself to start those pesky slave pvmds 
 1773         */ 
 1774  
 1775         if (addmesg) {
 1776                 struct pmsg *mp = addmesg;
 1777  
 1778                 addmesg = 0;
 1779                 sendmessage(mp);
 1780         }
 1781  
 1782         /*
 1783         * init bail (for PVMDSTARTUP) and ping times 
 1784         */ 
 1785  
 1786         pvmgetclock(&tnow);
 1787         tout.tv_sec = DDBAILTIME;
 1788         tout.tv_usec = 0;
 1789         TVXADDY(&tbail, &tnow, &tout);
 1790  
 1791         tout.tv_sec = DDPINGTIME;
 1792         tout.tv_usec = 0;
 1793         TVXADDY(&tping, &tnow, &tout);
 1794  
 1795         /* init select fd sets */ 
 1796  
 1797         wrk_fds_init();
 1798  
 1799         if (loclsock >= 0)
 1800                 wrk_fds_add(loclsock, 1);
 1801         wrk_fds_add(netsock, 1);
 1802  
 1803         for (; ; ) {
 1804  
 1805                 /*
 1806                 *       clean up after any tasks that we got SIGCHLDs for 
 1807                 */ 
 1808 #ifdef IMA_BEOSCYLD 
 1809                 reap(SIGCLD); 
 1810 #endif 
 1811                 while (rdead != wdead) {
 1812                         if (deads[rdead].dd_pid == pprime) {
 1813                                 int cc;
 1814 #ifdef SOCKLENISUINT 
 1815 #if defined(IMA_AIX4SP2) || defined(IMA_AIX5SP2) \
 1816                 || defined(IMA_AIX56K64) || defined(IMA_LINUXALPHA)
 1817                                 unsigned int oslen;
 1818 #else 
 1819                                 size_t oslen;
 1820 #endif 
 1821 #else 
 1822                                 int oslen;
 1823 #endif 
 1824                                 struct sockaddr_in osad;
 1825                                 struct timeval t;
 1826                                 char buf[DDFRAGHDR];
 1827  
 1828                                 hostfailentry(hosts->ht_hosts[0]);
 1829                                 clear_opq_of((int)(TIDPVMD | hosts->ht_hosts[0]->hd_hostpart));
 1830                                 pprime = 0;
 1831  
 1832                                 while (1) {
 1833                                         FD_ZERO(&rfds);
 1834                                         FD_SET(ppnetsock, &rfds);
 1835                                         t.tv_sec = 0;
 1836                                         t.tv_usec = 0;
 1837                                         cc = select(ppnetsock + 1,
 1838 #ifdef  FDSETISINT 
 1839                                                         (int *)&rfds, (int *)0, (int *)0, 
 1840 #else 
 1841                                                         (fd_set *)&rfds, (fd_set *)0, (fd_set *)0,
 1842 #endif 
 1843                                                         &t);
 1844                                         if (cc == 1) {
 1845                                                 oslen = sizeof(osad);
 1846                                                 recvfrom(ppnetsock, buf, sizeof(buf),
 1847                                                                 0, (struct sockaddr*)&osad, &oslen);
 1848  
 1849                                         } else if (cc != -1 || errno != EINTR)
 1850                                                 break;
 1851                                 }
 1852  
 1853                         } else {
 1854                                 if (tp = task_findpid(deads[rdead].dd_pid)) {
 1855  
 1856                 /* check for output one last time 
 1857                    XXX this could be cleaner by going through main select again 
 1858                    XXX before flushing the task */ 
 1859  
 1860                                         tp->t_status = deads[rdead].dd_es;
 1861                                         tp->t_utime = deads[rdead].dd_ut;
 1862                                         tp->t_stime = deads[rdead].dd_st;
 1863                                         while (tp->t_out >= 0) {
 1864  
 1865 #ifdef FDSETNOTSTRUCT 
 1866                                                 fd_set rfds;
 1867 #else 
 1868                                                 struct fd_set rfds; 
 1869 #endif 
 1870  
 1871                                                 FD_ZERO(&rfds);
 1872                                                 FD_SET(tp->t_out, &rfds);
 1873                                                 TVCLEAR(&tout);
 1874                                                 if (select(tp->t_out + 1,
 1875 #ifdef  FDSETISINT 
 1876                                                                 (int *)&rfds, (int *)0, (int *)0, 
 1877 #else 
 1878                                                                 (fd_set *)&rfds, (fd_set *)0, (fd_set *)0,
 1879 #endif 
 1880                                                                 &tout) == 1)
 1881                                                         loclstout(tp);
 1882  
 1883                                                 else 
 1884                                                         break;
 1885                                         }
 1886 #if defined(IMA_PGON) || defined(IMA_SP2MPI) || defined(IMA_AIX4SP2) \
 1887         || defined(IMA_AIX5SP2) || defined(IMA_BEOLIN) 
 1888                                         mpp_free(tp); 
 1889 #endif 
 1890                                         task_cleanup(tp);
 1891                                         task_free(tp);
 1892                                 }
 1893                         }
 1894                         if (++rdead >= ndead)
 1895                                 rdead = 0;
 1896                 }
 1897  
 1898                 netoutput();
 1899  
 1900                 if (runstate == PVMDHALTING) {
 1901                         pvmlogerror("work() pvmd halting\n");
 1902                         pvmbailout(0);
 1903                 }
 1904  
 1905                 /* bail if new slave and haven't been configured for too long */ 
 1906                 pvmgetclock(&tnow);
 1907                 if (runstate == PVMDSTARTUP && TVXLTY(&tbail, &tnow)) {
 1908                         pvmlogerror("work() run = STARTUP, timed out waiting for master\n");
 1909                         pvmbailout(0);
 1910                 }
 1911  
 1912                 /*
 1913                 * send keepalive message to remote pvmd once in a while 
 1914                 */ 
 1915                 if (TVXLTY(&tping, &tnow)) {
 1916                         if (pvmdebmask & (PDMPACKET|PDMSELECT))
 1917                                 pvmlogerror("work() ping timer\n");
 1918                         if (runstate == PVMDNORMAL || runstate == PVMDHTUPD) {
 1919                                 do {
 1920                                         if (++lastpinged > hosts->ht_last)
 1921                                                 lastpinged = 1;
 1922                                 } while (!(hp = hosts->ht_hosts[lastpinged]));
 1923  
 1924                                 if (hp->hd_hostpart != myhostpart 
 1925                                 && hp->hd_txq->pk_link == hp->hd_txq) {
true1926                                         mp = mesg_new(0);
mp <= 40951927                                         mp->m_tag = DM_NULL;     /* Null Pointer Dereference */
 1928                                         mp->m_dst = hp->hd_hostpart | TIDPVMD;
 1929                                         sendmessage(mp);
 1930                                 }
 1931                         }
 1932                         tout.tv_sec = DDPINGTIME;
 1933                         tout.tv_usec = 0;
 1934                         TVXADDY(&tping, &tnow, &tout);
 1935                 }
 1936  
 1937                 /*
 1938                 * figure select timeout 
 1939                 */ 
 1940  
 1941                 if (opq->pk_tlink == opq)
 1942                         tout = tping;
 1943                 else 
 1944                         tout = opq->pk_tlink->pk_rtv;   /* Use After Free (ID: 22033.28690) */
 1945  
 1946                 if (TVXLTY(&tout, &tnow)) {
 1947                         TVCLEAR(&tout);
 1948  
 1949                 } else {
 1950                         TVXSUBY(&tout, &tout, &tnow);
 1951                 }
 1952  
 1953                 if (pvmdebmask & PDMSELECT) {
 1954                         pvmlogprintf("work() select tout is %d.%06d\n",
 1955                                         tout.tv_sec, tout.tv_usec);
 1956                 }
 1957  
 1958  
 1959 #ifdef SHMEM 
 1960                 if ((nodemsg = mpp_probe()) == 1) {
 1961                         mpp_input();
 1962                         TVCLEAR(&tout);
 1963                 } 
 1964 #endif 
 1965  
 1966                 rfds = wrk_rfds;
 1967                 wfds = wrk_wfds;
 1968 /*
 1969                 efds = wrk_efds;
 1970 */ 
 1971                 if (pvmdebmask & PDMSELECT) {
 1972                         pvmlogprintf("work() wrk_nfds=%d\n", wrk_nfds);
 1973                         print_fdset("work() rfds=", wrk_nfds, &rfds);
 1974                         print_fdset("work() wfds=", wrk_nfds, &wfds);
 1975                 }
 1976  
 1977 #if !defined(IMA_PGON) && !defined(IMA_I860)
 1978  
 1979                 if ((nrdy = select(wrk_nfds,
 1980 #ifdef  FDSETISINT 
 1981                                 (int *)&rfds, (int *)&wfds, (int *)0, 
 1982 #else 
 1983                                 (fd_set *)&rfds, (fd_set *)&wfds, (fd_set *)0,
 1984 #endif 
 1985                                 &tout)) == -1) {
 1986                         if (errno != EINTR) {
 1987                                 pvmlogperror("work() select");
 1988                                 pvmlogprintf(" wrk_nfds=%d\n", wrk_nfds);
 1989                                 print_fdset(" rfds=", wrk_nfds, &wrk_rfds);
 1990                                 print_fdset(" wfds=", wrk_nfds, &wrk_wfds);
 1991                                 pvmlogprintf(" netsock=%d, ppnetsock=%d, loclsock=%d\n",
 1992                                                 netsock, ppnetsock, loclsock);
 1993                                 task_dump();
 1994                                 pvmbailout(0);
 1995                         }
 1996                 }
   ...
 2054                         }
 2055  
 2056                         /* Try to send packets that are still on the mpp output q */ 
 2057                         mpp_output( (struct task *) NULL, (struct pkt *) NULL);
 2058  
 2059                 } while(!(nrdy || nodemsg || timed_out)); 
 2060  
 2061 #endif /*IMA_PGON/IMA_I860*/ 
 2062  
 2063 #ifdef  STATISTICS 
 2064                 switch (nrdy) {
 2065                 case -1: 
 2066                         stats.selneg++;
 2067                         break;
 2068                 case 0: 
 2069                         stats.selzer++;
 2070                         break;
 2071                 default: 
 2072                         stats.selrdy++;
 2073                         break;
 2074                 }
 2075 #endif 
 2076                 if (pvmdebmask & PDMSELECT) {
 2077                         pvmlogprintf("work() SELECT returns %d\n", nrdy);
 2078                 }
 2079  
 2080         /*
 2081         *       check network socket and local master socket for action 
 2082         */ 
 2083  
 2084                 if (nrdy > 0) {
 2085                         if (FD_ISSET(netsock, &rfds)) {
 2086                                 nrdy--;
 2087                                 netinput();
 2088                         }
 2089                         if (loclsock >= 0 && FD_ISSET(loclsock, &rfds)) {
 2090                                 nrdy--;
 2091                                 loclconn();
 2092                         }
 2093                 }
 2094  
 2095         /*
 2096         *       check tasks for action 
 2097         */ 
 2098  
 2099 #ifdef  SHMEM 
 2100                 someclosed = 0; 
 2101 #endif 
 2102                 if (loclsock >= 0) {
 2103                         for (tp = locltasks->t_link;
 2104                                         nrdy > 0 && tp != locltasks;
 2105                                         tp = tp->t_link) {
 2106  
 2107                                 if (tp->t_sock >= 0 && FD_ISSET(tp->t_sock, &rfds)) {
 2108                                         FD_CLR(tp->t_sock, &rfds);
 2109                                         nrdy--;
 2110                                         if (loclinput(tp)) {
 2111 #ifdef  SHMEM 
 2112                                                 if (tp->t_tid == 0)
 2113                                                         someclosed++; 
 2114 #endif 
 2115                                                 if (pvmdebmask & PDMTASK) {
 2116                                                         pvmlogprintf( 
 2117                                                                         "work() error reading from t%x, marking dead\n",
 2118                                                                         tp->t_tid);
 2119                                                 }
 2120                                                 if (!(tp->t_flag & TF_FORKD)) {
 2121                                                         tp = tp->t_rlink;
 2122                                                         task_cleanup(tp->t_link);
 2123                                                         task_free(tp->t_link);
 2124  
 2125                                                 } else 
 2126                                                         wrk_fds_delete(tp->t_sock, 3);
 2127                                                 continue;
 2128                                         }
 2129                                 }
 2130  
 2131                                 if (tp->t_sock >= 0 && FD_ISSET(tp->t_sock, &wfds)) {
 2132                                         FD_CLR(tp->t_sock, &wfds);
 2133                                         nrdy--;
 2134                                         if (locloutput(tp)) {
 2135 #ifdef  SHMEM 
 2136                                                 if (tp->t_tid == 0)
 2137                                                         someclosed++; 
 2138 #endif 
 2139                                                 if (!(tp->t_flag & TF_FORKD)) {
 2140                                                         tp = tp->t_rlink;
 2141                                                         task_cleanup(tp->t_link);
 2142                                                         task_free(tp->t_link);
 2143  
 2144                                                 } else 
 2145                                                         wrk_fds_delete(tp->t_sock, 3);
 2146                                                 continue;
 2147                                         }
 2148                                 }
 2149  
 2150                                 if (tp->t_out >= 0 && FD_ISSET(tp->t_out, &rfds)) {
 2151                                         FD_CLR(tp->t_out, &rfds);
 2152                                         nrdy--;
 2153                                         loclstout(tp);
Preconditions 
locltasks->t_ccs >= 0
locltasks->t_wait >= 0
locltasks->t_txq >= 0
locltasks->t_rxp >= 0
locltasks->t_rxm >= 0
locltasks->t_authnam >= 0
((char*)$unknown_234584)[80] = ((char*)&$unknown_234584)[80]
((char*)&$unknown_234584)[4] != 0
loclsock <= -1
myhostpart = 0
pvmdebmask != 0
runstate != 5
$input_12 <= 25
$input_12 >= 0
tnow.tv_usec >= 1000000
wdead <= ndead - 1
Postconditions 
locltasks->t_out' <= -1
locltasks->t_mca' = 0
*locltasks' is freed
addmesg' = 0
ctime_buf[0]' = $input_444
strlen(&ctime_buf[0])' = $input_12
errno' != 0
freepmsgs.m_link' = &freepmsgs.m_link
freepmsgs.m_rlink' = &freepmsgs.m_link
hp' = &$unknown_234584
mp' = 0
mp' = addmesg
numpmsgs' = 0
rdead' = wdead
runstate' = 1
tbail.tv_usec' = tnow.tv_usec - 1000000
time_temp' = &$unknown_234540
tp' = locltasks



Change Warning 98.28691 : Null Pointer Dereference

Priority:
State:
Finding:
Owner:
Note: