summary refs log tree commit diff stats
path: root/TODO
diff options
context:
space:
mode:
Diffstat (limited to 'TODO')
-rw-r--r--TODO2
1 files changed, 1 insertions, 1 deletions
diff --git a/TODO b/TODO
index da5e686e..8d8b65f5 100644
--- a/TODO
+++ b/TODO
@@ -24,7 +24,7 @@ General
    (X) #22  10/01/03  add getopt options to change flags/mode
    (X) #29  10/01/06  add chmod command
    (X) #30  10/01/06  add a way to create symlinks
-   ( ) #32  10/01/08  place the (hidden) cursor to a meaningful position
+   (X) #32  10/01/08  place the (hidden) cursor to a meaningful position
    (X) #34  10/01/09  display free disk space
    (X) #35  10/01/09  display disk usage of files in current directory
    ( ) #36  10/01/11  help coloring is terribly inefficient
generated by cgit-pink 1.4.1-2-gfad0 (git 2.36.2.497.gbbea4dcf42) at 2024-12-27 07:01:45 +0000
id=88f9b692af5cf402e7022a0b39c5bccd129f1fe8'>^ 
563174a ^








28facff ^


563174a ^



27b6c24 ^

c3f5553

563174a ^




27b6c24 ^


c3f5553


5649bb2 ^


01aa975 ^










































3523bbd ^

9f6eff6 ^

9f6eff6 ^

3523bbd ^


9f6eff6 ^



01aa975 ^


106064e ^

01aa975 ^

106064e ^

01aa975 ^


106064e ^


01aa975 ^

106064e ^



01aa975 ^









9f6eff6 ^


3523bbd ^



9f6eff6 ^

9f6eff6 ^

01aa975 ^








3523bbd ^











9f6eff6 ^

3523bbd ^



9f6eff6 ^

3523bbd ^



9f6eff6 ^

106064e ^






3523bbd ^


5649bb2 ^

5b9130d ^


f3be424 ^

5b9130d ^

476e00f ^


087b8ef ^




5b9130d ^



563174a ^


f3be424 ^


5b9130d ^







476e00f ^

5b9130d ^




563174a ^




5b9130d ^

a4e6141 ^

5b9130d ^



e018867 ^



5b9130d ^






1c8f4ad ^

5b9130d ^

1c8f4ad ^


5b9130d ^



e018867 ^



5b9130d ^






1c8f4ad ^

5b9130d ^

1c8f4ad ^


5b9130d ^

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

                   

                   
                       
 

                                                 


                                                       

                                     







                                                           

                    


 
                                                                     
                                 



                                        

                          

           

 









































                                                                               
 
 
 

                                                          


 

                                           
                    
 
                                     

           

                                      
 


                                                   








                                                 

                                                                


                  
                                                                          
 







                                                                              










                                                                     
 


                                                                          
 


                                                                 
 





                                                             

                 
 

 
                                                   
                                                

                     



                                                                 


                    

                                        

                                                  






                                                     
                     



                     



                                        
 
           


 


                                                      





                          
                        
                                              

                                 


 


                                                     





                          
                        
                                    

                                 
 
#include <stdlib.h>
#include <string.h>

#include "src/common.h"

static void uv_link_maybe_close(uv_link_t* link);

static void uv_link_def_alloc_cb(uv_link_t* link,
                                 size_t suggested_size,
                                 uv_buf_t* buf) {
  buf->base = malloc(suggested_size);
  buf->len = suggested_size;

  CHECK_NE(buf->base, NULL, "uv_link_t: alloc_cb failure");
}


static void uv_link_def_read_cb(uv_link_t* link,
                                ssize_t nread,
                                const uv_buf_t* buf) {
  if (buf != NULL)
    free(buf->base);
}


int uv_link_init(uv_link_t* link, uv_link_methods_t const* methods) {
  memset(link, 0, sizeof(*link));

  link->alloc_cb = uv_link_def_alloc_cb;
  link->read_cb = uv_link_def_read_cb;

  link->methods = methods;

  return 0;
}


#define CLOSE_WRAP(RES)                                                       \
    do {                                                                      \
      int err;                                                                \
      link->close_depth++;                                                    \
      err = (RES);                                                            \
      if (--link->close_depth == 0)                                           \
        uv_link_maybe_close(link);                                            \
      return err;                                                             \
    } while (0)


int uv_link_propagate_write(uv_link_t* link, uv_link_t* source,
                            const uv_buf_t bufs[], unsigned int nbufs,
                            uv_stream_t* send_handle,
                            uv_link_write_cb cb, void* arg) {
  CLOSE_WRAP(link->methods->write(link, source, bufs, nbufs, send_handle, cb,
                                  arg));
}


int uv_link_propagate_shutdown(uv_link_t* link,
                               uv_link_t* source,
                               uv_link_shutdown_cb cb,
                               void* arg) {
  CLOSE_WRAP(link->methods->shutdown(link, source, cb, arg));
}


int uv_link_read_start(uv_link_t* link) {
  CLOSE_WRAP(link->methods->read_start(link));
}


int uv_link_read_stop(uv_link_t* link) {
  CLOSE_WRAP(link->methods->read_stop(link));
}


int uv_link_try_write(uv_link_t* link,
                      const uv_buf_t bufs[],
                      unsigned int nbufs) {
  CLOSE_WRAP(link->methods->try_write(link, bufs, nbufs));
}


void uv_link_close(uv_link_t* link, uv_link_close_cb cb) {
  uv_link_propagate_close(link, link, cb);
}


void uv_link_maybe_close(uv_link_t* link) {
  uv_link_close_cb cb;
  uv_link_t* source;

  if (link->pending_close_cb == NULL)
    return;

  cb = link->pending_close_cb;
  source = link->pending_close_source;

  link->pending_close_cb = NULL;
  link->pending_close_source = NULL;
  return uv_link_propagate_close(link, source, cb);
}


static void uv_link_close_join(uv_link_t* link) {
  if (--link->close_waiting == 0)
    return link->saved_close_cb(link);
}


void uv_link_propagate_close(uv_link_t* link, uv_link_t* source,
                             uv_link_close_cb cb) {
  uv_link_t* root;
  int count;

  CHECK_EQ(link->child, NULL, "uv_link_t: attempt to close chained link");

  /* We are in an API call, wait for it to end before destroying everything */
  if (link->close_depth != 0) {
    CHECK_EQ(link, source, "pending close_cb for non-leaf link");

    link->saved_close_cb = cb;
    return;
  }

  /* Find root */
  count = 1;
  for (root = link; root->parent != NULL; root = root->parent)
    count++;

  /* NOTE: This is very important line. Only because we `+=` here the
   * recursive propagation is possible
   */
  source->close_waiting += count;

  source->saved_close_cb = cb;

  /* Go from the root to the leaf, disconnecting and closing everything */
  while (root != NULL) {
    uv_link_t* child;

    child = root->child;
    if (child != NULL)
      CHECK_EQ(uv_link_unchain(root, child), 0, "close unchain");

    if (root->close_depth == 0) {
      root->methods->close(root, source, uv_link_close_join);
    } else {
      root->pending_close_cb = uv_link_close_join;
      root->pending_close_source = source;
    }
    root = child;
  }
}


int uv_link_chain(uv_link_t* from, uv_link_t* to) {
  if (from->child != NULL || to->parent != NULL)
    return UV_EINVAL;

  CHECK(to->methods->alloc_cb_override != NULL &&
            to->methods->read_cb_override != NULL,
        "Attempting to chain link without overriding callbacks");

  from->child = to;
  to->parent = from;

  from->saved_alloc_cb = from->alloc_cb;
  from->saved_read_cb = from->read_cb;
  from->alloc_cb = to->methods->alloc_cb_override;
  from->read_cb = to->methods->read_cb_override;

  return 0;
}


int uv_link_unchain(uv_link_t* from, uv_link_t* to) {
  if (from->child != to || to->parent != from)
    return UV_EINVAL;

  from->child = NULL;
  to->parent = NULL;

  from->alloc_cb = from->saved_alloc_cb;
  from->read_cb = from->saved_read_cb;
  from->saved_alloc_cb = NULL;
  from->saved_read_cb = NULL;

  return 0;
}


void uv_link_propagate_alloc_cb(uv_link_t* link,
                                size_t suggested_size,
                                uv_buf_t* buf) {
  uv_link_t* target;

  target = link;
  if (link->child != NULL)
    target = link->child;

  target->close_depth++;
  link->alloc_cb(target, suggested_size, buf);
  if (--target->close_depth == 0)
    uv_link_maybe_close(target);
}


void uv_link_propagate_read_cb(uv_link_t* link,
                               ssize_t nread,
                               const uv_buf_t* buf) {
  uv_link_t* target;

  target = link;
  if (link->child != NULL)
    target = link->child;

  target->close_depth++;
  link->read_cb(target, nread, buf);
  if (--target->close_depth == 0)
    uv_link_maybe_close(target);
}
generated by cgit-pink 1.4.1-2-gfad0 (git 2.36.2.497.gbbea4dcf42) at 2024-12-27 07:01:45 +0000