/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */

#include <stdio.h>

#if defined(LINUX)

#  include <string.h>
#  include "nspr.h"

static const char abstractSocketName[] = "\0testsocket";

static void ClientThread(void* aArg) {
  PRFileDesc* socket;
  PRNetAddr addr;
  PRUint8 buf[1024];
  PRInt32 len;
  PRInt32 total;

  addr.local.family = PR_AF_LOCAL;
  memcpy(addr.local.path, abstractSocketName, sizeof(abstractSocketName));

  socket = PR_OpenTCPSocket(addr.raw.family);
  if (!socket) {
    fprintf(stderr, "PR_OpenTCPSokcet failed\n");
    exit(1);
  }

  if (PR_Connect(socket, &addr, PR_INTERVAL_NO_TIMEOUT) == PR_FAILURE) {
    fprintf(stderr, "PR_Connect failed\n");
    exit(1);
  }

  total = 0;
  while (total < sizeof(buf)) {
    len = PR_Recv(socket, buf + total, sizeof(buf) - total, 0,
                  PR_INTERVAL_NO_TIMEOUT);
    if (len < 1) {
      fprintf(stderr, "PR_Recv failed\n");
      exit(1);
    }
    total += len;
  }

  total = 0;
  while (total < sizeof(buf)) {
    len = PR_Send(socket, buf + total, sizeof(buf) - total, 0,
                  PR_INTERVAL_NO_TIMEOUT);
    if (len < 1) {
      fprintf(stderr, "PR_Send failed\n");
      exit(1);
    }
    total += len;
  }

  if (PR_Close(socket) == PR_FAILURE) {
    fprintf(stderr, "PR_Close failed\n");
    exit(1);
  }
}

int main() {
  PRFileDesc* socket;
  PRFileDesc* acceptSocket;
  PRThread* thread;
  PRNetAddr addr;
  PRUint8 buf[1024];
  PRInt32 len;
  PRInt32 total;

  addr.local.family = PR_AF_LOCAL;
  memcpy(addr.local.path, abstractSocketName, sizeof(abstractSocketName));

  socket = PR_OpenTCPSocket(addr.raw.family);
  if (!socket) {
    fprintf(stderr, "PR_OpenTCPSocket failed\n");
    exit(1);
  }
  if (PR_Bind(socket, &addr) == PR_FAILURE) {
    fprintf(stderr, "PR_Bind failed\n");
    exit(1);
  }

  if (PR_Listen(socket, 5) == PR_FAILURE) {
    fprintf(stderr, "PR_Listen failed\n");
    exit(1);
  }

  thread = PR_CreateThread(PR_USER_THREAD, ClientThread, 0, PR_PRIORITY_NORMAL,
                           PR_GLOBAL_THREAD, PR_JOINABLE_THREAD, 0);
  if (!thread) {
    fprintf(stderr, "PR_CreateThread failed");
    exit(1);
  }

  acceptSocket = PR_Accept(socket, NULL, PR_INTERVAL_NO_TIMEOUT);
  if (!acceptSocket) {
    fprintf(stderr, "PR_Accept failed\n");
    exit(1);
  }

  memset(buf, 'A', sizeof(buf));

  total = 0;
  while (total < sizeof(buf)) {
    len = PR_Send(acceptSocket, buf + total, sizeof(buf) - total, 0,
                  PR_INTERVAL_NO_TIMEOUT);
    if (len < 1) {
      fprintf(stderr, "PR_Send failed\n");
      exit(1);
    }
    total += len;
  }

  total = 0;
  while (total < sizeof(buf)) {
    len = PR_Recv(acceptSocket, buf + total, sizeof(buf) - total, 0,
                  PR_INTERVAL_NO_TIMEOUT);
    if (len < 1) {
      fprintf(stderr, "PR_Recv failed\n");
      exit(1);
    }
    total += len;
  }

  if (PR_Close(acceptSocket) == PR_FAILURE) {
    fprintf(stderr, "PR_Close failed\n");
    exit(1);
  }

  if (PR_JoinThread(thread) == PR_FAILURE) {
    fprintf(stderr, "PR_JoinThread failed\n");
    exit(1);
  }

  if (PR_Close(socket) == PR_FAILURE) {
    fprintf(stderr, "PR_Close failed\n");
    exit(1);
  }
  printf("PASS\n");
  return 0;
}

#else
int main() {
  printf("PASS\n");
  return 0;
}
#endif