Kiln » Kiln Extensions
Clone URL:  
Pushed to 2 repositories · View In Graph Contained in tip

upgrade Kiln extensions to 2.5.121

Changeset cfd62a21bd59

Parent 10e6ab531de6

by Profile picture of User 12Benjamin Pollack <benjamin@fogcreek.com>

Changes to 51 files · Browse files at cfd62a21bd59 Showing diff from parent 10e6ab531de6 Diff from another changeset...

 
3
4
5
6
 
7
8
9
10
 
 
11
12
13
 
54
55
56
57
 
58
59
60
 
90
91
92
93
 
94
95
96
 
147
148
149
 
 
150
151
152
 
165
166
167
168
 
169
170
171
 
3
4
5
 
6
7
8
9
10
11
12
13
14
15
 
56
57
58
 
59
60
61
62
 
92
93
94
 
95
96
97
98
 
149
150
151
152
153
154
155
156
 
169
170
171
 
172
173
174
175
@@ -3,11 +3,13 @@
 import os  import tempfile  import binascii -import bfutil +import re    from mercurial import util, node, error, url as url_, hg  from mercurial.i18n import _   +import bfutil +  class StoreError(Exception):   '''Raised when there is a problem getting files from or putting   files to a central store.''' @@ -54,7 +56,7 @@
    at = 0   for filename, hash in files: - ui.progress(_('Getting kbfiles'), at, unit='kbfile', total=len(files)) + ui.progress(_('getting kbfiles'), at, unit='kbfile', total=len(files))   at += 1   ui.note(_('getting %s\n') % filename)   outfilename = self.repo.wjoin(filename) @@ -90,7 +92,7 @@
  bfutil.copy_to_cache(self.repo, self.repo['.'].node(), filename, True)   success.append((filename, hhash))   - ui.progress(_('Getting bfiles'), None) + ui.progress(_('getting bfiles'), None)   return (success, missing)     def verify(self, revs, contents=False): @@ -147,6 +149,8 @@
  'https': (httpstore, 'httpstore'),   }   +_scheme_re = re.compile(r'^([a-zA-Z0-9+-.]+)://') +  # During clone this function is passed the src's ui object  # but it needs the dest's ui object so it can read out of  # the config file. Use repo.ui instead. @@ -165,7 +169,7 @@
  if path:   path = hg.repository(ui, path).path   - match = url_.scheme_re.match(path) + match = _scheme_re.match(path)   if not match: # regular filesystem path   scheme = 'file'   else:
 
83
84
85
86
 
87
88
89
 
90
91
92
 
101
102
103
104
 
105
106
107
 
108
109
110
 
329
330
331
332
 
333
334
335
 
339
340
341
342
 
343
344
345
 
356
357
358
359
 
360
361
362
 
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
386
387
388
 
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
 
407
408
409
 
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
441
442
443
 
456
457
458
459
 
460
461
462
 
499
500
501
502
 
503
504
505
506
 
 
 
 
 
 
 
507
508
509
 
83
84
85
 
86
87
88
 
89
90
91
92
 
101
102
103
 
104
105
106
 
107
108
109
110
 
329
330
331
 
332
333
334
335
 
339
340
341
 
342
343
344
345
 
356
357
358
 
359
360
361
362
 
368
369
370
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
 
401
402
403
 
 
 
 
 
 
 
 
 
404
405
406
 
407
408
409
410
 
421
422
423
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
 
463
464
465
 
466
467
468
469
 
506
507
508
 
509
510
511
512
 
513
514
515
516
517
518
519
520
521
522
@@ -83,10 +83,10 @@
    bfiletohash = {}   for ctx in ctxs: - ui.progress(_('Converting revisions'), ctx.rev(), unit=_('revision'), total=rsrc['tip'].rev()) + ui.progress(_('converting revisions'), ctx.rev(), unit=_('revision'), total=rsrc['tip'].rev())   _bfconvert_addchangeset(rsrc, rdst, ctx, revmap,   bfiles, normalfiles, matcher, size, bfiletohash) - ui.progress(_('Converting revisions'), None) + ui.progress(_('converting revisions'), None)     if os.path.exists(rdst.wjoin(bfutil.short_name)):   shutil.rmtree(rdst.wjoin(bfutil.short_name)) @@ -101,10 +101,10 @@
    else:   for ctx in ctxs: - ui.progress(_('Converting revisions'), ctx.rev(), unit=_('revision'), total=rsrc['tip'].rev()) + ui.progress(_('converting revisions'), ctx.rev(), unit=_('revision'), total=rsrc['tip'].rev())   _addchangeset(ui, rsrc, rdst, ctx, revmap)   - ui.progress(_('Converting revisions'), None) + ui.progress(_('converting revisions'), None)   except:   # we failed, remove the new directory   shutil.rmtree(rdst.root) @@ -329,7 +329,7 @@
    at = 0   for hash in files: - ui.progress(_('Uploading bfiles'), at, unit='bfile', total=len(files)) + ui.progress(_('uploading bfiles'), at, unit='bfile', total=len(files))   if store.exists(hash):   at += 1   continue @@ -339,7 +339,7 @@
  # XXX check for errors here   store.put(source, hash)   at += 1 - ui.progress('Uploading bfiles', None) + ui.progress('uploading bfiles', None)    def verify_bfiles(ui, repo, all=False, contents=False):   '''Verify that every big file revision in the current changeset @@ -356,7 +356,7 @@
  store = basestore._open_store(repo)   return store.verify(revs, contents=contents)   -def revert_bfiles(ui, repo): +def revert_bfiles(ui, repo, file_list=None):   wlock = repo.wlock()   try:   bfdirstate = bfutil.open_bfdirstate(ui, repo) @@ -368,21 +368,31 @@
  at = 0   updated = 0   for bfile in bfiles: - if not os.path.exists(repo.wjoin(bfutil.standin(bfile))): - bfdirstate.remove(bfile) - continue - if os.path.exists(repo.wjoin(bfutil.standin(os.path.join(bfile + '.orig')))): - shutil.copyfile(repo.wjoin(bfile), repo.wjoin(bfile + '.orig')) - at += 1 - expectedhash = repo[None][bfutil.standin(bfile)].data().strip() - mode = os.stat(repo.wjoin(bfutil.standin(bfile))).st_mode - if not os.path.exists(repo.wjoin(bfile)) or expectedhash != bfutil.hashfile(repo.wjoin(bfile)): - path = bfutil.find_file(repo, expectedhash) - if path is None: - toget.append((bfile, expectedhash)) - else: - util.makedirs(os.path.dirname(repo.wjoin(bfile))) - shutil.copy(path, repo.wjoin(bfile)) + if file_list == None or bfile in file_list: + if not os.path.exists(repo.wjoin(bfutil.standin(bfile))): + bfdirstate.remove(bfile) + continue + if os.path.exists(repo.wjoin(bfutil.standin(os.path.join(bfile + '.orig')))): + shutil.copyfile(repo.wjoin(bfile), repo.wjoin(bfile + '.orig')) + at += 1 + expectedhash = repo[None][bfutil.standin(bfile)].data().strip() + mode = os.stat(repo.wjoin(bfutil.standin(bfile))).st_mode + if not os.path.exists(repo.wjoin(bfile)) or expectedhash != bfutil.hashfile(repo.wjoin(bfile)): + path = bfutil.find_file(repo, expectedhash) + if path is None: + toget.append((bfile, expectedhash)) + else: + util.makedirs(os.path.dirname(repo.wjoin(bfile))) + shutil.copy(path, repo.wjoin(bfile)) + os.chmod(repo.wjoin(bfile), mode) + updated += 1 + if bfutil.standin(bfile) not in repo['.']: + bfdirstate.add(bfutil.unixpath(bfile)) + elif expectedhash == repo['.'][bfutil.standin(bfile)].data().strip(): + bfdirstate.normal(bfutil.unixpath(bfile)) + else: + bfutil.dirstate_normaldirty(bfdirstate, bfutil.unixpath(bfile)) + elif os.path.exists(repo.wjoin(bfile)) and mode != os.stat(repo.wjoin(bfile)).st_mode:   os.chmod(repo.wjoin(bfile), mode)   updated += 1   if bfutil.standin(bfile) not in repo['.']: @@ -391,19 +401,10 @@
  bfdirstate.normal(bfutil.unixpath(bfile))   else:   bfutil.dirstate_normaldirty(bfdirstate, bfutil.unixpath(bfile)) - elif os.path.exists(repo.wjoin(bfile)) and mode != os.stat(repo.wjoin(bfile)).st_mode: - os.chmod(repo.wjoin(bfile), mode) - updated += 1 - if bfutil.standin(bfile) not in repo['.']: - bfdirstate.add(bfutil.unixpath(bfile)) - elif expectedhash == repo['.'][bfutil.standin(bfile)].data().strip(): - bfdirstate.normal(bfutil.unixpath(bfile)) - else: - bfutil.dirstate_normaldirty(bfdirstate, bfutil.unixpath(bfile))     if toget:   store = basestore._open_store(repo) - (success, missing) = store.get(toget) + success, missing = store.get(toget)   else:   success, missing = [], []   @@ -420,24 +421,30 @@
    removed = 0   for bfile in bfdirstate: - if not os.path.exists(repo.wjoin(bfutil.standin(bfile))): - if os.path.exists(repo.wjoin(bfile)): - os.unlink(repo.wjoin(bfile)) - removed += 1 - if bfutil.standin(bfile) in repo['.']: - bfdirstate.remove(bfutil.unixpath(bfile)) - else: - bfdirstate.forget(bfutil.unixpath(bfile)) - else: - state = repo.dirstate[bfutil.standin(bfile)] - if state == 'n': - bfdirstate.normal(bfile) - elif state == 'r': - bfdirstate.remove(bfile) - elif state == 'a': - bfdirstate.add(bfile) - elif state == '?': - bfdirstate.forget(bfile) + if file_list == None or bfile in file_list: + if not os.path.exists(repo.wjoin(bfutil.standin(bfile))): + if os.path.exists(repo.wjoin(bfile)): + os.unlink(repo.wjoin(bfile)) + removed += 1 + if bfutil.standin(bfile) in repo['.']: + bfdirstate.remove(bfutil.unixpath(bfile)) + else: + bfdirstate.forget(bfutil.unixpath(bfile)) + else: + state = repo.dirstate[bfutil.standin(bfile)] + if state == 'n': + bfdirstate.normal(bfile) + elif state == 'r': + bfdirstate.remove(bfile) + elif state == 'a': + bfdirstate.add(bfile) + elif state == '?': + try: + # Mercurial >= 1.9 + bfdirstate.drop(bfile) + except AttributeError: + # Mercurial <= 1.8 + bfdirstate.forget(bfile)   bfdirstate.write()   finally:   wlock.release() @@ -456,7 +463,7 @@
  removed = 0   printed = False   if bfiles: - ui.status(_('Getting changed bfiles\n')) + ui.status(_('getting changed bfiles\n'))   printed = True     for bfile in bfiles: @@ -499,11 +506,17 @@
  if bfile not in bfiles:   if os.path.exists(repo.wjoin(bfile)):   if not printed: - ui.status(_('Getting changed bfiles\n')) + ui.status(_('getting changed bfiles\n'))   printed = True   os.unlink(repo.wjoin(bfile))   removed += 1 - bfdirstate.forget(bfutil.unixpath(bfile)) + path = bfutil.unixpath(bfile) + try: + # Mercurial >= 1.9 + bfdirstate.drop(path) + except AttributeError: + # Mercurial <= 1.8 + bfdirstate.forget(path)     bfdirstate.write()   if printed:
1
2
3
4
5
 
6
7
8
 
9
10
 
11
12
13
14
15
16
 
 
 
 
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
31
32
33
34
 
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
 
 
 
 
 
 
199
200
201
202
203
204
205
206
207
208
 
 
 
 
 
209
210
211
 
 
 
 
 
 
 
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
 
 
 
 
 
 
 
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
 
 
 
 
 
 
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
 
 
 
 
 
 
397
398
399
400
401
402
403
404
405
406
407
408
409
 
 
 
 
 
 
 
 
 
 
410
411
412
413
414
415
 
 
 
 
 
 
416
417
418
419
420
421
422
423
424
425
426
427
 
 
 
 
 
 
 
 
 
 
428
429
430
431
432
 
 
 
 
 
 
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
 
 
 
 
 
 
 
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
 
 
 
 
 
 
 
576
577
 
 
 
 
 
 
578
579
580
581
582
583
584
585
586
587
588
 
 
 
 
 
 
589
590
591
592
593
594
595
596
597
598
599
600
 
 
 
 
 
 
601
602
603
604
605
606
607
608
609
 
 
 
 
 
 
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
 
 
 
 
 
 
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
 
 
 
 
 
 
686
687
688
689
690
691
692
 
 
 
 
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
 
 
 
 
 
 
709
710
711
712
 
 
 
 
 
 
713
714
715
 
716
717
718
719
720
721
722
723
 
 
 
 
 
 
 
 
 
 
 
724
725
726
727
 
 
 
 
 
 
728
729
730
731
 
 
 
 
 
 
 
 
 
 
732
733
734
 
 
 
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
 
 
757
758
759
760
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
761
762
 
 
 
 
 
 
 
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
 
850
851
 
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
 
 
 
 
 
 
871
872
873
874
875
876
877
878
879
880
881
882
 
 
 
 
 
 
 
 
 
 
 
 
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
1001
1002
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1003
1004
1005
1006
1007
1008
1009
1010
1011
1012
1013
1014
1015
 
1016
1017
1018
1019
1020
1021
1022
1023
1024
1025
1026
1027
1028
1029
1030
1031
1032
1033
1034
1035
1036
1037
1038
1039
1040
1041
1042
1043
1044
1045
1046
1047
 
 
 
 
1048
1049
1050
1051
 
 
 
 
1052
1053
1
2
3
4
5
6
7
8
 
9
10
11
12
13
14
 
 
 
 
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
 
32
33
34
35
 
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
 
 
247
248
249
250
251
252
253
 
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
 
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
 
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
 
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
 
 
 
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
 
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
 
 
 
502
503
504
505
506
507
508
509
510
511
512
513
514
515
 
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
 
671
672
673
674
675
676
677
678
 
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
 
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
 
712
713
714
715
716
717
718
719
720
721
722
723
724
725
 
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
 
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
 
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
 
844
845
846
847
848
849
850
851
 
 
852
853
854
855
856
857
858
859
 
860
861
862
863
864
865
866
867
 
868
869
870
871
872
873
874
875
876
877
878
879
880
881
 
882
883
884
885
886
887
888
889
 
 
890
891
892
893
894
895
896
897
898
899
900
 
 
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
 
 
924
925
926
 
927
 
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
1001
1002
1003
1004
1005
1006
1007
1008
1009
1010
1011
1012
1013
1014
1015
1016
1017
1018
1019
1020
1021
1022
1023
1024
1025
1026
1027
1028
1029
1030
1031
1032
1033
1034
1035
1036
1037
1038
1039
1040
1041
1042
1043
1044
1045
1046
1047
1048
1049
1050
1051
1052
1053
 
1054
1055
 
1056
1057
1058
1059
1060
1061
1062
1063
1064
1065
1066
1067
1068
1069
1070
1071
1072
1073
1074
 
1075
1076
1077
1078
1079
1080
1081
1082
1083
1084
1085
1086
1087
1088
1089
 
 
 
1090
1091
1092
1093
1094
1095
1096
1097
1098
1099
1100
1101
1102
 
1103
1104
1105
1106
1107
1108
1109
1110
1111
1112
1113
1114
1115
1116
1117
1118
1119
1120
1121
1122
1123
1124
1125
1126
1127
1128
1129
1130
1131
1132
1133
1134
1135
1136
1137
1138
1139
1140
1141
1142
1143
1144
1145
1146
1147
1148
1149
1150
1151
1152
1153
1154
1155
1156
1157
1158
1159
1160
1161
1162
1163
1164
1165
1166
1167
1168
1169
1170
1171
1172
1173
1174
1175
1176
1177
1178
1179
1180
1181
1182
1183
1184
1185
1186
1187
1188
1189
1190
1191
1192
1193
1194
1195
1196
1197
1198
1199
1200
1201
1202
1203
1204
1205
1206
1207
1208
1209
1210
1211
1212
1213
1214
1215
1216
1217
1218
1219
1220
1221
1222
1223
1224
1225
1226
1227
1228
1229
1230
1231
1232
1233
1234
1235
1236
1237
1238
1239
1240
1241
1242
1243
1244
1245
1246
1247
1248
1249
1250
1251
1252
1253
1254
1255
1256
1257
1258
1259
1260
1261
1262
1263
1264
1265
1266
1267
1268
1269
1270
1271
1272
1273
1274
1275
1276
1277
1278
1279
1280
1281
1282
 
1283
1284
1285
1286
1287
1288
1289
1290
1291
1292
1293
1294
1295
1296
 '''Setup code for bfiles extension: reposetup(), uisetup().'''    import os  import types  import copy +import re    from mercurial import hg, extensions, commands, util, context, cmdutil, \ - match as match_, filemerge, node, archival, httprepo, error + match as match_, filemerge, node, archival, httprepo, error, manifest  from mercurial.i18n import _  from mercurial.node import hex +from hgext import rebase  import bfutil, bfcommands   -def hgversion(): - from mercurial.__version__ import version - return [int(n) for n in version.partition('+')[0].split('.')] -hgversion = hgversion() +try: + from mercurial import scmutil +except ImportError: + pass    # -- Wrappers: modify existing commands --------------------------------    def reposetup(ui, repo):   # add a kbfiles-specific querystring argument to remote requests, so kiln can reject   # operations on a kbfiles-enabled remote repo from a non-kbfiles local repo.   if issubclass(repo.__class__, httprepo.httprepository):   class kbfilesrepo(repo.__class__):   # The function we want to override is do_cmd for Mercurial <= 1.6   # and _callstream for Mercurial > 1.6. Wrap whichever one we can find.   if hasattr(repo.__class__, 'do_cmd'):   def do_cmd(self, cmd, **args):   args['kbfiles'] = 'true' - return super(repo.__class__, self).do_cmd(cmd, **args) + return super(kbfilesrepo, self).do_cmd(cmd, **args)   if hasattr(repo.__class__, '_callstream'):   def _callstream(self, cmd, **args):   args['kbfiles'] = 'true' - return super(repo.__class__, self)._callstream(cmd, **args) + return super(kbfilesrepo, self)._callstream(cmd, **args)   repo.__class__ = kbfilesrepo     # bfiles doesn't support non-local repositories -- get out quick in   # such a case   if not repo.local():   return     for name in ('status', 'commitctx', 'commit', 'push'):   method = getattr(repo, name)   #if not (isinstance(method, types.MethodType) and   # method.im_func is repo.__class__.commitctx.im_func):   if isinstance(method, types.FunctionType) and method.func_name == 'wrap':   ui.warn(_('kbfiles: repo method %r appears to have already been '   'wrapped by another extension: '   'kbfiles may behave incorrectly\n')   % name)     class bfiles_repo(repo.__class__):   bfstatus = False   def status_nobfiles(self, *args, **kwargs):   return super(bfiles_repo, self).status(*args, **kwargs)   + # When bfstatus is set, return a context that gives the names of bfiles + # instead of their corresponding standins and identifies the bfiles as + # always binary, regardless of their actual contents. + def __getitem__(self, changeid): + ctx = super(bfiles_repo, self).__getitem__(changeid) + if self.bfstatus: + class bfiles_manifestdict(manifest.manifestdict): + def __contains__(self, filename): + if super(bfiles_manifestdict, self).__contains__(filename): + return True + return super(bfiles_manifestdict, self).__contains__('.kbf/' + filename) + class bfiles_ctx(ctx.__class__): + def files(self): + filenames = super(bfiles_ctx, self).files() + return [re.sub(r'^\.kbf/', '', filename) for filename in filenames] + def manifest(self): + man1 = super(bfiles_ctx, self).manifest() + man1.__class__ = bfiles_manifestdict + return man1 + def filectx(self, path, fileid=None, filelog=None): + try: + result = super(bfiles_ctx, self).filectx(path, fileid, filelog) + except error.LookupError: + # Adding a null character will cause Mercurial to identify this + # as a binary file. + result = super(bfiles_ctx, self).filectx('.kbf/' + path, fileid, filelog) + olddata = result.data + result.data = lambda: olddata() + '\0' + return result + ctx.__class__ = bfiles_ctx + return ctx +   # Figure out the status of big files and insert them into the   # appropriate list in the result. Also removes standin files from   # the listing. This function reverts to the original status if   # self.bfstatus is False   def status(self, node1='.', node2=None, match=None, ignored=False, clean=False, unknown=False, subrepos=None):   listignored, listclean, listunknown = ignored, clean, unknown   if not self.bfstatus:   try:   return super(bfiles_repo, self).status(node1, node2, match, listignored, listclean, listunknown, subrepos)   except TypeError:   return super(bfiles_repo, self).status(node1, node2, match, listignored, listclean, listunknown)   else:   # some calls in this function rely on the old version of status   self.bfstatus = False   if isinstance(node1, context.changectx):   ctx1 = node1   else:   ctx1 = repo[node1]   if isinstance(node2, context.changectx):   ctx2 = node2   else:   ctx2 = repo[node2]   working = ctx2.rev() is None   parentworking = working and ctx1 == self['.']     def inctx(file, ctx):   try:   if ctx.rev() is None:   return file in ctx.manifest()   ctx[file]   return True   except:   return False     # create a copy of match that matches standins instead of bfiles   # if matcher not set then it is the always matcher so overwrite that   if match is None:   match = match_.always(self.root, self.getcwd())     def tostandin(file):   if inctx(bfutil.standin(file), ctx2):   return bfutil.standin(file)   return file     m = copy.copy(match)   m._files = [tostandin(f) for f in m._files]     # get ignored clean and unknown but remove them later if they were not asked for   try:   result = super(bfiles_repo, self).status(node1, node2, m, True, True, True, subrepos)   except TypeError:   result = super(bfiles_repo, self).status(node1, node2, m, True, True, True)   if working:   # Hold the wlock while we read bfiles and update the bfdirstate   wlock = repo.wlock()   try:   # Any non bfiles that were explicitly listed must be taken out or   # bfdirstate.status will report an error. The status of these files   # was already computed using super's status.   bfdirstate = bfutil.open_bfdirstate(ui, self)   match._files = [f for f in match._files if f in bfdirstate]   s = bfdirstate.status(match, [], listignored, listclean, listunknown)   (unsure, modified, added, removed, missing, unknown, ignored, clean) = s   if parentworking:   for bfile in unsure:   if ctx1[bfutil.standin(bfile)].data().strip() != bfutil.hashfile(self.wjoin(bfile)):   modified.append(bfile)   else:   clean.append(bfile)   bfdirstate.normal(bfutil.unixpath(bfile))   bfdirstate.write()   else:   tocheck = unsure + modified + added + clean   modified, added, clean = [], [], []     for bfile in tocheck:   standin = bfutil.standin(bfile)   if inctx(standin, ctx1):   if ctx1[standin].data().strip() != bfutil.hashfile(self.wjoin(bfile)):   modified.append(bfile)   else:   clean.append(bfile)   else:   added.append(bfile)   finally:   wlock.release()     for standin in ctx1.manifest():   if not bfutil.is_standin(standin):   continue   bfile = bfutil.split_standin(standin)   if not match(bfile):   continue   if bfile not in bfdirstate:   removed.append(bfile)   # Handle unknown and ignored differently   bfiles = (modified, added, removed, missing, [], [], clean)   result = list(result)   # Unknown files   result[4] = [f for f in unknown if repo.dirstate[f] == '?' and not bfutil.is_standin(f)]   # Ignored files must be ignored by both the dirstate and bfdirstate   result[5] = set(ignored).intersection(set(result[5]))   # combine normal files and bfiles   normals = [[fn for fn in filelist if not bfutil.is_standin(fn)] for filelist in result]   result = [sorted(list1 + list2) for (list1, list2) in zip(normals, bfiles)]   else:   def toname(f):   if bfutil.is_standin(f):   return bfutil.split_standin(f)   return f   result = [[toname(f) for f in items] for items in result]     if not listunknown:   result[4] = []   if not listignored:   result[5] = []   if not listclean:   result[6] = []   self.bfstatus = True   return result     # This call happens after a commit has occurred. Copy all of the bfiles   # into the cache   def commitctx(self, *args, **kwargs):   node = super(bfiles_repo, self).commitctx(*args, **kwargs)   ctx = self[node]   for filename in ctx.files():   if bfutil.is_standin(filename) and filename in ctx.manifest():   realfile = bfutil.split_standin(filename)   bfutil.copy_to_cache(self, ctx.node(), realfile)     return node     # This call happens before a commit has occurred. The bfile standins   # have not had their contents updated (to reflect the hash of their bfile).   # Do that here.   def commit(self, text="", user=None, date=None, match=None, force=False,   editor=False, extra={}):   orig = super(bfiles_repo, self).commit     wlock = repo.wlock()   try: + if getattr(repo, "_isrebasing", False): + # We have to take the time to pull down the new bfiles now. Otherwise + # if we are rebasing, any bfiles that were modified in the changesets we + # are rebasing on top of get overwritten either by the rebase or in the + # first commit after the rebase. + bfcommands.update_bfiles(repo.ui, repo)   # Case 1: user calls commit with no specific files or   # include/exclude patterns: refresh and commit everything.   if (match is None) or (not match.anypats() and not match.files()):   bfiles = bfutil.list_bfiles(self)   bfdirstate = bfutil.open_bfdirstate(ui, self)   # this only loops through bfiles that exist (not removed/renamed)   for bfile in bfiles:   if os.path.exists(self.wjoin(bfutil.standin(bfile))): - bfutil.update_standin(self, bfutil.standin(bfile)) - bfdirstate.normal(bfutil.unixpath(bfile)) + # this handles the case where a rebase is being performed and the + # working copy is not updated yet. + if os.path.exists(self.wjoin(bfile)): + bfutil.update_standin(self, bfutil.standin(bfile)) + bfdirstate.normal(bfutil.unixpath(bfile))   for bfile in bfdirstate:   if not os.path.exists(repo.wjoin(bfutil.standin(bfile))): - bfdirstate.forget(bfutil.unixpath(bfile)) + path = bfutil.unixpath(bfile) + try: + # Mercurial >= 1.9 + bfdirstate.drop(path) + except AttributeError: + # Mercurial <= 1.8 + bfdirstate.forget(path)   bfdirstate.write()     return orig(text=text, user=user, date=date, match=match,   force=force, editor=editor, extra=extra)     for file in match.files():   if bfutil.is_standin(file):   raise util.Abort("Don't commit bfile standin. Commit bfile.")     # Case 2: user calls commit with specified patterns: refresh any   # matching big files.   smatcher = bfutil.compose_standin_matcher(self, match)   standins = bfutil.dirstate_walk(self.dirstate, smatcher)     # No matching big files: get out of the way and pass control to   # the usual commit() method.   if not standins:   return orig(text=text, user=user, date=date, match=match,   force=force, editor=editor, extra=extra)     # Refresh all matching big files. It's possible that the commit   # will end up failing, in which case the big files will stay   # refreshed. No harm done: the user modified them and asked to   # commit them, so sooner or later we're going to refresh the   # standins. Might as well leave them refreshed.   bfdirstate = bfutil.open_bfdirstate(ui, self)   for standin in standins:   bfile = bfutil.split_standin(standin)   if bfdirstate[bfile] is not 'r':   bfutil.update_standin(self, standin)   bfdirstate.normal(bfutil.unixpath(bfile))   else: - bfdirstate.forget(bfutil.unixpath(bfile)) + path = bfutil.unixpath(bfile) + try: + # Mercurial >= 1.9 + bfdirstate.drop(path) + except AttributeError: + # Mercurial <= 1.8 + bfdirstate.forget(path)   bfdirstate.write()     # Cook up a new matcher that only matches regular files or   # standins corresponding to the big files requested by the user.   # Have to modify _files to prevent commit() from complaining   # "not tracked" for big files.   bfiles = bfutil.list_bfiles(repo)   match = copy.copy(match)   orig_matchfn = match.matchfn     # Check both the list of bfiles and the list of standins because if a bfile was removed, it   # won't be in the list of bfiles at this point   match._files += sorted(standins)     actualfiles = []   for f in match._files:   fstandin = bfutil.standin(f)     # Ignore known bfiles and standins   if f in bfiles or fstandin in standins:   continue     # Append directory separator to avoid collisions   if not fstandin.endswith(os.sep):   fstandin += os.sep     # Prevalidate matching standin directories   if any(st for st in match._files if st.startswith(fstandin)):   continue   actualfiles.append(f)   match._files = actualfiles     def matchfn(f):   if orig_matchfn(f):   return f not in bfiles   else:   return f in standins     match.matchfn = matchfn   return orig(text=text, user=user, date=date, match=match,   force=force, editor=editor, extra=extra)   finally:   wlock.release()     def push(self, remote, force=False, revs=None, newbranch=False):   o = bfutil.findoutgoing(repo, remote, force)   if o:   toupload = set()   o = repo.changelog.nodesbetween(o, revs)[0]   for n in o:   parents = [p for p in repo.changelog.parents(n) if p != node.nullid]   ctx = repo[n]   files = set(ctx.files())   if len(parents) == 2:   mc = ctx.manifest()   mp1 = ctx.parents()[0].manifest()   mp2 = ctx.parents()[1].manifest()   for f in mp1:   if f not in mc:   files.add(f)   for f in mp2:   if f not in mc:   files.add(f)   for f in mc:   if mc[f] != mp1.get(f, None) or mc[f] != mp2.get(f, None):   files.add(f)     toupload = toupload.union(set([ctx[f].data().strip() for f in files if bfutil.is_standin(f) and f in ctx]))   bfcommands.upload_bfiles(ui, self, remote, toupload)   # Mercurial >= 1.6 takes the newbranch argument, try that first.   try:   return super(bfiles_repo, self).push(remote, force, revs, newbranch)   except TypeError:   return super(bfiles_repo, self).push(remote, force, revs)     repo.__class__ = bfiles_repo    # Add works by going through the files that the user wanted to add  # and checking if they should be added as bfiles. Then making a new  # matcher which matches only the normal files and running the original  # version of add.  def override_add(orig, ui, repo, *pats, **opts):   bf = opts.pop('bf', None)     bfsize = opts.pop('bfsize', None)   if bfsize:   try:   bfsize = int(bfsize)   except ValueError:   raise util.Abort(_('size must be an integer, was %s\n') % bfsize)   else:   if os.path.exists(repo.wjoin(bfutil.short_name)):   bfsize = ui.config(bfutil.long_name, 'size', default='10')   if bfsize:   try:   bfsize = int(bfsize)   except ValueError:   raise util.Abort(_('bfiles.size must be integer, was %s\n') % bfsize)     bfmatcher = None   if os.path.exists(repo.wjoin(bfutil.short_name)):   bfpats = ui.config(bfutil.long_name, 'patterns', default=())   if bfpats:   bfpats = bfpats.split(' ')   bfmatcher = match_.match(repo.root, '', list(bfpats))     bfnames = [] - m = cmdutil.match(repo, pats, opts) + try: + # Mercurial >= 1.9 + m = scmutil.match(repo[None], pats, opts) + except ImportError: + # Mercurial <= 1.8 + m = cmdutil.match(repo, pats, opts)   m.bad = lambda x,y: None   wctx = repo[None]   for f in repo.walk(m):   exact = m.exact(f)   bfile = bfutil.standin(f) in wctx   nfile = f in wctx     if exact and bfile:   ui.warn(_('%s already a bfile\n') % f)   continue   # Don't warn the user when they attempt to add a normal tracked file. The normal add code   # will do that for us.   if exact and nfile:   continue   if exact or (not bfile and not nfile):   if bf or (bfsize and os.path.getsize(repo.wjoin(f)) >= bfsize*1024*1024) \   or (bfmatcher and bfmatcher(f)):   bfnames.append(f)   if ui.verbose or not exact:   ui.status(_('adding %s as bfile\n') % m.rel(f))     bad = []   standins = []     # Need to lock otherwise there could be a race condition inbetween when standins are created   # and added to the repo   wlock = repo.wlock()   try:   if not opts.get('dry_run'):   bfdirstate = bfutil.open_bfdirstate(ui, repo)   for f in bfnames:   standinname = bfutil.standin(f)   bfutil.write_standin(repo, standinname, hash='', executable=bfutil.get_executable(repo.wjoin(f)))   standins.append(standinname)   if bfdirstate[bfutil.unixpath(f)] == 'r':   bfdirstate.normallookup(bfutil.unixpath(f))   else:   bfdirstate.add(bfutil.unixpath(f))   bfdirstate.write()   bad += [bfutil.split_standin(f) for f in bfutil.repo_add(repo, standins) if f in m.files()]   finally:   wlock.release()   - oldmatch = cmdutil.match + try: + # Mercurial >= 1.9 + oldmatch = scmutil.match + except ImportError: + # Mercurial <= 1.8 + oldmatch = cmdutil.match   manifest = repo[None].manifest()   def override_match(repo, pats=[], opts={}, globbed=False, default='relpath'):   match = oldmatch(repo, pats, opts, globbed, default)   m = copy.copy(match)   notbfile = lambda f: not bfutil.is_standin(f) and bfutil.standin(f) not in manifest   m._files = [f for f in m._files if notbfile(f)]   m._fmap = set(m._files)   orig_matchfn = m.matchfn   m.matchfn = lambda f: notbfile(f) and orig_matchfn(f) or None   return m - cmdutil.match = override_match - result = orig(ui, repo, *pats, **opts) - cmdutil.match = oldmatch + try: + # Mercurial >= 1.9 + scmutil.match = override_match + result = orig(ui, repo, *pats, **opts) + scmutil.match = oldmatch + except ImportError: + # Mercurial <= 1.8 + cmdutil.match = override_match + result = orig(ui, repo, *pats, **opts) + cmdutil.match = oldmatch     return (result is 1 or bad) and 1 or 0    def override_remove(orig, ui, repo, *pats, **opts):   wctx = repo[None].manifest() - oldmatch = cmdutil.match + try: + # Mercurial >= 1.9 + oldmatch = scmutil.match + except ImportError: + # Mercurial <= 1.8 + oldmatch = cmdutil.match   def override_match(repo, pats=[], opts={}, globbed=False, default='relpath'):   match = oldmatch(repo, pats, opts, globbed, default)   m = copy.copy(match)   notbfile = lambda f: not bfutil.is_standin(f) and bfutil.standin(f) not in wctx   m._files = [f for f in m._files if notbfile(f)]   m._fmap = set(m._files)   orig_matchfn = m.matchfn   m.matchfn = lambda f: orig_matchfn(f) and notbfile(f)   return m - cmdutil.match = override_match - orig(ui, repo, *pats, **opts) - cmdutil.match = oldmatch + try: + # Mercurial >= 1.9 + scmutil.match = override_match + orig(ui, repo, *pats, **opts) + scmutil.match = oldmatch + except ImportError: + # Mercurial <= 1.8 + cmdutil.match = override_match + orig(ui, repo, *pats, **opts) + cmdutil.match = oldmatch     after, force = opts.get('after'), opts.get('force')   if not pats and not after:   raise util.Abort(_('no files specified')) - m = cmdutil.match(repo, pats, opts) + try: + # Mercurial >= 1.9 + m = scmutil.match(repo[None], pats, opts) + except ImportError: + # Mercurial <= 1.8 + m = cmdutil.match(repo, pats, opts)   try:   repo.bfstatus = True   s = repo.status(match=m, clean=True)   finally:   repo.bfstatus = False   modified, added, deleted, clean = [[f for f in list if bfutil.standin(f) in wctx] for list in [s[0], s[1], s[3], s[6]]]     def warn(files, reason):   for f in files:   ui.warn(_('not removing %s: file %s (use -f to force removal)\n')   % (m.rel(f), reason))     if force:   remove, forget = modified + deleted + clean, added   elif after:   remove, forget = deleted, []   warn(modified + added + clean, _('still exists'))   else:   remove, forget = deleted + clean, []   warn(modified, _('is modified'))   warn(added, _('has been marked for add'))     for f in sorted(remove + forget):   if ui.verbose or not m.exact(f):   ui.status(_('removing %s\n') % m.rel(f))     # Need to lock because standin files are deleted then removed from the repository   # and we could race inbetween.   wlock = repo.wlock()   try:   bfdirstate = bfutil.open_bfdirstate(ui, repo)   for f in remove:   if not after:   os.unlink(repo.wjoin(f))   currentdir = os.path.split(f)[0]   while currentdir and not os.listdir(repo.wjoin(currentdir)):   os.rmdir(repo.wjoin(currentdir))   currentdir = os.path.split(currentdir)[0]   bfdirstate.remove(bfutil.unixpath(f))   bfdirstate.write()     forget = [bfutil.standin(f) for f in forget]   remove = [bfutil.standin(f) for f in remove]   bfutil.repo_forget(repo, forget)   bfutil.repo_remove(repo, remove, unlink=True)   finally:   wlock.release()    def override_status(orig, ui, repo, *pats, **opts):   try:   repo.bfstatus = True   return orig(ui, repo, *pats, **opts)   finally:   repo.bfstatus = False   +def override_log(orig, ui, repo, *pats, **opts): + try: + repo.bfstatus = True + orig(ui, repo, *pats, **opts) + finally: + repo.bfstatus = False +  def override_verify(orig, ui, repo, *pats, **opts):   bf = opts.pop('bf', False)   all = opts.pop('bfa', False)   contents = opts.pop('bfc', False)     result = orig(ui, repo, *pats, **opts)   if bf:   result = result or bfcommands.verify_bfiles(ui, repo, all, contents)   return result    # Override needs to refresh standins so that update's normal merge  # will go through properly. Then the other update hook (overriding repo.update)  # will get the new files. Filemerge is also overriden so that the merge  # will merge standins correctly.  def override_update(orig, ui, repo, *pats, **opts):   bfdirstate = bfutil.open_bfdirstate(ui, repo)   s = bfdirstate.status(match_.always(repo.root, repo.getcwd()), [], False, False, False)   (unsure, modified, added, removed, missing, unknown, ignored, clean) = s     # Need to lock between the standins getting updated and their bfiles getting updated   wlock = repo.wlock()   try:   if opts['check']:   mod = len(modified) > 0   for bfile in unsure:   standin = bfutil.standin(bfile)   if repo['.'][standin].data().strip() != bfutil.hashfile(repo.wjoin(bfile)):   mod = True   else:   bfdirstate.normal(bfutil.unixpath(bfile))   bfdirstate.write()   if mod:   raise util.Abort(_('uncommitted local changes'))   # XXX handle removed differently   if not opts['clean']:   for bfile in unsure + modified + added:   bfutil.update_standin(repo, bfutil.standin(bfile))   finally:   wlock.release()   return orig(ui, repo, *pats, **opts)    # Override filemerge to prompt the user about how they wish to merge bfiles.  # This will handle identical edits, and copy/rename + edit without prompting the user.  def override_filemerge(origfn, repo, mynode, orig, fcd, fco, fca):   # Use better variable names here. Because this is a wrapper we cannot change   # the variable names in the function declaration.   fcdest, fcother, fcancestor = fcd, fco, fca   if not bfutil.is_standin(orig):   return origfn(repo, mynode, orig, fcdest, fcother, fcancestor)   else:   if not fcother.cmp(fcdest): # files identical?   return None     if fcancestor == fcother: # backwards, use working dir parent as ancestor   fcancestor = fcdest.parents()[0]     if orig != fcother.path():   repo.ui.status(_('merging %s and %s to %s\n')   % (bfutil.split_standin(orig), bfutil.split_standin(fcother.path()), bfutil.split_standin(fcdest.path())))   else:   repo.ui.status(_('merging %s\n') % bfutil.split_standin(fcdest.path()))     if fcancestor.path() != fcother.path() and fcother.data() == fcancestor.data():   return 0   if fcancestor.path() != fcdest.path() and fcdest.data() == fcancestor.data():   repo.wwrite(fcdest.path(), fcother.data(), fcother.flags())   return 0     if repo.ui.promptchoice(_('bfile %s has a merge conflict\n'   'keep (l)ocal or take (o)ther?') % bfutil.split_standin(orig),   (_('&Local'), _('&Other')), 0) == 0:   return 0   else:   repo.wwrite(fcdest.path(), fcother.data(), fcother.flags())   return 0    # Copy first changes the matchers to match standins instead of bfiles.  # Then it overrides util.copyfile in that function it checks if the destination  # bfile already exists. It also keeps a list of copied files so that the bfiles  # can be copied and the dirstate updated.  def override_copy(orig, ui, repo, pats, opts, rename=False):   # doesn't remove bfile on rename   if len(pats) < 2:   # this isn't legal, let the original function deal with it   return orig(ui, repo, pats, opts, rename)     def makestandin(relpath): - return os.path.join(os.path.relpath('.', repo.getcwd()), bfutil.standin(util.canonpath(repo.root, repo.getcwd(), relpath))) + try: + # Mercurial >= 1.9 + path = scmutil.canonpath(repo.root, repo.getcwd(), relpath) + except ImportError: + # Mercurial <= 1.8 + path = util.canonpath(repo.root, repo.getcwd(), relpath) + return os.path.join(os.path.relpath('.', repo.getcwd()), bfutil.standin(path))   - fullpats = cmdutil.expandpats(pats) + try: + # Mercurial >= 1.9 + fullpats = scmutil.expandpats(pats) + except ImportError: + # Mercurial <= 1.8 + fullpats = cmdutil.expandpats(pats)   dest = fullpats[-1]     if os.path.isdir(dest):   if not os.path.isdir(makestandin(dest)):   os.makedirs(makestandin(dest))   # This could copy both bfiles and normal files in one command, but we don't want   # to do that first replace their matcher to only match normal files and run it   # then replace it to just match bfiles and run it again   nonormalfiles = False   nobfiles = False - oldmatch = cmdutil.match + try: + # Mercurial >= 1.9 + oldmatch = scmutil.match + except ImportError: + # Mercurial <= 1.8 + oldmatch = cmdutil.match   try:   manifest = repo[None].manifest()   def override_match(repo, pats=[], opts={}, globbed=False, default='relpath'):   match = oldmatch(repo, pats, opts, globbed, default)   m = copy.copy(match)   notbfile = lambda f: not bfutil.is_standin(f) and bfutil.standin(f) not in manifest   m._files = [f for f in m._files if notbfile(f)]   m._fmap = set(m._files)   orig_matchfn = m.matchfn   m.matchfn = lambda f: notbfile(f) and orig_matchfn(f) or None   return m - cmdutil.match = override_match + try: + # Mercurial >= 1.9 + scmutil.match = override_match + except ImportError: + # Mercurial <= 1.8 + cmdutil.match = override_match   result = orig(ui, repo, pats, opts, rename)   except util.Abort as e:   if str(e) != 'no files to copy':   raise e   else:   nonormalfiles = True   result = 0   finally: - cmdutil.match = oldmatch + try: + # Mercurial >= 1.9 + scmutil.match = oldmatch + except ImportError: + # Mercurial <= 1.8 + cmdutil.match = oldmatch     # The first rename can cause our current working directory to be removed. In that case   # there is nothing left to copy/rename so just quit.   try:   repo.getcwd()   except OSError:   return result     try:   # When we call orig below it creates the standins but we don't add them to the dir state   # until later so lock during that time.   wlock = repo.wlock()     manifest = repo[None].manifest()   def override_match(repo, pats=[], opts={}, globbed=False, default='relpath'):   newpats = []   # The patterns were previously mangled to add .hgbfiles, we need to remove that now   for pat in pats:   if match_.patkind(pat) == None and bfutil.short_name in pat:   newpats.append(pat.replace( bfutil.short_name, ''))   else:   newpats.append(pat)   match = oldmatch(repo, newpats, opts, globbed, default)   m = copy.copy(match)   bfile = lambda f: bfutil.standin(f) in manifest   m._files = [bfutil.standin(f) for f in m._files if bfile(f)]   m._fmap = set(m._files)   orig_matchfn = m.matchfn   m.matchfn = lambda f: bfutil.is_standin(f) and bfile(bfutil.split_standin(f)) and orig_matchfn(bfutil.split_standin(f)) or None   return m - cmdutil.match = override_match + try: + # Mercurial >= 1.9 + scmutil.match = override_match + except ImportError: + # Mercurial <= 1.9 + cmdutil.match = override_match   listpats = []   for pat in pats:   if match_.patkind(pat) != None:   listpats.append(pat)   else:   listpats.append(makestandin(pat))     try:   origcopyfile = util.copyfile   copiedfiles = []   def override_copyfile(src, dest):   if bfutil.short_name in src and bfutil.short_name in dest:   destbfile = dest.replace(bfutil.short_name, '')   if not opts['force'] and os.path.exists(destbfile):   raise IOError('', _('destination bfile already exists'))   copiedfiles.append((src, dest))   origcopyfile(src, dest)     util.copyfile = override_copyfile   result += orig(ui, repo, listpats, opts, rename)   finally:   util.copyfile = origcopyfile     bfdirstate = bfutil.open_bfdirstate(ui, repo)   for (src, dest) in copiedfiles:   if bfutil.short_name in src and bfutil.short_name in dest:   srcbfile = src.replace(bfutil.short_name, '')   destbfile = dest.replace(bfutil.short_name, '')   destbfiledir = os.path.dirname(destbfile) or '.'   if not os.path.isdir(destbfiledir):   os.makedirs(destbfiledir)   if rename:   os.rename(srcbfile, destbfile)   bfdirstate.remove(bfutil.unixpath(os.path.relpath(srcbfile, repo.root)))   else:   util.copyfile(srcbfile, destbfile)   bfdirstate.add(bfutil.unixpath(os.path.relpath(destbfile, repo.root)))   bfdirstate.write()   except util.Abort as e:   if str(e) != 'no files to copy':   raise e   else:   nobfiles = True   finally: - cmdutil.match = oldmatch + try: + # Mercurial >= 1.9 + scmutil.match = oldmatch + except ImportError: + # Mercurial <= 1.8 + cmdutil.match = oldmatch   wlock.release()     if nobfiles and nonormalfiles:   raise util.Abort(_('no files to copy'))     return result   +# When the user calls revert, we have to be careful to not revert any changes to other +# bfiles accidentally. This means we have to keep track of the bfiles that are +# being reverted so we only pull down the necessary bfiles. +#  # Standins are only updated (to match the hash of bfiles) before commits.  # Update the standins then run the original revert (changing the matcher to hit standins  # instead of bfiles). Based on the resulting standins update the bfiles. Then return the  # standins to their proper state  def override_revert(orig, ui, repo, *pats, **opts):   # Because we put the standins in a bad state (by updating them) and then return them   # to a correct state we need to lock to prevent others from changing them in their   # incorrect state.   wlock = repo.wlock()   try:   bfdirstate = bfutil.open_bfdirstate(ui, repo)   (modified, added, removed, missing, unknown, ignored, clean) = bfutil.bfdirstate_status(bfdirstate, repo, repo['.'].rev())   for bfile in modified:   bfutil.update_standin(repo, bfutil.standin(bfile))   - oldmatch = cmdutil.match + try: + # Mercurial >= 1.9 + oldmatch = scmutil.match + except ImportError: + # Mercurial <= 1.8 + oldmatch = cmdutil.match   try:   ctx = repo[opts.get('rev')] - def override_match(repo, pats=[], opts={}, globbed=False, default='relpath'): - match = oldmatch(repo, pats, opts, globbed, default) + def override_match(ctxorrepo, pats=[], opts={}, globbed=False, default='relpath'): + if hasattr(ctxorrepo, 'match'): + ctx0 = ctxorrepo + else: + ctx0 = ctxorrepo[None] + match = oldmatch(ctxorrepo, pats, opts, globbed, default)   m = copy.copy(match)   def tostandin(f): - if bfutil.standin(f) in repo[None] or bfutil.standin(f) in ctx: + if bfutil.standin(f) in ctx0 or bfutil.standin(f) in ctx:   return bfutil.standin(f)   return f   m._files = [tostandin(f) for f in m._files]   m._fmap = set(m._files)   orig_matchfn = m.matchfn   def matchfn(f):   if bfutil.is_standin(f): - return orig_matchfn(bfutil.split_standin(f)) and (f in repo[None] or f in ctx) + # We need to keep track of what bfiles are being matched so we know which + # ones to update later (otherwise we revert changes to other bfiles + # accidentally). This is repo specific, so duckpunch the repo object to + # keep the list of bfiles for us later. + if(orig_matchfn(bfutil.split_standin(f)) and (f in repo[None] or f in ctx)): + bfiles_list = getattr(repo, '_bfiles_to_update', []) + bfiles_list.append(bfutil.split_standin(f)) + repo._bfiles_to_update = bfiles_list; + return True + else: + return False   return orig_matchfn(f)   m.matchfn = matchfn   return m - cmdutil.match = override_match + try: + # Mercurial >= 1.9 + scmutil.match = override_match + except ImportError: + # Mercurial <= 1.8 + cmdutil.match = override_match   orig(ui, repo, *pats, **opts)   finally: - cmdutil.match = oldmatch - bfcommands.revert_bfiles(ui, repo) + try: + # Mercurial >= 1.9 + scmutil.match = oldmatch + except ImportError: + # Mercurial <= 1.8 + cmdutil.match = oldmatch + bfiles_list = getattr(repo, '_bfiles_to_update', []) + bfcommands.revert_bfiles(ui, repo, bfiles_list) + # Empty out the bfiles list so we start fresh next time + repo._bfiles_to_update = []   for bfile in modified: - if os.path.exists(repo.wjoin(bfutil.standin(bfile))) and bfile in repo['.']: - bfutil.write_standin(repo, bfutil.standin(bfile), repo['.'][bfile].data().strip(), 'x' in repo['.'][bfile].flags()) + if bfile in bfiles_list: + if os.path.exists(repo.wjoin(bfutil.standin(bfile))) and bfile in repo['.']: + bfutil.write_standin(repo, bfutil.standin(bfile), repo['.'][bfile].data().strip(), 'x' in repo['.'][bfile].flags())   finally:   wlock.release()    def hg_update(orig, repo, node):   result = orig(repo, node)   # XXX check if it worked first   bfcommands.update_bfiles(repo.ui, repo)   return result    def hg_clean(orig, repo, node, show_stats=True):   result = orig(repo, node, show_stats)   bfcommands.update_bfiles(repo.ui, repo)   return result    def hg_merge(orig, repo, node, force=None, remind=True):   result = orig(repo, node, force, remind)   bfcommands.update_bfiles(repo.ui, repo)   return result    # When we rebase a repository with remotely changed bfiles, we need -# to explicitly do a clean update so that the entries in .kbf are -# udpated and the new bfiles are pulled +# to take some extra care so that the bfiles are correctly updated +# in the working copy  def override_pull(orig, ui, repo, source="default", **opts): - result = orig(ui, repo, source, **opts)   if opts.get('rebase', False): - commands.update(repo.ui, repo, clean = True) + repo._isrebasing = True + try: + if opts.get('update'): + del opts['update'] + ui.debug('--update and --rebase are not compatible, ignoring ' + 'the update flag\n') + del opts['rebase'] + try: + # Mercurial >= 1.9 + cmdutil.bailifchanged(repo) + except AttributeError: + # Mercurial <= 1.8 + cmdutil.bail_if_changed(repo) + revsprepull = len(repo) + origpostincoming = commands.postincoming + def _dummy(*args, **kwargs): + pass + commands.postincoming = _dummy + try: + result = commands.pull(ui, repo, source, **opts) + finally: + commands.postincoming = origpostincoming + revspostpull = len(repo) + if revspostpull > revsprepull: + result = result or rebase.rebase(ui, repo) + branch = repo[None].branch() + dest = repo[branch].rev() + finally: + repo._isrebasing = False + else: + result = orig(ui, repo, source, **opts)   return result   +def override_rebase(orig, ui, repo, **opts): + repo._isrebasing = True + try: + orig(ui, repo, **opts) + finally: + repo._isrebasing = False +  def override_archive(orig, repo, dest, node, kind, decode=True, matchfn=None,   prefix=None, mtime=None, subrepos=None):   # No need to lock because we are only reading history and bfile caches   # neither of which are modified     if kind not in archival.archivers:   raise util.Abort(_("unknown archive type '%s'") % kind)     ctx = repo[node]     # In Mercurial <= 1.5 the prefix is passed to the archiver so try that   # if that doesn't work we are probably in Mercurial >= 1.6 where the   # prefix is not handled by the archiver   try:   archiver = archival.archivers[kind](dest, prefix, mtime or ctx.date()[0])     def write(name, mode, islink, getdata):   if matchfn and not matchfn(name):   return   data = getdata()   if decode:   data = repo.wwritedata(name, data)   archiver.addfile(name, mode, islink, data)   except TypeError:   if kind == 'files':   if prefix:   raise util.Abort(_('cannot give prefix when archiving to files'))   else:   prefix = archival.tidyprefix(dest, kind, prefix)     def write(name, mode, islink, getdata):   if matchfn and not matchfn(name):   return   data = getdata()   if decode:   data = repo.wwritedata(name, data)   archiver.addfile(prefix + name, mode, islink, data)     archiver = archival.archivers[kind](dest, mtime or ctx.date()[0])     if repo.ui.configbool("ui", "archivemeta", True):   def metadata():   base = 'repo: %s\nnode: %s\nbranch: %s\n' % (   hex(repo.changelog.node(0)), hex(node), ctx.branch())     tags = ''.join('tag: %s\n' % t for t in ctx.tags()   if repo.tagtype(t) == 'global')   if not tags:   repo.ui.pushbuffer()   opts = {'template': '{latesttag}\n{latesttagdistance}',   'style': '', 'patch': None, 'git': None}   cmdutil.show_changeset(repo.ui, repo, opts).show(ctx)   ltags, dist = repo.ui.popbuffer().split('\n')   tags = ''.join('latesttag: %s\n' % t for t in ltags.split(':'))   tags += 'latesttagdistance: %s\n' % dist     return base + tags     write('.hg_archival.txt', 0644, False, metadata)     for f in ctx:   ff = ctx.flags(f)   getdata = ctx[f].data   if bfutil.is_standin(f):   path = bfutil.find_file(repo, getdata().strip())   ### TODO: What if the file is not cached?   f = bfutil.split_standin(f)     def getdatafn():   with open(path, 'rb') as fd:   return fd.read()     getdata = getdatafn   write(f, 'x' in ff and 0755 or 0644, 'l' in ff, getdata)     if subrepos:   for subpath in ctx.substate:   sub = ctx.sub(subpath)   try:   sub.archive(repo.ui, archiver, prefix)   except TypeError:   sub.archive(archiver, prefix)     archiver.done()    # If a bfile is modified the change is not reflected in its standin until a commit. -# cmdutil.bail_if_changed raises an exception if the repo has uncommitted changes. +# cmdutil.bailifchanged raises an exception if the repo has uncommitted changes.  # Wrap it to also check if bfiles were changed. This is used by bisect and backout. -def override_bail_if_changed(orig, repo): +def override_bailifchanged(orig, repo):   orig(repo)   repo.bfstatus = True   modified, added, removed, deleted = repo.status()[:4]   repo.bfstatus = False   if modified or added or removed or deleted:   raise util.Abort(_('outstanding uncommitted changes'))    # Fetch doesn't use cmdutil.bail_if_changed so override it to add the check  def override_fetch(orig, ui, repo, *pats, **opts):   repo.bfstatus = True   modified, added, removed, deleted = repo.status()[:4]   repo.bfstatus = False   if modified or added or removed or deleted:   raise util.Abort(_('outstanding uncommitted changes'))   return orig(ui, repo, *pats, **opts)    def override_forget(orig, ui, repo, *pats, **opts):   wctx = repo[None].manifest() - oldmatch = cmdutil.match + try: + # Mercurial >= 1.9 + oldmatch = scmutil.match + except ImportError: + # Mercurial <= 1.8 + oldmatch = cmdutil.match   def override_match(repo, pats=[], opts={}, globbed=False, default='relpath'):   match = oldmatch(repo, pats, opts, globbed, default)   m = copy.copy(match)   notbfile = lambda f: not bfutil.is_standin(f) and bfutil.standin(f) not in wctx   m._files = [f for f in m._files if notbfile(f)]   m._fmap = set(m._files)   orig_matchfn = m.matchfn   m.matchfn = lambda f: orig_matchfn(f) and notbfile(f)   return m - cmdutil.match = override_match - orig(ui, repo, *pats, **opts) - cmdutil.match = oldmatch + try: + # Mercurial >= 1.9 + scmutil.match = override_match + orig(ui, repo, *pats, **opts) + scmutil.match = oldmatch + m = scmutil.match(repo[None], pats, opts) + except ImportError: + # Mercurial <= 1.8 + cmdutil.match = override_match + orig(ui, repo, *pats, **opts) + cmdutil.match = oldmatch + m = cmdutil.match(repo, pats, opts)   - m = cmdutil.match(repo, pats, opts)   try:   repo.bfstatus = True   s = repo.status(match=m, clean=True)   finally:   repo.bfstatus = False   forget = sorted(s[0] + s[1] + s[3] + s[6])   forget = [f for f in forget if bfutil.standin(f) in wctx]     for f in forget:   if bfutil.standin(f) not in repo.dirstate and not os.path.isdir(m.rel(bfutil.standin(f))):   ui.warn(_('not removing %s: file is already untracked\n')   % m.rel(f))     for f in forget:   if ui.verbose or not m.exact(f):   ui.status(_('removing %s\n') % m.rel(f))     # Need to lock because standin files are deleted then removed from the repository   # and we could race inbetween.   wlock = repo.wlock()   try:   bfdirstate = bfutil.open_bfdirstate(ui, repo)   for f in forget:   bfdirstate.remove(bfutil.unixpath(f))   bfdirstate.write()   bfutil.repo_remove(repo, [bfutil.standin(f) for f in forget], unlink=True)   finally:   wlock.release()    def get_outgoing_bfiles(ui, repo, dest=None, **opts):   dest = ui.expandpath(dest or 'default-push', dest or 'default')   dest, branches = hg.parseurl(dest, opts.get('branch'))   revs, checkout = hg.addbranchrevs(repo, repo, branches, opts.get('rev'))   if revs:   revs = [repo.lookup(rev) for rev in revs]     # Mercurial <= 1.5 had remoteui in cmdutil, then it moved to hg   try:   remoteui = cmdutil.remoteui   except AttributeError:   remoteui = hg.remoteui     try:   remote = hg.repository(remoteui(repo, opts), dest)   except error.RepoError:   return None   o = bfutil.findoutgoing(repo, remote, False)   if not o:   return None   o = repo.changelog.nodesbetween(o, revs)[0]   if opts.get('newest_first'):   o.reverse()     toupload = set()   for n in o:   parents = [p for p in repo.changelog.parents(n) if p != node.nullid]   ctx = repo[n]   files = set(ctx.files())   if len(parents) == 2:   mc = ctx.manifest()   mp1 = ctx.parents()[0].manifest()   mp2 = ctx.parents()[1].manifest()   for f in mp1:   if f not in mc:   files.add(f)   for f in mp2:   if f not in mc:   files.add(f)   for f in mc:   if mc[f] != mp1.get(f, None) or mc[f] != mp2.get(f, None):   files.add(f)   toupload = toupload.union(set([f for f in files if bfutil.is_standin(f) and f in ctx]))   return toupload    def override_outgoing(orig, ui, repo, dest=None, **opts):   orig(ui, repo, dest, **opts)     if opts.pop('bf', None):   toupload = get_outgoing_bfiles(ui, repo, dest, **opts)   if toupload is None:   ui.status(_('kbfiles: No remote repo\n'))   else:   ui.status(_('kbfiles to upload:\n'))   for file in toupload:   ui.status(bfutil.split_standin(file) + '\n')   ui.status('\n')    def override_summary(orig, ui, repo, *pats, **opts):   orig(ui, repo, *pats, **opts)     if opts.pop('bf', None):   toupload = get_outgoing_bfiles(ui, repo, None, **opts)   if toupload is None:   ui.status(_('kbfiles: No remote repo\n'))   else:   ui.status(_('kbfiles: %d to upload\n') % len(toupload))    def override_addremove(orig, ui, repo, *pats, **opts):   # Check if the parent or child has bfiles if they do don't allow it.   # If there is a symlink in the manifest then getting the manifest throws an exception   # catch it and let addremove deal with it. This happens in Mercurial's test   # test-addremove-symlink   try:   manifesttip = set(repo['tip'].manifest())   except util.Abort:   manifesttip = set()   try:   manifestworking = set(repo[None].manifest())   except util.Abort:   manifestworking = set()     # Manifests are only iterable so turn them into sets then union   for file in manifesttip.union(manifestworking):   if file.startswith(bfutil.short_name):   raise util.Abort(_('addremove cannot be run on a repo with bfiles'))     return orig(ui, repo, *pats, **opts)   +# Calling purge with --all will cause the kbfiles to be deleted. +# Override repo.status to prevent this from happening. +def override_purge(orig, ui, repo, *dirs, **opts): + oldstatus = repo.status + def override_status(node1='.', node2=None, match=None, ignored=False, + clean=False, unknown=False, listsubrepos=False): + r = oldstatus(node1, node2, match, ignored, clean, unknown, + listsubrepos) + bfdirstate = bfutil.open_bfdirstate(ui, repo) + modified, added, removed, deleted, unknown, ignored, clean = r + unknown = [f for f in unknown if bfdirstate[f] == '?'] + ignored = [f for f in ignored if bfdirstate[f] == '?'] + return modified, added, removed, deleted, unknown, ignored, clean + repo.status = override_status + orig(ui, repo, *dirs, **opts) + repo.status = oldstatus +  def uisetup(ui):   # Disable auto-status for some commands which assume that all   # files in the result are under Mercurial's control     entry = extensions.wrapcommand(commands.table, 'add', override_add)   addopt = [('', 'bf', None, _('add as bfile')),   ('', 'bfsize', '', _('add all files above this size (in megabytes) as bfiles (default: 10)'))]   entry[1].extend(addopt)     entry = extensions.wrapcommand(commands.table, 'addremove', override_addremove)   entry = extensions.wrapcommand(commands.table, 'remove', override_remove)   entry = extensions.wrapcommand(commands.table, 'forget', override_forget)   entry = extensions.wrapcommand(commands.table, 'status', override_status) + entry = extensions.wrapcommand(commands.table, 'log', override_log)     entry = extensions.wrapcommand(commands.table, 'verify', override_verify)   verifyopt = [('', 'bf', None, _('verify bfiles')),   ('', 'bfa', None, _('verify all revisions of bfiles not just current')),   ('', 'bfc', None, _('verify bfile contents not just existence'))]   entry[1].extend(verifyopt)     entry = extensions.wrapcommand(commands.table, 'outgoing', override_outgoing)   outgoingopt = [('', 'bf', None, _('display outgoing bfiles'))]   entry[1].extend(outgoingopt)   entry = extensions.wrapcommand(commands.table, 'summary', override_summary)   summaryopt = [('', 'bf', None, _('display outgoing bfiles'))]   entry[1].extend(summaryopt)     entry = extensions.wrapcommand(commands.table, 'update', override_update)   entry = extensions.wrapcommand(commands.table, 'pull', override_pull)   entry = extensions.wrapfunction(filemerge, 'filemerge', override_filemerge)   entry = extensions.wrapfunction(cmdutil, 'copy', override_copy)     # Backout calls revert so we need to override both the command and the function   entry = extensions.wrapcommand(commands.table, 'revert', override_revert)   entry = extensions.wrapfunction(commands, 'revert', override_revert)     # clone uses hg._update instead of hg.update even though they are the   # same function... so wrap both of them)   extensions.wrapfunction(hg, 'update', hg_update)   extensions.wrapfunction(hg, '_update', hg_update)   extensions.wrapfunction(hg, 'clean', hg_clean)   extensions.wrapfunction(hg, 'merge', hg_merge)     extensions.wrapfunction(archival, 'archive', override_archive) - extensions.wrapfunction(cmdutil, 'bail_if_changed', override_bail_if_changed) + if hasattr(cmdutil, 'bailifchanged'): + extensions.wrapfunction(cmdutil, 'bailifchanged', override_bailifchanged) + else: + extensions.wrapfunction(cmdutil, 'bail_if_changed', override_bailifchanged)     for name, module in extensions.extensions():   if name == 'fetch':   extensions.wrapcommand(getattr(module, 'cmdtable'), 'fetch', override_fetch) + if name == 'purge': + extensions.wrapcommand(getattr(module, 'cmdtable'), 'purge', override_purge) + if name == 'rebase': + extensions.wrapcommand(getattr(module, 'cmdtable'), 'rebase', override_rebase)    
 
10
11
12
 
 
 
 
 
13
14
15
 
40
41
42
43
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
44
45
46
 
74
75
76
77
 
 
 
 
 
 
 
78
79
80
81
82
83
 
 
 
 
84
85
86
 
123
124
125
126
 
 
 
 
 
 
127
128
129
 
225
226
227
 
 
 
 
228
229
230
 
240
241
242
243
 
 
 
 
 
 
 
244
245
246
 
286
287
288
289
290
291
 
 
 
 
292
293
294
 
318
319
320
 
 
321
322
323
 
10
11
12
13
14
15
16
17
18
19
20
 
45
46
47
 
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
 
97
98
99
 
100
101
102
103
104
105
106
107
108
109
110
111
 
112
113
114
115
116
117
118
 
155
156
157
 
158
159
160
161
162
163
164
165
166
 
262
263
264
265
266
267
268
269
270
271
 
281
282
283
 
284
285
286
287
288
289
290
291
292
293
 
333
334
335
 
 
 
336
337
338
339
340
341
342
 
366
367
368
369
370
371
372
373
@@ -10,6 +10,11 @@
  util, dirstate, cmdutil, match as match_  from mercurial.i18n import _   +try: + from mercurial import scmutil +except ImportError: + pass +  short_name = '.kbf'  long_name = 'kilnbfiles'   @@ -40,7 +45,25 @@
  remove = repo.remove   except AttributeError:   # Mercurial >= 1.6 - remove = repo[None].remove + try: + # Mercurial <= 1.8 + remove = repo[None].remove + except AttributeError: + # Mercurial >= 1.9 + def remove(list, unlink): + wlock = repo.wlock() + try: + if unlink: + for f in list: + try: + util.unlinkpath(repo.wjoin(f)) + except OSError, inst: + if inst.errno != errno.ENOENT: + raise + repo[None].forget(list) + finally: + wlock.release() +   return remove(list, unlink=unlink)    def repo_forget(repo, list): @@ -74,13 +97,22 @@
  return repo.findoutgoing(remote)   except AttributeError:   from mercurial import discovery - return discovery.findoutgoing(repo, remote, force=force) + try: + # Mercurial <= 1.8 + return discovery.findoutgoing(repo, remote, force=force) + except AttributeError: + # Mercurial >= 1.9 + common, _anyinc, _heads = discovery.findcommonincoming(repo, remote, force=force) + return repo.changelog.findmissing(common)    # -- Private worker functions ------------------------------------------    if os.name == 'nt':   from mercurial import win32 - linkfn = win32.os_link + try: + linkfn = win32.oslink + except: + linkfn = win32.os_link  else:   linkfn = os.link   @@ -123,7 +155,12 @@
  repo root, but it is saved in .hg/bfiles/dirstate.   '''   admin = repo.join(long_name) - opener = util.opener(admin) + try: + # Mercurial >= 1.9 + opener = scmutil.opener(admin) + except ImportError: + # Mercurial <= 1.8 + opener = util.opener(admin)   if hasattr(repo.dirstate, '_validate'):   bfdirstate = dirstate.dirstate(opener, ui, repo.root, repo.dirstate._validate)   else: @@ -225,6 +262,10 @@
  if pats:   # patterns supplied: search .hgbfiles relative to current dir   cwd = repo.getcwd() + if os.path.isabs(cwd): + # cwd is an absolute path for hg -R <reponame> + # work relative to the repository root in this case + cwd = ''   pats = [os.path.join(standin_dir, cwd, pat) for pat in pats]   elif os.path.isdir(standin_dir):   # no patterns: relative to repo root @@ -240,7 +281,13 @@
  '''Wrapper around cmdutil.match() that adds showbad: if false, neuter   the match object\'s bad() method so it does not print any warnings   about missing files or directories.''' - match = cmdutil.match(repo, pats, opts) + try: + # Mercurial >= 1.9 + match = scmutil.match(repo[None], pats, opts) + except ImportError: + # Mercurial <= 1.8 + match = cmdutil.match(repo, pats, opts) +   if not showbad:   match.bad = lambda f, msg: None   return match @@ -286,9 +333,10 @@
   def update_standin(repo, standin):   file = repo.wjoin(split_standin(standin)) - hash = hashfile(file) - executable = get_executable(file) - write_standin(repo, standin, hash, executable) + if os.path.exists(file): + hash = hashfile(file) + executable = get_executable(file) + write_standin(repo, standin, hash, executable)    def read_standin(repo, standin):   '''read hex hash from <repo.root>/<standin>''' @@ -318,6 +366,8 @@
  return hashfile(repo.wjoin(file))    def hashfile(file): + if not os.path.exists(file): + return ''   hasher = util.sha1('')   with open(file, 'rb') as fd:   for data in blockstream(fd):
 
1
2
 
3
4
5
6
7
8
 
 
 
 
 
9
10
11
 
14
15
16
17
 
 
 
 
 
 
18
19
20
 
29
30
31
32
 
 
 
 
 
 
33
34
35
 
 
 
 
 
 
 
 
 
 
36
37
38
 
45
46
47
48
 
 
 
 
 
 
49
50
51
 
62
63
64
65
 
 
 
 
 
 
66
67
68
 
76
77
78
79
 
 
 
 
 
 
80
81
82
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
 
20
21
22
 
23
24
25
26
27
28
29
30
31
 
40
41
42
 
43
44
45
46
47
48
49
50
 
51
52
53
54
55
56
57
58
59
60
61
62
63
 
70
71
72
 
73
74
75
76
77
78
79
80
81
 
92
93
94
 
95
96
97
98
99
100
101
102
103
 
111
112
113
 
114
115
116
117
118
119
120
121
122
@@ -1,11 +1,17 @@
 '''HTTP-based store.'''   +import inspect  import urlparse  import urllib2    from mercurial import util, url as url_  from mercurial.i18n import _   +try: + from mercurial import httpconnection +except ImportError: + pass +  import bfutil, basestore    class httpstore(basestore.basestore): @@ -14,7 +20,12 @@
  url = bfutil.urljoin(url, 'bfile')   super(httpstore, self).__init__(ui, repo, url)   self.rawurl, self.path = urlparse.urlsplit(self.url)[1:3] - (baseurl, authinfo) = url_.getauthinfo(self.url) + try: + # Mercurial >= 1.9 + baseurl, authinfo = util.url(self.url).authinfo() + except AttributeError: + # Mercurial <= 1.8 + baseurl, authinfo = url_.getauthinfo(self.url)   self.opener = url_.opener(self.ui, authinfo)     def put(self, source, hash): @@ -29,10 +40,24 @@
  return     self.ui.debug('httpstore.sendfile(%s, %s)\n' % (filename, hash)) - baseurl, authinfo = url_.getauthinfo(self.url) + try: + # Mercurial >= 1.9 + baseurl, authinfo = util.url(self.url).authinfo() + except AttributeError: + # Mercurial <= 1.8 + baseurl, authinfo = url_.getauthinfo(self.url)   fd = None   try: - fd = url_.httpsendfile(filename, 'rb') + try: + # Mercurial >= 1.9 + fd = httpconnection.httpsendfile(self.ui, filename, 'rb') + except ImportError: + if 'ui' in inspect.getargspec(url_.httpsendfile.__init__)[0]: + # Mercurial == 1.8 + fd = url_.httpsendfile(self.ui, filename, 'rb') + else: + # Mercurial <= 1.7 + fd = url_.httpsendfile(filename, 'rb')   request = urllib2.Request(bfutil.urljoin(baseurl, hash), fd)   try:   url = self.opener.open(request) @@ -45,7 +70,12 @@
  if fd: fd.close()     def _getfile(self, tmpfile, filename, hash): - (baseurl, authinfo) = url_.getauthinfo(self.url) + try: + # Mercurial >= 1.9 + baseurl, authinfo = util.url(self.url).authinfo() + except AttributeError: + # Mercurial <= 1.8 + baseurl, authinfo = url_.getauthinfo(self.url)   url = bfutil.urljoin(baseurl, hash)   try:   request = urllib2.Request(url) @@ -62,7 +92,12 @@
  return bfutil.copy_and_hash(bfutil.blockstream(infile), tmpfile)     def _verify(self, hash): - baseurl, authinfo = url_.getauthinfo(self.url) + try: + # Mercurial >= 1.9 + baseurl, authinfo = util.url(self.url).authinfo() + except AttributeError: + # Mercurial <= 1.8 + baseurl, authinfo = url_.getauthinfo(self.url)   store_path = bfutil.urljoin(baseurl, hash)   request = urllib2.Request(store_path)   request.add_header('SHA1-Request', hash) @@ -76,7 +111,12 @@
  return False     def _verifyfile(self, cctx, cset, contents, standin, verified): - baseurl, authinfo = url_.getauthinfo(self.url) + try: + # Mercurial >= 1.9 + baseurl, authinfo = util.url(self.url).authinfo() + except AttributeError: + # Mercurial <= 1.8 + baseurl, authinfo = url_.getauthinfo(self.url)   filename = bfutil.split_standin(standin)   if not filename:   return False
 
4
5
6
7
 
 
 
 
 
4
5
6
 
7
8
9
10
@@ -4,4 +4,7 @@
  python <path to Mercurial source directory>/tests/run-tests.py    For the tests that use Kiln, you need to change the Kiln settings in -kilntest.py. +custom.py. Also, you must run at least one operation that involves +interacting with the Kiln server and entering your username and password +so that they are stored in the kilnauth extension prior to running the +tests.
Show Entire File bfiles/​tests/​__init__.py Stacked
(No changes)
 
2
3
4
 
5
6
 
7
8
9
10
11
12
13
14
 
 
15
16
17
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
18
19
20
 
205
206
207
208
 
2
3
4
5
6
7
8
9
10
 
 
11
12
13
 
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
 
229
230
231
 
@@ -2,19 +2,43 @@
 import os  import stat  import subprocess +import re    import hgtest +import kilntest    # assumes we're run by hg's run-tests.py -TESTDIR = os.environ['TESTDIR'] -  STOREDIR = os.path.join(os.getcwd(), 'store')    DEFAULTRC = { - 'extensions': [('kbfiles', '%s/../kbfiles' % TESTDIR),], + 'extensions': [('kbfiles', kilntest.KBFILESPATH), + ('rebase', '')],   'kilnbfiles': [('systemcache', os.path.join(os.getcwd(), 'bfilesstore')),],   }   +def getversion(): + hgname = 'hg' + if os.name == 'nt': + for path in os.environ['PATH'].split(';'): + if os.path.exists(os.path.join(path, 'hg')): + hgname = r'python %s\hg' % path + break + cmd = [hgname, 'version'] + child = subprocess.Popen( + cmd, + stdout=subprocess.PIPE, + stderr=subprocess.PIPE, + universal_newlines=True) + stdout, stderr = child.communicate() + versions = re.findall(r'\d+\.\d+\.\d+', stdout) + parts = [re.match(r'\d+', v).group(0) for v in versions[0].split('.')] + version = [0, 0, 0] + for i, part in enumerate(map(int, parts)): + version[i] = part + return tuple(version) + +version = getversion() +  class BfilesTester(hgtest.Tester):   def updaterc(self, extraconfig=None):   '''Append configuration settings to $HGRCPATH to configure bfiles @@ -205,4 +229,3 @@
  hgt.asserttrue(checkdirs(repo1, repo2), 'repos dont match at %d' % i)   hgt.hg(['up', '-R', repo1, '-C'], stdout=hgt.ANYTHING, log=False)   hgt.hg(['up', '-R', repo2, '-C'], stdout=hgt.ANYTHING, log=False) -
Change 1 of 1 Show Entire File bfiles/​tests/​custom.py Stacked
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
@@ -0,0 +1,10 @@
+# Update the four variables below +# Your local kiln must have a project Test with a repo group called Test +# A repo Test in that group, as well as a branch repository TestBranch, will +# be created as part of the tests. The username and password given must have +# write access to that repo group. + +KILNEXTPATH = '~/kiln/extensions' +KILNURL = 'http://localhost/FogBugz/kiln' +USER = 'test' +PASSWORD = 'tester'
 
1
2
 
3
 
4
5
6
7
8
9
10
 
11
12
13
14
15
 
 
 
 
16
 
 
 
 
 
 
 
 
17
18
19
 
27
28
29
30
 
31
32
33
 
53
54
55
56
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
57
58
59
60
61
 
62
63
64
 
69
70
71
72
73
74
75
76
77
78
79
80
81
82
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
 
 
 
 
9
10
 
 
 
 
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
 
34
35
36
 
37
38
39
40
 
60
61
62
 
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
 
107
108
109
 
 
 
 
 
 
 
 
 
 
 
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
@@ -1,19 +1,26 @@
 import json  import sys +import os  import time +import getpass  import urllib2  from urllib import urlencode   -# Update the four variables below -# Your local kiln must have a project Test with a repo group called Test -# The repo test in that group will be used for testing. The username -# and password given must have write access to that group. +from custom import *   -KILNAUTHPATH = '/code/kiln/2-0/extensions/kilnauth.py' -KILNURL = 'http://localhost/FogBugz/kiln' -USER = 'test' -PASSWORD = 'tester' +# Ensure that the home directory is set appropriately so that the kilnauth +# cookies will be found. This is important because Mercurial 1.9 and later +# changes the home directory in the test script. +os.environ['HOME'] = os.path.expanduser('~' + getpass.getuser());   +# Paths for the individual extensions +KBFILESPATH = KILNEXTPATH + '/bfiles/kbfiles' +KILNAUTHPATH = KILNEXTPATH + '/kilnauth.py' +GESTALTPATH = KILNEXTPATH + '/gestalt.py' +KILNPATHPATH = KILNEXTPATH + '/kilnpath.py' +BIGPUSHPATH = KILNEXTPATH + '/big-push.py' +KILNPATH = KILNEXTPATH + '/kiln.py' +CASEGUARDPATH = KILNEXTPATH + '/caseguard.py'    def api(url):   return KILNURL + '/api/1.0/' + url @@ -27,7 +34,7 @@
  return obj    def gettoken(): - return slurp(api('Auth/Login'), dict(sUser='test', sPassword='tester')) + return slurp(api('Auth/Login'), dict(sUser=USER, sPassword=PASSWORD))    def createtest(hgt, token):   projects = slurp(api('Project'), dict(token=token)) @@ -53,12 +60,43 @@
  while slurp(api('Repo/%d' % ixRepo), dict(token=token))['sStatus'] != 'good':   time.sleep(0.1)   - return (KILNURL + '/Repo/Test/Test/test', ixRepo) + return (KILNURL + '/Repo/Test/Test/Test', ixRepo) + +def createtestbranch(hgt, token, ixParent): + projects = slurp(api('Project'), dict(token=token)) + + found = False + for project in projects: + if project['sName'] == 'Test': + ixProject = project['ixProject'] + for group in project['repoGroups']: + if group['sName'] == 'Test': + ixRepoGroup = group['ixRepoGroup'] + found = True + + if not found: + return None + + time.sleep(1) + while slurp(api('Repo/%d' % ixParent), dict(token=token))['sStatus'] != 'good': + time.sleep(0.1) + + repo = slurp(api('Repo/Create'), dict(sName='TestBranch', sDescription='test branch', ixRepoGroup=ixRepoGroup, ixParent=ixParent, fCentral=False, sDefaultPermission='write', token=token)) + ixRepo = repo['ixRepo'] + + hgt.asserttrue(isinstance(ixRepo, int), 'Create failed %s' % (str(ixRepo))) + + time.sleep(1) + while slurp(api('Repo/%d' % ixRepo), dict(token=token))['sStatus'] != 'good': + time.sleep(0.1) + + return (KILNURL + '/Repo/Test/Test/TestBranch', ixRepo)    def deletetest(hgt, token):   projects = slurp(api('Project'), dict(token=token))     found = False + foundbranch = False   for project in projects:   if project['sName'] == 'Test':   ixProject = project['ixProject'] @@ -69,14 +107,22 @@
  if repo['sName'] == 'Test':   ixRepo = repo['ixRepo']   found = True - if not found: - return None - slurp(api('Repo/%d/Delete' % ixRepo), dict(token=token), post=True) - - try: - while True: - slurp(api('Repo/%d' % ixRepo), dict(token=token)) - time.sleep(0.1) - except urllib2.HTTPError: - pass - + if repo['sName'] == 'TestBranch': + ixBranch = repo['ixRepo'] + foundbranch = True + if foundbranch: + slurp(api('Repo/%d/Delete' % ixBranch), dict(token=token), post=True) + try: + while True: + slurp(api('Repo/%d' % ixBranch), dict(token=token)) + time.sleep(0.1) + except urllib2.HTTPError: + pass + if found: + slurp(api('Repo/%d/Delete' % ixRepo), dict(token=token), post=True) + try: + while True: + slurp(api('Repo/%d' % ixRepo), dict(token=token)) + time.sleep(0.1) + except urllib2.HTTPError: + pass
 
1
 
2
3
4
 
 
1
2
3
4
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python    # Test various tricky bfadd corner cases.  
 
1
 
2
3
4
 
 
1
2
3
4
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python  #  # Test basic kiln interaction  
 
1
 
2
3
4
 
 
1
2
3
4
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python    # Test various tricky bfadd corner cases.  
 
1
 
2
3
4
 
49
50
51
52
 
53
54
55
 
68
69
70
71
 
72
73
74
 
86
87
88
89
 
90
91
92
93
94
95
 
96
97
98
99
100
 
101
102
103
104
105
 
106
107
108
 
110
111
112
113
 
114
115
116
117
118
 
119
120
121
 
129
130
131
132
 
133
134
135
 
142
143
144
145
 
146
147
148
 
 
1
2
3
4
 
49
50
51
 
52
53
54
55
 
68
69
70
 
71
72
73
74
 
86
87
88
 
89
90
91
92
93
94
 
95
96
97
98
99
 
100
101
102
103
104
 
105
106
107
108
 
110
111
112
 
113
114
115
116
117
 
118
119
120
121
 
129
130
131
 
132
133
134
135
 
142
143
144
 
145
146
147
148
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python  #  # Every commit needs time stamps so that the commits are unique (Mercurial backout test  # does the same thing). @@ -49,7 +49,7 @@
 C dir/n2  ''')  hgt.hg(['backout', '2', '-d', '3 0'], - stdout='''Getting changed bfiles + stdout='''getting changed bfiles  0 big files updated, 0 removed  adding ../.kbf/dir/dir/b3  adding dir/n3 @@ -68,7 +68,7 @@
 hgt.asserttrue(hgt.readfile('dir/n3') == 'n3', 'file changed')  hgt.asserttrue(hgt.readfile('dir/b3') == 'b3', 'file changed')  hgt.hg(['backout', '3', '-d', '4 0'], - stdout='''Getting changed bfiles + stdout='''getting changed bfiles  0 big files updated, 0 removed  removing ../.kbf/dir/dir/b3  removing dir/n3 @@ -86,23 +86,23 @@
 hgt.assertfalse(os.path.exists('dir/b3'), 'file shouldnt exist')  hgt.announce('backout... from the past!')  hgt.hg(['backout', '2', '-d', '5 0', '--merge'], - stdout='''Getting changed bfiles + stdout='''getting changed bfiles  0 big files updated, 0 removed  adding ../.kbf/dir/dir/b3  adding dir/n3  created new head  changeset 5:df61b823c9a6 backs out changeset 2:99a2429e853e -Getting changed bfiles +getting changed bfiles  0 big files updated, 1 removed  merging with changeset 5:df61b823c9a6  2 files updated, 0 files merged, 0 files removed, 0 files unresolved  (branch merge, don't forget to commit) -Getting changed bfiles +getting changed bfiles  1 big files updated, 0 removed  ''')  hgt.hg(['commit', '-m', 'merge', '-d', '6 0'])  hgt.hg(['backout', '1', '--merge', '-d', '7 0'], - stdout='''Getting changed bfiles + stdout='''getting changed bfiles  0 big files updated, 0 removed  reverting ../.kbf/dir/b1  reverting ../.kbf/dir/dir/dir/b4 @@ -110,12 +110,12 @@
 reverting n1  created new head  changeset 7:5e72be42125c backs out changeset 1:837f6fa72847 -Getting changed bfiles +getting changed bfiles  2 big files updated, 0 removed  merging with changeset 7:5e72be42125c  4 files updated, 0 files merged, 0 files removed, 0 files unresolved  (branch merge, don't forget to commit) -Getting changed bfiles +getting changed bfiles  2 big files updated, 0 removed  ''')  hgt.asserttrue(hgt.readfile('n1') == 'n1', 'file should match start') @@ -129,7 +129,7 @@
 hgt.hg(['commit', '-m', 'merge', '-d', '8 0'])  hgt.hg(['up', '-r', '0'],   stdout='''4 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  0 big files updated, 0 removed  ''')  hgt.asserttrue(hgt.readfile('n1') == 'n1', 'file should match start') @@ -142,7 +142,7 @@
 hgt.asserttrue(hgt.readfile('dir/dir/b4') == 'b4', 'file should match start')  hgt.hg(['up'],   stdout='''4 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  0 big files updated, 0 removed  ''')  hgt.asserttrue(hgt.readfile('n1') == 'n1', 'file should match start')
 
1
 
2
3
4
 
52
53
54
55
 
56
57
58
 
60
61
62
63
 
64
65
66
 
73
74
75
76
 
77
78
79
 
93
94
95
96
 
97
98
99
100
101
102
 
103
104
105
106
107
108
 
109
110
111
112
113
114
 
115
116
117
 
125
126
127
128
 
129
130
 
 
1
2
3
4
 
52
53
54
 
55
56
57
58
 
60
61
62
 
63
64
65
66
 
73
74
75
 
76
77
78
79
 
93
94
95
 
96
97
98
99
100
101
 
102
103
104
105
106
107
 
108
109
110
111
112
113
 
114
115
116
117
 
125
126
127
 
128
129
130
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python    # Test various tricky bfadd corner cases.   @@ -52,7 +52,7 @@
 hgt.hg(['bisect', '-b'],   stdout='''Testing changeset 2:04f4251bb360 (4 changesets remaining, ~2 tests)  4 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  2 big files updated, 0 removed  ''')  hgt.writefile('big1', 'blah') @@ -60,7 +60,7 @@
 hgt.hg(['revert', '-a'], stdout='reverting .kbf/big1\n')  hgt.hg(['bisect', '-g'], stdout='''Testing changeset 3:bbc1532f9dcf (2 changesets remaining, ~1 tests)  4 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  2 big files updated, 0 removed  ''')  hgt.hg(['bisect', '-b'], @@ -73,7 +73,7 @@
 ''')  hgt.hg(['up'],   stdout='''4 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  2 big files updated, 0 removed  ''')   @@ -93,25 +93,25 @@
 hgt.hg(['bisect', '-b'])  hgt.hg(['up', '-r', '1'],   stdout='''4 files updated, 0 files merged, 2 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  2 big files updated, 1 removed  ''')  hgt.hg(['bisect', '-g'],   stdout='''Testing changeset 3:bbc1532f9dcf (5 changesets remaining, ~2 tests)  4 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  2 big files updated, 0 removed  ''')  hgt.hg(['bisect', '-g'],   stdout='''Testing changeset 4:de7b6579c9e2 (3 changesets remaining, ~1 tests)  4 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  2 big files updated, 0 removed  ''')  hgt.hg(['bisect', '-g'],   stdout='''Testing changeset 5:5e56aef38802 (2 changesets remaining, ~1 tests)  2 files updated, 0 files merged, 2 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  1 big files updated, 1 removed  ''')  hgt.hg(['bisect', '-g'], @@ -125,6 +125,6 @@
 ''')  hgt.hg(['up'],   stdout='''2 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  1 big files updated, 0 removed  ''')
 
1
 
2
3
4
 
54
55
56
57
 
58
59
60
 
64
65
66
67
 
68
69
70
71
72
 
73
74
75
 
79
80
81
82
 
83
84
85
86
87
 
88
89
90
 
94
95
96
97
 
98
99
100
101
102
 
103
104
105
 
109
110
111
112
 
113
114
115
 
119
120
121
122
 
123
124
125
126
127
 
128
129
130
 
134
135
136
137
 
138
139
140
141
142
 
143
144
145
 
149
150
151
152
 
153
154
155
156
157
 
158
159
160
 
185
186
187
188
 
189
190
191
 
202
203
204
205
 
206
207
208
209
210
211
 
212
213
214
 
 
1
2
3
4
 
54
55
56
 
57
58
59
60
 
64
65
66
 
67
68
69
70
71
 
72
73
74
75
 
79
80
81
 
82
83
84
85
86
 
87
88
89
90
 
94
95
96
 
97
98
99
100
101
 
102
103
104
105
 
109
110
111
 
112
113
114
115
 
119
120
121
 
122
123
124
125
126
 
127
128
129
130
 
134
135
136
 
137
138
139
140
141
 
142
143
144
145
 
149
150
151
 
152
153
154
155
156
 
157
158
159
160
 
185
186
187
 
188
189
190
191
 
202
203
204
 
205
206
207
208
209
210
 
211
212
213
214
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python    # Test cloning a repo   @@ -54,7 +54,7 @@
 hgt.hg(['clone', 'repo1', 'repo2'],   stdout=('updating to branch default\n'   '7 files updated, 0 files merged, 0 files removed, 0 files unresolved\n' - 'Getting changed bfiles\n' + 'getting changed bfiles\n'   '3 big files updated, 0 removed\n'))  files = ['normal1', 'sub/normal2', 'sub/normal3.txt', 'sub/normal4.txt', 'big1', 'sub/big2', 'sub/big3.txt']  for file in files: @@ -64,12 +64,12 @@
 os.chdir('repo1')  hgt.hg(['up', '-r', '0'],   stdout=('2 files updated, 0 files merged, 3 files removed, 0 files unresolved\n' - 'Getting changed bfiles\n' + 'getting changed bfiles\n'   '0 big files updated, 3 removed\n'))  os.chdir('../repo2')  hgt.hg(['up', '-r', '0'],   stdout=('2 files updated, 0 files merged, 3 files removed, 0 files unresolved\n' - 'Getting changed bfiles\n' + 'getting changed bfiles\n'   '0 big files updated, 3 removed\n'))  os.chdir('..')  for file in files: @@ -79,12 +79,12 @@
 os.chdir('repo1')  hgt.hg(['up', '-r', '1'],   stdout=('3 files updated, 0 files merged, 0 files removed, 0 files unresolved\n' - 'Getting changed bfiles\n' + 'getting changed bfiles\n'   '3 big files updated, 0 removed\n'))  os.chdir('../repo2')  hgt.hg(['up', '-r', '1'],   stdout=('3 files updated, 0 files merged, 0 files removed, 0 files unresolved\n' - 'Getting changed bfiles\n' + 'getting changed bfiles\n'   '3 big files updated, 0 removed\n'))  os.chdir('..')  for file in files: @@ -94,12 +94,12 @@
 os.chdir('repo1')  hgt.hg(['up', '-r', '2'],   stdout=('4 files updated, 0 files merged, 0 files removed, 0 files unresolved\n' - 'Getting changed bfiles\n' + 'getting changed bfiles\n'   '2 big files updated, 0 removed\n'))  os.chdir('../repo2')  hgt.hg(['up', '-r', '2'],   stdout=('4 files updated, 0 files merged, 0 files removed, 0 files unresolved\n' - 'Getting changed bfiles\n' + 'getting changed bfiles\n'   '2 big files updated, 0 removed\n'))  os.chdir('..')  for file in files: @@ -109,7 +109,7 @@
 hgt.hg(['clone', '-U', 'repo2', 'repo3'])  os.chdir('repo3')  hgt.hg(['up'], stdout=('7 files updated, 0 files merged, 0 files removed, 0 files unresolved\n' - 'Getting changed bfiles\n' + 'getting changed bfiles\n'   '3 big files updated, 0 removed\n'))  os.chdir('..')  for file in files: @@ -119,12 +119,12 @@
 os.chdir('repo2')  hgt.hg(['up', '-r', '0'],   stdout=('2 files updated, 0 files merged, 3 files removed, 0 files unresolved\n' - 'Getting changed bfiles\n' + 'getting changed bfiles\n'   '0 big files updated, 3 removed\n'))  os.chdir('../repo3')  hgt.hg(['up', '-r', '0'],   stdout=('2 files updated, 0 files merged, 3 files removed, 0 files unresolved\n' - 'Getting changed bfiles\n' + 'getting changed bfiles\n'   '0 big files updated, 3 removed\n'))  os.chdir('..')  for file in files: @@ -134,12 +134,12 @@
 os.chdir('repo2')  hgt.hg(['up', '-r', '1'],   stdout=('3 files updated, 0 files merged, 0 files removed, 0 files unresolved\n' - 'Getting changed bfiles\n' + 'getting changed bfiles\n'   '3 big files updated, 0 removed\n'))  os.chdir('../repo3')  hgt.hg(['up', '-r', '1'],   stdout=('3 files updated, 0 files merged, 0 files removed, 0 files unresolved\n' - 'Getting changed bfiles\n' + 'getting changed bfiles\n'   '3 big files updated, 0 removed\n'))  os.chdir('..')  for file in files: @@ -149,12 +149,12 @@
 os.chdir('repo2')  hgt.hg(['up', '-r', '2'],   stdout=('4 files updated, 0 files merged, 0 files removed, 0 files unresolved\n' - 'Getting changed bfiles\n' + 'getting changed bfiles\n'   '2 big files updated, 0 removed\n'))  os.chdir('../repo3')  hgt.hg(['up', '-r', '2'],   stdout=('4 files updated, 0 files merged, 0 files removed, 0 files unresolved\n' - 'Getting changed bfiles\n' + 'getting changed bfiles\n'   '2 big files updated, 0 removed\n'))  os.chdir('..')  for file in files: @@ -185,7 +185,7 @@
  hgt.asserttrue(file.startswith('.hg'), 'files shouldnt exist')  hgt.hg(['up'],   stdout='''17 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  7 big files updated, 0 removed  ''')  os.chdir('..') @@ -202,13 +202,13 @@
 os.chdir('repo3')  hgt.hg(['up', '-r', '2'],   stdout='''0 files updated, 0 files merged, 10 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  0 big files updated, 4 removed  ''')  os.chdir('../repo4')  hgt.hg(['up', '-r', '2'],   stdout='''0 files updated, 0 files merged, 10 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  0 big files updated, 4 removed  ''')  os.chdir('..')
 
1
 
2
3
4
 
55
56
57
 
 
 
 
 
 
 
1
2
3
4
 
55
56
57
58
59
60
61
62
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python  #  # Test commit (lots of other tests commit all files so just try committing specific files)  # @@ -55,3 +55,8 @@
 ''')  hgt.hg(['commit', '-m', 'adding', 'dir/b2', 'dir/n2'])  hgt.hg(['status']) +hgt.writefile('b1', 'b11') +hgt.hg(['status'], + stdout='M b1\n') +hgt.hg(['commit', '-m', 'modifying b1']) +hgt.asserttrue(hgt.readfile('b1') == 'b11', 'file contents dont match')
 
11
12
13
 
 
 
11
12
13
14
15
@@ -11,3 +11,5 @@
 hg status  hg commit -m adding dir/b2 dir/n2  hg status +hg status +hg commit -m 'modifying b1'
 
1
 
2
3
4
 
165
166
167
168
 
169
170
171
 
213
214
215
216
 
217
218
219
 
 
1
2
3
4
 
165
166
167
 
168
169
170
171
 
213
214
215
 
216
217
218
219
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python    # Test various tricky bfadd corner cases.   @@ -165,7 +165,7 @@
 ''')  hgt.hg(['up'],   stdout='''8 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  6 big files updated, 0 removed  ''')  hgt.asserttrue(os.path.exists('.kbf'), 'bfile standins should exist') @@ -213,7 +213,7 @@
 ''')  hgt.hg(['up'],   stdout='''8 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  8 big files updated, 0 removed  ''')  hgt.asserttrue(os.path.exists('.kbf'), 'bfile standins should exist')
 
1
 
2
3
4
 
161
162
163
164
 
165
166
167
168
169
 
170
171
172
173
174
 
175
176
177
178
179
 
180
181
182
183
184
 
185
186
187
 
252
253
254
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
 
161
162
163
 
164
165
166
167
168
 
169
170
171
172
173
 
174
175
176
177
178
 
179
180
181
182
183
 
184
185
186
187
 
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python    # Test that kbfconvert handles tags properly   @@ -161,27 +161,27 @@
   ''')  hgt.hg(['up', '-r', '0'], stdout='''6 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  2 big files updated, 0 removed  ''')  hgt.assertfalse(os.path.exists('.hgtags'), "hgtags doesn't match")  hgt.hg(['up', '-r', '1'], stdout='''6 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  4 big files updated, 0 removed  ''')  hgt.assertfalse(os.path.exists('.hgtags'), "hgtags doesn't match")  hgt.hg(['up', '-r', '2'], stdout='''1 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  0 big files updated, 0 removed  ''')  hgt.asserttrue(hgt.readfile('.hgtags') == '494d68993338ddb5b7fd854396a003be5ed72755 first\n', "hgtags doesn't match")  hgt.hg(['up', '-r', '3'], stdout='''1 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  0 big files updated, 0 removed  ''')  hgt.asserttrue(hgt.readfile('.hgtags') == '494d68993338ddb5b7fd854396a003be5ed72755 first\na633211558b85df9a4e0c18c0777284421721158 second\n', "hgtags doesn't match")  hgt.hg(['up', '-r', '4'], stdout='''1 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  0 big files updated, 0 removed  ''')  hgt.asserttrue(hgt.readfile('.hgtags') == '494d68993338ddb5b7fd854396a003be5ed72755 first\na633211558b85df9a4e0c18c0777284421721158 second\n3c50e5db999358097d2b8602f50b2acda3886bc9 last\n', "hgtags doesn't match") @@ -252,3 +252,78 @@
 hgt.asserttrue(hgt.readfile('.hgtags') == 'd82117283c29e97adb8ebbcc5ea8fb7613ad0864 first\n73960f5ccfe2ca2f74002e55d74f186678f53872 second\n', "hgtags doesn't match")  hgt.hg(['up', '-r', '4'], stdout='1 files updated, 0 files merged, 0 files removed, 0 files unresolved\n')  hgt.asserttrue(hgt.readfile('.hgtags') == 'd82117283c29e97adb8ebbcc5ea8fb7613ad0864 first\n73960f5ccfe2ca2f74002e55d74f186678f53872 second\ne229b8d1bac18cbd3eef20f9433c076fe45fa97d last\n', "hgtags doesn't match") +os.chdir('..') +hgt.hg(['tag', '-R', 'repo3', 'fromroot']) +hgt.hg(['log', '-R', 'repo3'], stdout='''changeset: 5:d9771069dce1 +tag: tip +user: test +date: Thu Jan 01 00:00:00 1970 +0000 +summary: Added tag fromroot for changeset c4495ce62a60 + +changeset: 4:c4495ce62a60 +tag: fromroot +user: test +date: Thu Jan 01 00:00:00 1970 +0000 +summary: Added tag last for changeset e229b8d1bac1 + +changeset: 3:e229b8d1bac1 +tag: last +user: test +date: Thu Jan 01 00:00:00 1970 +0000 +summary: Added tag second for changeset 73960f5ccfe2 + +changeset: 2:d41643b333a9 +user: test +date: Thu Jan 01 00:00:00 1970 +0000 +summary: Added tag first for changeset d82117283c29 + +changeset: 1:73960f5ccfe2 +tag: second +user: test +date: Thu Jan 01 00:00:00 1970 +0000 +summary: add more files + +changeset: 0:d82117283c29 +tag: first +user: test +date: Thu Jan 01 00:00:00 1970 +0000 +summary: initial commit + +''') +hgt.hg(['tag', '-R', 'repo2', 'fromroot']) +hgt.hg(['log', '-R', 'repo2'], stdout='''changeset: 5:e861e23e4324 +tag: tip +user: test +date: Thu Jan 01 00:00:00 1970 +0000 +summary: Added tag fromroot for changeset d6940222c000 + +changeset: 4:d6940222c000 +tag: fromroot +user: test +date: Thu Jan 01 00:00:00 1970 +0000 +summary: Added tag last for changeset e229b8d1bac1 + +changeset: 3:3c50e5db9993 +tag: last +user: test +date: Thu Jan 01 00:00:00 1970 +0000 +summary: Added tag second for changeset 73960f5ccfe2 + +changeset: 2:4a283e03a784 +user: test +date: Thu Jan 01 00:00:00 1970 +0000 +summary: Added tag first for changeset d82117283c29 + +changeset: 1:a633211558b8 +tag: second +user: test +date: Thu Jan 01 00:00:00 1970 +0000 +summary: add more files + +changeset: 0:494d68993338 +tag: first +user: test +date: Thu Jan 01 00:00:00 1970 +0000 +summary: initial commit + +''')
 
31
32
33
 
 
 
 
 
31
32
33
34
35
36
37
@@ -31,3 +31,7 @@
 hg up -r 2  hg up -r 3  hg up -r 4 +hg tag -R repo3 fromroot +hg log -R repo3 +hg tag -R repo2 fromroot +hg log -R repo2
 
1
 
2
3
4
 
 
1
2
3
4
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python    # Test copy and rename  
 
1
 
2
3
4
 
 
1
2
3
4
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python    # Test that edited bfiles show up as modified  
 
1
 
2
3
4
 
28
29
30
31
 
32
33
34
 
47
48
49
50
 
51
52
53
 
66
67
68
69
 
70
71
72
73
74
75
 
76
77
78
 
 
1
2
3
4
 
28
29
30
 
31
32
33
34
 
47
48
49
 
50
51
52
53
 
66
67
68
 
69
70
71
72
73
74
 
75
76
77
78
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python  #  # Test the fetch extension. Always give it a specific message because the message  # it automatically adds includes the path which is randomly generated. @@ -28,7 +28,7 @@
 hgt.hg(['clone', 'repo1', 'repo2'],   stdout='''updating to branch default  4 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  2 big files updated, 0 removed  ''')  os.chdir('repo1') @@ -47,7 +47,7 @@
 adding file changes  added 1 changesets with 2 changes to 2 files  2 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  1 big files updated, 0 removed  ''')  hgt.hg(['mv', 'dir/n2', 'n2']) @@ -66,13 +66,13 @@
 added 1 changesets with 2 changes to 2 files (+1 heads)  updating to 3:04650d35496d  2 files updated, 0 files merged, 2 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  1 big files updated, 1 removed  merging with 2:6db24b20137f  merging b2 and dir/b2 to b2  merging n2 and dir/n2 to n2  0 files updated, 2 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  1 big files updated, 0 removed  new changeset 4:dacf855d6b8a merges remote changes with local  ''')
 
1
 
2
3
4
 
56
57
58
59
 
60
61
62
 
67
68
69
70
 
71
72
73
 
 
1
2
3
4
 
56
57
58
 
59
60
61
62
 
67
68
69
 
70
71
72
73
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python    # Test remove   @@ -56,7 +56,7 @@
 hgt.announce('test update')  hgt.hg(['up', '-r', '1'],   stdout=('3 files updated, 0 files merged, 0 files removed, 0 files unresolved\n' - 'Getting changed bfiles\n' + 'getting changed bfiles\n'   '1 big files updated, 0 removed\n'))  hgt.asserttrue(os.path.exists('sub/normal3.txt'), 'added file doesnt exist')  hgt.asserttrue(os.path.exists('sub/normal4.txt'), 'added file doesnt exist') @@ -67,7 +67,7 @@
 hgt.asserttrue(os.path.exists('sub/big2'), 'added file doesnt exist')  hgt.hg(['up'],   stdout=('0 files updated, 0 files merged, 3 files removed, 0 files unresolved\n' - 'Getting changed bfiles\n' + 'getting changed bfiles\n'   '0 big files updated, 1 removed\n'))  hgt.assertfalse(os.path.exists('sub/normal3.txt'), 'removed file exists')  hgt.assertfalse(os.path.exists('sub/normal4.txt'), 'removed file exists')
 
1
 
2
3
4
 
43
44
45
46
 
47
48
49
 
70
71
72
73
 
74
75
76
77
78
79
 
80
81
82
 
92
93
94
95
 
96
97
98
99
100
 
101
102
103
104
105
 
106
107
108
 
112
113
114
115
 
116
117
118
 
126
127
128
129
 
130
131
132
133
134
135
136
 
137
138
139
 
143
144
145
146
 
147
148
149
150
151
152
153
 
154
155
156
 
167
168
169
170
 
171
172
173
 
180
181
182
183
 
184
185
186
187
188
 
189
190
191
 
215
216
217
218
 
219
220
221
222
223
224
225
 
226
227
228
229
230
231
 
232
233
234
 
245
246
247
248
 
249
250
251
 
254
255
256
257
 
258
259
260
261
262
263
 
264
265
266
 
270
271
272
273
 
274
275
276
 
295
296
297
298
 
299
300
301
302
303
304
305
 
306
307
308
 
332
333
334
335
 
336
337
338
339
340
341
342
 
343
344
345
 
 
1
2
3
4
 
43
44
45
 
46
47
48
49
 
70
71
72
 
73
74
75
76
77
78
 
79
80
81
82
 
92
93
94
 
95
96
97
98
99
 
100
101
102
103
104
 
105
106
107
108
 
112
113
114
 
115
116
117
118
 
126
127
128
 
129
130
131
132
133
134
135
 
136
137
138
139
 
143
144
145
 
146
147
148
149
150
151
152
 
153
154
155
156
 
167
168
169
 
170
171
172
173
 
180
181
182
 
183
184
185
186
187
 
188
189
190
191
 
215
216
217
 
218
219
220
221
222
223
224
 
225
226
227
228
229
230
 
231
232
233
234
 
245
246
247
 
248
249
250
251
 
254
255
256
 
257
258
259
260
261
262
 
263
264
265
266
 
270
271
272
 
273
274
275
276
 
295
296
297
 
298
299
300
301
302
303
304
 
305
306
307
308
 
332
333
334
 
335
336
337
338
339
340
341
 
342
343
344
345
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python  #  # Test basic kiln interaction   @@ -43,7 +43,7 @@
 ''')  hgt.hg(['commit', '-m', 'add files'])  hgt.hg(['out', '--bf'], - stdout='''comparing with %s/Repo/Test/Test/test + stdout='''comparing with %s/Repo/Test/Test/Test  searching for changes  changeset: 0:da6857b8d2bf  tag: tip @@ -70,13 +70,13 @@
 kbfiles: 4 to upload  ''')  hgt.hg(['push'], - stdout='''pushing to %s/Repo/Test/Test/test + stdout='''pushing to %s/Repo/Test/Test/Test  searching for changes  searching for changes  remote: kiln: successfully pushed one changeset  ''' % kilntest.KILNURL)  hgt.hg(['out', '--bf'], - stdout='''comparing with %s/Repo/Test/Test/test + stdout='''comparing with %s/Repo/Test/Test/Test  searching for changes  no changes found  searching for changes @@ -92,17 +92,17 @@
 added 1 changesets with 8 changes to 8 files  updating to branch default  8 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  4 big files updated, 0 removed  ''')  os.chdir('repo2')  hgt.hg(['in'], - stdout='''comparing with %s/Repo/Test/Test/test + stdout='''comparing with %s/Repo/Test/Test/Test  searching for changes  no changes found  ''' % kilntest.KILNURL, status=1)  hgt.hg(['out', '--bf'], - stdout='''comparing with %s/Repo/Test/Test/test + stdout='''comparing with %s/Repo/Test/Test/Test  searching for changes  no changes found  searching for changes @@ -112,7 +112,7 @@
 hgt.writefile('b4', 'b44')  hgt.hg(['commit', '-m', 'edit n4 and b4'])  hgt.hg(['out', '--bf'], - stdout='''comparing with %s/Repo/Test/Test/test + stdout='''comparing with %s/Repo/Test/Test/Test  searching for changes  changeset: 1:8499483c24d0  tag: tip @@ -126,14 +126,14 @@
   ''' % kilntest.KILNURL)  hgt.hg(['push'], - stdout='''pushing to %s/Repo/Test/Test/test + stdout='''pushing to %s/Repo/Test/Test/Test  searching for changes  searching for changes  remote: kiln: successfully pushed one changeset  ''' % kilntest.KILNURL)  os.chdir('../repo1')  hgt.hg(['in'], - stdout='''comparing with %s/Repo/Test/Test/test + stdout='''comparing with %s/Repo/Test/Test/Test  searching for changes  changeset: 1:8499483c24d0  tag: tip @@ -143,14 +143,14 @@
   ''' % kilntest.KILNURL)  hgt.hg(['out'], - stdout='''comparing with %s/Repo/Test/Test/test + stdout='''comparing with %s/Repo/Test/Test/Test  searching for changes  no changes found  ''' % kilntest.KILNURL)  hgt.hg(['mv', 'n4', 'b4', 'a'])  hgt.hg(['commit', '-m', 'move n4 and b4'])  hgt.hg(['out', '--bf'], - stdout='''comparing with %s/Repo/Test/Test/test + stdout='''comparing with %s/Repo/Test/Test/Test  searching for changes  changeset: 1:6b693340d9c6  tag: tip @@ -167,7 +167,7 @@
 # to stderr at some version after Mercurial 1.6. Just don't check stdout/stderr.  hgt.hg(['push'], stdout=hgtest.ANYTHING, stderr=hgtest.ANYTHING, status=[1, 255])  hgt.hg(['pull'], - stdout='''pulling from %s/Repo/Test/Test/test + stdout='''pulling from %s/Repo/Test/Test/Test  searching for changes  adding changesets  adding manifests @@ -180,12 +180,12 @@
 merging a/n4 and n4 to a/n4  0 files updated, 2 files merged, 0 files removed, 0 files unresolved  (branch merge, don't forget to commit) -Getting changed bfiles +getting changed bfiles  1 big files updated, 0 removed  ''')  hgt.hg(['commit', '-m', 'merge'])  hgt.hg(['out', '--bf'], - stdout='''comparing with %s/Repo/Test/Test/test + stdout='''comparing with %s/Repo/Test/Test/Test  searching for changes  changeset: 1:6b693340d9c6  user: test @@ -215,20 +215,20 @@
 searching for changes  kbfiles: 1 to upload  ''') -hgt.hg(['push'], stdout='''pushing to %s/Repo/Test/Test/test +hgt.hg(['push'], stdout='''pushing to %s/Repo/Test/Test/Test  searching for changes  searching for changes  remote: kiln: successfully pushed 2 changesets  ''' % kilntest.KILNURL)  os.chdir('../repo2')  hgt.hg(['out', '--bf'], - stdout='''comparing with %s/Repo/Test/Test/test + stdout='''comparing with %s/Repo/Test/Test/Test  searching for changes  no changes found  searching for changes  kbfiles: No remote repo  ''' % kilntest.KILNURL) -hgt.hg(['in'], stdout='''comparing with %s/Repo/Test/Test/test +hgt.hg(['in'], stdout='''comparing with %s/Repo/Test/Test/Test  searching for changes  changeset: 2:6b693340d9c6  parent: 0:da6857b8d2bf @@ -245,7 +245,7 @@
 summary: merge    ''' % kilntest.KILNURL) -hgt.hg(['pull'], stdout='''pulling from %s/Repo/Test/Test/test +hgt.hg(['pull'], stdout='''pulling from %s/Repo/Test/Test/Test  searching for changes  adding changesets  adding manifests @@ -254,13 +254,13 @@
 (run 'hg update' to get a working copy)  ''' % kilntest.KILNURL)  hgt.hg(['in'], - stdout='''comparing with %s/Repo/Test/Test/test + stdout='''comparing with %s/Repo/Test/Test/Test  searching for changes  no changes found  ''' % kilntest.KILNURL, status=1)  hgt.hg(['up'],   stdout='''2 files updated, 0 files merged, 2 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  1 big files updated, 1 removed  ''')  os.chdir('..') @@ -270,7 +270,7 @@
 hgt.writefile('a/b1', 'b11')  hgt.hg(['commit', '-m', 'edit n1 and b1'])  hgt.hg(['out', '--bf'], - stdout='''comparing with %s/Repo/Test/Test/test + stdout='''comparing with %s/Repo/Test/Test/Test  searching for changes  changeset: 4:fdb0cdc62a97  tag: tip @@ -295,14 +295,14 @@
 ''')  hgt.hg(['up'],   stdout='''2 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  1 big files updated, 0 removed  ''')  hgt.writefile('a/b/n2', 'n22')  hgt.writefile('a/b/b2', 'b22')  hgt.hg(['commit', '-m', 'edit n22 and b22'])  hgt.hg(['out', '--bf'], - stdout='''comparing with %s/Repo/Test/Test/test + stdout='''comparing with %s/Repo/Test/Test/Test  searching for changes  changeset: 4:fdb0cdc62a97  user: test @@ -332,14 +332,14 @@
 kbfiles: 2 to upload  ''')  hgt.hg(['push'], - stdout='''pushing to %s/Repo/Test/Test/test + stdout='''pushing to %s/Repo/Test/Test/Test  searching for changes  searching for changes  remote: kiln: successfully pushed 2 changesets  ''' % kilntest.KILNURL)  os.chdir('../repo2')  hgt.hg(['pull'], - stdout='''pulling from %s/Repo/Test/Test/test + stdout='''pulling from %s/Repo/Test/Test/Test  searching for changes  adding changesets  adding manifests
 
1
 
2
3
4
 
43
44
45
46
 
47
48
49
 
62
63
64
65
 
66
67
68
 
 
1
2
3
4
 
43
44
45
 
46
47
48
49
 
62
63
64
 
65
66
67
68
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python  #  # Test basic kiln interaction   @@ -43,7 +43,7 @@
 ''')  hgt.hg(['commit', '-m', 'add files'])  hgt.hg(['push'], - stdout='''pushing to %s/Repo/Test/Test/test + stdout='''pushing to %s/Repo/Test/Test/Test  searching for changes  searching for changes  remote: kiln: successfully pushed one changeset @@ -62,7 +62,7 @@
  stdout='requesting all changes\n', log=False,   stderr='abort: HTTP Error 400: To access this repository, install the kiln-bfiles extension from %s/Tools\n' % kilntest.KILNURL, status=255)  os.chdir('repo1') -hgt.hg(['push'], stdout='''pushing to %s/Repo/Test/Test/test +hgt.hg(['push'], stdout='''pushing to %s/Repo/Test/Test/Test  searching for changes  remote: ERROR: Big file a/b1 at revision 1 has not been uploaded to the kiln server.  remote: ERROR: All big files must be uploaded to the kiln server before the repository is changed.
Show Entire File bfiles/​tests/​test-log.py Stacked
This file's diff was not loaded because this changeset is very large. Load changes
Change 1 of 1 Show Entire File bfiles/​tests/​test-log.py.out Stacked
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
@@ -0,0 +1,15 @@
+% setup +hg init +hg add n1 +hg commit -m 'add file' +hg add --bf b1 +hg commit -m 'add bfile' +hg commit -m 'modify file' +hg commit -m 'modify bfile' +hg rm n1 +hg commit -m 'remove file' +hg rm b1 +hg commit -m 'remove bfile' +hg log -v +hg log -p +hg log --stat
 
1
 
2
3
4
 
27
28
29
30
 
31
32
33
 
38
39
40
41
42
 
 
 
 
 
 
43
44
45
 
 
1
2
3
4
 
27
28
29
 
30
31
32
33
 
38
39
40
 
 
41
42
43
44
45
46
47
48
49
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python  #  # Test summary   @@ -27,7 +27,7 @@
 hgt.hg(['clone', 'repo1', 'repo2'],   stdout='''updating to branch default  4 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  2 big files updated, 0 removed  ''')  os.chdir('repo2') @@ -38,8 +38,12 @@
   hgt.announce('outgoing')  os.chdir('repo1') -hgt.hg(['out'], status=255, stderr='abort: repository default-push not found!\n') -hgt.hg(['out', '--bf'], status=255, stderr='abort: repository default-push not found!\n') +if common.version >= (1, 8, 0): + hgt.hg(['out'], status=255, stdout='comparing with default-push\n', stderr='abort: repository default-push not found!\n') + hgt.hg(['out', '--bf'], status=255, stdout='comparing with default-push\n', stderr='abort: repository default-push not found!\n') +else: + hgt.hg(['out'], status=255, stderr='abort: repository default-push not found!\n') + hgt.hg(['out', '--bf'], status=255, stderr='abort: repository default-push not found!\n')  os.chdir('../repo2')  hgt.hg(['out'],   stdout='''comparing with $HGTMP/test-outgoing.py/repo1
 
1
 
2
3
4
 
116
117
118
119
 
120
121
122
123
124
125
126
 
127
128
129
 
157
158
159
160
 
161
162
163
 
 
1
2
3
4
 
116
117
118
 
119
120
121
122
123
124
125
 
126
127
128
129
 
157
158
159
 
160
161
162
163
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python    # Test various tricky bfadd corner cases.   @@ -116,14 +116,14 @@
   if windows:   hgt.hg(['backout', '-r', '2'], - stdout='''Getting changed bfiles + stdout='''getting changed bfiles  0 big files updated, 0 removed  reverting foo/dir/n3  changeset 3:8abd5724a95c backs out changeset 2:df964af3433e  ''')  else:   hgt.hg(['backout', '-r', '2'], - stdout='''Getting changed bfiles + stdout='''getting changed bfiles  0 big files updated, 0 removed  reverting .kbf/b1  reverting .kbf/foo/b2 @@ -157,7 +157,7 @@
 hgt.hg(['clone', 'repo1', 'repo2'],   stdout='''updating to branch default  6 files updated, 0 files merged, 0 files removed, 0 files unresolved -Getting changed bfiles +getting changed bfiles  3 big files updated, 0 removed  ''')  common.checkrepos(hgt, 'repo1', 'repo2', [0, 1, 2, 3])
Change 1 of 1 Show Entire File bfiles/​tests/​test-purge.py Stacked
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
@@ -0,0 +1,37 @@
+#!/usr/bin/env python + +# Test hg purge + +import os +import common + +hgt = common.BfilesTester() + +hgt.updaterc({'extensions': [('purge', '')]}) +hgt.announce('setup') +os.mkdir('repo1') +os.chdir('repo1') +hgt.hg(['init']) +hgt.writefile('b1', 'b1') +hgt.writefile('n1', 'n1') +hgt.writefile('n2', 'n2') +hgt.hg(['add', '--bf', 'b1']) +hgt.hg(['add', 'n1']) +hgt.hg(['commit', '-m', 'add some files']) +hgt.hg(['purge']) +hgt.asserttrue(os.path.exists('b1'), 'missing b1') +hgt.asserttrue(hgt.readfile('b1') == 'b1', 'wrong file contents') +hgt.writefile('b2', 'b2') +hgt.hg(['purge']) +hgt.assertfalse(os.path.exists('b2'), 'failed to purge b2') +hgt.writefile('b2', 'b2') +hgt.hg(['add', '--bf', 'b2']) +hgt.hg(['purge']) +hgt.asserttrue(os.path.exists('b2'), 'missing b2') +hgt.asserttrue(hgt.readfile('b2') == 'b2', 'wrong file contents') +hgt.hg(['commit', '-m', 'add another bfile']) +hgt.writefile('b2', 'b22') +hgt.hg(['purge']) +hgt.asserttrue(os.path.exists('b2'), 'missing b2') +hgt.asserttrue(hgt.readfile('b2') == 'b22', 'wrong file contents') +os.chdir('..')
Change 1 of 1 Show Entire File bfiles/​tests/​test-purge.py.out Stacked
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
@@ -0,0 +1,11 @@
+% setup +hg init +hg add --bf b1 +hg add n1 +hg commit -m 'add some files' +hg purge +hg purge +hg add --bf b2 +hg purge +hg commit -m 'add another bfile' +hg purge
Show Entire File bfiles/​tests/​test-pushpull.py Stacked
This file's diff was not loaded because this changeset is very large. Load changes
Show Entire File bfiles/​tests/​test-rebase.py Stacked
This file's diff was not loaded because this changeset is very large. Load changes
Show Entire File bfiles/​tests/​test-rebase.py.out Stacked
This file's diff was not loaded because this changeset is very large. Load changes
Show Entire File bfiles/​tests/​test-remove.py Stacked
This file's diff was not loaded because this changeset is very large. Load changes
Show Entire File bfiles/​tests/​test-remove.py.out Stacked
This file's diff was not loaded because this changeset is very large. Load changes
 
1
 
2
3
4
 
 
1
2
3
4
@@ -1,4 +1,4 @@
-#!/usr/bin/python +#!/usr/bin/env python    # Test that bfiles does not conflict with other extensions  # (e.g. bookmarks) that override localrepository.commit().
Show Entire File bfiles/​tests/​test-revert.py Stacked
This file's diff was not loaded because this changeset is very large. Load changes
 
23
24
25
 
 
 
 
 
 
 
 
 
 
 
 
 
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
@@ -23,3 +23,15 @@
 hg status  hg revert -r 0 n2.txt b2.txt  hg status +hg init -q +hg add n1 +hg commit -m 'added normal file' +hg add --bf b1 +hg commit -m 'added bfile' +hg revert n1 +hg init -q +hg add --bf b1 +hg commit -m 'added first bfile' +hg add --bf b2 +hg commit -m 'added second bfile' +hg revert b1
Show Entire File bfiles/​tests/​test-schemes.py Stacked
This file's diff was not loaded because this changeset is very large. Load changes
Show Entire File bfiles/​tests/​test-schemes.py.out Stacked
This file's diff was not loaded because this changeset is very large. Load changes
Show Entire File bfiles/​tests/​test-status.py Stacked
This file's diff was not loaded because this changeset is very large. Load changes
Show Entire File bfiles/​tests/​test-summary.py Stacked
This file's diff was not loaded because this changeset is very large. Load changes
Show Entire File bfiles/​tests/​test-update.py Stacked
This file's diff was not loaded because this changeset is very large. Load changes
Show Entire File bfiles/​tests/​test-verify.py Stacked
This file's diff was not loaded because this changeset is very large. Load changes
Show Entire File caseguard.py Stacked
This file's diff was not loaded because this changeset is very large. Load changes
Show Entire File gestalt.py Stacked
This file's diff was not loaded because this changeset is very large. Load changes
Show Entire File kiln.py Stacked
This file's diff was not loaded because this changeset is very large. Load changes
Show Entire File kilnauth.py Stacked
This file's diff was not loaded because this changeset is very large. Load changes