January 2018 - tor-commits - lists.torproject.org

[orbot/master] add bridge wizard testing code
by n8fr8＠torproject.org 03 Jan '18

03 Jan '18

commit df37b8c4a98455c4ac42fb52a6089997fdaa6c0d Author: n8fr8 <nathan(a)freitas.net> Date: Wed Jan 3 12:49:11 2018 -0500 add bridge wizard testing code --- .../ui/onboarding/BridgeWizardActivity.java | 91 ++++++++++++++++++++++ app/src/main/res/layout/content_bridge_wizard.xml | 34 +++++--- app/src/main/res/values/strings.xml | 5 +- 3 files changed, 117 insertions(+), 13 deletions(-) diff --git a/app/src/main/java/org/torproject/android/ui/onboarding/BridgeWizardActivity.java b/app/src/main/java/org/torproject/android/ui/onboarding/BridgeWizardActivity.java index 63a7e072..40b7177c 100644 --- a/app/src/main/java/org/torproject/android/ui/onboarding/BridgeWizardActivity.java +++ b/app/src/main/java/org/torproject/android/ui/onboarding/BridgeWizardActivity.java @@ -7,11 +7,13 @@ import android.content.Intent; import android.content.pm.PackageInfo; import android.content.pm.PackageManager; import android.net.Uri; +import android.os.AsyncTask; import android.os.Bundle; import android.support.design.widget.FloatingActionButton; import android.support.design.widget.Snackbar; import android.support.v7.app.AppCompatActivity; import android.support.v7.widget.Toolbar; +import android.text.TextUtils; import android.view.LayoutInflater; import android.view.View; import android.widget.TextView; @@ -22,8 +24,15 @@ import org.torproject.android.service.OrbotConstants; import org.torproject.android.service.TorServiceConstants; import org.torproject.android.service.util.Prefs; +import java.io.IOException; +import java.net.InetSocketAddress; +import java.net.Socket; +import java.net.SocketAddress; + public class BridgeWizardActivity extends AppCompatActivity { + private TextView tvStatus; + @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); @@ -32,6 +41,9 @@ public class BridgeWizardActivity extends AppCompatActivity { setSupportActionBar(toolbar); getSupportActionBar().setDisplayHomeAsUpEnabled(true); + tvStatus = (TextView)findViewById(R.id.lbl_bridge_test_status); + tvStatus.setVisibility(View.GONE); + setTitle(getString(R.string.bridges)); findViewById(R.id.btnBridgesDirect).setOnClickListener(new View.OnClickListener() { @@ -39,6 +51,8 @@ public class BridgeWizardActivity extends AppCompatActivity { public void onClick(View v) { Prefs.setBridgesList(""); Prefs.putBridgesEnabled(false); + testBridgeConnection(); + } }); @@ -47,6 +61,8 @@ public class BridgeWizardActivity extends AppCompatActivity { public void onClick(View v) { Prefs.setBridgesList("obfs4"); Prefs.putBridgesEnabled(true); + testBridgeConnection(); + } }); @@ -56,6 +72,8 @@ public class BridgeWizardActivity extends AppCompatActivity { public void onClick(View v) { Prefs.setBridgesList("meek"); Prefs.putBridgesEnabled(true); + testBridgeConnection(); + } }); @@ -213,4 +231,77 @@ public class BridgeWizardActivity extends AppCompatActivity { } } + private void testBridgeConnection () + { + if (TextUtils.isEmpty(Prefs.getBridgesList()) || (!Prefs.bridgesEnabled())) + { + new HostTester().execute("check.torproject.org","443"); + } + else if (Prefs.getBridgesList().equals("meek")) + { + new HostTester().execute("meek.azureedge.net","443","d2cly7j4zqgua7.cloudfront.net","443"); + } + else if (Prefs.getBridgesList().equals("obfs4")) + { + new HostTester().execute("85.17.30.79","443","154.35.22.9","443","192.99.11.54","443"); + } + else + { + tvStatus.setText(""); + } + } + + private class HostTester extends AsyncTask<String, Void, Boolean> { + protected void onPreExecute() { + // Pre Code + tvStatus.setVisibility(View.VISIBLE); + tvStatus.setText(R.string.testing_bridges); + } + protected Boolean doInBackground(String... host) { + // Background Code + boolean result = false; + + for (int i = 0; i < host.length; i++) { + String testHost = host[i]; + i++; //move to the port + int testPort = Integer.parseInt(host[i]); + result = isHostReachable(testHost, testPort, 5000); + if (result) + return result; + } + + return result; + } + protected void onPostExecute(Boolean result) { + // Post Code + if (result) + { + tvStatus.setText(R.string.testing_bridges_success); + + } + else + { + tvStatus.setText(R.string.testing_bridges_fail); + + } + }}; + + private static boolean isHostReachable(String serverAddress, int serverTCPport, int timeoutMS){ + boolean connected = false; + Socket socket; + try { + socket = new Socket(); + SocketAddress socketAddress = new InetSocketAddress(serverAddress, serverTCPport); + socket.connect(socketAddress, timeoutMS); + if (socket.isConnected()) { + connected = true; + socket.close(); + } + } catch (IOException e) { + e.printStackTrace(); + } finally { + socket = null; + } + return connected; + } } diff --git a/app/src/main/res/layout/content_bridge_wizard.xml b/app/src/main/res/layout/content_bridge_wizard.xml index fb1473ff..609bcdf4 100644 --- a/app/src/main/res/layout/content_bridge_wizard.xml +++ b/app/src/main/res/layout/content_bridge_wizard.xml @@ -26,37 +26,47 @@ <RadioButton android:id="@+id/btnBridgesDirect" - android:layout_width="315dp" - android:layout_height="29dp" - android:text="Direct connection to Tor" + android:layout_width="wrap_content" + android:layout_height="wrap_content" + android:text="Connect directly to Tor\n(Best, if you can!)" android:layout_margin="12dp" /> <RadioButton android:id="@+id/btnBridgesObfs4" - android:layout_width="315dp" - android:layout_height="29dp" - android:text="Connect through community bridges (Obfs4)" + android:layout_width="wrap_content" + android:layout_height="wrap_content" + android:text="Connect through community bridges\n(Second best option, if it works)" android:layout_margin="12dp" /> <RadioButton android:id="@+id/btnBridgesMeek" - android:layout_width="315dp" - android:layout_height="29dp" - android:text="Hide traffic through Cloud Services" + android:layout_width="wrap_content" + android:layout_height="wrap_content" + android:text="Hide traffic through cloud services\n(Slower, but harder to block)" android:layout_margin="12dp" /> <RadioButton android:id="@+id/btnBridgesNew" - android:layout_width="315dp" - android:layout_height="29dp" - android:text="Request New Bridges..." + android:layout_width="wrap_content" + android:layout_height="wrap_content" + android:text="Request New Bridges...\n(If all the other options fail...)" android:layout_margin="12dp" /> </RadioGroup> + <TextView + android:layout_width="match_parent" + android:layout_height="wrap_content" + android:text="testing..." + android:gravity="center" + android:id="@+id/lbl_bridge_test_status" + android:layout_margin="12dp" + android:textStyle="bold" + android:textSize="16sp" + /> </LinearLayout> diff --git a/app/src/main/res/values/strings.xml b/app/src/main/res/values/strings.xml index cb1a4366..72a226a3 100644 --- a/app/src/main/res/values/strings.xml +++ b/app/src/main/res/values/strings.xml @@ -311,7 +311,7 @@ <string name="menu_qr">QR Codes</string> - <string name="if_your_mobile_network_actively_blocks_tor_you_can_use_a_tor_bridge_to_access_the_network_another_way_to_get_bridges_is_to_send_an_email_to_bridges_torproject_org_please_note_that_you_must_send_the_email_using_an_address_from_one_of_the_following_email_providers_riseup_gmail_or_yahoo_">If your mobile network actively blocks Tor, you can use a Bridge to access the network. SELECT one of the bridge types above to enable bridges.</string> + <string name="if_your_mobile_network_actively_blocks_tor_you_can_use_a_tor_bridge_to_access_the_network_another_way_to_get_bridges_is_to_send_an_email_to_bridges_torproject_org_please_note_that_you_must_send_the_email_using_an_address_from_one_of_the_following_email_providers_riseup_gmail_or_yahoo_">If your mobile network actively blocks Tor, you can use a \'Bridge Server\' as an alternate way in. SELECT one of the options to configure and test..,.</string> <string name="bridge_mode">Bridge Mode</string> @@ -391,4 +391,7 @@ <string name="please_enable_vpn">Please activate the VPN mode to enable apps to use Tor</string> <string name="app_shortcuts">Tor-Enabled Apps</string> <string name="title_activity_bridge_wizard">BridgeWizardActivity</string> + <string name="testing_bridges">Testing bridge connection to Tor....</string> + <string name="testing_bridges_success">Success. Bridge configuration is good!</string> + <string name="testing_bridges_fail">FAILED. Try another option</string> </resources>

1 0

[tor/master] Add all the missed scheduler_state assignments
by nickm＠torproject.org 03 Jan '18

03 Jan '18

commit 273325e216ff10b2ce938b243122d08f075f7881 Author: Matt Traudt <sirmatt(a)ksu.edu> Date: Mon Dec 11 09:03:16 2017 -0500 Add all the missed scheduler_state assignments --- src/or/scheduler_kist.c | 14 +++++++------- src/or/scheduler_vanilla.c | 12 ++++++------ 2 files changed, 13 insertions(+), 13 deletions(-) diff --git a/src/or/scheduler_kist.c b/src/or/scheduler_kist.c index e02926e47..6a5b8d4f4 100644 --- a/src/or/scheduler_kist.c +++ b/src/or/scheduler_kist.c @@ -611,7 +611,7 @@ kist_scheduler_run(void) if (!CHANNEL_IS_OPEN(chan)) { /* Channel isn't open so we put it back in IDLE mode. It is either * renegotiating its TLS session or about to be released. */ - chan->scheduler_state = SCHED_CHAN_IDLE; + scheduler_set_channel_state(chan, SCHED_CHAN_IDLE); continue; } /* flush_result has the # cells flushed */ @@ -632,7 +632,7 @@ kist_scheduler_run(void) "stop scheduling it this round.", channel_state_to_string(chan->state), chan->scheduler_state); - chan->scheduler_state = SCHED_CHAN_WAITING_FOR_CELLS; + scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_FOR_CELLS); continue; } } @@ -659,14 +659,14 @@ kist_scheduler_run(void) * SCHED_CHAN_WAITING_FOR_CELLS to SCHED_CHAN_IDLE and seeing if Tor * starts having serious throughput issues. Best done in shadow/chutney. */ - chan->scheduler_state = SCHED_CHAN_WAITING_FOR_CELLS; + scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_FOR_CELLS); log_debug(LD_SCHED, "chan=%" PRIu64 " now waiting_for_cells", chan->global_identifier); } else if (!channel_more_to_flush(chan)) { /* Case 2: no more cells to send, but still open for writes */ - chan->scheduler_state = SCHED_CHAN_WAITING_FOR_CELLS; + scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_FOR_CELLS); log_debug(LD_SCHED, "chan=%" PRIu64 " now waiting_for_cells", chan->global_identifier); } else if (!socket_can_write(&socket_table, chan)) { @@ -680,7 +680,7 @@ kist_scheduler_run(void) * after the scheduling loop is over. They can hopefully be taken care of * in the next scheduling round. */ - chan->scheduler_state = SCHED_CHAN_WAITING_TO_WRITE; + scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_TO_WRITE); if (!to_readd) { to_readd = smartlist_new(); } @@ -691,7 +691,7 @@ kist_scheduler_run(void) /* Case 4: cells to send, and still open for writes */ - chan->scheduler_state = SCHED_CHAN_PENDING; + scheduler_set_channel_state(chan, SCHED_CHAN_PENDING); smartlist_pqueue_add(cp, scheduler_compare_channels, offsetof(channel_t, sched_heap_idx), chan); } @@ -711,7 +711,7 @@ kist_scheduler_run(void) /* Re-add any channels we need to */ if (to_readd) { SMARTLIST_FOREACH_BEGIN(to_readd, channel_t *, readd_chan) { - readd_chan->scheduler_state = SCHED_CHAN_PENDING; + scheduler_set_channel_state(readd_chan, SCHED_CHAN_PENDING); if (!smartlist_contains(cp, readd_chan)) { smartlist_pqueue_add(cp, scheduler_compare_channels, offsetof(channel_t, sched_heap_idx), readd_chan); diff --git a/src/or/scheduler_vanilla.c b/src/or/scheduler_vanilla.c index 303b3dbba..64655c024 100644 --- a/src/or/scheduler_vanilla.c +++ b/src/or/scheduler_vanilla.c @@ -89,7 +89,7 @@ vanilla_scheduler_run(void) if (flushed < n_cells) { /* We ran out of cells to flush */ - chan->scheduler_state = SCHED_CHAN_WAITING_FOR_CELLS; + scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_FOR_CELLS); log_debug(LD_SCHED, "Channel " U64_FORMAT " at %p " "entered waiting_for_cells from pending", @@ -110,7 +110,7 @@ vanilla_scheduler_run(void) chan); } else { /* It's waiting to be able to write more */ - chan->scheduler_state = SCHED_CHAN_WAITING_TO_WRITE; + scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_TO_WRITE); log_debug(LD_SCHED, "Channel " U64_FORMAT " at %p " "entered waiting_to_write from pending", @@ -124,7 +124,7 @@ vanilla_scheduler_run(void) * It can still accept writes, so it goes to * waiting_for_cells */ - chan->scheduler_state = SCHED_CHAN_WAITING_FOR_CELLS; + scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_FOR_CELLS); log_debug(LD_SCHED, "Channel " U64_FORMAT " at %p " "entered waiting_for_cells from pending", @@ -135,7 +135,7 @@ vanilla_scheduler_run(void) * We exactly filled up the output queue with all available * cells; go to idle. */ - chan->scheduler_state = SCHED_CHAN_IDLE; + scheduler_set_channel_state(chan, SCHED_CHAN_IDLE); log_debug(LD_SCHED, "Channel " U64_FORMAT " at %p " "become idle from pending", @@ -156,14 +156,14 @@ vanilla_scheduler_run(void) "no cells writeable", U64_PRINTF_ARG(chan->global_identifier), chan); /* Put it back to WAITING_TO_WRITE */ - chan->scheduler_state = SCHED_CHAN_WAITING_TO_WRITE; + scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_TO_WRITE); } } /* Readd any channels we need to */ if (to_readd) { SMARTLIST_FOREACH_BEGIN(to_readd, channel_t *, readd_chan) { - readd_chan->scheduler_state = SCHED_CHAN_PENDING; + scheduler_set_channel_state(readd_chan, SCHED_CHAN_PENDING); smartlist_pqueue_add(cp, scheduler_compare_channels, offsetof(channel_t, sched_heap_idx),

1 0

[tor/master] Fix cosmetic issues around scheduler_set_channel_state
by nickm＠torproject.org 03 Jan '18

03 Jan '18

commit 5e7fdb8b3f397c8f9b1cecacf07a6bacf0d47e2d Author: Matt Traudt <sirmatt(a)ksu.edu> Date: Mon Dec 11 08:56:03 2017 -0500 Fix cosmetic issues around scheduler_set_channel_state Whitespace issues Line length Unused variable --- src/or/scheduler.c | 28 +++++++++++++++------------- src/or/scheduler.h | 3 +-- 2 files changed, 16 insertions(+), 15 deletions(-) diff --git a/src/or/scheduler.c b/src/or/scheduler.c index 36aa6ba92..1d51550f9 100644 --- a/src/or/scheduler.c +++ b/src/or/scheduler.c @@ -361,12 +361,15 @@ set_scheduler(void) * * Functions that can only be accessed from scheduler*.c *****************************************************************************/ -/* Function to log and change all the old and new states*/ -void scheduler_set_channel_state(channel_t *chan,int new_state){ - log_debug(LD_SCHED, "chan %s changed from scheduler state %d to %d",chan->global_identifier, chan->scheduler_state, new_state); +/** Helper that logs channel scheduler_state changes. Use this instead of + * setting scheduler_state directly. */ +void scheduler_set_channel_state(channel_t *chan, int new_state){ + log_debug(LD_SCHED, "chan %s changed from scheduler state %d to %d", + chan->global_identifier, chan->scheduler_state, new_state); chan->scheduler_state = new_state; } + /** Return the pending channel list. */ smartlist_t * get_channels_pending(void) @@ -494,7 +497,7 @@ scheduler_channel_doesnt_want_writes,(channel_t *chan)) } /* If it's already in pending, we can put it in waiting_to_write */ - if (chan->scheduler_state == SCHED_CHAN_PENDING){ + if (chan->scheduler_state == SCHED_CHAN_PENDING) { /* * It's in channels_pending, so it shouldn't be in any of * the other lists. It can't write any more, so it goes to @@ -504,7 +507,7 @@ scheduler_channel_doesnt_want_writes,(channel_t *chan)) scheduler_compare_channels, offsetof(channel_t, sched_heap_idx), chan); - scheduler_set_channel_state(chan,SCHED_CHAN_WAITING_TO_WRITE); + scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_TO_WRITE); log_debug(LD_SCHED, "Channel " U64_FORMAT " at %p went from pending " "to waiting_to_write", @@ -515,8 +518,8 @@ scheduler_channel_doesnt_want_writes,(channel_t *chan)) * either not in any of the lists (nothing to do) or it's already in * waiting_for_cells (remove it, can't write any more). */ - if (chan->scheduler_state == SCHED_CHAN_WAITING_FOR_CELLS){ - scheduler_set_channel_state(chan,SCHED_CHAN_IDLE); + if (chan->scheduler_state == SCHED_CHAN_WAITING_FOR_CELLS) { + scheduler_set_channel_state(chan, SCHED_CHAN_IDLE); log_debug(LD_SCHED, "Channel " U64_FORMAT " at %p left waiting_for_cells", U64_PRINTF_ARG(chan->global_identifier), chan); @@ -536,13 +539,13 @@ scheduler_channel_has_waiting_cells,(channel_t *chan)) } /* First, check if it's also writeable */ - if (chan->scheduler_state == SCHED_CHAN_WAITING_FOR_CELLS){ + if (chan->scheduler_state == SCHED_CHAN_WAITING_FOR_CELLS) { /* * It's in channels_waiting_for_cells, so it shouldn't be in any of * the other lists. It has waiting cells now, so it goes to * channels_pending. */ - scheduler_set_channel_state(chan,SCHED_CHAN_PENDING); + scheduler_set_channel_state(chan, SCHED_CHAN_PENDING); smartlist_pqueue_add(channels_pending, scheduler_compare_channels, offsetof(channel_t, sched_heap_idx), @@ -561,7 +564,7 @@ scheduler_channel_has_waiting_cells,(channel_t *chan)) * or it's already in waiting_to_write or pending (we do nothing) */ if (!(chan->scheduler_state == SCHED_CHAN_WAITING_TO_WRITE || - chan->scheduler_state== SCHED_CHAN_PENDING)) { + chan->scheduler_state == SCHED_CHAN_PENDING)) { scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_TO_WRITE); log_debug(LD_SCHED, "Channel " U64_FORMAT " at %p entered waiting_to_write", @@ -648,7 +651,7 @@ scheduler_release_channel,(channel_t *chan)) if (the_scheduler->on_channel_free) { the_scheduler->on_channel_free(chan); } - scheduler_set_channel_state(chan,SCHED_CHAN_IDLE); + scheduler_set_channel_state(chan, SCHED_CHAN_IDLE); } /** Mark a channel as ready to accept writes */ @@ -674,7 +677,7 @@ scheduler_channel_wants_writes(channel_t *chan) scheduler_compare_channels, offsetof(channel_t, sched_heap_idx), chan); - scheduler_set_channel_state(chan,SCHED_CHAN_PENDING); + scheduler_set_channel_state(chan, SCHED_CHAN_PENDING); log_debug(LD_SCHED, "Channel " U64_FORMAT " at %p went from waiting_to_write " "to pending", @@ -705,7 +708,6 @@ scheduler_bug_occurred(const channel_t *chan) char buf[128]; if (chan != NULL) { - int new_state=0; const size_t outbuf_len = buf_datalen(TO_CONN(BASE_CHAN_TO_TLS((channel_t *) chan)->conn)->outbuf); tor_snprintf(buf, sizeof(buf), diff --git a/src/or/scheduler.h b/src/or/scheduler.h index 2c2559f2c..da212c50c 100644 --- a/src/or/scheduler.h +++ b/src/or/scheduler.h @@ -143,9 +143,8 @@ MOCK_DECL(void, scheduler_channel_has_waiting_cells, (channel_t *chan)); /********************************* * Defined in scheduler.c *********************************/ -/* Function to log and change all the old and new states*/ -void scheduler_set_channel_state(channel_t *chan,int new_state); +void scheduler_set_channel_state(channel_t *chan, int new_state); /* Triggers a BUG() and extra information with chan if available. */ #define SCHED_BUG(cond, chan) \

1 0

[tor/master] Bug:24531 Add function to change scheduler state and always use it
by nickm＠torproject.org 03 Jan '18

03 Jan '18

commit d77cacb7ab97e876900063f4d7c852a458bdab93 Author: ArunaMaurya221B <aruna.maurya12(a)gmail.com> Date: Thu Dec 7 19:58:02 2017 +0530 Bug:24531 Add function to change scheduler state and always use it --- src/or/scheduler.c | 37 +++++++++++++++++++++---------------- src/or/scheduler.h | 3 +++ 2 files changed, 24 insertions(+), 16 deletions(-) diff --git a/src/or/scheduler.c b/src/or/scheduler.c index cd047d5a7..38b2ee5ef 100644 --- a/src/or/scheduler.c +++ b/src/or/scheduler.c @@ -361,7 +361,12 @@ set_scheduler(void) * * Functions that can only be accessed from scheduler*.c *****************************************************************************/ +/* Function to log and change all the old and new states*/ +void scheduler_set_channel(chan,new_state){ + log_debug(LD_SCHED, "chan %d changed from scheduler state %d to %d",chan->global_id, chan->scheduler_state, new_state); + chan->scheduler_state = new_state; +} /** Return the pending channel list. */ smartlist_t * get_channels_pending(void) @@ -510,8 +515,8 @@ scheduler_channel_doesnt_want_writes,(channel_t *chan)) * either not in any of the lists (nothing to do) or it's already in * waiting_for_cells (remove it, can't write any more). */ - if (chan->scheduler_state == SCHED_CHAN_WAITING_FOR_CELLS) { - chan->scheduler_state = SCHED_CHAN_IDLE; + if (scheduler_set_channel(chan,new_state) == SCHED_CHAN_WAITING_FOR_CELLS) { + scheduler_set_channel(chan,new_state) = SCHED_CHAN_IDLE; log_debug(LD_SCHED, "Channel " U64_FORMAT " at %p left waiting_for_cells", U64_PRINTF_ARG(chan->global_identifier), chan); @@ -531,13 +536,13 @@ scheduler_channel_has_waiting_cells,(channel_t *chan)) } /* First, check if it's also writeable */ - if (chan->scheduler_state == SCHED_CHAN_WAITING_FOR_CELLS) { + if (scheduler_set_channel(chan,new_state) == SCHED_CHAN_WAITING_FOR_CELLS) { /* * It's in channels_waiting_for_cells, so it shouldn't be in any of * the other lists. It has waiting cells now, so it goes to * channels_pending. */ - chan->scheduler_state = SCHED_CHAN_PENDING; + scheduler_set_channel(chan,new_state) = SCHED_CHAN_PENDING; smartlist_pqueue_add(channels_pending, scheduler_compare_channels, offsetof(channel_t, sched_heap_idx), @@ -555,9 +560,9 @@ scheduler_channel_has_waiting_cells,(channel_t *chan)) * either not in any of the lists (we add it to waiting_to_write) * or it's already in waiting_to_write or pending (we do nothing) */ - if (!(chan->scheduler_state == SCHED_CHAN_WAITING_TO_WRITE || - chan->scheduler_state == SCHED_CHAN_PENDING)) { - chan->scheduler_state = SCHED_CHAN_WAITING_TO_WRITE; + if (!(scheduler_set_channel(chan,new_state) == SCHED_CHAN_WAITING_TO_WRITE || + scheduler_set_channel(chan,new_state) == SCHED_CHAN_PENDING)) { + scheduler_set_channel(chan,new_state) = SCHED_CHAN_WAITING_TO_WRITE; log_debug(LD_SCHED, "Channel " U64_FORMAT " at %p entered waiting_to_write", U64_PRINTF_ARG(chan->global_identifier), chan); @@ -627,7 +632,7 @@ scheduler_release_channel,(channel_t *chan)) return; } - if (chan->scheduler_state == SCHED_CHAN_PENDING) { + if (scheduler_set_channel(chan,new_state) == SCHED_CHAN_PENDING) { if (SCHED_BUG(smartlist_pos(channels_pending, chan) == -1, chan)) { log_warn(LD_SCHED, "Scheduler asked to release channel %" PRIu64 " " "but it wasn't in channels_pending", @@ -643,7 +648,7 @@ scheduler_release_channel,(channel_t *chan)) if (the_scheduler->on_channel_free) { the_scheduler->on_channel_free(chan); } - chan->scheduler_state = SCHED_CHAN_IDLE; + scheduler_set_channel(chan,new_state) = SCHED_CHAN_IDLE; } /** Mark a channel as ready to accept writes */ @@ -659,7 +664,7 @@ scheduler_channel_wants_writes(channel_t *chan) } /* If it's already in waiting_to_write, we can put it in pending */ - if (chan->scheduler_state == SCHED_CHAN_WAITING_TO_WRITE) { + if (scheduler_set_channel(chan,new_state) == SCHED_CHAN_WAITING_TO_WRITE) { /* * It can write now, so it goes to channels_pending. */ @@ -669,7 +674,7 @@ scheduler_channel_wants_writes(channel_t *chan) scheduler_compare_channels, offsetof(channel_t, sched_heap_idx), chan); - chan->scheduler_state = SCHED_CHAN_PENDING; + scheduler_set_channel(chan,new_state) = SCHED_CHAN_PENDING; log_debug(LD_SCHED, "Channel " U64_FORMAT " at %p went from waiting_to_write " "to pending", @@ -681,9 +686,9 @@ scheduler_channel_wants_writes(channel_t *chan) * It's not in SCHED_CHAN_WAITING_TO_WRITE, so it can't become pending; * it's either idle and goes to WAITING_FOR_CELLS, or it's a no-op. */ - if (!(chan->scheduler_state == SCHED_CHAN_WAITING_FOR_CELLS || - chan->scheduler_state == SCHED_CHAN_PENDING)) { - chan->scheduler_state = SCHED_CHAN_WAITING_FOR_CELLS; + if (!(scheduler_set_channel(chan,new_state) == SCHED_CHAN_WAITING_FOR_CELLS || + scheduler_set_channel(chan,new_state) == SCHED_CHAN_PENDING)) { + scheduler_set_channel(chan,new_state) = SCHED_CHAN_WAITING_FOR_CELLS; log_debug(LD_SCHED, "Channel " U64_FORMAT " at %p entered waiting_for_cells", U64_PRINTF_ARG(chan->global_identifier), chan); @@ -707,7 +712,7 @@ scheduler_bug_occurred(const channel_t *chan) " Num cells on cmux: %d. Connection outbuf len: %lu.", chan->global_identifier, channel_state_to_string(chan->state), - chan->scheduler_state, circuitmux_num_cells(chan->cmux), + scheduler_set_channel(chan,new_state), circuitmux_num_cells(chan->cmux), (unsigned long)outbuf_len); } @@ -740,7 +745,7 @@ scheduler_touch_channel(channel_t *chan) return; } - if (chan->scheduler_state == SCHED_CHAN_PENDING) { + if (scheduler_set_channel(chan,new_state) == SCHED_CHAN_PENDING) { /* Remove and re-add it */ smartlist_pqueue_remove(channels_pending, scheduler_compare_channels, diff --git a/src/or/scheduler.h b/src/or/scheduler.h index 47c98f096..b2d05166a 100644 --- a/src/or/scheduler.h +++ b/src/or/scheduler.h @@ -143,6 +143,9 @@ MOCK_DECL(void, scheduler_channel_has_waiting_cells, (channel_t *chan)); /********************************* * Defined in scheduler.c *********************************/ +/* Function to log and change all the old and new states*/ + +void scheduler_set_channel(chan,new_state); /* Triggers a BUG() and extra information with chan if available. */ #define SCHED_BUG(cond, chan) \

1 0

[tor/master] Bug:24531 Function to change channel scheduler state for easy debugging added.
by nickm＠torproject.org 03 Jan '18

03 Jan '18

commit ad5cfa30396fcbf8e60806594a1a59fd411bc325 Author: ArunaMaurya221B <aruna.maurya12(a)gmail.com> Date: Fri Dec 8 16:48:27 2017 +0530 Bug:24531 Function to change channel scheduler state for easy debugging added. --- src/or/scheduler.c | 41 +++++++++++++++++++++-------------------- src/or/scheduler.h | 2 +- 2 files changed, 22 insertions(+), 21 deletions(-) diff --git a/src/or/scheduler.c b/src/or/scheduler.c index 38b2ee5ef..36aa6ba92 100644 --- a/src/or/scheduler.c +++ b/src/or/scheduler.c @@ -363,8 +363,8 @@ set_scheduler(void) *****************************************************************************/ /* Function to log and change all the old and new states*/ -void scheduler_set_channel(chan,new_state){ - log_debug(LD_SCHED, "chan %d changed from scheduler state %d to %d",chan->global_id, chan->scheduler_state, new_state); +void scheduler_set_channel_state(channel_t *chan,int new_state){ + log_debug(LD_SCHED, "chan %s changed from scheduler state %d to %d",chan->global_identifier, chan->scheduler_state, new_state); chan->scheduler_state = new_state; } /** Return the pending channel list. */ @@ -494,7 +494,7 @@ scheduler_channel_doesnt_want_writes,(channel_t *chan)) } /* If it's already in pending, we can put it in waiting_to_write */ - if (chan->scheduler_state == SCHED_CHAN_PENDING) { + if (chan->scheduler_state == SCHED_CHAN_PENDING){ /* * It's in channels_pending, so it shouldn't be in any of * the other lists. It can't write any more, so it goes to @@ -504,7 +504,7 @@ scheduler_channel_doesnt_want_writes,(channel_t *chan)) scheduler_compare_channels, offsetof(channel_t, sched_heap_idx), chan); - chan->scheduler_state = SCHED_CHAN_WAITING_TO_WRITE; + scheduler_set_channel_state(chan,SCHED_CHAN_WAITING_TO_WRITE); log_debug(LD_SCHED, "Channel " U64_FORMAT " at %p went from pending " "to waiting_to_write", @@ -515,8 +515,8 @@ scheduler_channel_doesnt_want_writes,(channel_t *chan)) * either not in any of the lists (nothing to do) or it's already in * waiting_for_cells (remove it, can't write any more). */ - if (scheduler_set_channel(chan,new_state) == SCHED_CHAN_WAITING_FOR_CELLS) { - scheduler_set_channel(chan,new_state) = SCHED_CHAN_IDLE; + if (chan->scheduler_state == SCHED_CHAN_WAITING_FOR_CELLS){ + scheduler_set_channel_state(chan,SCHED_CHAN_IDLE); log_debug(LD_SCHED, "Channel " U64_FORMAT " at %p left waiting_for_cells", U64_PRINTF_ARG(chan->global_identifier), chan); @@ -536,13 +536,13 @@ scheduler_channel_has_waiting_cells,(channel_t *chan)) } /* First, check if it's also writeable */ - if (scheduler_set_channel(chan,new_state) == SCHED_CHAN_WAITING_FOR_CELLS) { + if (chan->scheduler_state == SCHED_CHAN_WAITING_FOR_CELLS){ /* * It's in channels_waiting_for_cells, so it shouldn't be in any of * the other lists. It has waiting cells now, so it goes to * channels_pending. */ - scheduler_set_channel(chan,new_state) = SCHED_CHAN_PENDING; + scheduler_set_channel_state(chan,SCHED_CHAN_PENDING); smartlist_pqueue_add(channels_pending, scheduler_compare_channels, offsetof(channel_t, sched_heap_idx), @@ -560,9 +560,9 @@ scheduler_channel_has_waiting_cells,(channel_t *chan)) * either not in any of the lists (we add it to waiting_to_write) * or it's already in waiting_to_write or pending (we do nothing) */ - if (!(scheduler_set_channel(chan,new_state) == SCHED_CHAN_WAITING_TO_WRITE || - scheduler_set_channel(chan,new_state) == SCHED_CHAN_PENDING)) { - scheduler_set_channel(chan,new_state) = SCHED_CHAN_WAITING_TO_WRITE; + if (!(chan->scheduler_state == SCHED_CHAN_WAITING_TO_WRITE || + chan->scheduler_state== SCHED_CHAN_PENDING)) { + scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_TO_WRITE); log_debug(LD_SCHED, "Channel " U64_FORMAT " at %p entered waiting_to_write", U64_PRINTF_ARG(chan->global_identifier), chan); @@ -632,7 +632,7 @@ scheduler_release_channel,(channel_t *chan)) return; } - if (scheduler_set_channel(chan,new_state) == SCHED_CHAN_PENDING) { + if (chan->scheduler_state == SCHED_CHAN_PENDING) { if (SCHED_BUG(smartlist_pos(channels_pending, chan) == -1, chan)) { log_warn(LD_SCHED, "Scheduler asked to release channel %" PRIu64 " " "but it wasn't in channels_pending", @@ -648,7 +648,7 @@ scheduler_release_channel,(channel_t *chan)) if (the_scheduler->on_channel_free) { the_scheduler->on_channel_free(chan); } - scheduler_set_channel(chan,new_state) = SCHED_CHAN_IDLE; + scheduler_set_channel_state(chan,SCHED_CHAN_IDLE); } /** Mark a channel as ready to accept writes */ @@ -664,7 +664,7 @@ scheduler_channel_wants_writes(channel_t *chan) } /* If it's already in waiting_to_write, we can put it in pending */ - if (scheduler_set_channel(chan,new_state) == SCHED_CHAN_WAITING_TO_WRITE) { + if (chan->scheduler_state == SCHED_CHAN_WAITING_TO_WRITE) { /* * It can write now, so it goes to channels_pending. */ @@ -674,7 +674,7 @@ scheduler_channel_wants_writes(channel_t *chan) scheduler_compare_channels, offsetof(channel_t, sched_heap_idx), chan); - scheduler_set_channel(chan,new_state) = SCHED_CHAN_PENDING; + scheduler_set_channel_state(chan,SCHED_CHAN_PENDING); log_debug(LD_SCHED, "Channel " U64_FORMAT " at %p went from waiting_to_write " "to pending", @@ -686,9 +686,9 @@ scheduler_channel_wants_writes(channel_t *chan) * It's not in SCHED_CHAN_WAITING_TO_WRITE, so it can't become pending; * it's either idle and goes to WAITING_FOR_CELLS, or it's a no-op. */ - if (!(scheduler_set_channel(chan,new_state) == SCHED_CHAN_WAITING_FOR_CELLS || - scheduler_set_channel(chan,new_state) == SCHED_CHAN_PENDING)) { - scheduler_set_channel(chan,new_state) = SCHED_CHAN_WAITING_FOR_CELLS; + if (!(chan->scheduler_state == SCHED_CHAN_WAITING_FOR_CELLS || + chan->scheduler_state == SCHED_CHAN_PENDING)) { + scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_FOR_CELLS); log_debug(LD_SCHED, "Channel " U64_FORMAT " at %p entered waiting_for_cells", U64_PRINTF_ARG(chan->global_identifier), chan); @@ -705,6 +705,7 @@ scheduler_bug_occurred(const channel_t *chan) char buf[128]; if (chan != NULL) { + int new_state=0; const size_t outbuf_len = buf_datalen(TO_CONN(BASE_CHAN_TO_TLS((channel_t *) chan)->conn)->outbuf); tor_snprintf(buf, sizeof(buf), @@ -712,7 +713,7 @@ scheduler_bug_occurred(const channel_t *chan) " Num cells on cmux: %d. Connection outbuf len: %lu.", chan->global_identifier, channel_state_to_string(chan->state), - scheduler_set_channel(chan,new_state), circuitmux_num_cells(chan->cmux), + chan->scheduler_state, circuitmux_num_cells(chan->cmux), (unsigned long)outbuf_len); } @@ -745,7 +746,7 @@ scheduler_touch_channel(channel_t *chan) return; } - if (scheduler_set_channel(chan,new_state) == SCHED_CHAN_PENDING) { + if (chan->scheduler_state == SCHED_CHAN_PENDING) { /* Remove and re-add it */ smartlist_pqueue_remove(channels_pending, scheduler_compare_channels, diff --git a/src/or/scheduler.h b/src/or/scheduler.h index b2d05166a..2c2559f2c 100644 --- a/src/or/scheduler.h +++ b/src/or/scheduler.h @@ -145,7 +145,7 @@ MOCK_DECL(void, scheduler_channel_has_waiting_cells, (channel_t *chan)); *********************************/ /* Function to log and change all the old and new states*/ -void scheduler_set_channel(chan,new_state); +void scheduler_set_channel_state(channel_t *chan,int new_state); /* Triggers a BUG() and extra information with chan if available. */ #define SCHED_BUG(cond, chan) \

1 0

[tor/master] One more missed chance to use get_scheduler_state_string
by nickm＠torproject.org 03 Jan '18

03 Jan '18

commit 67793b615b581b23ff8b49ab560801b59039695a Author: Matt Traudt <sirmatt(a)ksu.edu> Date: Mon Dec 11 09:33:07 2017 -0500 One more missed chance to use get_scheduler_state_string --- src/or/scheduler.c | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/or/scheduler.c b/src/or/scheduler.c index 09e8894a4..c42c567f9 100644 --- a/src/or/scheduler.c +++ b/src/or/scheduler.c @@ -708,11 +708,12 @@ scheduler_bug_occurred(const channel_t *chan) const size_t outbuf_len = buf_datalen(TO_CONN(BASE_CHAN_TO_TLS((channel_t *) chan)->conn)->outbuf); tor_snprintf(buf, sizeof(buf), - "Channel %" PRIu64 " in state %s and scheduler state %d." + "Channel %" PRIu64 " in state %s and scheduler state %s." " Num cells on cmux: %d. Connection outbuf len: %lu.", chan->global_identifier, channel_state_to_string(chan->state), - chan->scheduler_state, circuitmux_num_cells(chan->cmux), + get_scheduler_state_string(chan->scheduler_state), + circuitmux_num_cells(chan->cmux), (unsigned long)outbuf_len); }

1 0

[tor/master] Remove now-duplicate log_debug lines
by nickm＠torproject.org 03 Jan '18

03 Jan '18

commit 8797c8fbd34132f462be4a4544270ee1b8a071cf Author: Matt Traudt <sirmatt(a)ksu.edu> Date: Mon Dec 11 09:20:54 2017 -0500 Remove now-duplicate log_debug lines --- src/or/scheduler.c | 23 ----------------------- src/or/scheduler_kist.c | 6 ------ src/or/scheduler_vanilla.c | 20 -------------------- 3 files changed, 49 deletions(-) diff --git a/src/or/scheduler.c b/src/or/scheduler.c index 42d9c9f08..1b6d160b8 100644 --- a/src/or/scheduler.c +++ b/src/or/scheduler.c @@ -528,10 +528,6 @@ scheduler_channel_doesnt_want_writes,(channel_t *chan)) offsetof(channel_t, sched_heap_idx), chan); scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_TO_WRITE); - log_debug(LD_SCHED, - "Channel " U64_FORMAT " at %p went from pending " - "to waiting_to_write", - U64_PRINTF_ARG(chan->global_identifier), chan); } else { /* * It's not in pending, so it can't become waiting_to_write; it's @@ -540,9 +536,6 @@ scheduler_channel_doesnt_want_writes,(channel_t *chan)) */ if (chan->scheduler_state == SCHED_CHAN_WAITING_FOR_CELLS) { scheduler_set_channel_state(chan, SCHED_CHAN_IDLE); - log_debug(LD_SCHED, - "Channel " U64_FORMAT " at %p left waiting_for_cells", - U64_PRINTF_ARG(chan->global_identifier), chan); } } } @@ -570,10 +563,6 @@ scheduler_channel_has_waiting_cells,(channel_t *chan)) scheduler_compare_channels, offsetof(channel_t, sched_heap_idx), chan); - log_debug(LD_SCHED, - "Channel " U64_FORMAT " at %p went from waiting_for_cells " - "to pending", - U64_PRINTF_ARG(chan->global_identifier), chan); /* If we made a channel pending, we potentially have scheduling work to * do. */ the_scheduler->schedule(); @@ -586,9 +575,6 @@ scheduler_channel_has_waiting_cells,(channel_t *chan)) if (!(chan->scheduler_state == SCHED_CHAN_WAITING_TO_WRITE || chan->scheduler_state == SCHED_CHAN_PENDING)) { scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_TO_WRITE); - log_debug(LD_SCHED, - "Channel " U64_FORMAT " at %p entered waiting_to_write", - U64_PRINTF_ARG(chan->global_identifier), chan); } } } @@ -691,17 +677,11 @@ scheduler_channel_wants_writes(channel_t *chan) /* * It can write now, so it goes to channels_pending. */ - log_debug(LD_SCHED, "chan=%" PRIu64 " became pending", - chan->global_identifier); smartlist_pqueue_add(channels_pending, scheduler_compare_channels, offsetof(channel_t, sched_heap_idx), chan); scheduler_set_channel_state(chan, SCHED_CHAN_PENDING); - log_debug(LD_SCHED, - "Channel " U64_FORMAT " at %p went from waiting_to_write " - "to pending", - U64_PRINTF_ARG(chan->global_identifier), chan); /* We just made a channel pending, we have scheduling work to do. */ the_scheduler->schedule(); } else { @@ -712,9 +692,6 @@ scheduler_channel_wants_writes(channel_t *chan) if (!(chan->scheduler_state == SCHED_CHAN_WAITING_FOR_CELLS || chan->scheduler_state == SCHED_CHAN_PENDING)) { scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_FOR_CELLS); - log_debug(LD_SCHED, - "Channel " U64_FORMAT " at %p entered waiting_for_cells", - U64_PRINTF_ARG(chan->global_identifier), chan); } } } diff --git a/src/or/scheduler_kist.c b/src/or/scheduler_kist.c index 6a5b8d4f4..5e0e8be45 100644 --- a/src/or/scheduler_kist.c +++ b/src/or/scheduler_kist.c @@ -660,15 +660,11 @@ kist_scheduler_run(void) * starts having serious throughput issues. Best done in shadow/chutney. */ scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_FOR_CELLS); - log_debug(LD_SCHED, "chan=%" PRIu64 " now waiting_for_cells", - chan->global_identifier); } else if (!channel_more_to_flush(chan)) { /* Case 2: no more cells to send, but still open for writes */ scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_FOR_CELLS); - log_debug(LD_SCHED, "chan=%" PRIu64 " now waiting_for_cells", - chan->global_identifier); } else if (!socket_can_write(&socket_table, chan)) { /* Case 3: cells to send, but cannot write */ @@ -685,8 +681,6 @@ kist_scheduler_run(void) to_readd = smartlist_new(); } smartlist_add(to_readd, chan); - log_debug(LD_SCHED, "chan=%" PRIu64 " now waiting_to_write", - chan->global_identifier); } else { /* Case 4: cells to send, and still open for writes */ diff --git a/src/or/scheduler_vanilla.c b/src/or/scheduler_vanilla.c index 64655c024..7a83b9da1 100644 --- a/src/or/scheduler_vanilla.c +++ b/src/or/scheduler_vanilla.c @@ -90,11 +90,6 @@ vanilla_scheduler_run(void) if (flushed < n_cells) { /* We ran out of cells to flush */ scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_FOR_CELLS); - log_debug(LD_SCHED, - "Channel " U64_FORMAT " at %p " - "entered waiting_for_cells from pending", - U64_PRINTF_ARG(chan->global_identifier), - chan); } else { /* The channel may still have some cells */ if (channel_more_to_flush(chan)) { @@ -111,11 +106,6 @@ vanilla_scheduler_run(void) } else { /* It's waiting to be able to write more */ scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_TO_WRITE); - log_debug(LD_SCHED, - "Channel " U64_FORMAT " at %p " - "entered waiting_to_write from pending", - U64_PRINTF_ARG(chan->global_identifier), - chan); } } else { /* No cells left; it can go to idle or waiting_for_cells */ @@ -125,22 +115,12 @@ vanilla_scheduler_run(void) * waiting_for_cells */ scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_FOR_CELLS); - log_debug(LD_SCHED, - "Channel " U64_FORMAT " at %p " - "entered waiting_for_cells from pending", - U64_PRINTF_ARG(chan->global_identifier), - chan); } else { /* * We exactly filled up the output queue with all available * cells; go to idle. */ scheduler_set_channel_state(chan, SCHED_CHAN_IDLE); - log_debug(LD_SCHED, - "Channel " U64_FORMAT " at %p " - "become idle from pending", - U64_PRINTF_ARG(chan->global_identifier), - chan); } } }

1 0

[tor/master] Make get_scheduler_state_string available to scheduler*.c
by nickm＠torproject.org 03 Jan '18

03 Jan '18

commit 667f9311776af65f7546a70c8ad5c27e0d23a02b Author: Matt Traudt <sirmatt(a)ksu.edu> Date: Mon Dec 11 09:32:47 2017 -0500 Make get_scheduler_state_string available to scheduler*.c --- src/or/scheduler.c | 36 ++++++++++++++++++------------------ src/or/scheduler.h | 1 + src/or/scheduler_kist.c | 4 ++-- 3 files changed, 21 insertions(+), 20 deletions(-) diff --git a/src/or/scheduler.c b/src/or/scheduler.c index 1b6d160b8..09e8894a4 100644 --- a/src/or/scheduler.c +++ b/src/or/scheduler.c @@ -198,24 +198,6 @@ get_scheduler_type_string(scheduler_types_t type) } } -/** Returns human readable string for the given channel scheduler state. */ -static const char * -get_scheduler_state_string(int scheduler_state) -{ - switch (scheduler_state) { - case SCHED_CHAN_IDLE: - return "IDLE"; - case SCHED_CHAN_WAITING_FOR_CELLS: - return "WAITING_FOR_CELLS"; - case SCHED_CHAN_WAITING_TO_WRITE: - return "WAITING_TO_WRITE"; - case SCHED_CHAN_PENDING: - return "PENDING"; - default: - return "(invalid)"; - } -} - /** * Scheduler event callback; this should get triggered once per event loop * if any scheduling work was created during the event loop. @@ -380,6 +362,24 @@ set_scheduler(void) * Functions that can only be accessed from scheduler*.c *****************************************************************************/ +/** Returns human readable string for the given channel scheduler state. */ +const char * +get_scheduler_state_string(int scheduler_state) +{ + switch (scheduler_state) { + case SCHED_CHAN_IDLE: + return "IDLE"; + case SCHED_CHAN_WAITING_FOR_CELLS: + return "WAITING_FOR_CELLS"; + case SCHED_CHAN_WAITING_TO_WRITE: + return "WAITING_TO_WRITE"; + case SCHED_CHAN_PENDING: + return "PENDING"; + default: + return "(invalid)"; + } +} + /** Helper that logs channel scheduler_state changes. Use this instead of * setting scheduler_state directly. */ void scheduler_set_channel_state(channel_t *chan, int new_state){ diff --git a/src/or/scheduler.h b/src/or/scheduler.h index da212c50c..ac405c21b 100644 --- a/src/or/scheduler.h +++ b/src/or/scheduler.h @@ -145,6 +145,7 @@ MOCK_DECL(void, scheduler_channel_has_waiting_cells, (channel_t *chan)); *********************************/ void scheduler_set_channel_state(channel_t *chan, int new_state); +const char *get_scheduler_state_string(int scheduler_state); /* Triggers a BUG() and extra information with chan if available. */ #define SCHED_BUG(cond, chan) \ diff --git a/src/or/scheduler_kist.c b/src/or/scheduler_kist.c index 5e0e8be45..f3e6243a8 100644 --- a/src/or/scheduler_kist.c +++ b/src/or/scheduler_kist.c @@ -627,11 +627,11 @@ kist_scheduler_run(void) log_debug(LD_SCHED, "We didn't flush anything on a chan that we think " "can write and wants to write. The channel's state is '%s' " - "and in scheduler state %d. We're going to mark it as " + "and in scheduler state '%s'. We're going to mark it as " "waiting_for_cells (as that's most likely the issue) and " "stop scheduling it this round.", channel_state_to_string(chan->state), - chan->scheduler_state); + get_scheduler_state_string(chan->scheduler_state)); scheduler_set_channel_state(chan, SCHED_CHAN_WAITING_FOR_CELLS); continue; }

1 0

[tor/master] Helper to log chan scheduler_states as strings not ints
by nickm＠torproject.org 03 Jan '18

03 Jan '18

commit 07898fb2a66b9cbfbfb015750b10ef0316258452 Author: Matt Traudt <sirmatt(a)ksu.edu> Date: Mon Dec 11 09:12:24 2017 -0500 Helper to log chan scheduler_states as strings not ints --- src/or/scheduler.c | 24 ++++++++++++++++++++++-- 1 file changed, 22 insertions(+), 2 deletions(-) diff --git a/src/or/scheduler.c b/src/or/scheduler.c index 1d51550f9..42d9c9f08 100644 --- a/src/or/scheduler.c +++ b/src/or/scheduler.c @@ -198,6 +198,24 @@ get_scheduler_type_string(scheduler_types_t type) } } +/** Returns human readable string for the given channel scheduler state. */ +static const char * +get_scheduler_state_string(int scheduler_state) +{ + switch (scheduler_state) { + case SCHED_CHAN_IDLE: + return "IDLE"; + case SCHED_CHAN_WAITING_FOR_CELLS: + return "WAITING_FOR_CELLS"; + case SCHED_CHAN_WAITING_TO_WRITE: + return "WAITING_TO_WRITE"; + case SCHED_CHAN_PENDING: + return "PENDING"; + default: + return "(invalid)"; + } +} + /** * Scheduler event callback; this should get triggered once per event loop * if any scheduling work was created during the event loop. @@ -365,8 +383,10 @@ set_scheduler(void) /** Helper that logs channel scheduler_state changes. Use this instead of * setting scheduler_state directly. */ void scheduler_set_channel_state(channel_t *chan, int new_state){ - log_debug(LD_SCHED, "chan %s changed from scheduler state %d to %d", - chan->global_identifier, chan->scheduler_state, new_state); + log_debug(LD_SCHED, "chan %" PRIu64 " changed from scheduler state %s to %s", + chan->global_identifier, + get_scheduler_state_string(chan->scheduler_state), + get_scheduler_state_string(new_state)); chan->scheduler_state = new_state; }

1 0

[tor/master] Function declaration whitespace
by nickm＠torproject.org 03 Jan '18

03 Jan '18

commit 265b8e8645c36a4be9391c66ac4b7c4da3e2b59e Author: Matt Traudt <sirmatt(a)ksu.edu> Date: Mon Dec 11 09:36:20 2017 -0500 Function declaration whitespace --- src/or/scheduler.c | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/or/scheduler.c b/src/or/scheduler.c index c42c567f9..058efc7be 100644 --- a/src/or/scheduler.c +++ b/src/or/scheduler.c @@ -382,7 +382,9 @@ get_scheduler_state_string(int scheduler_state) /** Helper that logs channel scheduler_state changes. Use this instead of * setting scheduler_state directly. */ -void scheduler_set_channel_state(channel_t *chan, int new_state){ +void +scheduler_set_channel_state(channel_t *chan, int new_state) +{ log_debug(LD_SCHED, "chan %" PRIu64 " changed from scheduler state %s to %s", chan->global_identifier, get_scheduler_state_string(chan->scheduler_state),

1 0