Some start on netplay. :)

Makefile

@@ -2,7 +2,7 @@ include config.mk
 
 TARGET = ssnes tools/ssnes-joyconfig
 
-OBJ = ssnes.o file.o driver.o settings.o dynamic.o message.o rewind.o movie.o autosave.o
+OBJ = ssnes.o file.o driver.o settings.o dynamic.o message.o rewind.o movie.o autosave.o netplay.o
 JOYCONFIG_OBJ = tools/ssnes-joyconfig.o conf/config_file.o
 HEADERS = $(wildcard */*.h) $(wildcard *.h)
 

general.h

@@ -27,6 +27,7 @@
 #include "rewind.h"
 #include "movie.h"
 #include "autosave.h"
+#include "netplay.h"
 
 #ifdef HAVE_CONFIG_H
 #include "config.h"
@@ -178,6 +179,10 @@ struct global
 
    autosave_t *autosave[2];
 
+   netplay_t *netplay;
+   char netplay_server[256];
+   bool netplay_enable;
+
 #ifdef HAVE_FFMPEG
    ffemu_t *rec;
    char record_path[256];

netplay.c

@@ -0,0 +1,260 @@
+/*  SSNES - A Super Nintendo Entertainment System (SNES) Emulator frontend for libsnes.
+ *  Copyright (C) 2010-2011 - Hans-Kristian Arntzen
+ *
+ *  Some code herein may be based on code found in BSNES.
+ * 
+ *  SSNES is free software: you can redistribute it and/or modify it under the terms
+ *  of the GNU General Public License as published by the Free Software Found-
+ *  ation, either version 3 of the License, or (at your option) any later version.
+ *
+ *  SSNES is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
+ *  without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
+ *  PURPOSE.  See the GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License along with SSNES.
+ *  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#include "netplay.h"
+#include "general.h"
+#include "dynamic.h"
+#include <stdlib.h>
+#include <string.h>
+
+#ifdef _WIN32
+#define _WIN32_WINNT 0x0501
+#define WIN32_LEAN_AND_MEAN
+#include <windows.h>
+#include <winsock2.h>
+#include <ws2tcpip.h>
+#define close(x) closesocket(x)
+#define CONST_CAST (const char*)
+#else
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <netinet/tcp.h>
+#include <arpa/inet.h>
+#include <netdb.h>
+#define CONST_CAST
+#endif
+
+struct netplay
+{
+   struct snes_callbacks cbs;
+   int fd;
+   unsigned port;
+   bool has_connection;
+   unsigned frames;
+
+   uint16_t input_state;
+};
+
+void input_poll_net(void)
+{
+   netplay_callbacks(g_extern.netplay)->poll_cb();
+   netplay_poll(g_extern.netplay);
+}
+
+void video_frame_net(const uint16_t *data, unsigned width, unsigned height)
+{
+   netplay_callbacks(g_extern.netplay)->frame_cb(data, width, height);
+}
+
+void audio_sample_net(uint16_t left, uint16_t right)
+{
+   netplay_callbacks(g_extern.netplay)->sample_cb(left, right);
+}
+
+int16_t input_state_net(bool port, unsigned device, unsigned index, unsigned id)
+{
+   if (netplay_is_port(g_extern.netplay, port, index))
+      return netplay_input_state(g_extern.netplay, port, device, index, id);
+   else
+      return netplay_callbacks(g_extern.netplay)->state_cb(port, device, index, id);
+}
+
+static bool init_socket(netplay_t *handle, const char *server, uint16_t port)
+{
+#ifdef _WIN32
+   WSADATA wsaData;
+   int retval;
+
+   if ((retval = WSAStartup(MAKEWORD(2,2), &wsaData)) != 0)
+   {
+      WSACleanup();
+      return false;
+   }
+#endif
+
+   struct addrinfo hints, *res = NULL;
+   memset(&hints, 0, sizeof(hints));
+#ifdef _WIN32 // Lolol, no AF_UNSPEC, wtf.
+   hints.ai_family = AF_INET;
+#else
+   hints.ai_family = AF_UNSPEC;
+#endif
+   hints.ai_socktype = SOCK_STREAM;
+   if (!server)
+      hints.ai_flags = AI_PASSIVE;
+
+   char port_buf[16];
+   snprintf(port_buf, sizeof(port_buf), "%hu", (unsigned short)port);
+   if (getaddrinfo(server, port_buf, &hints, &res) < 0)
+      return false;
+
+   handle->fd = socket(res->ai_family, res->ai_socktype, res->ai_protocol);
+   if (handle->fd < 0)
+   {
+      freeaddrinfo(res);
+      return false;
+   }
+
+   if (server)
+   {
+      if (connect(handle->fd, res->ai_addr, res->ai_addrlen) < 0)
+      {
+         close(handle->fd);
+         freeaddrinfo(res);
+         return false;
+      }
+   }
+   else
+   {
+      if (bind(handle->fd, res->ai_addr, res->ai_addrlen) < 0 || listen(handle->fd, 1) < 0)
+      {
+         close(handle->fd);
+         freeaddrinfo(res);
+         return false;
+      }
+      int new_fd = accept(handle->fd, NULL, NULL);
+      if (new_fd < 0)
+      {
+         close(handle->fd);
+         freeaddrinfo(res);
+         return false;
+      }
+      close(handle->fd);
+      handle->fd = new_fd;
+   }
+
+   freeaddrinfo(res);
+
+   const int nodelay = 1;
+   setsockopt(handle->fd, SOL_SOCKET, TCP_NODELAY, &nodelay, sizeof(int));
+
+   return true;
+}
+
+static bool send_info(netplay_t *handle)
+{
+   uint32_t header[2] = { htonl(g_extern.cart_crc), htonl(psnes_serialize_size()) };
+   if (send(handle->fd, header, sizeof(header), 0) != sizeof(header))
+      return false;
+   return true;
+}
+
+static bool get_info(netplay_t *handle)
+{
+   uint32_t header[2];
+   if (recv(handle->fd, header, sizeof(header), 0) != sizeof(header))
+      return false;
+   if (g_extern.cart_crc != ntohl(header[0]))
+      return false;
+   if (psnes_serialize_size() != ntohl(header[1]))
+      return false;
+   return true;
+}
+
+netplay_t *netplay_new(const char *server, uint16_t port, unsigned frames, const struct snes_callbacks *cb)
+{
+   netplay_t *handle = calloc(1, sizeof(*handle));
+   if (!handle)
+      return NULL;
+
+   handle->cbs = *cb;
+   handle->port = server ? 0 : 1;
+   handle->frames = frames;
+
+   if (!init_socket(handle, server, port))
+   {
+      free(handle);
+      return NULL;
+   }
+
+   if (server)
+   {
+      if (!send_info(handle))
+      {
+         close(handle->fd);
+         free(handle);
+         return NULL;
+      }
+   }
+   else
+   {
+      if (!get_info(handle))
+      {
+         close(handle->fd);
+         free(handle);
+         return NULL;
+      }
+   }
+
+   handle->has_connection = true;
+   return handle;
+}
+
+bool netplay_is_port(netplay_t *handle, bool port, unsigned index)
+{
+   if (!handle->has_connection)
+      return false;
+   unsigned port_num = port ? 1 : 0;
+   if (handle->port == port_num)
+      return true;
+   else
+      return false;
+}
+
+bool netplay_poll(netplay_t *handle)
+{
+   uint16_t state = 0;
+   snes_input_state_t cb = handle->cbs.state_cb;
+   for (int i = 0; i <= 11; i++)
+   {
+      int16_t tmp = cb(!handle->port, SNES_DEVICE_JOYPAD, 0, i);
+      state |= tmp ? 1 << i : 0;
+   }
+
+   state = htons(state);
+   if (send(handle->fd, &state, sizeof(state), 0) != sizeof(state))
+   {
+      handle->has_connection = false;
+      return false;
+   }
+
+   if (recv(handle->fd, &handle->input_state, sizeof(handle->input_state), 0) != sizeof(handle->input_state))
+   {
+      handle->has_connection = false;
+      return false;
+   }
+
+   handle->input_state = ntohs(handle->input_state);
+   return true;
+}
+
+int16_t netplay_input_state(netplay_t *handle, bool port, unsigned device, unsigned index, unsigned id)
+{
+   return ((1 << id) & handle->input_state) ? 1 : 0;
+}
+
+void netplay_free(netplay_t *handle)
+{
+   close(handle->fd);
+   free(handle);
+}
+
+const struct snes_callbacks* netplay_callbacks(netplay_t *handle)
+{
+   return &handle->cbs;
+}

netplay.h

@@ -0,0 +1,59 @@
+/*  SSNES - A Super Nintendo Entertainment System (SNES) Emulator frontend for libsnes.
+ *  Copyright (C) 2010-2011 - Hans-Kristian Arntzen
+ *
+ *  Some code herein may be based on code found in BSNES.
+ * 
+ *  SSNES is free software: you can redistribute it and/or modify it under the terms
+ *  of the GNU General Public License as published by the Free Software Found-
+ *  ation, either version 3 of the License, or (at your option) any later version.
+ *
+ *  SSNES is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
+ *  without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
+ *  PURPOSE.  See the GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License along with SSNES.
+ *  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+
+#ifndef __SSNES_NETPLAY_H
+#define __SSNES_NETPLAY_H
+
+#include <stdint.h>
+#include <stdbool.h>
+#include <libsnes.hpp>
+
+void input_poll_net(void);
+int16_t input_state_net(bool port, unsigned device, unsigned index, unsigned id);
+void video_frame_net(const uint16_t *data, unsigned width, unsigned height);
+void audio_sample_net(uint16_t left, uint16_t right);
+
+typedef struct netplay netplay_t;
+
+struct snes_callbacks
+{
+   snes_video_refresh_t frame_cb;
+   snes_audio_sample_t sample_cb;
+   snes_input_poll_t poll_cb;
+   snes_input_state_t state_cb;
+};
+
+// Creates a new netplay handle. A NULL host means we're hosting (player 1). :)
+netplay_t *netplay_new(const char *server, uint16_t port, unsigned frames, const struct snes_callbacks *cb);
+void netplay_free(netplay_t *handle);
+
+// Checks if input port/index is controlled by netplay or not.
+bool netplay_is_port(netplay_t *handle, bool port, unsigned index);
+
+bool netplay_poll(netplay_t *handle);
+int16_t netplay_input_state(netplay_t *handle, bool port, unsigned device, unsigned index, unsigned id);
+
+// If we're fast-forward replaying to resync, check if we should actually show frame.
+// bool netplay_should_skip(netplay_t *handle);
+const struct snes_callbacks* netplay_callbacks(netplay_t *handle);
+
+
+
+
+
+#endif

ssnes.c

@@ -31,6 +31,7 @@
 #include "record/ffemu.h"
 #include "rewind.h"
 #include "movie.h"
+#include "netplay.h"
 #include <assert.h>
 #ifdef HAVE_SRC
 #include <samplerate.h>
@@ -342,6 +343,8 @@ static void print_help(void)
    puts("\t-J/--justifiers: Daisy chain two virtual Konami Justifiers into port 2 of the SNES.");
    puts("\t-4/--multitap: Connect a multitap to port 2 of the SNES.");
    puts("\t-P/--bsvplay: Playback a BSV movie file.");
+   puts("\t-H/--host: Host netplay as player 1.");
+   puts("\t-C/--connect: Connect to netplay as player 2.");
 
 #ifdef HAVE_FFMPEG
    puts("\t-r/--record: Path to record video file. Settings for video/audio codecs are found in config file.");
@@ -391,6 +394,8 @@ static void parse_input(int argc, char *argv[])
       { "sufamiA", 1, NULL, 'Y' },
       { "sufamiB", 1, NULL, 'Z' },
       { "bsvplay", 1, NULL, 'P' },
+      { "host", 0, NULL, 'H' },
+      { "connect", 1, NULL, 'C' },
       { NULL, 0, NULL, 0 }
    };
 
@@ -408,7 +413,7 @@ static void parse_input(int argc, char *argv[])
 #define CONFIG_FILE_ARG
 #endif
 
-   char optstring[] = "hs:vS:m:p4jJg:b:B:Y:Z:P:" FFMPEG_RECORD_ARG CONFIG_FILE_ARG;
+   char optstring[] = "hs:vS:m:p4jJg:b:B:Y:Z:P:HC:" FFMPEG_RECORD_ARG CONFIG_FILE_ARG;
    for(;;)
    {
       int c = getopt_long(argc, argv, optstring, opts, &option_index);
@@ -507,6 +512,15 @@ static void parse_input(int argc, char *argv[])
             g_extern.bsv_movie_playback = true;
             break;
 
+         case 'H':
+            g_extern.netplay_enable = true;
+            break;
+
+         case 'C':
+            g_extern.netplay_enable = true;
+            strncpy(g_extern.netplay_server, optarg, sizeof(g_extern.netplay_server) - 1);
+            break;
+
          case '?':
             print_help();
             exit(1);
@@ -741,6 +755,28 @@ static void deinit_movie(void)
       bsv_movie_free(g_extern.bsv_movie);
 }
 
+static void init_netplay(void)
+{
+   if (g_extern.netplay_enable)
+   {
+      struct snes_callbacks cbs = {
+         .frame_cb = video_frame,
+         .sample_cb = audio_sample,
+         .poll_cb = input_poll,
+         .state_cb = input_state
+      };
+      g_extern.netplay = netplay_new(strlen(g_extern.netplay_server) > 0 ? g_extern.netplay_server : NULL, 55435, 1, &cbs);
+      if (!g_extern.netplay)
+         SSNES_WARN("Failed to init netplay...\n");
+   }
+}
+
+static void deinit_netplay(void)
+{
+   if (g_extern.netplay)
+      netplay_free(g_extern.netplay);
+}
+
 static void init_autosave(void)
 {
    int ram_types[2] = {-1, -1};
@@ -1110,23 +1146,27 @@ static void check_pause(void)
 
 static void do_state_checks(void)
 {
-   check_pause();
-   if (g_extern.is_paused)
-      return;
-
-   set_fast_forward_button(driver.input->key_pressed(driver.input_data, SSNES_FAST_FORWARD_KEY));
-
-   if (!g_extern.bsv_movie)
+   if (!g_extern.netplay)
    {
-      check_stateslots();
-      check_savestates();
-      check_rewind();
+      check_pause();
+      if (g_extern.is_paused)
+         return;
+
+      set_fast_forward_button(driver.input->key_pressed(driver.input_data, SSNES_FAST_FORWARD_KEY));
+
+      if (!g_extern.bsv_movie)
+      {
+         check_stateslots();
+         check_savestates();
+         check_rewind();
+      }
+
+      if (!g_extern.bsv_movie_playback)
+         check_movie_record();
    }
+
    check_fullscreen();
    check_input_rate();
-
-   if (!g_extern.bsv_movie_playback)
-      check_movie_record();
 }
 
 
@@ -1148,11 +1188,12 @@ int main(int argc, char *argv[])
       goto error;
 
    init_drivers();
+   init_netplay();
 
-   psnes_set_video_refresh(video_frame);
-   psnes_set_audio_sample(audio_sample);
-   psnes_set_input_poll(input_poll);
-   psnes_set_input_state(input_state);
+   psnes_set_video_refresh(g_extern.netplay ? video_frame_net : video_frame);
+   psnes_set_audio_sample(g_extern.netplay ? audio_sample_net : audio_sample);
+   psnes_set_input_poll(g_extern.netplay ? input_poll_net : input_poll);
+   psnes_set_input_state(g_extern.netplay ? input_state_net : input_state);
    
    init_msg_queue();
    init_controllers();
@@ -1203,6 +1244,7 @@ int main(int argc, char *argv[])
       }
    }
 
+   deinit_netplay();
    deinit_autosave();
 
 #ifdef HAVE_FFMPEG