implab/ImplabNet Commit - r198:b305c678923a

1

using System;

1

using System;

2

using System.Threading;

2

using System.Threading;

3

4

namespace Implab {

4

namespace Implab {

5

public class ActionChainTaskBase : AbstractTask {

5

public class ActionChainTaskBase : AbstractTask {

6

readonly Func<Exception, IPromise> m_error;

6

readonly Func<Exception, IPromise> m_error;

7

readonly Func<Exception, IPromise> m_cancel;

7

readonly Func<Exception, IPromise> m_cancel;

8

9

protected ActionChainTaskBase(Func<Exception, IPromise> error, Func<Exception, IPromise> cancel, bool autoCancellable) {

9

protected ActionChainTaskBase(Func<Exception, IPromise> error, Func<Exception, IPromise> cancel, bool autoCancellable) {

10

m_error = error;

10

m_error = error;

11

m_cancel = cancel;

11

m_cancel = cancel;

12

if (autoCancellable)

12

if (autoCancellable)

13

CancellationRequested(CancelOperation);

13

CancellationRequested(CancelOperation);

14

}

14

}

15

16

public void Reject(Exception error) {

16

public void Reject(Exception error) {

17

if (LockCancelation())

17

if (LockCancelation())

18

HandleErrorInternal(error);

18

HandleErrorInternal(error);

19

}

19

}

20

21

public override void CancelOperation(Exception reason) {

21

public override void CancelOperation(Exception reason) {

22

if (LockCancelation())

22

if (LockCancelation())

23

// отмена вызвана до начала выполнения задачи

23

// отмена вызвана до начала выполнения задачи

24

HandleCancelInternal(reason);

24

HandleCancelInternal(reason);

25

}

25

}

26

27

protected void HandleCancelInternal(Exception reason) {

27

protected void HandleCancelInternal(Exception reason) {

28

if (m_cancel != null) {

28

if (m_cancel != null) {

29

try {

29

try {

30

// вызываем обработчик отмены

30

// вызываем обработчик отмены

31

var p = m_cancel(reason);

31

var p = m_cancel(reason);

32

p.On(SetResult, HandleErrorInternal, SetCancelledInternal);

32

p.On(SetResult, HandleErrorInternal, SetCancelledInternal);

33

// сообщаем асинхронной операции, что клиент уже не хочет получать результат

33

// сообщаем асинхронной операции, что клиент уже не хочет получать результат

34

// т.е. если он инициировал отмену, задача отменилась, вызвался обрабочик отмены

34

// т.е. если он инициировал отмену, задача отменилась, вызвался обрабочик отмены

35

// отбработчику сообщили, что результат уже не нужен и уже сам обработчик решает

35

// отбработчику сообщили, что результат уже не нужен и уже сам обработчик решает

36

// отдавать ли результат или подтвердить отмену (или вернуть ошибку).

36

// отдавать ли результат или подтвердить отмену (или вернуть ошибку).

37

CancellationRequested(p.Cancel);

37

CancellationRequested(p.Cancel);

38

} catch (Exception err) {

38

} catch (Exception err) {

39

SetErrorInternal(err);

39

SetErrorInternal(err);

40

}

40

}

41

} else {

41

} else {

42

SetCancelledInternal(reason);

42

SetCancelledInternal(reason);

43

}

43

}

44

}

44

}

45

46

protected void HandleErrorInternal(Exception error) {

46

protected void HandleErrorInternal(Exception error) {

47

if (m_error != null) {

47

if (m_error != null) {

48

try {

48

try {

49

var p = m_error(error);

49

var p = m_error(error);

50

p.On(SetResult, SetErrorInternal, SetCancelledInternal);

50

p.On(SetResult, SetErrorInternal, SetCancelledInternal);

51

CancellationRequested(p.Cancel);

51

CancellationRequested(p.Cancel);

52

} catch (Exception err) {

52

} catch (Exception err) {

53

SetErrorInternal(error);

53

SetErrorInternal(err);

54

}

54

}

55

} else {

55

} else {

56

SetErrorInternal(error);

56

SetErrorInternal(error);

57

}

57

}

58

}

58

}

59

60

}

60

}

61

}

61

}

62

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

             using System;
             using System.Threading;
             namespace Implab {
                 public class ActionChainTaskBase : AbstractTask {
                     readonly Func<Exception, IPromise> m_error;
                     readonly Func<Exception, IPromise> m_cancel;
                     protected ActionChainTaskBase(Func<Exception, IPromise> error, Func<Exception, IPromise> cancel, bool autoCancellable) {
                         m_error = error;
                         m_cancel = cancel;
                         if (autoCancellable)
                             CancellationRequested(CancelOperation);
                     }
                     public void Reject(Exception error) {
                         if (LockCancelation())
                             HandleErrorInternal(error);
                     }
                     public override void CancelOperation(Exception reason) {
                         if (LockCancelation())
                             // отмена вызвана до начала выполнения задачи
                             HandleCancelInternal(reason);
                     }
                     protected void HandleCancelInternal(Exception reason) {
                         if (m_cancel != null) {
                             try {
                                 // вызываем обработчик отмены
                                 var p = m_cancel(reason);
                                 p.On(SetResult, HandleErrorInternal, SetCancelledInternal);
                                 // сообщаем асинхронной операции, что клиент уже не хочет получать результат
                                 // т.е. если он инициировал отмену, задача отменилась, вызвался обрабочик отмены
                                 // отбработчику сообщили, что результат уже не нужен и уже сам обработчик решает
                                 // отдавать ли результат или подтвердить отмену (или вернуть ошибку).
                                 CancellationRequested(p.Cancel);
                             } catch (Exception err) {
                                 SetErrorInternal(err);
                             }
                         } else {
                             SetCancelledInternal(reason);
                         }
                     }
                     protected void HandleErrorInternal(Exception error) {
                         if (m_error != null) {
                             try {
                                 var p = m_error(error);
                                 p.On(SetResult, SetErrorInternal, SetCancelledInternal);
                                 CancellationRequested(p.Cancel);
                             } catch (Exception err) {
-                                SetErrorInternal(error);
+                                SetErrorInternal(err);
                             }
                         } else {
                             SetErrorInternal(error);
                         }
                     }
                 }
             }