src/buffer_event.c

changeset 97
dfe23f13242d
parent 96
570e309a8d3e
child 102
dc3809bf780a
equal deleted inserted replaced
96:570e309a8d3e 97:dfe23f13242d
151 if(!ev->ev) return 0; 151 if(!ev->ev) return 0;
152 152
153 low = lua_tonumber(L, 2); 153 low = lua_tonumber(L, 2);
154 high = lua_tonumber(L, 3); 154 high = lua_tonumber(L, 3);
155 155
156 ev->ev->wm_read.low = low; 156 bufferevent_setwatermark(ev->ev, EV_READ, low, high);
157 ev->ev->wm_read.high = high;
158 return 0; 157 return 0;
159 } 158 }
160 159
161 static int buffer_event_set_write_watermarks(lua_State* L) { 160 static int buffer_event_set_write_watermarks(lua_State* L) {
162 int low, high; 161 int low, high;
164 if(!ev->ev) return 0; 163 if(!ev->ev) return 0;
165 164
166 low = lua_tonumber(L, 2); 165 low = lua_tonumber(L, 2);
167 high = lua_tonumber(L, 3); 166 high = lua_tonumber(L, 3);
168 167
169 ev->ev->wm_write.low = low; 168 bufferevent_setwatermark(ev->ev, EV_WRITE, low, high);
170 ev->ev->wm_write.high = high;
171 return 0; 169 return 0;
172 } 170 }
173 171
174 static int buffer_event_set_timeouts(lua_State* L) { 172 static int buffer_event_set_timeouts(lua_State* L) {
175 int timeout_read, timeout_write; 173 int timeout_read, timeout_write;

mercurial