diff --git a/src/netops.c b/src/netops.c
index 532d0d3d0..6c164a960 100644
--- a/src/netops.c
+++ b/src/netops.c
@@ -38,6 +38,53 @@
 #include "common.h"
 #include "netops.h"
 
+void gitno_buffer_setup(gitno_buffer *buf, void*data,  unsigned int len, int fd)
+{
+	memset(buf, 0x0, sizeof(gitno_buffer));
+	memset(data, 0x0, len);
+	buf->data = data;
+	buf->len = len - 1;
+	buf->offset = 0;
+	buf->fd = fd;
+}
+
+int gitno_recv(gitno_buffer *buf)
+{
+	int ret;
+
+	ret = recv(buf->fd, buf->data + buf->offset, buf->len - buf->offset, 0);
+	if (ret < 0)
+		return git__throw(GIT_EOSERR, "Failed to receive data");
+	if (ret == 0) /* Orderly shutdown, so exit */
+		return GIT_SUCCESS;
+
+	buf->offset += ret;
+
+	return ret;
+}
+
+/* Consume up to ptr and move the rest of the buffer to the beginning */
+void gitno_consume(gitno_buffer *buf, void *ptr)
+{
+	int left;
+
+	assert(ptr - buf->data <= (int) buf->len);
+
+	left = buf->len - (ptr - buf->data);
+
+	memmove(buf->data, ptr, left);
+	memset(ptr, 0x0, left);
+	buf->offset = left;
+}
+
+/* Consume const bytes and move the rest of the buffer to the beginning */
+void gitno_consume_n(gitno_buffer *buf, unsigned int cons)
+{
+	memmove(buf->data, buf->data + cons, buf->len - buf->offset);
+	memset(buf->data + cons, 0x0, buf->len - buf->offset);
+	buf->offset -= cons;
+}
+
 int gitno_connect(const char *host, const char *port)
 {
 	struct addrinfo *info, *p;
diff --git a/src/netops.h b/src/netops.h
index 620fb12ea..9c5279822 100644
--- a/src/netops.h
+++ b/src/netops.h
@@ -4,6 +4,18 @@
 #ifndef INCLUDE_netops_h__
 #define INCLUDE_netops_h__
 
+typedef struct gitno_buffer {
+	void *data;
+	unsigned int len;
+	unsigned int offset;
+	int fd;
+} gitno_buffer;
+
+void gitno_buffer_setup(gitno_buffer *buf, void *data, unsigned int len, int fd);
+int gitno_recv(gitno_buffer *buf);
+void gitno_consume(gitno_buffer *buf, void *ptr);
+void gitno_consume_n(gitno_buffer *buf, unsigned int cons);
+
 int gitno_connect(const char *host, const char *port);
 int gitno_send(int s, const char *msg, int len, int flags);