CWE-400: Uncontrolled Resource Consumption

class Worker implements Executor {
                        ...public void execute(Runnable r) {
                              
                                 try {...}catch (InterruptedException ie) {
                                    
                                       
                                       // postpone response
                                       Thread.currentThread().interrupt();
                                 }
                           }
                           public Worker(Channel ch, int nworkers) {...}
                           protected void activate() {
                              
                                 Runnable loop = new Runnable() {
                                    
                                       public void run() {
                                          
                                             try {for (;;) {Runnable r = ...;r.run();}}catch (InterruptedException ie) {...}
                                       }
                                 };new Thread(loop).start();
                           }
                     }

sock=socket(AF_INET, SOCK_STREAM, 0);while (1) {newsock=accept(sock, ...);printf("A connection has been accepted\n");pid = fork();}

int writeDataFromSocketToFile(char *host, int port){
                        
                           char filename[FILENAME_SIZE];char buffer[BUFFER_SIZE];int socket = openSocketConnection(host, port);
                           if (socket < 0) {printf("Unable to open socket connection");return(FAIL);}if (getNextMessage(socket, filename, FILENAME_SIZE) > 0) {
                              if (openFileToWrite(filename) > 0) {
                                    while (getNextMessage(socket, buffer, BUFFER_SIZE) > 0){if (!(writeToFile(buffer) > 0))break;
                                       }
                                 }closeFile();
                           }closeSocket(socket);
                     }

/* process message accepts a two-dimensional character array of the form [length][body] containing the message to be processed */
                     int processMessage(char **message){
                        char *body;
                           int length = getMessageLength(message[0]);
                           if (length > 0) {body = &message[1][0];processMessageBody(body);return(SUCCESS);}else {printf("Unable to process message; invalid message length");return(FAIL);}
                     }

unsigned int length = getMessageLength(message[0]);if ((length > 0) && (length < MAX_LENGTH)) {...}