int r_pid;
gras_hostdata_t *remote_hd;
- DEBUG3("select on %s@%s with timeout=%d",
+ DEBUG3("select on %s@%s with timeout=%f",
MSG_process_get_name(MSG_process_self()),
MSG_host_get_name(MSG_host_self()),
timeout);
gras_error_t
gras_trp_chunk_send(gras_socket_t *sd,
char *data,
- size_t size) {
+ long int size) {
gras_assert1(sd->outgoing,
"Socket not suited for data send (outgoing=%c)",
sd->outgoing?'y':'n');
gras_error_t
gras_trp_chunk_recv(gras_socket_t *sd,
char *data,
- size_t size) {
+ long int size) {
gras_assert0(sd->incoming,
"Socket not suited for data receive");
gras_assert1(sd->plugin->chunk_recv,
***/
gras_error_t gras_trp_chunk_send(gras_socket_t *sd,
char *data,
- size_t size);
+ long int size);
gras_error_t gras_trp_chunk_recv(gras_socket_t *sd,
char *data,
- size_t size);
+ long int size);
/* Find which socket needs to be read next */
gras_error_t
gras_error_t (*chunk_send)(gras_socket_t *sd,
char *data,
- size_t size);
+ long int size);
gras_error_t (*chunk_recv)(gras_socket_t *sd,
char *Data,
- size_t size);
+ long int size);
void *data;
gras_error_t gras_trp_file_chunk_send(gras_socket_t *sd,
char *data,
- size_t size);
+ long int size);
gras_error_t gras_trp_file_chunk_recv(gras_socket_t *sd,
char *data,
- size_t size);
+ long int size);
/***
gras_error_t
gras_trp_file_chunk_send(gras_socket_t *sock,
char *data,
- size_t size) {
+ long int size) {
gras_assert0(sock->outgoing, "Cannot write on client file socket");
gras_assert0(size >= 0, "Cannot send a negative amount of data");
while (size) {
int status = 0;
- DEBUG3("write(%d, %p, %ld);", sock->sd, data, (size_t)size);
- status = write(sock->sd, data, (size_t)size);
+ DEBUG3("write(%d, %p, %ld);", sock->sd, data, (long int)size);
+ status = write(sock->sd, data, (long int)size);
if (status == -1) {
RAISE4(system_error,"write(%d,%p,%d) failed: %s",
gras_error_t
gras_trp_file_chunk_recv(gras_socket_t *sock,
char *data,
- size_t size) {
+ long int size) {
gras_assert0(sock, "Cannot recv on an NULL socket");
gras_assert0(sock->incoming, "Cannot recv on client file socket");
while (size) {
int status = 0;
- status = read(sock->sd, data, (size_t)size);
+ status = read(sock->sd, data, (long int)size);
DEBUG3("read(%d, %p, %ld);", sock->sd, data, size);
if (status == -1) {
gras_error_t gras_trp_sg_chunk_send(gras_socket_t *sd,
char *data,
- size_t size);
+ long int size);
gras_error_t gras_trp_sg_chunk_recv(gras_socket_t *sd,
char *data,
- size_t size);
+ long int size);
/* FIXME
gras_error_t gras_trp_sg_flush(gras_socket_t *sd);
INFO6("'%s' (%d) ears on %s:%d%s (%p)",
MSG_process_get_name(MSG_process_self()), MSG_process_self_PID(),
- host,port,sock->raw? " (mode RAW)":"",*sock);
+ host,port,sock->raw? " (mode RAW)":"",sock);
return no_error;
}
gras_error_t gras_trp_sg_chunk_send(gras_socket_t *sock,
char *data,
- size_t size) {
+ long int size) {
m_task_t task=NULL;
static unsigned int count=0;
char name[256];
gras_error_t gras_trp_sg_chunk_recv(gras_socket_t *sock,
char *data,
- size_t size){
+ long int size){
gras_procdata_t *pd=gras_procdata_get();
m_task_t task=NULL;
task_data = MSG_task_get_data(task);
gras_assert2(task_data->size == size,
- "Got %d bytes when %d where expected",
+ "Got %d bytes when %ld where expected",
task_data->size, size);
memcpy(data,task_data->data,size);
free(task_data->data);
gras_error_t gras_trp_tcp_chunk_send(gras_socket_t *sd,
char *data,
- size_t size);
+ long int size);
gras_error_t gras_trp_tcp_chunk_recv(gras_socket_t *sd,
char *data,
- size_t size);
+ long int size);
void gras_trp_tcp_exit(gras_trp_plugin_t *plug);
*/
gras_error_t
gras_trp_tcp_chunk_send(gras_socket_t *sock,
- char *data,
- size_t size) {
+ char *data,
+ long int size) {
/* TCP sockets are in duplex mode, don't check direction */
gras_assert0(size >= 0, "Cannot send a negative amount of data");
DEBUG3("write(%d, %p, %ld);", sock->sd, data, size);
if (status == -1) {
- RAISE4(system_error,"write(%d,%p,%d) failed: %s",
- sock->sd, data, (int)size,
+ RAISE4(system_error,"write(%d,%p,%ld) failed: %s",
+ sock->sd, data, size,
strerror(errno));
}
gras_error_t
gras_trp_tcp_chunk_recv(gras_socket_t *sock,
char *data,
- size_t size) {
+ long int size) {
/* TCP sockets are in duplex mode, don't check direction */
gras_assert0(sock, "Cannot recv on an NULL socket");