Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Partial fix of GRAS: gras-ping-sg now works again
[simgrid.git] / src / gras / Transport / transport_plugin_file.c
index c112bb3..4139999 100644 (file)
@@ -20,9 +20,9 @@ XBT_LOG_NEW_DEFAULT_SUBCATEGORY(gras_trp_file, gras_trp,
 void gras_trp_file_close(gras_socket_t sd);
 
 void gras_trp_file_chunk_send_raw(gras_socket_t sd,
-                                  const char *data, unsigned long int size);
-void gras_trp_file_chunk_send(gras_socket_t sd,
-                              const char *data,
+                                  const char *data,
+                                  unsigned long int size);
+void gras_trp_file_chunk_send(gras_socket_t sd, const char *data,
                               unsigned long int size, int stable_ignored);
 
 int gras_trp_file_chunk_recv(gras_socket_t sd,
@@ -40,7 +40,24 @@ typedef struct {
  *** Specific socket part
  ***/
 
-
+/***
+ *** Info about who's speaking
+ ***/
+static int gras_trp_file_my_port(gras_socket_t s) {
+  THROW_UNIMPLEMENTED;
+}
+static int gras_trp_file_peer_port(gras_socket_t s) {
+  THROW_UNIMPLEMENTED;
+}
+static char* gras_trp_file_peer_name(gras_socket_t s) {
+  THROW_UNIMPLEMENTED;
+}
+static char* gras_trp_file_peer_proc(gras_socket_t s) {
+  THROW_UNIMPLEMENTED;
+}
+static void gras_trp_file_peer_proc_set(gras_socket_t s,char *name) {
+  THROW_UNIMPLEMENTED;
+}
 
 /***
  *** Code
@@ -52,6 +69,12 @@ void gras_trp_file_setup(gras_trp_plugin_t plug)
 
   FD_ZERO(&(file->incoming_socks));
 
+  plug->my_port = gras_trp_file_my_port;
+  plug->peer_port = gras_trp_file_peer_port;
+  plug->peer_name = gras_trp_file_peer_name;
+  plug->peer_proc = gras_trp_file_peer_proc;
+  plug->peer_proc_set = gras_trp_file_peer_proc_set;
+
   plug->socket_close = gras_trp_file_close;
 
   plug->raw_send = gras_trp_file_chunk_send_raw;
@@ -81,8 +104,8 @@ gras_socket_t gras_socket_client_from_file(const char *path)
 
   if (strcmp("-", path)) {
     res->sd =
-      open(path, O_TRUNC | O_WRONLY | O_CREAT | O_BINARY,
-           S_IRUSR | S_IWUSR | S_IRGRP);
+        open(path, O_TRUNC | O_WRONLY | O_CREAT | O_BINARY,
+             S_IRUSR | S_IWUSR | S_IRGRP);
 
     if (res->sd < 0) {
       THROW2(system_error, 0,