Lines Matching refs:g
119 static void check_multi_info(GlobalInfo *g) in check_multi_info() argument
128 MSG_OUT("REMAINING: %d\n", g->still_running); in check_multi_info()
129 while((msg = curl_multi_info_read(g->multi, &msgs_left))) { in check_multi_info()
136 curl_multi_remove_handle(g->multi, easy); in check_multi_info()
147 GlobalInfo *g = (GlobalInfo *)data; in timer_cb() local
150 rc = curl_multi_socket_action(g->multi, in timer_cb()
151 CURL_SOCKET_TIMEOUT, 0, &g->still_running); in timer_cb()
153 check_multi_info(g); in timer_cb()
161 GlobalInfo *g = (GlobalInfo *)userp; in update_timeout_cb() local
175 g->timer_event = g_timeout_add(timeout_ms, timer_cb, g); in update_timeout_cb()
182 GlobalInfo *g = (GlobalInfo*) data; in event_cb() local
190 rc = curl_multi_socket_action(g->multi, fd, action, &g->still_running); in event_cb()
193 check_multi_info(g); in event_cb()
194 if(g->still_running) { in event_cb()
199 if(g->timer_event) { in event_cb()
200 g_source_remove(g->timer_event); in event_cb()
220 GlobalInfo *g) in setsock() argument
232 f->ev = g_io_add_watch(f->ch, kind, event_cb, g); in setsock()
236 static void addsock(curl_socket_t s, CURL *easy, int action, GlobalInfo *g) in addsock() argument
240 fdp->global = g; in addsock()
242 setsock(fdp, s, easy, action, g); in addsock()
243 curl_multi_assign(g->multi, s, fdp); in addsock()
249 GlobalInfo *g = (GlobalInfo*) cbp; in sock_cb() local
263 addsock(s, e, what, g); in sock_cb()
268 setsock(fdp, s, e, what, g); in sock_cb()
294 static void new_conn(char *url, GlobalInfo *g) in new_conn() argument
306 conn->global = g; in new_conn()
322 MSG_OUT("Adding easy %p to multi %p (%s)\n", conn->easy, g->multi, url); in new_conn()
323 rc = curl_multi_add_handle(g->multi, conn->easy); in new_conn()
416 GlobalInfo *g; in main() local
420 g = g_malloc0(sizeof(GlobalInfo)); in main()
424 g_io_add_watch(ch, G_IO_IN, fifo_cb, g); in main()
426 g->multi = curl_multi_init(); in main()
427 curl_multi_setopt(g->multi, CURLMOPT_SOCKETFUNCTION, sock_cb); in main()
428 curl_multi_setopt(g->multi, CURLMOPT_SOCKETDATA, g); in main()
429 curl_multi_setopt(g->multi, CURLMOPT_TIMERFUNCTION, update_timeout_cb); in main()
430 curl_multi_setopt(g->multi, CURLMOPT_TIMERDATA, g); in main()
436 curl_multi_cleanup(g->multi); in main()
