Send notify_price_sched messages if either the primary or the secondary

network are connected.

Author: tompntn

pc/manager.cpp

@@ -572,6 +572,9 @@ void manager::poll( bool do_wait )
     }
   }
 
+  // request product quotes from publishers
+  poll_schedule();
+
   // try to (re)connect to tx proxy
   if ( do_tx_ && ( !tconn_.get_is_connect() || tconn_.get_is_err() ) ) {
     tconn_.reconnect();
@@ -580,9 +583,6 @@ void manager::poll( bool do_wait )
   if ( has_status( PC_PYTH_RPC_CONNECTED ) &&
        !hconn_.get_is_err() &&
        ( !wconn_ || !wconn_->get_is_err() ) ) {
-    // request product quotes from pythd's clients while connected
-    poll_schedule();
-
     send_pending_ups();
   } else {
     reconnect_rpc();

pc/request.cpp

@@ -1101,9 +1101,21 @@ uint64_t price_sched::get_hash() const
 bool price_sched::get_is_ready()
 {
   manager *cptr = get_manager();
-  return cptr->has_status( PC_PYTH_RPC_CONNECTED |
-                           PC_PYTH_HAS_BLOCK_HASH |
-                           PC_PYTH_HAS_MAPPING );
+
+  bool primary_ready = cptr->has_status(
+    PC_PYTH_RPC_CONNECTED |
+    PC_PYTH_HAS_BLOCK_HASH |
+    PC_PYTH_HAS_MAPPING
+  );
+
+  bool secondary_ready = cptr->has_secondary() &&
+    cptr->get_secondary()->has_status( 
+        PC_PYTH_RPC_CONNECTED |
+        PC_PYTH_HAS_BLOCK_HASH |
+        PC_PYTH_HAS_MAPPING
+    );
+
+  return primary_ready || secondary_ready;
 }
 
 void price_sched::submit()

pc/user.cpp

@@ -274,6 +274,10 @@ void user::parse_sub_price_sched( uint32_t tok, uint32_t itok )
     pub_key pkey;
     pkey.init_from_text( jp_.get_str( ntok ) );
     price *sptr = sptr_->get_price( pkey );
+    if ( PC_UNLIKELY( !sptr && sptr_->has_secondary() ) ) {
+      sptr = sptr_->get_secondary()->get_price( pkey );
+    }
+
     if ( PC_UNLIKELY( !sptr ) ) { add_unknown_symbol(itok); return; }
 
     // add subscription