Displaying 3 results from an estimated 3 matches for "old_ioloop".
2017 Aug 03
2
proxy-dict with tcp connection
...use tcp connections
instead of a unix domain socket.
I'm replacing connection_init_client_unix with connection_init_client_ip:
--- ./src/lib-dict/dict-client.c.orig
+++ ./src/lib-dict/dict-client.c
@@ -721,6 +721,10 @@ client_dict_init(struct dict *driver, const char *uri,
struct ioloop *old_ioloop = current_ioloop;
struct client_dict *dict;
const char *p, *dest_uri, *path;
+ const char *const *args;
+ unsigned int argc;
+ struct ip_addr ip;
+ in_port_t port=0;
unsigned int idle_msecs = DICT_CLIENT_DEFAULT_TIMEOUT_MSECS;
unsigned int warn_slow_msecs = DICT_CLIE...
2017 Aug 03
0
proxy-dict with tcp connection
...ix domain socket.
>
> I'm replacing connection_init_client_unix with connection_init_client_ip:
>
> --- ./src/lib-dict/dict-client.c.orig
> +++ ./src/lib-dict/dict-client.c
> @@ -721,6 +721,10 @@ client_dict_init(struct dict *driver, const char *uri,
> struct ioloop *old_ioloop = current_ioloop;
> struct client_dict *dict;
> const char *p, *dest_uri, *path;
> + const char *const *args;
> + unsigned int argc;
> + struct ip_addr ip;
> + in_port_t port=0;
> unsigned int idle_msecs = DICT_CLIENT_DEFAULT_TIMEOUT_MSECS;
>...
2010 Apr 14
4
PostgreSQL driver supporting [round-robin] load balancing and redundancy [LONG]
..._pgc(pgdb);
+ if (pgc) {
+ start_query(qry, pgc);
+ return;
+ }
+
+ dprintf(("%s: %p: no pgcs ready, queueing", __func__, pgdb));
+ queue_query_to_pgdb(qry, pgdb);
+}
+
+
+static void pgdb_sync_query(struct multi_pgsql_db *pgdb,
+ struct multi_pgsql_query *qry)
+{
+ struct ioloop *old_ioloop, *sync_ioloop;
+
+ dprintf(("%s: %p: %p", __func__, pgdb, qry));
+
+ old_ioloop = current_ioloop;
+ sync_ioloop = io_loop_create();
+ switch_pgdb_pgcs(pgdb);
+
+ set_query_sync_ioloop(qry, sync_ioloop);
+ pgdb_async_query(pgdb, qry);
+
+ io_loop_run(sync_ioloop);
+
+ io_loop_set_current...