[libvirt] [libvirt-php PATCH v2 04/11] Split up the bindings for libvirt stream API
Dawid Zamirski
dzrudy at gmail.com
Thu Aug 3 18:35:02 UTC 2017
---
src/Makefile.am | 3 +-
src/libvirt-php.c | 231 +--------------------------------------------------
src/libvirt-php.h | 15 +---
src/libvirt-stream.c | 230 ++++++++++++++++++++++++++++++++++++++++++++++++++
src/libvirt-stream.h | 39 +++++++++
5 files changed, 274 insertions(+), 244 deletions(-)
create mode 100644 src/libvirt-stream.c
create mode 100644 src/libvirt-stream.h
diff --git a/src/Makefile.am b/src/Makefile.am
index ba2be62..ddfad41 100644
--- a/src/Makefile.am
+++ b/src/Makefile.am
@@ -23,7 +23,8 @@ libvirt_php_la_SOURCES = \
sockets.c sockets.h \
libvirt-php.c libvirt-php.h \
libvirt-connection.c libvirt-connection.h \
- libvirt-node.c libvirt-node.h
+ libvirt-node.c libvirt-node.h \
+ libvirt-stream.c libvirt-stream.h
libvirt_php_la_CFLAGS = \
$(AM_CFLAGS) \
-DCOMPILE_DL_LIBVIRT=1
diff --git a/src/libvirt-php.c b/src/libvirt-php.c
index 6315ec4..c84aaef 100644
--- a/src/libvirt-php.c
+++ b/src/libvirt-php.c
@@ -21,11 +21,10 @@
#include "sockets.h"
#include "libvirt-connection.h"
#include "libvirt-node.h"
+#include "libvirt-stream.h"
DEBUG_INIT("core");
-
-
#ifndef EXTWIN
/* Additional binaries */
const char *features[] = { "screenshot", "create-image", "screenshot-convert", NULL };
@@ -41,7 +40,6 @@ int le_libvirt_storagepool;
int le_libvirt_volume;
int le_libvirt_network;
int le_libvirt_nodedev;
-int le_libvirt_stream;
int le_libvirt_snapshot;
int le_libvirt_nwfilter;
@@ -476,15 +474,8 @@ ZEND_END_ARG_INFO()
static zend_function_entry libvirt_functions[] = {
/* Common functions */
PHP_FE(libvirt_get_last_error, arginfo_libvirt_void)
- /* Connect functions */
PHP_FE_LIBVIRT_CONNECTION
- /* Stream functions */
- PHP_FE(libvirt_stream_create, arginfo_libvirt_conn)
- PHP_FE(libvirt_stream_close, arginfo_libvirt_conn)
- PHP_FE(libvirt_stream_abort, arginfo_libvirt_conn)
- PHP_FE(libvirt_stream_finish, arginfo_libvirt_conn)
- PHP_FE(libvirt_stream_send, arginfo_libvirt_stream_send)
- PHP_FE(libvirt_stream_recv, arginfo_libvirt_stream_recv)
+ PHP_FE_LIBVIRT_STREAM
/* Domain functions */
PHP_FE(libvirt_domain_new, arginfo_libvirt_domain_new)
PHP_FE(libvirt_domain_new_get_vnc, arginfo_libvirt_void)
@@ -1357,33 +1348,6 @@ static void php_libvirt_domain_dtor(virt_resource *rsrc TSRMLS_DC)
}
}
-/* Destructor for stream resource */
-static void php_libvirt_stream_dtor(virt_resource *rsrc TSRMLS_DC)
-{
- php_libvirt_stream *stream = (php_libvirt_stream *)rsrc->ptr;
- int rv = 0;
-
- if (stream != NULL) {
- if (stream->stream != NULL) {
- if (!check_resource_allocation(NULL, INT_RESOURCE_STREAM, stream->stream TSRMLS_CC)) {
- stream->stream = NULL;
- efree(stream);
- return;
- }
- rv = virStreamFree(stream->stream);
- if (rv != 0) {
- DPRINTF("%s: virStreamFree(%p) returned %d (%s)\n", __FUNCTION__, stream->stream, rv, LIBVIRT_G(last_error));
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "virStreamFree failed with %i on destructor: %s", rv, LIBVIRT_G(last_error));
- } else {
- DPRINTF("%s: virStreamFree(%p) completed successfully\n", __FUNCTION__, stream->stream);
- resource_change_counter(INT_RESOURCE_STREAM, NULL, stream->stream, 0 TSRMLS_CC);
- }
- stream->stream = NULL;
- }
- efree(stream);
- }
-}
-
/* Destructor for storagepool resource */
static void php_libvirt_storagepool_dtor(virt_resource *rsrc TSRMLS_DC)
{
@@ -3251,197 +3215,6 @@ PHP_FUNCTION(libvirt_domain_lookup_by_uuid_string)
}
/*
- * Function name: libvirt_stream_create
- * Since version: 0.5.0
- * Description: Function is used to create new stream from libvirt conn
- * Arguments: @res [resource]: libvirt connection resource from libvirt_connect()
- * Returns: resource libvirt stream resource
- */
-PHP_FUNCTION(libvirt_stream_create)
-{
- php_libvirt_connection *conn = NULL;
- zval *zconn;
- virStreamPtr stream = NULL;
- php_libvirt_stream *res_stream;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &zconn) == FAILURE)
- RETURN_FALSE;
- VIRT_FETCH_RESOURCE(conn, php_libvirt_connection*, &zconn, PHP_LIBVIRT_CONNECTION_RES_NAME, le_libvirt_connection);
- if ((conn == NULL) || (conn->conn == NULL))
- RETURN_FALSE;
-
- stream = virStreamNew(conn->conn, 0);
- if (stream == NULL) {
- set_error("Cannot create new stream" TSRMLS_CC);
- RETURN_FALSE;
- }
-
- res_stream = (php_libvirt_stream *)emalloc(sizeof(php_libvirt_stream));
- res_stream->stream = stream;
- res_stream->conn = conn;
-
- resource_change_counter(INT_RESOURCE_STREAM, conn->conn, res_stream->stream, 1 TSRMLS_CC);
-
- VIRT_REGISTER_RESOURCE(res_stream, le_libvirt_stream);
-}
-
-/*
- * Function name: libvirt_stream_close
- * Since version: 0.5.0
- * Description: Function is used to close stream
- * Arguments: @res [resource]: libvirt stream resource from libvirt_stream_create()
- * Returns: int
- */
-PHP_FUNCTION(libvirt_stream_close)
-{
- zval *zstream;
- php_libvirt_stream *stream = NULL;
- int retval = -1;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &zstream) == FAILURE)
- RETURN_LONG(retval);
- VIRT_FETCH_RESOURCE(stream, php_libvirt_stream*, &zstream, PHP_LIBVIRT_STREAM_RES_NAME, le_libvirt_stream);
- if ((stream == NULL) || (stream->stream == NULL))
- RETURN_LONG(retval);
-
- retval = virStreamFree(stream->stream);
- if (retval != 0) {
- set_error("Cannot free stream" TSRMLS_CC);
- RETURN_LONG(retval);
- }
-
- resource_change_counter(INT_RESOURCE_STREAM, stream->conn->conn, stream->stream, 0 TSRMLS_CC);
- RETURN_LONG(retval);
-}
-
-/*
- * Function name: libvirt_stream_abort
- * Since version: 0.5.0
- * Description: Function is used to abort transfer
- * Arguments: @res [resource]: libvirt stream resource from libvirt_stream_create()
- * Returns: int
- */
-PHP_FUNCTION(libvirt_stream_abort)
-{
- zval *zstream;
- php_libvirt_stream *stream = NULL;
- int retval = -1;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &zstream) == FAILURE)
- RETURN_LONG(retval);
- VIRT_FETCH_RESOURCE(stream, php_libvirt_stream*, &zstream, PHP_LIBVIRT_STREAM_RES_NAME, le_libvirt_stream);
- if ((stream == NULL) || (stream->stream == NULL))
- RETURN_LONG(retval);
-
- retval = virStreamAbort(stream->stream);
- if (retval != 0) {
- set_error("Cannot abort stream" TSRMLS_CC);
- RETURN_LONG(retval);
- }
- RETURN_LONG(retval);
-}
-
-/*
- * Function name: libvirt_stream_finish
- * Since version: 0.5.0
- * Description: Function is used to finish transfer
- * Arguments: @res [resource]: libvirt stream resource from libvirt_stream_create()
- * Returns: int
- */
-PHP_FUNCTION(libvirt_stream_finish)
-{
- zval *zstream;
- php_libvirt_stream *stream = NULL;
- int retval = -1;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &zstream) == FAILURE)
- RETURN_LONG(retval);
- VIRT_FETCH_RESOURCE(stream, php_libvirt_stream*, &zstream, PHP_LIBVIRT_STREAM_RES_NAME, le_libvirt_stream);
- if ((stream == NULL) || (stream->stream == NULL))
- RETURN_LONG(retval);
-
- retval = virStreamFinish(stream->stream);
- if (retval != 0) {
- set_error("Cannot finish stream" TSRMLS_CC);
- RETURN_LONG(retval);
- }
- RETURN_LONG(retval);
-}
-
-/*
- * Function name: libvirt_stream_recv
- * Since version: 0.5.0
- * Description: Function is used to recv from stream via libvirt conn
- * Arguments: @res [resource]: libvirt stream resource from libvirt_stream_create()
- * @data [string]: buffer
- * @len [int]: amout of data to recieve
- * Returns: int
- */
-PHP_FUNCTION(libvirt_stream_recv)
-{
- zval *zstream, *zbuf;
- php_libvirt_stream *stream = NULL;
- char *recv_buf = NULL;
- int retval = -1;
- zend_long length = 0;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rz|l", &zstream, &zbuf, &length) == FAILURE)
- RETURN_LONG(retval);
- VIRT_FETCH_RESOURCE(stream, php_libvirt_stream*, &zstream, PHP_LIBVIRT_STREAM_RES_NAME, le_libvirt_stream);
- if ((stream == NULL) || (stream->stream == NULL))
- RETURN_LONG(retval);
-
- recv_buf = emalloc(length + 1);
-
- retval = virStreamRecv(stream->stream, recv_buf, length);
- if (retval < 0) {
- zval_dtor(zbuf);
- ZVAL_NULL(zbuf);
- } else {
- recv_buf[retval] = '\0';
- VIRT_ZVAL_STRINGL(zbuf, recv_buf, retval);
- }
-
- if (retval == -1)
- set_error("Cannot recv from stream" TSRMLS_CC);
-
- efree(recv_buf);
- RETURN_LONG(retval);
-}
-
-/*
- * Function name: libvirt_stream_send
- * Since version: 0.5.0
- * Description: Function is used to send to stream via libvirt conn
- * Arguments: @res [resource]: libvirt stream resource from libvirt_stream_create()
- * @data [string]: buffer
- * @length [int]: amout of data to send
- * Returns: int
- */
-PHP_FUNCTION(libvirt_stream_send)
-{
- zval *zstream, *zbuf;
- php_libvirt_stream *stream = NULL;
- int retval = -1;
- zend_long length = 0;
- char *cstr;
-
- if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rz|l", &zstream, &zbuf, &length) == FAILURE)
- RETURN_LONG(retval);
- VIRT_FETCH_RESOURCE(stream, php_libvirt_stream*, &zstream, PHP_LIBVIRT_STREAM_RES_NAME, le_libvirt_stream);
- if ((stream == NULL) || (stream->stream == NULL))
- RETURN_LONG(retval);
-
- cstr = Z_STRVAL_P(zbuf);
-
- retval = virStreamSend(stream->stream, cstr, length);
- if (retval == -1)
- set_error("Cannot send to stream" TSRMLS_CC);
-
- RETURN_LONG(retval);
-}
-
-/*
* Function name: libvirt_domain_lookup_by_id
* Since version: 0.4.1(-1)
* Description: Function is used to get domain by it's ID, applicable only to running guests
diff --git a/src/libvirt-php.h b/src/libvirt-php.h
index a701235..49bcdc9 100644
--- a/src/libvirt-php.h
+++ b/src/libvirt-php.h
@@ -127,7 +127,6 @@ typedef uint64_t arch_uint;
#define INT_RESOURCE_STORAGEPOOL 0x10
#define INT_RESOURCE_VOLUME 0x20
#define INT_RESOURCE_SNAPSHOT 0x40
-#define INT_RESOURCE_STREAM 0x50
#define INT_RESOURCE_NWFILTER 0x60
typedef struct tTokenizer {
@@ -161,11 +160,6 @@ typedef struct tVMNetwork {
typedef struct _php_libvirt_connection php_libvirt_connection;
/* Libvirt-php types */
-typedef struct _php_libvirt_stream {
- virStreamPtr stream;
- php_libvirt_connection* conn;
-} php_libvirt_stream;
-
typedef struct _php_libvirt_domain {
virDomainPtr domain;
php_libvirt_connection* conn;
@@ -228,6 +222,7 @@ void set_error(char *msg TSRMLS_DC);
void reset_error(TSRMLS_D);
int count_resources(int type TSRMLS_DC);
int resource_change_counter(int type, virConnectPtr conn, void *mem, int inc TSRMLS_DC);
+int check_resource_allocation(virConnectPtr conn, int type, void *mem TSRMLS_DC);
void free_resource(int type, void *mem TSRMLS_DC);
char *connection_get_emulator(virConnectPtr conn, char *arch TSRMLS_DC);
int is_local_connection(virConnectPtr conn);
@@ -238,7 +233,6 @@ char *get_string_from_xpath(char *xml, char *xpath, zval **val, int *retVal);
char **get_array_from_xpath(char *xml, char *xpath, int *num);
#define PHP_LIBVIRT_DOMAIN_RES_NAME "Libvirt domain"
-#define PHP_LIBVIRT_STREAM_RES_NAME "Libvirt stream"
#define PHP_LIBVIRT_STORAGEPOOL_RES_NAME "Libvirt storagepool"
#define PHP_LIBVIRT_VOLUME_RES_NAME "Libvirt volume"
#define PHP_LIBVIRT_NETWORK_RES_NAME "Libvirt virtual network"
@@ -254,13 +248,6 @@ PHP_MINFO_FUNCTION(libvirt);
/* Common functions */
PHP_FUNCTION(libvirt_get_last_error);
-/* Stream functions */
-PHP_FUNCTION(libvirt_stream_create);
-PHP_FUNCTION(libvirt_stream_close);
-PHP_FUNCTION(libvirt_stream_abort);
-PHP_FUNCTION(libvirt_stream_finish);
-PHP_FUNCTION(libvirt_stream_recv);
-PHP_FUNCTION(libvirt_stream_send);
/* Domain functions */
PHP_FUNCTION(libvirt_domain_new);
PHP_FUNCTION(libvirt_domain_new_get_vnc);
diff --git a/src/libvirt-stream.c b/src/libvirt-stream.c
new file mode 100644
index 0000000..f1fc1ff
--- /dev/null
+++ b/src/libvirt-stream.c
@@ -0,0 +1,230 @@
+/*
+ * libvirt-stream.c: The PHP bindings to libvirt stream API
+ *
+ * See COPYING for the license of this software
+ */
+
+#include <libvirt/libvirt.h>
+
+#include "libvirt-php.h"
+#include "libvirt-stream.h"
+
+DEBUG_INIT("stream");
+
+void
+php_libvirt_stream_dtor(virt_resource *rsrc TSRMLS_DC)
+{
+ php_libvirt_stream *stream = (php_libvirt_stream *)rsrc->ptr;
+ int rv = 0;
+
+ if (stream != NULL) {
+ if (stream->stream != NULL) {
+ if (!check_resource_allocation(NULL, INT_RESOURCE_STREAM, stream->stream TSRMLS_CC)) {
+ stream->stream = NULL;
+ efree(stream);
+ return;
+ }
+ rv = virStreamFree(stream->stream);
+ if (rv != 0) {
+ DPRINTF("%s: virStreamFree(%p) returned %d (%s)\n", __FUNCTION__, stream->stream, rv, LIBVIRT_G(last_error));
+ php_error_docref(NULL TSRMLS_CC, E_WARNING, "virStreamFree failed with %i on destructor: %s", rv, LIBVIRT_G(last_error));
+ } else {
+ DPRINTF("%s: virStreamFree(%p) completed successfully\n", __FUNCTION__, stream->stream);
+ resource_change_counter(INT_RESOURCE_STREAM, NULL, stream->stream, 0 TSRMLS_CC);
+ }
+ stream->stream = NULL;
+ }
+ efree(stream);
+ }
+}
+
+/*
+ * Function name: libvirt_stream_create
+ * Since version: 0.5.0
+ * Description: Function is used to create new stream from libvirt conn
+ * Arguments: @res [resource]: libvirt connection resource from libvirt_connect()
+ * Returns: resource libvirt stream resource
+ */
+PHP_FUNCTION(libvirt_stream_create)
+{
+ php_libvirt_connection *conn = NULL;
+ zval *zconn;
+ virStreamPtr stream = NULL;
+ php_libvirt_stream *res_stream;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &zconn) == FAILURE)
+ RETURN_FALSE;
+ VIRT_FETCH_RESOURCE(conn, php_libvirt_connection*, &zconn, PHP_LIBVIRT_CONNECTION_RES_NAME, le_libvirt_connection);
+ if ((conn == NULL) || (conn->conn == NULL))
+ RETURN_FALSE;
+
+ stream = virStreamNew(conn->conn, 0);
+ if (stream == NULL) {
+ set_error("Cannot create new stream" TSRMLS_CC);
+ RETURN_FALSE;
+ }
+
+ res_stream = (php_libvirt_stream *)emalloc(sizeof(php_libvirt_stream));
+ res_stream->stream = stream;
+ res_stream->conn = conn;
+
+ resource_change_counter(INT_RESOURCE_STREAM, conn->conn, res_stream->stream, 1 TSRMLS_CC);
+
+ VIRT_REGISTER_RESOURCE(res_stream, le_libvirt_stream);
+}
+
+/*
+ * Function name: libvirt_stream_close
+ * Since version: 0.5.0
+ * Description: Function is used to close stream
+ * Arguments: @res [resource]: libvirt stream resource from libvirt_stream_create()
+ * Returns: int
+ */
+PHP_FUNCTION(libvirt_stream_close)
+{
+ zval *zstream;
+ php_libvirt_stream *stream = NULL;
+ int retval = -1;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &zstream) == FAILURE)
+ RETURN_LONG(retval);
+ VIRT_FETCH_RESOURCE(stream, php_libvirt_stream*, &zstream, PHP_LIBVIRT_STREAM_RES_NAME, le_libvirt_stream);
+ if ((stream == NULL) || (stream->stream == NULL))
+ RETURN_LONG(retval);
+
+ retval = virStreamFree(stream->stream);
+ if (retval != 0) {
+ set_error("Cannot free stream" TSRMLS_CC);
+ RETURN_LONG(retval);
+ }
+
+ resource_change_counter(INT_RESOURCE_STREAM, stream->conn->conn, stream->stream, 0 TSRMLS_CC);
+ RETURN_LONG(retval);
+}
+
+/*
+ * Function name: libvirt_stream_abort
+ * Since version: 0.5.0
+ * Description: Function is used to abort transfer
+ * Arguments: @res [resource]: libvirt stream resource from libvirt_stream_create()
+ * Returns: int
+ */
+PHP_FUNCTION(libvirt_stream_abort)
+{
+ zval *zstream;
+ php_libvirt_stream *stream = NULL;
+ int retval = -1;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &zstream) == FAILURE)
+ RETURN_LONG(retval);
+ VIRT_FETCH_RESOURCE(stream, php_libvirt_stream*, &zstream, PHP_LIBVIRT_STREAM_RES_NAME, le_libvirt_stream);
+ if ((stream == NULL) || (stream->stream == NULL))
+ RETURN_LONG(retval);
+
+ retval = virStreamAbort(stream->stream);
+ if (retval != 0) {
+ set_error("Cannot abort stream" TSRMLS_CC);
+ RETURN_LONG(retval);
+ }
+ RETURN_LONG(retval);
+}
+
+/*
+ * Function name: libvirt_stream_finish
+ * Since version: 0.5.0
+ * Description: Function is used to finish transfer
+ * Arguments: @res [resource]: libvirt stream resource from libvirt_stream_create()
+ * Returns: int
+ */
+PHP_FUNCTION(libvirt_stream_finish)
+{
+ zval *zstream;
+ php_libvirt_stream *stream = NULL;
+ int retval = -1;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &zstream) == FAILURE)
+ RETURN_LONG(retval);
+ VIRT_FETCH_RESOURCE(stream, php_libvirt_stream*, &zstream, PHP_LIBVIRT_STREAM_RES_NAME, le_libvirt_stream);
+ if ((stream == NULL) || (stream->stream == NULL))
+ RETURN_LONG(retval);
+
+ retval = virStreamFinish(stream->stream);
+ if (retval != 0) {
+ set_error("Cannot finish stream" TSRMLS_CC);
+ RETURN_LONG(retval);
+ }
+ RETURN_LONG(retval);
+}
+
+/*
+ * Function name: libvirt_stream_recv
+ * Since version: 0.5.0
+ * Description: Function is used to recv from stream via libvirt conn
+ * Arguments: @res [resource]: libvirt stream resource from libvirt_stream_create()
+ * @data [string]: buffer
+ * @len [int]: amout of data to recieve
+ * Returns: int
+ */
+PHP_FUNCTION(libvirt_stream_recv)
+{
+ zval *zstream, *zbuf;
+ php_libvirt_stream *stream = NULL;
+ char *recv_buf = NULL;
+ int retval = -1;
+ zend_long length = 0;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rz|l", &zstream, &zbuf, &length) == FAILURE)
+ RETURN_LONG(retval);
+ VIRT_FETCH_RESOURCE(stream, php_libvirt_stream*, &zstream, PHP_LIBVIRT_STREAM_RES_NAME, le_libvirt_stream);
+ if ((stream == NULL) || (stream->stream == NULL))
+ RETURN_LONG(retval);
+
+ recv_buf = emalloc(length + 1);
+
+ retval = virStreamRecv(stream->stream, recv_buf, length);
+ if (retval < 0) {
+ zval_dtor(zbuf);
+ ZVAL_NULL(zbuf);
+ } else {
+ recv_buf[retval] = '\0';
+ VIRT_ZVAL_STRINGL(zbuf, recv_buf, retval);
+ }
+
+ if (retval == -1)
+ set_error("Cannot recv from stream" TSRMLS_CC);
+
+ efree(recv_buf);
+ RETURN_LONG(retval);
+}
+
+/*
+ * Function name: libvirt_stream_send
+ * Since version: 0.5.0
+ * Description: Function is used to send to stream via libvirt conn
+ * Arguments: @res [resource]: libvirt stream resource from libvirt_stream_create()
+ * @data [string]: buffer
+ * @length [int]: amout of data to send
+ * Returns: int
+ */
+PHP_FUNCTION(libvirt_stream_send)
+{
+ zval *zstream, *zbuf;
+ php_libvirt_stream *stream = NULL;
+ int retval = -1;
+ zend_long length = 0;
+ char *cstr;
+
+ if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rz|l", &zstream, &zbuf, &length) == FAILURE)
+ RETURN_LONG(retval);
+ VIRT_FETCH_RESOURCE(stream, php_libvirt_stream*, &zstream, PHP_LIBVIRT_STREAM_RES_NAME, le_libvirt_stream);
+ if ((stream == NULL) || (stream->stream == NULL))
+ RETURN_LONG(retval);
+
+ cstr = Z_STRVAL_P(zbuf);
+
+ retval = virStreamSend(stream->stream, cstr, length);
+ if (retval == -1)
+ set_error("Cannot send to stream" TSRMLS_CC);
+
+ RETURN_LONG(retval);
+}
diff --git a/src/libvirt-stream.h b/src/libvirt-stream.h
new file mode 100644
index 0000000..89b28a6
--- /dev/null
+++ b/src/libvirt-stream.h
@@ -0,0 +1,39 @@
+/*
+ * libvirt-stream.h: The PHP bindings to libvirt stream API
+ *
+ * See COPYING for the license of this software
+ */
+
+#ifndef __LIBVIRT_STREAM_H__
+# define __LIBVIRT_STREAM_H__
+
+# include "libvirt-connection.h"
+
+# define PHP_LIBVIRT_STREAM_RES_NAME "Libvirt stream"
+# define INT_RESOURCE_STREAM 0x50
+
+# define PHP_FE_LIBVIRT_STREAM \
+ PHP_FE(libvirt_stream_create, arginfo_libvirt_conn) \
+ PHP_FE(libvirt_stream_close, arginfo_libvirt_conn) \
+ PHP_FE(libvirt_stream_abort, arginfo_libvirt_conn) \
+ PHP_FE(libvirt_stream_finish, arginfo_libvirt_conn) \
+ PHP_FE(libvirt_stream_send, arginfo_libvirt_stream_send) \
+ PHP_FE(libvirt_stream_recv, arginfo_libvirt_stream_recv)
+
+int le_libvirt_stream;
+
+typedef struct _php_libvirt_stream {
+ virStreamPtr stream;
+ php_libvirt_connection* conn;
+} php_libvirt_stream;
+
+void php_libvirt_stream_dtor(virt_resource *rsrc TSRMLS_DC);
+
+PHP_FUNCTION(libvirt_stream_create);
+PHP_FUNCTION(libvirt_stream_close);
+PHP_FUNCTION(libvirt_stream_abort);
+PHP_FUNCTION(libvirt_stream_finish);
+PHP_FUNCTION(libvirt_stream_recv);
+PHP_FUNCTION(libvirt_stream_send);
+
+#endif
--
2.13.3
More information about the libvir-list
mailing list