Uncontrolled Resource Consumption

The product does not properly control the allocation and maintenance of a limited resource, thereby enabling an actor to influence the amount of resources consumed, eventually leading to the exhaustion of available resources.


Description

Limited resources include memory, file system storage, database connection pool entries, and CPU. If an attacker can trigger the allocation of these limited resources, but the number or size of the resources is not controlled, then the attacker could cause a denial of service that consumes all available resources. This would prevent valid users from accessing the product, and it could potentially have an impact on the surrounding environment. For example, a memory exhaustion attack against an application could slow down the application as well as its host operating system.

There are at least three distinct scenarios which can commonly lead to resource exhaustion:

Lack of throttling for the number of allocated resources

Losing all references to a resource before reaching the shutdown stage

Not closing/returning a resource after processing

Resource exhaustion problems are often result due to an incorrect implementation of the following situations:

Error conditions and other exceptional circumstances.

Confusion over which part of the program is responsible for releasing the resource.

Demonstrations

The following examples help to illustrate the nature of this weakness and describe methods or techniques which can be used to mitigate the risk.

Note that the examples here are by no means exhaustive and any given weakness may have many subtle varieties, each of which may require different detection methods or runtime controls.

Example One

The following example demonstrates the weakness.

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();

  }

}

There are no limits to runnables. Potentially an attacker could cause resource problems very quickly.

Example Two

This code allocates a socket and forks each time it receives a new connection.

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

The program does not track how many connections have been made, and it does not limit the number of connections. Because forking is a relatively expensive operation, an attacker would be able to cause the system to run out of CPU, processes, or memory by making a large number of connections. Alternatively, an attacker could consume all available connections, preventing others from accessing the system remotely.

Example Three

In the following example a server socket connection is used to accept a request to store data on the local file system using a specified filename. The method openSocketConnection establishes a server socket to accept requests from a client. When a client establishes a connection to this service the getNextMessage method is first used to retrieve from the socket the name of the file to store the data, the openFileToWrite method will validate the filename and open a file to write to on the local file system. The getNextMessage is then used within a while loop to continuously read data from the socket and output the data to the file until there is no longer any data from the socket.

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);

}

This example creates a situation where data can be dumped to a file on the local file system without any limits on the size of the file. This could potentially exhaust file or disk resources and/or limit other clients' ability to access the service.

Example Four

In the following example, the processMessage method receives a two dimensional character array containing the message to be processed. The two-dimensional character array contains the length of the message in the first character array and the message body in the second character array. The getMessageLength method retrieves the integer value of the length from the first character array. After validating that the message length is greater than zero, the body character array pointer points to the start of the second character array of the two-dimensional character array and memory is allocated for the new body character array.

/* 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);
  }

}

This example creates a situation where the length of the body character array can be very large and will consume excessive memory, exhausting system resources. This can be avoided by restricting the length of the second character array with a maximum length check

Also, consider changing the type from 'int' to 'unsigned int', so that you are always guaranteed that the number is positive. This might not be possible if the protocol specifically requires allowing negative values, or if you cannot control the return value from getMessageLength(), but it could simplify the check to ensure the input is positive, and eliminate other errors such as signed-to-unsigned conversion errors (CWE-195) that may occur elsewhere in the code.

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

Example Five

In the following example, a server object creates a server socket and accepts client connections to the socket. For every client connection to the socket a separate thread object is generated using the ClientSocketThread class that handles request made by the client through the socket.

public void acceptConnections() {


  try {
    ServerSocket serverSocket = new ServerSocket(SERVER_PORT);
    int counter = 0;
    boolean hasConnections = true;
    while (hasConnections) {
      Socket client = serverSocket.accept();
      Thread t = new Thread(new ClientSocketThread(client));
      t.setName(client.getInetAddress().getHostName() + ":" + counter++);
      t.start();
    }
    serverSocket.close();


  } catch (IOException ex) {...}

}

In this example there is no limit to the number of client connections and client threads that are created. Allowing an unlimited number of client connections and threads could potentially overwhelm the system and system resources.

The server should limit the number of client connections and the client threads that are created. This can be easily done by creating a thread pool object that limits the number of threads that are generated.

public static final int SERVER_PORT = 4444;
public static final int MAX_CONNECTIONS = 10;
...

public void acceptConnections() {


  try {
    ServerSocket serverSocket = new ServerSocket(SERVER_PORT);
    int counter = 0;
    boolean hasConnections = true;
    while (hasConnections) {
      hasConnections = checkForMoreConnections();
      Socket client = serverSocket.accept();
      Thread t = new Thread(new ClientSocketThread(client));
      t.setName(client.getInetAddress().getHostName() + ":" + counter++);
      ExecutorService pool = Executors.newFixedThreadPool(MAX_CONNECTIONS);
      pool.execute(t);
    }
    serverSocket.close();


  } catch (IOException ex) {...}

}

Example Six

In the following example, the serve function receives an http request and an http response writer. It reads the entire request body.

func serve(w http.ResponseWriter, r *http.Request) {
  var body []byte
  if r.Body != nil {

    if data, err := io.ReadAll(r.Body); err == nil {

      body = data

    }
  }
}

Because ReadAll is defined to read from src until EOF, it does not treat an EOF from Read as an error to be reported. This example creates a situation where the length of the body supplied can be very large and will consume excessive memory, exhausting system resources. This can be avoided by ensuring the body does not exceed a predetermined length of bytes.

MaxBytesReader prevents clients from accidentally or maliciously sending a large request and wasting server resources. If possible, the code could be changed to tell ResponseWriter to close the connection after the limit has been reached.

func serve(w http.ResponseWriter, r *http.Request) {
  var body []byte
  const MaxRespBodyLength = 1e6
  if r.Body != nil {

    r.Body = http.MaxBytesReader(w, r.Body, MaxRespBodyLength)
    if data, err := io.ReadAll(r.Body); err == nil {

      body = data

    }
  }
}

See Also

Comprehensive Categorization: Resource Lifecycle Management

Weaknesses in this category are related to resource lifecycle management.

SEI CERT Oracle Secure Coding Standard for Java - Guidelines 49. Miscellaneous (MSC)

Weaknesses in this category are related to the rules and recommendations in the Miscellaneous (MSC) section of the SEI CERT Oracle Secure Coding Standard for Java.

SEI CERT Oracle Secure Coding Standard for Java - Guidelines 14. Serialization (SER)

Weaknesses in this category are related to the rules and recommendations in the Serialization (SER) section of the SEI CERT Oracle Secure Coding Standard for Java.

Comprehensive CWE Dictionary

This view (slice) covers all the elements in CWE.

Weaknesses Addressed by ISA/IEC 62443 Requirements

This view (slice) covers weaknesses that are addressed by following requirements in the ISA/IEC 62443 series of standards for industrial automation and control systems...

Weaknesses in the 2022 CWE Top 25 Most Dangerous Software Weaknesses

CWE entries in this view are listed in the 2022 CWE Top 25 Most Dangerous Software Weaknesses.


Common Weakness Enumeration content on this website is copyright of The MITRE Corporation unless otherwise specified. Use of the Common Weakness Enumeration and the associated references on this website are subject to the Terms of Use as specified by The MITRE Corporation.