summaryrefslogtreecommitdiffstats
path: root/libglusterfs/src
diff options
context:
space:
mode:
authorAnand V. Avati <avati@amp.gluster.com>2009-04-11 18:14:10 +0530
committerAnand V. Avati <avati@amp.gluster.com>2009-04-12 11:33:47 +0530
commit2e743ddc4a89f8a4d0c9ff0f16a6faf0218e453f (patch)
treea20ade97207ac280f6024503d41f9a5ef60bff94 /libglusterfs/src
parent0e9cda6d77a63723014bb2c040d8215fd7180a10 (diff)
updated transport interface functions to accommodate IOBUF/IOBREF
Signed-off-by: Anand V. Avati <avati@amp.gluster.com>
Diffstat (limited to 'libglusterfs/src')
-rw-r--r--libglusterfs/src/transport.c9
-rw-r--r--libglusterfs/src/transport.h10
2 files changed, 11 insertions, 8 deletions
diff --git a/libglusterfs/src/transport.c b/libglusterfs/src/transport.c
index 944817ef88f..2c2894d9031 100644
--- a/libglusterfs/src/transport.c
+++ b/libglusterfs/src/transport.c
@@ -211,14 +211,15 @@ fail:
int32_t
transport_submit (transport_t *this, char *buf, int32_t len,
- struct iovec *vector, int count, dict_t *refs)
+ struct iovec *vector, int count,
+ struct iobref *iobref)
{
int32_t ret = -1;
GF_VALIDATE_OR_GOTO("transport", this, fail);
GF_VALIDATE_OR_GOTO("transport", this->ops, fail);
- ret = this->ops->submit (this, buf, len, vector, count, refs);
+ ret = this->ops->submit (this, buf, len, vector, count, iobref);
fail:
return ret;
}
@@ -301,13 +302,13 @@ fail:
int32_t
transport_receive (transport_t *this, char **hdr_p, size_t *hdrlen_p,
- char **buf_p, size_t *buflen_p)
+ struct iobuf **iobuf_p)
{
int32_t ret = -1;
GF_VALIDATE_OR_GOTO("transport", this, fail);
- ret = this->ops->receive (this, hdr_p, hdrlen_p, buf_p, buflen_p);
+ ret = this->ops->receive (this, hdr_p, hdrlen_p, iobuf_p);
fail:
return ret;
}
diff --git a/libglusterfs/src/transport.h b/libglusterfs/src/transport.h
index eaf6286d683..a7cd5ec8f41 100644
--- a/libglusterfs/src/transport.h
+++ b/libglusterfs/src/transport.h
@@ -59,9 +59,10 @@ struct transport {
struct transport_ops {
int32_t (*receive) (transport_t *this, char **hdr_p, size_t *hdrlen_p,
- char **buf_p, size_t *buflen_p);
+ struct iobuf **iobuf_p);
int32_t (*submit) (transport_t *this, char *buf, int len,
- struct iovec *vector, int count, dict_t *refs);
+ struct iovec *vector, int count,
+ struct iobref *iobref);
int32_t (*connect) (transport_t *this);
int32_t (*listen) (transport_t *this);
int32_t (*disconnect) (transport_t *this);
@@ -73,9 +74,10 @@ int32_t transport_connect (transport_t *this);
int32_t transport_disconnect (transport_t *this);
int32_t transport_notify (transport_t *this, int event);
int32_t transport_submit (transport_t *this, char *buf, int len,
- struct iovec *vector, int count, dict_t *refs);
+ struct iovec *vector, int count,
+ struct iobref *iobref);
int32_t transport_receive (transport_t *this, char **hdr_p, size_t *hdrlen_p,
- char **buf_p, size_t *buflen_p);
+ struct iobuf **iobuf_p);
int32_t transport_destroy (transport_t *this);
transport_t *transport_load (dict_t *options, xlator_t *xl);