Method recvAll

jvm/core/src/main/java/org/apache/tvm/rpc/Utils.java:31–39

(final InputStream in, final int numBytes)

 */
class Utils {
  public static byte[] recvAll(final InputStream in, final int numBytes) throws IOException {
    byte[] res = new byte[numBytes];
    int numRead = 0;
    while (numRead < numBytes) {
      int chunk = in.read(res, numRead, Math.min(numBytes - numRead, 1024));
      numRead += chunk;
    }
    return res;
  }

  public static void closeQuietly(Socket socket) {
    if (socket != null) {