summary refs log tree commit diff stats
path: root/tests/niminaction/Chapter7/Tweeter
diff options
context:
space:
mode:
Diffstat (limited to 'tests/niminaction/Chapter7/Tweeter')
0 files changed, 0 insertions, 0 deletions
 

generated by cgit-pink 1.4.1-2-gfad0 (git 2.36.2.497.gbbea4dcf42) at 2025-02-28 18:27:01 +0000


 


href='#n58'>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


n/blame/src/io/posixstream.nim?id=d963385cd9fd77f0a950c5b92be7774bbf76d661'>^

21178cc6 ^

4b482418 ^

27577126 ^

4b482418 ^









21178cc6 ^



1e858c87 ^

7b6a2c6d ^

1e858c87 ^







4b482418 ^



1e858c87 ^



d526deb9 ^

1e858c87 ^

4b482418 ^


1e858c87 ^



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









                                                                       
                







                                       















                                                                     



                              
                                                            
                 
                              
                      
                     
                                                                      








                     


                                         
                  
                       






                                                        


                                   


                                                   
                       
                             

                               
   
# stdlib file handling is broken, so we use this instead of FileStream.
import posix
import streams

type
  PosixStream* = ref object of Stream
    fd*: FileHandle
    isend*: bool

  ErrorAgain* = object of IOError
  ErrorWouldBlock* = object of IOError
  ErrorBadFD* = object of IOError
  ErrorFault* = object of IOError
  ErrorInterrupted* = object of IOError
  ErrorInvalid* = object of IOError

proc raisePosixIOError*() =
  # In the nim stdlib, these are only constants on linux amd64, so we
  # can't use a switch.
  if errno == EAGAIN:
    raise newException(ErrorAgain, "eagain")
  elif errno == EWOULDBLOCK:
    raise newException(ErrorWouldBlock, "would block")
  elif errno == EBADF:
    raise newException(ErrorBadFD, "bad fd")
  elif errno == EFAULT:
    raise newException(ErrorFault, "fault")
  elif errno == EINVAL:
    raise newException(ErrorInvalid, "invalid")
  else:
    raise newException(IOError, $strerror(errno))

proc psClose(s: Stream) =
  let s = cast[PosixStream](s)
  discard close(s.fd)

proc psReadData(s: Stream, buffer: pointer, len: int): int =
  assert len != 0
  let s = cast[PosixStream](s)
  let wasend = s.isend
  while result < len:
    let n = read(s.fd, cast[pointer](cast[int](buffer) + result), len)
    if n < 0:
      if result == 0:
        result = n
      break
    elif n == 0:
      s.isend = true
      break
    result += n
  if result == 0:
    if wasend:
      raise newException(EOFError, "eof")
    s.isend = true
  if result == -1:
    raisePosixIOError()

proc psWriteData(s: Stream, buffer: pointer, len: int) =
  let s = cast[PosixStream](s)
  let res = write(s.fd, buffer, len)
  if res == -1:
    raise newException(IOError, $strerror(errno))

proc psAtEnd(s: Stream): bool =
  return cast[PosixStream](s).isend

proc newPosixStream*(fd: FileHandle): PosixStream =
  return PosixStream(
    fd: fd,
    closeImpl: psClose,
    readDataImpl: psReadData,
    writeDataImpl: psWriteData,
    atEndImpl: psAtEnd
  )