src/buffer_event.c

changeset 57
e20f175aa158
parent 55
dd80d289e1cc
child 58
03d12148100c
equal deleted inserted replaced
56:b5b5ff03a4a3 57:e20f175aa158
139 lua_getfenv(L, 1); 139 lua_getfenv(L, 1);
140 lua_rawgeti(L, -1, WRITE_BUFFER_LOCATION); 140 lua_rawgeti(L, -1, WRITE_BUFFER_LOCATION);
141 return 1; 141 return 1;
142 } 142 }
143 143
144 static int buffer_event_set_read_watermarks(lua_State* L) {
145 int low, high;
146 le_bufferevent* ev = buffer_event_get(L, 1);
147 if(!ev->ev) return 0;
148
149 low = lua_tonumber(L, 2);
150 high = lua_tonumber(L, 3);
151
152 ev->ev->wm_read.low = low;
153 ev->ev->wm_read.high = high;
154 return 0;
155 }
156
157 static int buffer_event_set_write_watermarks(lua_State* L) {
158 int low, high;
159 le_bufferevent* ev = buffer_event_get(L, 1);
160 if(!ev->ev) return 0;
161
162 low = lua_tonumber(L, 2);
163 high = lua_tonumber(L, 3);
164
165 ev->ev->wm_write.low = low;
166 ev->ev->wm_write.high = high;
167 return 0;
168 }
169
144 static luaL_Reg buffer_event_funcs[] = { 170 static luaL_Reg buffer_event_funcs[] = {
145 {"get_read", buffer_event_get_read}, 171 {"get_read", buffer_event_get_read},
146 {"get_write", buffer_event_get_write}, 172 {"get_write", buffer_event_get_write},
173 {"set_read_watermarks", buffer_event_set_read_watermarks},
174 {"set_write_watermarks", buffer_event_set_write_watermarks},
147 {NULL, NULL} 175 {NULL, NULL}
148 }; 176 };
149 177
150 static luaL_Reg funcs[] = { 178 static luaL_Reg funcs[] = {
151 {"new", buffer_event_push}, 179 {"new", buffer_event_push},

mercurial