mcs/class/corlib/System.IO/StreamAsyncResult.cs

   1 //
   2 // System.IO/StreamAsyncResult.cs
   3 //
   4 // Authors:
   5 //   Gonzalo Paniagua Javier (gonzalo@ximian.com)
   6 //
   7 // (c) 2004 Novell, Inc. (http://www.novell.com)
   8 //
   9
  10 //
  11 // Copyright (C) 2004 Novell, Inc (http://www.novell.com)
  12 //
  13 // Permission is hereby granted, free of charge, to any person obtaining
  14 // a copy of this software and associated documentation files (the
  15 // "Software"), to deal in the Software without restriction, including
  16 // without limitation the rights to use, copy, modify, merge, publish,
  17 // distribute, sublicense, and/or sell copies of the Software, and to
  18 // permit persons to whom the Software is furnished to do so, subject to
  19 // the following conditions:
  20 //
  21 // The above copyright notice and this permission notice shall be
  22 // included in all copies or substantial portions of the Software.
  23 //
  24 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  25 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  26 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  27 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
  28 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
  29 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
  30 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  31 //
  32
  33 using System.Threading;
  34
  35 namespace System.IO
  36 {
  37         class StreamAsyncResult : IAsyncResult {
  38                 object state;
  39                 bool completed;
  40                 bool done;
  41                 Exception exc;
  42                 int nbytes = -1;
  43                 ManualResetEvent wh;
  44
  45                 public StreamAsyncResult (object state)
  46                 {
  47                         this.state = state;
  48                 }
  49
  50                 public void SetComplete (Exception e)
  51                 {
  52                         exc = e;
  53                         completed = true;
  54                         lock (this) {
  55                                 if (wh != null)
  56                                         wh.Set ();
  57                         }
  58                 }
  59
  60                 public void SetComplete (Exception e, int nbytes)
  61                 {
  62                         this.nbytes = nbytes;
  63                         SetComplete (e);
  64                 }
  65
  66                 public object AsyncState {
  67                         get { return state; }
  68                 }
  69
  70                 public WaitHandle AsyncWaitHandle {
  71                         get {
  72                                 lock (this) {
  73                                         if (wh == null)
  74                                                 wh = new ManualResetEvent (completed);
  75
  76                                         return wh;
  77                                 }
  78                         }
  79                 }
  80
  81                 public virtual bool CompletedSynchronously {
  82                         get { return true; }
  83                 }
  84
  85                 public bool IsCompleted {
  86                         get { return completed; }
  87                 }
  88
  89                 public Exception Exception {
  90                         get { return exc; }
  91                 }
  92
  93                 public int NBytes {
  94                         get { return nbytes; }
  95                 }
  96
  97                 public bool Done {
  98                         get { return done; }
  99                         set { done = value; }
 100                 }
 101         }
 102 }
 103