Skip to content
Permalink
Browse files

implements network topology transfer to clients

  • Loading branch information...
StrumentiResistenti committed Sep 6, 2015
1 parent 90127aa commit 035458d44e77feb0aba7fe60c64ef99fea80d92e
Showing with 912 additions and 340 deletions.
  1. +8 −2 libmagma/libmagma/flare_system/magma_flare.c
  2. +1 −1 libmagma/libmagma/flare_system/magma_flare.h
  3. +149 −36 libmagma/libmagma/flare_system/server_flare.c
  4. +21 −21 libmagma/libmagma/flare_system/server_node.c
  5. +10 −4 libmagma/libmagma/net_layer.c
  6. +8 −2 libmagma/libmagma/protocol/flare/chmod.c
  7. +8 −2 libmagma/libmagma/protocol/flare/chown.c
  8. +5 −3 libmagma/libmagma/protocol/flare/commons.c
  9. +9 −2 libmagma/libmagma/protocol/flare/getattr.c
  10. +8 −2 libmagma/libmagma/protocol/flare/mkdir.c
  11. +8 −2 libmagma/libmagma/protocol/flare/mknod.c
  12. +9 −3 libmagma/libmagma/protocol/flare/open.c
  13. +38 −20 libmagma/libmagma/protocol/flare/protocol_flare.h
  14. +9 −2 libmagma/libmagma/protocol/flare/read.c
  15. +3 −2 libmagma/libmagma/protocol/flare/readdir.c
  16. +9 −2 libmagma/libmagma/protocol/flare/readlink.c
  17. +8 −2 libmagma/libmagma/protocol/flare/rename.c
  18. +8 −2 libmagma/libmagma/protocol/flare/rmdir.c
  19. +9 −2 libmagma/libmagma/protocol/flare/statfs.c
  20. +8 −2 libmagma/libmagma/protocol/flare/symlink.c
  21. +8 −2 libmagma/libmagma/protocol/flare/truncate.c
  22. +8 −2 libmagma/libmagma/protocol/flare/unlink.c
  23. +8 −2 libmagma/libmagma/protocol/flare/utime.c
  24. +8 −2 libmagma/libmagma/protocol/flare/write.c
  25. +57 −21 libmagma/libmagma/protocol/node/protocol_node.c
  26. +10 −10 libmagma/libmagma/protocol/node/protocol_node.h
  27. +4 −1 libmagma/libmagma/protocol/protocol.c
  28. +2 −1 libmagma/libmagma/protocol/protocol.h
  29. +2 −1 libmagma/libmagma/protocol/protocol_pkt.h
  30. +469 −184 mount.magma/src/mount.magma.c
@@ -1642,11 +1642,17 @@ void magma_clean_shutdown()
* @param peer a GInetSocketAddress to save remote peer information
* @transaction_id the ID of the failed transaction
*/
void magma_send_udp_failure(GSocket *socket, GSocketAddress *peer, int err_no, magma_transaction_id transaction_id) {
void magma_send_udp_failure(
GSocket *socket,
GSocketAddress *peer,
int err_no,
magma_transaction_id tid,
magma_flags flags)
{
gchar buffer[MAGMA_MAX_BUFFER_SIZE];
memset(buffer, 0, MAGMA_MAX_BUFFER_SIZE);

gchar *ptr = magma_format_response_header(buffer, -1, err_no, transaction_id);
gchar *ptr = magma_format_response_header(buffer, -1, err_no, tid, flags);

magma_send_buffer(socket, peer, buffer, ptr - buffer);
}
@@ -361,7 +361,7 @@ extern void magma_cleanup(int s);
*/
extern void magma_clean_shutdown();

extern void magma_send_udp_failure(GSocket *socket, GSocketAddress *peer, int err_no, magma_transaction_id transaction_id);
extern void magma_send_udp_failure(GSocket *socket, GSocketAddress *peer, int err_no, magma_transaction_id tid, magma_flags flags);

extern void magma_node_transmit_key(GSocket *socket, GSocketAddress *peer, const gchar *flare_key);

Oops, something went wrong.

0 comments on commit 035458d

Please sign in to comment.
You can’t perform that action at this time.