aboutsummaryrefslogtreecommitdiffstats
path: root/camel
diff options
context:
space:
mode:
authorbertrand <Bertrand.Guiheneuf@aful.org>1999-09-18 04:34:22 +0800
committerBertrand Guiheneuf <bertrand@src.gnome.org>1999-09-18 04:34:22 +0800
commitacd6bafa58cf5fdea4814e51aac175a99894a373 (patch)
treebc215f1df9b512eee2823969a2b796650574eafd /camel
parent63039bb99edd9f8c7aea9ef4ce8700d713b01354 (diff)
downloadgsoc2013-evolution-acd6bafa58cf5fdea4814e51aac175a99894a373.tar
gsoc2013-evolution-acd6bafa58cf5fdea4814e51aac175a99894a373.tar.gz
gsoc2013-evolution-acd6bafa58cf5fdea4814e51aac175a99894a373.tar.bz2
gsoc2013-evolution-acd6bafa58cf5fdea4814e51aac175a99894a373.tar.lz
gsoc2013-evolution-acd6bafa58cf5fdea4814e51aac175a99894a373.tar.xz
gsoc2013-evolution-acd6bafa58cf5fdea4814e51aac175a99894a373.tar.zst
gsoc2013-evolution-acd6bafa58cf5fdea4814e51aac175a99894a373.zip
added notify io_channel. new func. run the next operation.
1999-09-17 bertrand <Bertrand.Guiheneuf@aful.org> * camel/camel-folder-pt-proxy.c (_init_with_store): added notify io_channel. * (camel_op_queue_run_next_op): new func. run the next operation. svn path=/trunk/; revision=1236
Diffstat (limited to 'camel')
-rw-r--r--camel/camel-folder-pt-proxy.c36
-rw-r--r--camel/camel-folder-pt-proxy.h6
-rw-r--r--camel/camel-op-queue.c23
-rw-r--r--camel/camel-op-queue.h1
4 files changed, 64 insertions, 2 deletions
diff --git a/camel/camel-folder-pt-proxy.c b/camel/camel-folder-pt-proxy.c
index 0d7bc3c957..d8031fb398 100644
--- a/camel/camel-folder-pt-proxy.c
+++ b/camel/camel-folder-pt-proxy.c
@@ -44,6 +44,9 @@
#include "camel-folder-pt-proxy.h"
#include "camel-log.h"
#include <pthread.h>
+#include <unistd.h>
+#include <string.h>
+#include <errno.h>
/* needed for proper casts of async funcs when
* calling pthreads_create
@@ -132,6 +135,14 @@ camel_folder_proxy_class_init (CamelFolderPtProxyClass *camel_folder_pt_proxy_cl
+static void
+camel_folder_proxy_init (CamelFolderPtProxy *folder_pt_proxy)
+{
+
+
+ folder_pt_proxy->op_queue = camel_op_queue_new ();
+
+}
@@ -147,7 +158,7 @@ camel_folder_proxy_get_type (void)
sizeof (CamelFolderPtProxy),
sizeof (CamelFolderPtProxyClass),
(GtkClassInitFunc) camel_folder_proxy_class_init,
- (GtkObjectInitFunc) NULL,
+ (GtkObjectInitFunc) camel_folder_proxy_init,
/* reserved_1 */ NULL,
/* reserved_2 */ NULL,
(GtkClassInitFunc) NULL,
@@ -175,6 +186,13 @@ _finalize (GtkObject *object)
+static void
+_plan_op_for_exec (CamelOp *op)
+{
+
+
+}
+
/* folder->init_with_store implementation */
@@ -210,7 +228,23 @@ _init_with_store (CamelFolder *folder, CamelStore *parent_store)
CamelFolderPtProxy *proxy_folder = CAMEL_FOLDER_PT_PROXY (folder);
_InitStoreParam *param;
pthread_t init_store_thread;
+ int filedes[2];
+
+#warning Notify io_channel initialization should be elsewhere
+ /* it can not be in camel_folder_proxy_init
+ * because of the pipe error handling */
+ /* set up the notification channel */
+ if (!pipe (filedes)) {
+ CAMEL_LOG_WARNING ("could not create pipe in for camel_folder_proxy_init");
+ CAMEL_LOG_FULL_DEBUG ("Full error message : %s\n", strerror(errno));
+ return;
+ }
+
+ proxy_folder->pipe_client_fd = filedes [0];
+ proxy_folder->pipe_server_fd = filedes [1];
+ proxy_folder->notify_source = g_io_channel_unix_new (filedes [0]);
+
/* param will be freed in _async_init_with_store */
param = g_new (_InitStoreParam, 1);
param->folder = folder;
diff --git a/camel/camel-folder-pt-proxy.h b/camel/camel-folder-pt-proxy.h
index e2ce27a769..9051065b08 100644
--- a/camel/camel-folder-pt-proxy.h
+++ b/camel/camel-folder-pt-proxy.h
@@ -29,6 +29,7 @@
#define CAMEL_FOLDER_PT_PROXY_H 1
#include "camel-folder.h"
+#include "camel-op-queue.h"
#define CAMEL_FOLDER_PT_PROXY_TYPE (camel_folder_pt_proxy_get_type ())
@@ -43,6 +44,11 @@ typedef struct {
CamelFolder *real_folder;
GStaticMutex mutex;
+ CamelOpQueue *op_queue;
+ gint pipe_client_fd;
+ gint pipe_server_fd;
+ GIOChannel *notify_source;
+
} CamelFolderPtProxy;
diff --git a/camel/camel-op-queue.c b/camel/camel-op-queue.c
index 5549a40de1..c58ade9958 100644
--- a/camel/camel-op-queue.c
+++ b/camel/camel-op-queue.c
@@ -83,7 +83,28 @@ camel_op_queue_pop_op (CamelOpQueue *queue)
op = queue->ops_tail;
queue->ops_tail = queue->ops_tail->prev;
- return op;
+ return (CamelOp *)op->data;
}
+/**
+ * camel_op_queue_run_next_op: run the next pending operation
+ * @queue: queue object
+ *
+ * Run the next pending operation in the queue.
+ *
+ * Return value: TRUE if an operation was launched FALSE if there was no operation pending in the queue.
+ **/
+gboolean
+camel_op_queue_run_next_op (CamelOpQueue *queue)
+{
+ CamelOp *op;
+
+ op = camel_op_queue_pop_op (queue);
+ if (!op) return FALSE;
+
+ /* run the operation */
+ op->op_func (op->param);
+
+ return FALSE;
+}
diff --git a/camel/camel-op-queue.h b/camel/camel-op-queue.h
index 34ee8249a1..e99d785b93 100644
--- a/camel/camel-op-queue.h
+++ b/camel/camel-op-queue.h
@@ -52,6 +52,7 @@ typedef struct
CamelOpQueue *camel_op_queue_new ();
void camel_op_queue_push_op (CamelOpQueue *queue, CamelOp *op);
CamelOp *camel_op_queue_pop_op (CamelOpQueue *queue);
+gboolean camel_op_queue_run_next_op (CamelOpQueue *queue);
#ifdef __cplusplus
}