A
lgorithmique
N
umérique
D
istribuée
Public GIT Repository
projects
/
simgrid.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
also save the cbps in SG, the same way I do in RL since a long time. I love calltree
[simgrid.git]
/
src
/
gras
/
Transport
/
transport_plugin_sg.c
diff --git
a/src/gras/Transport/transport_plugin_sg.c
b/src/gras/Transport/transport_plugin_sg.c
index
92bea15
..
fdf2fe4
100644
(file)
--- a/
src/gras/Transport/transport_plugin_sg.c
+++ b/
src/gras/Transport/transport_plugin_sg.c
@@
-18,8
+18,7
@@
#include "transport_private.h"
#include "gras/Virtu/virtu_sg.h"
#include "transport_private.h"
#include "gras/Virtu/virtu_sg.h"
-XBT_LOG_EXTERNAL_CATEGORY(transport);
-XBT_LOG_NEW_DEFAULT_SUBCATEGORY(trp_sg,transport,"SimGrid pseudo-transport");
+XBT_LOG_NEW_DEFAULT_SUBCATEGORY(gras_trp_sg,gras_trp,"SimGrid pseudo-transport");
/***
*** Prototypes
/***
*** Prototypes
@@
-115,7
+114,7
@@
void gras_trp_sg_socket_client(gras_trp_plugin_t self,
find_port(hd,sock->peer_port,&pr);
} CATCH(e) {
if (e.category == mismatch_error) {
find_port(hd,sock->peer_port,&pr);
} CATCH(e) {
if (e.category == mismatch_error) {
- xbt_ex_free(
&
e);
+ xbt_ex_free(e);
THROW2(mismatch_error,0,
"can't connect to %s:%d, no process listen on this port",
sock->peer_name,sock->peer_port);
THROW2(mismatch_error,0,
"can't connect to %s:%d, no process listen on this port",
sock->peer_name,sock->peer_port);
@@
-173,7
+172,7
@@
void gras_trp_sg_socket_server(gras_trp_plugin_t self,
found = 1;
} CATCH(e) {
if (e.category == mismatch_error)
found = 1;
} CATCH(e) {
if (e.category == mismatch_error)
- xbt_ex_free(
&
e);
+ xbt_ex_free(e);
else
RETHROW;
}
else
RETHROW;
}
@@
-266,7
+265,7
@@
void gras_trp_sg_chunk_send_raw(gras_socket_t sock,
task_data->data = NULL;
}
task_data->data = NULL;
}
- task=MSG_task_create(name,0,((double)size)
/(1024.0*1024.0)
,task_data);
+ task=MSG_task_create(name,0,((double)size),task_data);
DEBUG5("send chunk %s from %s to %s:%d (size=%ld)",
name, MSG_host_get_name(MSG_host_self()),
DEBUG5("send chunk %s from %s to %s:%d (size=%ld)",
name, MSG_host_get_name(MSG_host_self()),