← Back to branch summary

~rmcbride/ubuntu/lucid/ubuntuone-client/fixucg

« back to all changes in this revision

Viewing changes to ubuntuone/syncdaemon/states.py

  • Committer: Bazaar Package Importer
  • Author(s): Rodney Dawes
  • Date: 2009-08-26 12:15:00 UTC
  • mto: (17.1.1 ubuntuone-client)
  • mto: This revision was merged to the branch mainline in revision 7.
  • Revision ID: james.westby@ubuntu.com-20090826121500-56s42txajzxvgsdv
Tags: upstream-0.93.0
Import upstream version 0.93.0

Show diffs side-by-side

added added

removed removed

Lines of Context:
ubuntuone/syncdaemon/states.py
50
50
        self.is_connected = is_connected
51
51
        self.is_online = is_online
52
52
        self.enter = enter
 
53
        self.is_handshake = 'SYS_HANDSHAKE_TIMEOUT' in other_transitions
53
54
        self.transitions = dict(SYS_NET_CONNECTED=sys_net_connected_trn,
54
55
                                SYS_CONNECT=sys_connect_trn,
55
56
                                SYS_NET_DISCONNECTED=sys_net_disconnected_trn,
315
316
    SYS_META_QUEUE_WAITING='READING_WAITING_WITH_BOTHQ',
316
317
    SYS_META_QUEUE_DONE='READING_WAITING_WITH_CONTQ',
317
318
    SYS_CONTENT_QUEUE_WAITING='READING_WAITING_WITH_BOTHQ',
318
 
    SYS_CONTENT_QUEUE_DONE='READING_WAITING_WITH_CONTQ',
 
319
    SYS_CONTENT_QUEUE_DONE='READING_WAITING_WITH_METAQ',
319
320
    )
320
321
 
321
322
READING_WAITING_WITH_NETWORK = SyncDaemonState(
490
491
    'START_CONNECTING_WITH_METAQ', 'READY_WAITING_WITH_METAQ',
491
492
    'READY_WAITING_WITH_METAQ', 'READY_FOR_NETWORK_WITH_METAQ',
492
493
    'READY_WAITING_WITH_METAQ',
493
 
    SYS_META_QUEUE_DONE='READY_WAITING_WITH_METAQ',
 
494
    SYS_META_QUEUE_DONE='READY_WAITING',
494
495
    SYS_META_QUEUE_WAITING='READY_WAITING_WITH_METAQ',
495
496
    SYS_CONTENT_QUEUE_WAITING='READY_WAITING_WITH_BOTHQ',
496
497
    SYS_CONTENT_QUEUE_DONE='READY_WAITING_WITH_METAQ',
502
503
    'START_CONNECTING_WITH_CONTQ', 'READY_WAITING_WITH_CONTQ',
503
504
    'READY_WAITING_WITH_CONTQ', 'READY_FOR_NETWORK_WITH_CONTQ',
504
505
    'READY_WAITING_WITH_CONTQ',
505
 
    SYS_META_QUEUE_WAITING='READY_WAITING_WITH_METAQ',
 
506
    SYS_META_QUEUE_WAITING='READY_WAITING_WITH_BOTHQ',
506
507
    SYS_META_QUEUE_DONE='READY_WAITING_WITH_CONTQ',
507
508
    SYS_CONTENT_QUEUE_WAITING='READY_WAITING_WITH_CONTQ',
508
509
    SYS_CONTENT_QUEUE_DONE='READY_WAITING',
530
531
    SYS_META_QUEUE_DONE='CONNECTING',
531
532
    SYS_CONTENT_QUEUE_WAITING='CONNECTING_WITH_CONTQ',
532
533
    SYS_CONTENT_QUEUE_DONE='CONNECTING',
 
534
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING',
533
535
    enter=lambda m: m.action_q.connect(),
534
536
    )
535
537
 
544
546
    SYS_META_QUEUE_DONE='CONNECTING',
545
547
    SYS_CONTENT_QUEUE_WAITING='CONNECTING_WITH_BOTHQ',
546
548
    SYS_CONTENT_QUEUE_DONE='CONNECTING_WITH_METAQ',
 
549
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_METAQ',
547
550
    enter=lambda m: m.action_q.connect(),
548
551
    )
549
552
 
558
561
    SYS_META_QUEUE_DONE='CONNECTING_WITH_CONTQ',
559
562
    SYS_CONTENT_QUEUE_WAITING='CONNECTING_WITH_CONTQ',
560
563
    SYS_CONTENT_QUEUE_DONE='CONNECTING',
 
564
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_CONTQ',
561
565
    enter=lambda m: m.action_q.connect(),
562
566
    )
563
567
 
572
576
    SYS_META_QUEUE_DONE='CONNECTING_WITH_CONTQ',
573
577
    SYS_CONTENT_QUEUE_WAITING='CONNECTING_WITH_BOTHQ',
574
578
    SYS_CONTENT_QUEUE_DONE='CONNECTING_WITH_METAQ',
 
579
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_BOTHQ',
575
580
    enter=lambda m: m.action_q.connect(),
576
581
    )
577
582
 
585
590
    SYS_META_QUEUE_DONE='CONNECTING',
586
591
    SYS_CONTENT_QUEUE_WAITING='CONNECTING_WITH_CONTQ',
587
592
    SYS_CONTENT_QUEUE_DONE='CONNECTING',
 
593
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING',
588
594
    )
589
595
 
590
596
CONNECTING_WITH_METAQ = SyncDaemonState(
598
604
    SYS_META_QUEUE_DONE='CONNECTING',
599
605
    SYS_CONTENT_QUEUE_WAITING='CONNECTING_WITH_BOTHQ',
600
606
    SYS_CONTENT_QUEUE_DONE='CONNECTING_WITH_METAQ',
 
607
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_METAQ',
601
608
    )
602
609
 
603
610
CONNECTING_WITH_CONTQ = SyncDaemonState(
611
618
    SYS_META_QUEUE_DONE='CONNECTING_WITH_CONTQ',
612
619
    SYS_CONTENT_QUEUE_WAITING='CONNECTING_WITH_CONTQ',
613
620
    SYS_CONTENT_QUEUE_DONE='CONNECTING',
 
621
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_CONTQ',
614
622
    )
615
623
 
616
624
CONNECTING_WITH_BOTHQ = SyncDaemonState(
624
632
    SYS_META_QUEUE_DONE='CONNECTING_WITH_CONTQ',
625
633
    SYS_CONTENT_QUEUE_WAITING='CONNECTING_WITH_BOTHQ',
626
634
    SYS_CONTENT_QUEUE_DONE='CONNECTING_WITH_METAQ',
 
635
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_BOTHQ',
627
636
    )
628
637
 
629
638
START_CONNECTED = NonActiveConnectedSDState(
635
644
    SYS_META_QUEUE_DONE='CONNECTED',
636
645
    SYS_CONTENT_QUEUE_WAITING='CONNECTED_WITH_CONTQ',
637
646
    SYS_CONTENT_QUEUE_DONE='CONNECTED',
 
647
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING',
638
648
    enter=lambda m: m.check_version(),
639
649
    )
640
650
 
648
658
    SYS_META_QUEUE_DONE='CONNECTED',
649
659
    SYS_CONTENT_QUEUE_WAITING='CONNECTED_WITH_BOTHQ',
650
660
    SYS_CONTENT_QUEUE_DONE='CONNECTED_WITH_METAQ',
 
661
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_METAQ',
651
662
    enter=lambda m: m.check_version(),
652
663
    )
653
664
 
661
672
    SYS_META_QUEUE_DONE='CONNECTED_WITH_CONTQ',
662
673
    SYS_CONTENT_QUEUE_WAITING='CONNECTED_WITH_CONTQ',
663
674
    SYS_CONTENT_QUEUE_DONE='CONNECTED',
 
675
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_CONTQ',
664
676
    enter=lambda m: m.check_version(),
665
677
    )
666
678
 
674
686
    SYS_META_QUEUE_DONE='CONNECTED_WITH_CONTQ',
675
687
    SYS_CONTENT_QUEUE_WAITING='CONNECTED_WITH_BOTHQ',
676
688
    SYS_CONTENT_QUEUE_DONE='CONNECTED_WITH_METAQ',
 
689
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_BOTHQ',
677
690
    enter=lambda m: m.check_version(),
678
691
    )
679
692
 
686
699
    SYS_META_QUEUE_DONE='CONNECTED',
687
700
    SYS_CONTENT_QUEUE_WAITING='CONNECTED_WITH_CONTQ',
688
701
    SYS_CONTENT_QUEUE_DONE='CONNECTED',
 
702
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING',
689
703
    )
690
704
 
691
705
CONNECTED_WITH_METAQ = NonActiveConnectedSDState(
698
712
    SYS_META_QUEUE_DONE='CONNECTED',
699
713
    SYS_CONTENT_QUEUE_WAITING='CONNECTED_WITH_BOTHQ',
700
714
    SYS_CONTENT_QUEUE_DONE='CONNECTED_WITH_METAQ',
 
715
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_METAQ',
701
716
    )
702
717
 
703
718
CONNECTED_WITH_CONTQ = NonActiveConnectedSDState(
710
725
    SYS_META_QUEUE_DONE='CONNECTED_WITH_CONTQ',
711
726
    SYS_CONTENT_QUEUE_WAITING='CONNECTED_WITH_CONTQ',
712
727
    SYS_CONTENT_QUEUE_DONE='CONNECTED',
 
728
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_CONTQ',
713
729
    )
714
730
 
715
731
CONNECTED_WITH_BOTHQ = NonActiveConnectedSDState(
722
738
    SYS_META_QUEUE_DONE='CONNECTED_WITH_CONTQ',
723
739
    SYS_CONTENT_QUEUE_WAITING='CONNECTED_WITH_BOTHQ',
724
740
    SYS_CONTENT_QUEUE_DONE='CONNECTED_WITH_METAQ',
 
741
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_BOTHQ',
725
742
    )
726
743
 
727
744
BAD_VERSION = AQErrorState(
738
755
    SYS_META_QUEUE_DONE='SET_CAPABILITIES',
739
756
    SYS_CONTENT_QUEUE_WAITING='SET_CAPABILITIES_WITH_CONTQ',
740
757
    SYS_CONTENT_QUEUE_DONE='SET_CAPABILITIES',
 
758
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING',
741
759
    enter=lambda m: m.set_capabilities(),
742
760
    )
743
761
 
751
769
    SYS_META_QUEUE_DONE='SET_CAPABILITIES',
752
770
    SYS_CONTENT_QUEUE_WAITING='SET_CAPABILITIES_WITH_BOTHQ',
753
771
    SYS_CONTENT_QUEUE_DONE='SET_CAPABILITIES_WITH_METAQ',
 
772
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_METAQ',
754
773
    enter=lambda m: m.set_capabilities(),
755
774
    )
756
775
 
764
783
    SYS_META_QUEUE_DONE='SET_CAPABILITIES_WITH_CONTQ',
765
784
    SYS_CONTENT_QUEUE_WAITING='SET_CAPABILITIES_WITH_CONTQ',
766
785
    SYS_CONTENT_QUEUE_DONE='SET_CAPABILITIES',
 
786
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_CONTQ',
767
787
    enter=lambda m: m.set_capabilities(),
768
788
    )
769
789
 
777
797
    SYS_META_QUEUE_DONE='SET_CAPABILITIES_WITH_CONTQ',
778
798
    SYS_CONTENT_QUEUE_WAITING='START_SET_CAPABILITIES_WITH_BOTHQ',
779
799
    SYS_CONTENT_QUEUE_DONE='SET_CAPABILITIES_WITH_METAQ',
 
800
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_BOTHQ',
780
801
    enter=lambda m: m.set_capabilities(),
781
802
    )
782
803
 
789
810
    SYS_META_QUEUE_DONE='SET_CAPABILITIES',
790
811
    SYS_CONTENT_QUEUE_WAITING='SET_CAPABILITIES_WITH_CONTQ',
791
812
    SYS_CONTENT_QUEUE_DONE='SET_CAPABILITIES',
 
813
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING',
792
814
    )
793
815
 
794
816
SET_CAPABILITIES_WITH_METAQ = NonActiveConnectedSDState(
801
823
    SYS_META_QUEUE_DONE='SET_CAPABILITIES',
802
824
    SYS_CONTENT_QUEUE_WAITING='SET_CAPABILITIES_WITH_BOTHQ',
803
825
    SYS_CONTENT_QUEUE_DONE='SET_CAPABILITIES_WITH_METAQ',
 
826
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_METAQ',
804
827
    )
805
828
 
806
829
SET_CAPABILITIES_WITH_CONTQ = NonActiveConnectedSDState(
813
836
    SYS_META_QUEUE_DONE='SET_CAPABILITIES_WITH_CONTQ',
814
837
    SYS_CONTENT_QUEUE_WAITING='SET_CAPABILITIES_WITH_CONTQ',
815
838
    SYS_CONTENT_QUEUE_DONE='SET_CAPABILITIES',
 
839
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_CONTQ',
816
840
    )
817
841
 
818
842
SET_CAPABILITIES_WITH_BOTHQ = NonActiveConnectedSDState(
825
849
    SYS_META_QUEUE_DONE='SET_CAPABILITIES_WITH_CONTQ',
826
850
    SYS_CONTENT_QUEUE_WAITING='SET_CAPABILITIES_WITH_BOTHQ',
827
851
    SYS_CONTENT_QUEUE_DONE='SET_CAPABILITIES_WITH_METAQ',
 
852
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_BOTHQ',
828
853
    )
829
854
 
830
855
CAPABILITIES_MISMATCH = AQErrorState(
841
866
    SYS_META_QUEUE_DONE='AUTHENTICATING',
842
867
    SYS_CONTENT_QUEUE_WAITING='AUTHENTICATING_WITH_CONTQ',
843
868
    SYS_CONTENT_QUEUE_DONE='AUTHENTICATING',
 
869
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING',
844
870
    enter=lambda m: m.authenticate(),
845
871
    )
846
872
 
854
880
    SYS_META_QUEUE_DONE='AUTHENTICATING',
855
881
    SYS_CONTENT_QUEUE_WAITING='AUTHENTICATING_WITH_BOTHQ',
856
882
    SYS_CONTENT_QUEUE_DONE='AUTHENTICATING_WITH_METAQ',
 
883
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_METAQ',
857
884
    enter=lambda m: m.authenticate(),
858
885
    )
859
886
 
867
894
    SYS_META_QUEUE_DONE='AUTHENTICATING_WITH_CONTQ',
868
895
    SYS_CONTENT_QUEUE_WAITING='AUTHENTICATING_WITH_CONTQ',
869
896
    SYS_CONTENT_QUEUE_DONE='AUTHENTICATING',
 
897
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_CONTQ',
870
898
    enter=lambda m: m.authenticate(),
871
899
    )
872
900
 
880
908
    SYS_META_QUEUE_DONE='AUTHENTICATING_WITH_CONTQ',
881
909
    SYS_CONTENT_QUEUE_WAITING='AUTHENTICATING_WITH_BOTHQ',
882
910
    SYS_CONTENT_QUEUE_DONE='AUTHENTICATING_WITH_METAQ',
 
911
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_BOTHQ',
883
912
    enter=lambda m: m.authenticate(),
884
913
    )
885
914
 
892
921
    SYS_META_QUEUE_DONE='AUTHENTICATING',
893
922
    SYS_CONTENT_QUEUE_WAITING='AUTHENTICATING_WITH_CONTQ',
894
923
    SYS_CONTENT_QUEUE_DONE='AUTHENTICATING',
 
924
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING',
895
925
    )
896
926
 
897
927
AUTHENTICATING_WITH_METAQ = NonActiveConnectedSDState(
904
934
    SYS_META_QUEUE_DONE='AUTHENTICATING',
905
935
    SYS_CONTENT_QUEUE_WAITING='AUTHENTICATING_WITH_BOTHQ',
906
936
    SYS_CONTENT_QUEUE_DONE='AUTHENTICATING_WITH_METAQ',
 
937
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_METAQ',
907
938
    )
908
939
 
909
940
AUTHENTICATING_WITH_CONTQ = NonActiveConnectedSDState(
916
947
    SYS_META_QUEUE_DONE='AUTHENTICATING_WITH_CONTQ',
917
948
    SYS_CONTENT_QUEUE_WAITING='AUTHENTICATING_WITH_CONTQ',
918
949
    SYS_CONTENT_QUEUE_DONE='AUTHENTICATING',
 
950
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_CONTQ',
919
951
    )
920
952
 
921
953
AUTHENTICATING_WITH_BOTHQ = NonActiveConnectedSDState(
928
960
    SYS_META_QUEUE_DONE='AUTHENTICATING_WITH_CONTQ',
929
961
    SYS_CONTENT_QUEUE_WAITING='AUTHENTICATING_WITH_BOTHQ',
930
962
    SYS_CONTENT_QUEUE_DONE='AUTHENTICATING_WITH_METAQ',
 
963
    SYS_HANDSHAKE_TIMEOUT='START_CONNECTING_WITH_BOTHQ',
931
964
    )
932
965
 
933
966
AUTH_FAILED = AQErrorState(
934
967
    'AUTH_FAILED',
935
968
    'OAuth failed')
936
969
 
 
970
EXCESSIVE_TIMEOUTS = AQErrorState(
 
971
    'EXCESSIVE_TIMEOUTS',
 
972
    'Too many timeouts. Giving up.')
 
973
 
937
974
UNKNOWN_ERROR = AQErrorState(
938
975
    'UNKNOWN_ERROR',
939
976
    "Some kind of strange error happened and I can't continue",