Rename run

10 files changed, 48 insertions, 48 deletions

diff --git a/test/core/iomgr/alarm_list_test.c b/test/core/iomgr/alarm_list_test.c
index 8867545b33..272524da63 100644
--- a/test/core/iomgr/alarm_list_test.c
+++ b/test/core/iomgr/alarm_list_test.c
@@ -74,7 +74,7 @@ add_test (void)
 
   /* collect alarms.  Only the first batch should be ready. */
   GPR_ASSERT (10 == grpc_alarm_check (gpr_time_add (start, gpr_time_from_millis (500, GPR_TIMESPAN)), NULL, &closure_list));
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
   for (i = 0; i < 20; i++)
     {
       GPR_ASSERT (cb_called[i][1] == (i < 10));
@@ -82,7 +82,7 @@ add_test (void)
     }
 
   GPR_ASSERT (0 == grpc_alarm_check (gpr_time_add (start, gpr_time_from_millis (600, GPR_TIMESPAN)), NULL, &closure_list));
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
   for (i = 0; i < 30; i++)
     {
       GPR_ASSERT (cb_called[i][1] == (i < 10));
@@ -91,7 +91,7 @@ add_test (void)
 
   /* collect the rest of the alarms */
   GPR_ASSERT (10 == grpc_alarm_check (gpr_time_add (start, gpr_time_from_millis (1500, GPR_TIMESPAN)), NULL, &closure_list));
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
   for (i = 0; i < 30; i++)
     {
       GPR_ASSERT (cb_called[i][1] == (i < 20));
@@ -106,7 +106,7 @@ add_test (void)
     }
 
   grpc_alarm_list_shutdown (&closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
 }
 
 static gpr_timespec
@@ -133,16 +133,16 @@ destruction_test (void)
   grpc_alarm_init (&alarms[3], tfm (3), cb, (void *) (gpr_intptr) 3, gpr_time_0 (GPR_CLOCK_REALTIME), &closure_list);
   grpc_alarm_init (&alarms[4], tfm (1), cb, (void *) (gpr_intptr) 4, gpr_time_0 (GPR_CLOCK_REALTIME), &closure_list);
   GPR_ASSERT (1 == grpc_alarm_check (tfm (2), NULL, &closure_list));
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
   GPR_ASSERT (1 == cb_called[4][1]);
   grpc_alarm_cancel (&alarms[0], &closure_list);
   grpc_alarm_cancel (&alarms[3], &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
   GPR_ASSERT (1 == cb_called[0][0]);
   GPR_ASSERT (1 == cb_called[3][0]);
 
   grpc_alarm_list_shutdown (&closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
   GPR_ASSERT (1 == cb_called[1][0]);
   GPR_ASSERT (1 == cb_called[2][0]);
 }
diff --git a/test/core/iomgr/endpoint_pair_test.c b/test/core/iomgr/endpoint_pair_test.c
index 2bc79301ea..9270f0772a 100644
--- a/test/core/iomgr/endpoint_pair_test.c
+++ b/test/core/iomgr/endpoint_pair_test.c
@@ -60,7 +60,7 @@ create_fixture_endpoint_pair (size_t slice_size)
   f.server_ep = p.server;
   grpc_endpoint_add_to_pollset (f.client_ep, &g_pollset, &closure_list);
   grpc_endpoint_add_to_pollset (f.server_ep, &g_pollset, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
 
   return f;
 }
@@ -86,7 +86,7 @@ main (int argc, char **argv)
   grpc_endpoint_tests (configs[0], &g_pollset);
   grpc_closure_init (&destroyed, destroy_pollset, &g_pollset);
   grpc_pollset_shutdown (&g_pollset, &destroyed, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
   grpc_shutdown ();
 
   return 0;
diff --git a/test/core/iomgr/endpoint_tests.c b/test/core/iomgr/endpoint_tests.c
index 32d08a7c6a..b1b5f71cb4 100644
--- a/test/core/iomgr/endpoint_tests.c
+++ b/test/core/iomgr/endpoint_tests.c
@@ -232,7 +232,7 @@ read_and_write_test (grpc_endpoint_test_config config, size_t num_bytes, size_t
      even when bytes_written is unsigned. */
   state.bytes_written -= state.current_write_size;
   read_and_write_test_write_handler (&state, 1, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
 
   grpc_endpoint_read (state.read_ep, &state.incoming, &state.done_read, &closure_list);
 
@@ -243,7 +243,7 @@ read_and_write_test (grpc_endpoint_test_config config, size_t num_bytes, size_t
       gpr_log (GPR_DEBUG, "shutdown write");
       grpc_endpoint_shutdown (state.write_ep, &closure_list);
     }
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
 
   gpr_mu_lock (GRPC_POLLSET_MU (g_pollset));
   while (!state.read_done || !state.write_done)
@@ -253,14 +253,14 @@ read_and_write_test (grpc_endpoint_test_config config, size_t num_bytes, size_t
       grpc_pollset_work (g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), deadline, &closure_list);
     }
   gpr_mu_unlock (GRPC_POLLSET_MU (g_pollset));
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
 
   end_test (config);
   gpr_slice_buffer_destroy (&state.outgoing);
   gpr_slice_buffer_destroy (&state.incoming);
   grpc_endpoint_destroy (state.read_ep, &closure_list);
   grpc_endpoint_destroy (state.write_ep, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
 }
 
 void
diff --git a/test/core/iomgr/fd_conservation_posix_test.c b/test/core/iomgr/fd_conservation_posix_test.c
index 703edc660e..d742917dc1 100644
--- a/test/core/iomgr/fd_conservation_posix_test.c
+++ b/test/core/iomgr/fd_conservation_posix_test.c
@@ -61,7 +61,7 @@ main (int argc, char **argv)
       p = grpc_iomgr_create_endpoint_pair ("test", 1);
       grpc_endpoint_destroy (p.client, &closure_list);
       grpc_endpoint_destroy (p.server, &closure_list);
-      grpc_closure_list_run (&closure_list);
+      grpc_exec_ctx_finish (&exec_ctx);
     }
 
   grpc_iomgr_shutdown ();
diff --git a/test/core/iomgr/fd_posix_test.c b/test/core/iomgr/fd_posix_test.c
index 82d6206c86..fac2ad4e3b 100644
--- a/test/core/iomgr/fd_posix_test.c
+++ b/test/core/iomgr/fd_posix_test.c
@@ -285,7 +285,7 @@ server_wait_and_shutdown (server * sv)
       grpc_pollset_worker worker;
       grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), gpr_inf_future (GPR_CLOCK_MONOTONIC), &closure_list);
       gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
-      grpc_closure_list_run (&closure_list);
+      grpc_exec_ctx_finish (&exec_ctx);
       gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
     }
   gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
@@ -425,7 +425,7 @@ client_wait_and_shutdown (client * cl)
       grpc_closure_list closure_list = GRPC_CLOSURE_LIST_INIT;
       grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), gpr_inf_future (GPR_CLOCK_MONOTONIC), &closure_list);
       gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
-      grpc_closure_list_run (&closure_list);
+      grpc_exec_ctx_finish (&exec_ctx);
       gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
     }
   gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
@@ -446,7 +446,7 @@ test_grpc_fd (void)
   port = server_start (&sv, &closure_list);
   client_init (&cl);
   client_start (&cl, port, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
   client_wait_and_shutdown (&cl);
   server_wait_and_shutdown (&sv);
   GPR_ASSERT (sv.read_bytes_total == cl.write_bytes_total);
@@ -540,7 +540,7 @@ test_grpc_fd_change (void)
       grpc_pollset_worker worker;
       grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), gpr_inf_future (GPR_CLOCK_MONOTONIC), &closure_list);
       gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
-      grpc_closure_list_run (&closure_list);
+      grpc_exec_ctx_finish (&exec_ctx);
       gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
     }
   GPR_ASSERT (a.cb_that_ran == first_read_callback);
@@ -563,7 +563,7 @@ test_grpc_fd_change (void)
       grpc_pollset_worker worker;
       grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), gpr_inf_future (GPR_CLOCK_MONOTONIC), &closure_list);
       gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
-      grpc_closure_list_run (&closure_list);
+      grpc_exec_ctx_finish (&exec_ctx);
       gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
     }
   /* Except now we verify that second_read_callback ran instead */
@@ -571,7 +571,7 @@ test_grpc_fd_change (void)
   gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
 
   grpc_fd_orphan (em_fd, NULL, "d", &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
   destroy_change_data (&a);
   destroy_change_data (&b);
   close (sv[1]);
@@ -595,7 +595,7 @@ main (int argc, char **argv)
   test_grpc_fd_change ();
   grpc_closure_init (&destroyed, destroy_pollset, &g_pollset);
   grpc_pollset_shutdown (&g_pollset, &destroyed, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
   grpc_iomgr_shutdown ();
   return 0;
 }
diff --git a/test/core/iomgr/tcp_client_posix_test.c b/test/core/iomgr/tcp_client_posix_test.c
index 6dcdf9ee25..519f8ceb95 100644
--- a/test/core/iomgr/tcp_client_posix_test.c
+++ b/test/core/iomgr/tcp_client_posix_test.c
@@ -134,7 +134,7 @@ test_succeeds (void)
       grpc_pollset_worker worker;
       grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), GRPC_TIMEOUT_SECONDS_TO_DEADLINE (5), &closure_list);
       gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
-      grpc_closure_list_run (&closure_list);
+      grpc_exec_ctx_finish (&exec_ctx);
       gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
     }
 
@@ -171,7 +171,7 @@ test_fails (void)
       grpc_pollset_worker worker;
       grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), test_deadline (), &closure_list);
       gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
-      grpc_closure_list_run (&closure_list);
+      grpc_exec_ctx_finish (&exec_ctx);
       gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
     }
 
@@ -257,7 +257,7 @@ test_times_out (void)
 	}
       grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), GRPC_TIMEOUT_MILLIS_TO_DEADLINE (10), &closure_list);
       gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
-      grpc_closure_list_run (&closure_list);
+      grpc_exec_ctx_finish (&exec_ctx);
       gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
     }
   gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
@@ -285,7 +285,7 @@ main (int argc, char **argv)
   grpc_pollset_set_init (&g_pollset_set);
   grpc_pollset_init (&g_pollset);
   grpc_pollset_set_add_pollset (&g_pollset_set, &g_pollset, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
   test_succeeds ();
   gpr_log (GPR_ERROR, "End of first test");
   test_fails ();
@@ -293,7 +293,7 @@ main (int argc, char **argv)
   grpc_pollset_set_destroy (&g_pollset_set);
   grpc_closure_init (&destroyed, destroy_pollset, &g_pollset);
   grpc_pollset_shutdown (&g_pollset, &destroyed, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
   grpc_shutdown ();
   return 0;
 }
diff --git a/test/core/iomgr/tcp_posix_test.c b/test/core/iomgr/tcp_posix_test.c
index 168fc87d16..f1c4d4a353 100644
--- a/test/core/iomgr/tcp_posix_test.c
+++ b/test/core/iomgr/tcp_posix_test.c
@@ -216,7 +216,7 @@ read_test (size_t num_bytes, size_t slice_size)
       grpc_pollset_worker worker;
       grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), deadline, &closure_list);
       gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
-      grpc_closure_list_run (&closure_list);
+      grpc_exec_ctx_finish (&exec_ctx);
       gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
     }
   GPR_ASSERT (state.read_bytes == state.target_read_bytes);
@@ -224,7 +224,7 @@ read_test (size_t num_bytes, size_t slice_size)
 
   gpr_slice_buffer_destroy (&state.incoming);
   grpc_endpoint_destroy (ep, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
 }
 
 /* Write to a socket until it fills up, then read from it using the grpc_tcp
@@ -263,7 +263,7 @@ large_read_test (size_t slice_size)
       grpc_pollset_worker worker;
       grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), deadline, &closure_list);
       gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
-      grpc_closure_list_run (&closure_list);
+      grpc_exec_ctx_finish (&exec_ctx);
       gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
     }
   GPR_ASSERT (state.read_bytes == state.target_read_bytes);
@@ -271,7 +271,7 @@ large_read_test (size_t slice_size)
 
   gpr_slice_buffer_destroy (&state.incoming);
   grpc_endpoint_destroy (ep, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
 }
 
 struct write_socket_state
@@ -338,7 +338,7 @@ drain_socket_blocking (int fd, size_t num_bytes, size_t read_size)
       gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
       grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), GRPC_TIMEOUT_MILLIS_TO_DEADLINE (10), &closure_list);
       gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
-      grpc_closure_list_run (&closure_list);
+      grpc_exec_ctx_finish (&exec_ctx);
       do
 	{
 	  bytes_read = read (fd, buf, bytes_left > read_size ? read_size : bytes_left);
@@ -405,7 +405,7 @@ write_test (size_t num_bytes, size_t slice_size)
 	}
       grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), deadline, &closure_list);
       gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
-      grpc_closure_list_run (&closure_list);
+      grpc_exec_ctx_finish (&exec_ctx);
       gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
     }
   gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
@@ -413,7 +413,7 @@ write_test (size_t num_bytes, size_t slice_size)
   gpr_slice_buffer_destroy (&outgoing);
   grpc_endpoint_destroy (ep, &closure_list);
   gpr_free (slices);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
 }
 
 void
@@ -458,7 +458,7 @@ create_fixture_tcp_socketpair (size_t slice_size)
   grpc_endpoint_add_to_pollset (f.client_ep, &g_pollset, &closure_list);
   grpc_endpoint_add_to_pollset (f.server_ep, &g_pollset, &closure_list);
 
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
 
   return f;
 }
@@ -485,7 +485,7 @@ main (int argc, char **argv)
   grpc_endpoint_tests (configs[0], &g_pollset);
   grpc_closure_init (&destroyed, destroy_pollset, &g_pollset);
   grpc_pollset_shutdown (&g_pollset, &destroyed, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
   grpc_shutdown ();
 
   return 0;
diff --git a/test/core/iomgr/tcp_server_posix_test.c b/test/core/iomgr/tcp_server_posix_test.c
index e59e45a8b2..4dbb7c9063 100644
--- a/test/core/iomgr/tcp_server_posix_test.c
+++ b/test/core/iomgr/tcp_server_posix_test.c
@@ -75,7 +75,7 @@ test_no_op_with_start (void)
   LOG_TEST ("test_no_op_with_start");
   grpc_tcp_server_start (s, NULL, 0, on_connect, NULL, &closure_list);
   grpc_tcp_server_destroy (s, NULL, NULL);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
 }
 
 static void
@@ -91,7 +91,7 @@ test_no_op_with_port (void)
   GPR_ASSERT (grpc_tcp_server_add_port (s, (struct sockaddr *) &addr, sizeof (addr)));
 
   grpc_tcp_server_destroy (s, NULL, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
 }
 
 static void
@@ -109,7 +109,7 @@ test_no_op_with_port_and_start (void)
   grpc_tcp_server_start (s, NULL, 0, on_connect, NULL, &closure_list);
 
   grpc_tcp_server_destroy (s, NULL, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
 }
 
 static void
@@ -157,7 +157,7 @@ test_connect (int n)
 	  grpc_pollset_worker worker;
 	  grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), deadline, &closure_list);
 	  gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
-	  grpc_closure_list_run (&closure_list);
+	  grpc_exec_ctx_finish (&exec_ctx);
 	  gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
 	}
       gpr_log (GPR_DEBUG, "wait done");
@@ -169,7 +169,7 @@ test_connect (int n)
   gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
 
   grpc_tcp_server_destroy (s, NULL, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
 }
 
 static void
@@ -196,7 +196,7 @@ main (int argc, char **argv)
 
   grpc_closure_init (&destroyed, destroy_pollset, &g_pollset);
   grpc_pollset_shutdown (&g_pollset, &destroyed, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
   grpc_iomgr_shutdown ();
   return 0;
 }
diff --git a/test/core/iomgr/udp_server_test.c b/test/core/iomgr/udp_server_test.c
index 86e84adb55..ac5c4f0d80 100644
--- a/test/core/iomgr/udp_server_test.c
+++ b/test/core/iomgr/udp_server_test.c
@@ -80,7 +80,7 @@ test_no_op_with_start (void)
   LOG_TEST ("test_no_op_with_start");
   grpc_udp_server_start (s, NULL, 0, &closure_list);
   grpc_udp_server_destroy (s, NULL, NULL);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
 }
 
 static void
@@ -112,7 +112,7 @@ test_no_op_with_port_and_start (void)
   grpc_udp_server_start (s, NULL, 0, &closure_list);
 
   grpc_udp_server_destroy (s, NULL, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
 }
 
 static void
@@ -161,7 +161,7 @@ test_receive (int number_of_clients)
 	  grpc_pollset_worker worker;
 	  grpc_pollset_work (&g_pollset, &worker, gpr_now (GPR_CLOCK_MONOTONIC), deadline, &closure_list);
 	  gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
-	  grpc_closure_list_run (&closure_list);
+	  grpc_exec_ctx_finish (&exec_ctx);
 	  gpr_mu_lock (GRPC_POLLSET_MU (&g_pollset));
 	}
       GPR_ASSERT (g_number_of_reads == number_of_reads_before + 1);
@@ -198,7 +198,7 @@ main (int argc, char **argv)
 
   grpc_closure_init (&destroyed, destroy_pollset, &g_pollset);
   grpc_pollset_shutdown (&g_pollset, &destroyed, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
   grpc_iomgr_shutdown ();
   return 0;
 }
diff --git a/test/core/iomgr/workqueue_test.c b/test/core/iomgr/workqueue_test.c
index 7e0f336a0d..8497f09a52 100644
--- a/test/core/iomgr/workqueue_test.c
+++ b/test/core/iomgr/workqueue_test.c
@@ -68,11 +68,11 @@ test_add_closure (void)
   GPR_ASSERT (!done);
   grpc_pollset_work (&g_pollset, &worker, gpr_now (deadline.clock_type), deadline, &closure_list);
   gpr_mu_unlock (GRPC_POLLSET_MU (&g_pollset));
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
   GPR_ASSERT (done);
 
   GRPC_WORKQUEUE_UNREF (wq, "destroy", &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
 }
 
 static void
@@ -94,7 +94,7 @@ main (int argc, char **argv)
 
   grpc_closure_init (&destroyed, destroy_pollset, &g_pollset);
   grpc_pollset_shutdown (&g_pollset, &destroyed, &closure_list);
-  grpc_closure_list_run (&closure_list);
+  grpc_exec_ctx_finish (&exec_ctx);
   grpc_shutdown ();
   return 0;
 }