aboutsummaryrefslogtreecommitdiff
path: root/src/lua-nng-aio.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/lua-nng-aio.c')
-rw-r--r--src/lua-nng-aio.c102
1 files changed, 51 insertions, 51 deletions
diff --git a/src/lua-nng-aio.c b/src/lua-nng-aio.c
index fa3db33..a4f8944 100644
--- a/src/lua-nng-aio.c
+++ b/src/lua-nng-aio.c
@@ -37,12 +37,12 @@ struct lnng_aio{
};
void lcallback(void *lfaa){
- printf("aio callback running\n");
+ /*printf("aio callback running\n");*/
struct lnng_aio *l = (struct lnng_aio*)lfaa;
lua_State *L = l->L;
- printf("At the beginning we have: %d\n",lua_gettop(L));
+ /*printf("At the beginning we have: %d\n",lua_gettop(L));*/
for(int i = 1; i <= lua_gettop(L); i++){
- printf("-%d - %s\n",i,lua_typename(L,lua_type(L,-i)));
+ /*printf("-%d - %s\n",i,lua_typename(L,lua_type(L,-i)));*/
lua_getglobal(L,"print");
lua_pushvalue(L,i);
lua_call(L,1,0);
@@ -50,25 +50,25 @@ void lcallback(void *lfaa){
lua_getglobal(L,"table");//{table}
lua_pushcfunction(L,traceback);//{table},traceback()
lua_rawgeti(L,LUA_REGISTRYINDEX, l->func);//{table},traceback(),callb()
- printf("foo\n");
+ /*printf("foo\n");*/
lua_getfield(L,-3,"unpack");//{table},traceback(),callb(),table.unpack()
- printf("unpacked\n");
- printf("unpack, -1 - %s\n",lua_typename(L,lua_type(L,-1)));
- printf("Args was: %d\n",l->args);
+ /*printf("unpacked\n");*/
+ /*printf("unpack, -1 - %s\n",lua_typename(L,lua_type(L,-1)));*/
+ /*printf("Args was: %d\n",l->args);*/
lua_rawgeti(L,LUA_REGISTRYINDEX, l->args);//{table},traceback(),callb(),table.unpack(),{args}
- printf("got args\n");
- printf("-2 - %s\n",lua_typename(L,lua_type(L,-2)));
- printf("-1 - %s\n",lua_typename(L,lua_type(L,-1)));
+ /*printf("got args\n");*/
+ /*printf("-2 - %s\n",lua_typename(L,lua_type(L,-2)));*/
+ /*printf("-1 - %s\n",lua_typename(L,lua_type(L,-1)));*/
lua_call(L, 1, LUA_MULTRET);//{table},traceback(), callb(), args...
- printf("bar\n");
- printf("Top: %d\n",lua_gettop(L));
+ /*printf("bar\n");*/
+ /*printf("Top: %d\n",lua_gettop(L));*/
for(int i = 1; i <= lua_gettop(L); i++){
- printf("-%d - %s\n",i,lua_typename(L,lua_type(L,-i)));
+ /*printf("-%d - %s\n",i,lua_typename(L,lua_type(L,-i)));*/
}
int numargs = lua_gettop(L) - 3;
- printf("Nargs:%d\n",numargs);
+ /*printf("Nargs:%d\n",numargs);*/
lua_pcall(L, numargs, 0, 2);//{table},traceback()
- printf("Finished with everything, poping last 2 and returning\n");
+ /*printf("Finished with everything, poping last 2 and returning\n");*/
lua_pop(L,2);//
}
@@ -77,7 +77,7 @@ int lnng_aio_alloc(lua_State *L){
int argc = lua_gettop(L);//callback(), args...
lua_createtable(L,argc - 1, 0);//callback(), args..., {}
for(int i = 1; i < argc; i++){
- printf("Adding element %d to arg table (%s)\n",i,lua_typename(L,lua_type(L,i + 1)));
+ /*printf("Adding element %d to arg table (%s)\n",i,lua_typename(L,lua_type(L,i + 1)));*/
lua_pushnumber(L, i);
lua_getglobal(L,"print");
lua_pushvalue(L, i + 1);
@@ -97,7 +97,7 @@ int lnng_aio_alloc(lua_State *L){
int err = nng_aio_alloc(&aio, lcallback, (void*)lfaa);
lfaa->aio = aio;
if(err == 0){
- printf("After aio_alloc we have:%d",lua_gettop(L));
+ /*printf("After aio_alloc we have:%d",lua_gettop(L));*/
luaL_setmetatable(L,"nng.aio.struct");
return 1;
}else{
@@ -114,13 +114,13 @@ struct nng_aio* toaio(lua_State *L, int index){
//sleep(duration, aio)
int lnng_aio_sleep(lua_State *L){
- printf("sleep called\n");
+ /*printf("sleep called\n");*/
int duration = luaL_checkinteger(L,1);
- printf("Duration was %d\n");
+ /*printf("Duration was %d\n");*/
nng_aio *aio = toaio(L,2);
- printf("Got aio: %p\n",aio);
+ /*printf("Got aio: %p\n",aio);*/
nng_sleep_aio(duration, aio);
- printf("did sleep\n");
+ /*printf("did sleep\n");*/
return 0;
}
@@ -135,15 +135,15 @@ struct callback_info {
};
void push_callback(void *v){
- printf("aio callback received!\n");
+ /*printf("aio callback received!\n");*/
struct callback_info *ci = (struct callback_info*)v;
lua_State *L = ci->L;
- printf("About to lock lua state in callback\n");
+ /*printf("About to lock lua state in callback\n");*/
nng_mtx_lock(ci->lmutex);//lock the lua state
- printf("Done locking lua state in callback\n");
+ /*printf("Done locking lua state in callback\n");*/
int err = nng_aio_result(ci->aio);
if(err != 0){
- printf("This callback was canceled or timed out: %d: %s\n", err, nng_strerror(err));
+ /*printf("This callback was canceled or timed out: %d: %s\n", err, nng_strerror(err));*/
nng_mtx_unlock(ci->lmutex);
return;
}
@@ -156,15 +156,15 @@ void push_callback(void *v){
nng_msg_free(msg);
ci->completed = 1;
lua_settable(L,1);
- printf("About to unlock lua state in callback\n");
+ /*printf("About to unlock lua state in callback\n");*/
nng_mtx_unlock(ci->lmutex);
- printf("About to lock condition mutex in callback\n");
+ /*printf("About to lock condition mutex in callback\n");*/
nng_mtx_lock(ci->cmutex);
- printf("About wake condition\n");
+ /*printf("About wake condition\n");*/
nng_cv_wake(ci->cv);
- printf("Done wake condition\n");
+ /*printf("Done wake condition\n");*/
nng_mtx_unlock(ci->cmutex);
- printf("Done with callback\n");
+ /*printf("Done with callback\n");*/
}
//TODO: there is a wierd bug here:
@@ -177,45 +177,45 @@ int lnng_aio_recv(lua_State *L){
err |= nng_mtx_alloc(&callbackmtx);
err |= nng_mtx_alloc(&setupmtx);
if(err != 0){
- printf("Something when wrong when allocating mutexes\n");
+ /*printf("Something when wrong when allocating mutexes\n");*/
lua_pushboolean(L,0);
lua_pushstring(L,nng_strerror(err));
return 2;
}
int argv = lua_gettop(L);
- printf("Receiving any on %d sockets\n",argv);
+ /*printf("Receiving any on %d sockets\n",argv);*/
struct callback_info **cis = (struct callback_info**)malloc(sizeof(struct callback_info*) * argv);
nng_mtx_lock(luamtx);
- printf("Locked lua state\n");
+ /*printf("Locked lua state\n");*/
nng_cv *cv;
nng_cv_alloc(&cv, callbackmtx);
/*nng_mtx_lock(callbackmtx);//wait for one of the callbacks to happen*/
- printf("Callback 1 happened\n");
+ /*printf("Callback 1 happened\n");*/
for(int i = 0; i < argv; i++){
- printf("\tSetting up async %d\n", i);
+ /*printf("\tSetting up async %d\n", i);*/
nng_socket *sock = tosocket(L,-1);
int sref = luaL_ref(L,LUA_REGISTRYINDEX);
- printf("\tGot socket ref %d\n", sref);
+ /*printf("\tGot socket ref %d\n", sref);*/
cis[i] = (struct callback_info*)malloc(sizeof(struct callback_info));
struct callback_info *ci = cis[i];
- printf("\tLooking at ci %p\n",ci);
+ /*printf("\tLooking at ci %p\n",ci);*/
ci->L = L;
ci->lmutex = luamtx;
ci->cmutex = callbackmtx;
ci->socketref = sref;
ci->completed = 0;
ci->cv = cv;
- printf("\tAbout to alloc aio\n");
+ /*printf("\tAbout to alloc aio\n");*/
nng_aio_alloc(&(ci->aio), push_callback, ci);
- printf("\tAllocated aio\n");
- printf("\tEverything else set on callback info\n");
+ /*printf("\tAllocated aio\n");*/
+ /*printf("\tEverything else set on callback info\n");*/
nng_recv_aio(*sock, ci->aio);
- printf("\tSet up async receive %d\n",i);
+ /*printf("\tSet up async receive %d\n",i);*/
}
lua_newtable(L);//table that will hold [socket] = message
- printf("About to unlock lua state\n");
+ /*printf("About to unlock lua state\n");*/
nng_mtx_unlock(luamtx);
- printf("Unlocked lua state\n");
+ /*printf("Unlocked lua state\n");*/
/*nng_mtx_lock(callbackmtx);//was unlocked by the callback, luamtx is locked at this point*/
int complete = 0;
nng_mtx_lock(callbackmtx);
@@ -223,30 +223,30 @@ int lnng_aio_recv(lua_State *L){
for(int i = 0; i < argv; i++){
struct callback_info *ci = cis[i];
if(ci->completed > 0){
- printf("At least 1 completed! breaking!\n");
+ /*printf("At least 1 completed! breaking!\n");*/
complete = 1;
goto found;
}
}
- printf("About to wait\n");
+ /*printf("About to wait\n");*/
nng_cv_wait(cv);
- printf("Done waiting, complete is: %d\n", complete);
+ /*printf("Done waiting, complete is: %d\n", complete);*/
}
found:
- printf("Callback 2 happened\n");
+ /*printf("Callback 2 happened\n");*/
nng_mtx_unlock(callbackmtx);
- printf("Callback done\n");
+ /*printf("Callback done\n");*/
for(int i = 0; i < argv; i++){
struct callback_info *ci = cis[i];
- printf("About to stop aio %d\n",ci->aio);
+ /*printf("About to stop aio %d\n",ci->aio);*/
/*nng_aio_cancel(ci->aio);*/
nng_aio_stop(ci->aio);
nng_aio_free(ci->aio);
free(ci);
- printf("Stopped aio %d\n",ci->aio);
+ /*printf("Stopped aio %d\n",ci->aio);*/
}
free(cis);
- printf("Freeing things\n");
+ /*printf("Freeing things\n");*/
nng_cv_free(cv);
nng_mtx_free(callbackmtx);
nng_mtx_unlock(luamtx);//mutexes must not be locked when they are freed
generated by cgit v1.2.3-70-g09d2 (git 2.46.0) at 2026-01-18 05:16:56 +0000