@@ -72,7 +72,6 @@ static void accept_connection(const int accepted_fd,
7272 const struct sockaddr * addr );
7373static void ping (const orte_process_name_t * proc );
7474static void send_nb (orte_rml_send_t * msg );
75- static void ft_event (int state );
7675
7776mca_oob_usock_module_t mca_oob_usock_module = {
7877 {
@@ -81,7 +80,7 @@ mca_oob_usock_module_t mca_oob_usock_module = {
8180 accept_connection ,
8281 ping ,
8382 send_nb ,
84- ft_event
83+ NULL
8584 }
8685};
8786
@@ -416,73 +415,3 @@ static void recv_handler(int sd, short flags, void *cbdata)
416415 cleanup :
417416 OBJ_RELEASE (op );
418417}
419-
420- /* Dummy function for when we are not using FT. */
421- #if OPAL_ENABLE_FT_CR == 0
422- static void ft_event (int state )
423- {
424- return ;
425- }
426-
427- #else
428- static void ft_event (int state ) {
429- #if 0
430- opal_list_item_t * item ;
431- #endif
432-
433- if (OPAL_CRS_CHECKPOINT == state ) {
434- #if 0
435- /*
436- * Disable event processing while we are working
437- */
438- opal_event_disable ();
439- #endif
440- }
441- else if (OPAL_CRS_CONTINUE == state ) {
442- #if 0
443- /*
444- * Resume event processing
445- */
446- opal_event_enable ();
447- }
448- else if (OPAL_CRS_RESTART == state ) {
449- /*
450- * Clean out cached connection information
451- * Select pieces of finalize/init
452- */
453- for (item = opal_list_remove_first (& mod -> peer_list );
454- item != NULL ;
455- item = opal_list_remove_first (& mod -> peer_list )) {
456- mca_oob_usock_peer_t * peer = (mca_oob_usock_peer_t * )item ;
457- /* JJH: Use the below command for debugging restarts with invalid sockets
458- * mca_oob_usock_peer_dump(peer, "RESTART CLEAN")
459- */
460- MCA_OOB_USOCK_PEER_RETURN (peer );
461- }
462-
463- OBJ_DESTRUCT (& mod -> peer_free );
464- OBJ_DESTRUCT (& mod -> peer_names );
465- OBJ_DESTRUCT (& mod -> peers );
466- OBJ_DESTRUCT (& mod -> peer_list );
467-
468- OBJ_CONSTRUCT (& mod -> peer_list , opal_list_t );
469- OBJ_CONSTRUCT (& mod -> peers , opal_hash_table_t );
470- OBJ_CONSTRUCT (& mod -> peer_names , opal_hash_table_t );
471- OBJ_CONSTRUCT (& mod -> peer_free , opal_free_list_t );
472-
473- /*
474- * Resume event processing
475- */
476- opal_event_enable ();
477- #endif
478- }
479- else if (OPAL_CRS_TERM == state ) {
480- ;
481- }
482- else {
483- ;
484- }
485-
486- return ;
487- }
488- #endif
0 commit comments