nxt-decompiled/Nxt$UserAsyncListener.java at master · DeepCoin/nxt-decompiled · GitHub

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
import java.io.IOException;
import java.io.PrintWriter;
import java.io.Writer;
import javax.servlet.AsyncContext;
import javax.servlet.AsyncEvent;
import javax.servlet.AsyncListener;
import javax.servlet.ServletResponse;
import org.json.simple.JSONObject;

class Nxt$UserAsyncListener
  implements AsyncListener
{
  final Nxt.User user;

  Nxt$UserAsyncListener(Nxt.User paramUser)
  {
    this.user = paramUser;
  }

  public void onComplete(AsyncEvent paramAsyncEvent)
    throws IOException
  {}

  public void onError(AsyncEvent paramAsyncEvent)
    throws IOException
  {
    synchronized (this.user)
    {
      this.user.asyncContext.getResponse().setContentType("text/plain; charset=UTF-8");
      PrintWriter localPrintWriter = this.user.asyncContext.getResponse().getWriter();
      Object localObject1 = null;
      try
      {
        new JSONObject().writeJSONString(localPrintWriter);
      }
      catch (Throwable localThrowable2)
      {
        localObject1 = localThrowable2;
        throw localThrowable2;
      }
      finally
      {
        if (localPrintWriter != null) {
          if (localObject1 != null) {
            try
            {
              localPrintWriter.close();
            }
            catch (Throwable localThrowable3)
            {
              localObject1.addSuppressed(localThrowable3);
            }
          } else {
            localPrintWriter.close();
          }
        }
      }
      this.user.asyncContext.complete();
      this.user.asyncContext = null;
    }
  }

  public void onStartAsync(AsyncEvent paramAsyncEvent)
    throws IOException
  {}

  public void onTimeout(AsyncEvent paramAsyncEvent)
    throws IOException
  {
    synchronized (this.user)
    {
      this.user.asyncContext.getResponse().setContentType("text/plain; charset=UTF-8");
      PrintWriter localPrintWriter = this.user.asyncContext.getResponse().getWriter();
      Object localObject1 = null;
      try
      {
        new JSONObject().writeJSONString(localPrintWriter);
      }
      catch (Throwable localThrowable2)
      {
        localObject1 = localThrowable2;
        throw localThrowable2;
      }
      finally
      {
        if (localPrintWriter != null) {
          if (localObject1 != null) {
            try
            {
              localPrintWriter.close();
            }
            catch (Throwable localThrowable3)
            {
              localObject1.addSuppressed(localThrowable3);
            }
          } else {
            localPrintWriter.close();
          }
        }
      }
      this.user.asyncContext.complete();
      this.user.asyncContext = null;
    }
  }