update code use c99 and update code style

This commit is contained in:
vcaesar 2019-02-19 11:03:09 -04:00
parent fe1bbb57e6
commit 1da30b1d41
4 changed files with 33 additions and 21 deletions

View File

@ -566,7 +566,8 @@ static inline void port_list_free(port_list l) {
} }
/* Release each port in our list */ /* Release each port in our list */
for (size_t i = 0; i < l->len; i++) { size_t i;
for (i = 0; i < l->len; i++) {
eb_port_release(l->ports[i]); eb_port_release(l->ports[i]);
} }
@ -613,7 +614,8 @@ static inline bool port_list_rm(port_list l, eb_port p) {
eb_assert_or_bail(l->len <= l->cap, "Sanity-check failed"); eb_assert_or_bail(l->len <= l->cap, "Sanity-check failed");
/* Search for first occurence of the given port. If we find it, release it and move the last port in the list into the hole. */ /* Search for first occurence of the given port. If we find it, release it and move the last port in the list into the hole. */
for (size_t i = 0; i < l->len; i++) { size_t i;
for (i = 0; i < l->len; i++) {
if (l->ports[i] == p) { if (l->ports[i] == p) {
/* Move the last element in the port list into the now-vacant spot */ /* Move the last element in the port list into the now-vacant spot */
l->ports[i] = l->ports[l->len-1]; l->ports[i] = l->ports[l->len-1];
@ -639,7 +641,8 @@ static inline void port_list_signal_first(const port_list l, eb_port ignore) {
eb_port p = NULL; eb_port p = NULL;
eb_spinlock_lock(&l->lock); eb_spinlock_lock(&l->lock);
for (size_t i = 0; i < l->len; i++) { size_t i;
for (i = 0; i < l->len; i++) {
if (l->ports[i] != ignore) { if (l->ports[i] != ignore) {
p = eb_port_retain(l->ports[i]); p = eb_port_retain(l->ports[i]);
break; break;
@ -845,7 +848,8 @@ enum {
static inline void cleanup_ops(const do_state *state) { static inline void cleanup_ops(const do_state *state) {
assert(state); assert(state);
for (size_t i = 0; i < state->nops; i++) { size_t i;
for (i = 0; i < state->nops; i++) {
if (state->cleanup_ops[i]) { if (state->cleanup_ops[i]) {
eb_chan_op *op = state->ops[i]; eb_chan_op *op = state->ops[i];
eb_chan c = op->chan; eb_chan c = op->chan;
@ -1310,7 +1314,8 @@ eb_chan_op *eb_chan_select_list(eb_nsec timeout, eb_chan_op *const ops[], size_t
if (timeout == eb_nsec_zero) { if (timeout == eb_nsec_zero) {
/* ## timeout == 0: try every op exactly once; if none of them can proceed, return NULL. */ /* ## timeout == 0: try every op exactly once; if none of them can proceed, return NULL. */
for (size_t i = 0, idx = idx_start; i < nops; i++, idx = next_idx(nops, idx_delta, idx)) { size_t i, idx;
for (i = 0, idx = idx_start; i < nops; i++, idx = next_idx(nops, idx_delta, idx)) {
eb_chan_op *op = ops[idx]; eb_chan_op *op = ops[idx];
op_result r; op_result r;
while ((r = try_op(&state, op, idx)) == op_result_retry) { while ((r = try_op(&state, op, idx)) == op_result_retry) {
@ -1336,7 +1341,8 @@ eb_chan_op *eb_chan_select_list(eb_nsec timeout, eb_chan_op *const ops[], size_t
for (;;) { for (;;) {
/* ## Fast path: loop over our operations to see if one of them was able to send/receive. (If not, /* ## Fast path: loop over our operations to see if one of them was able to send/receive. (If not,
we'll enter the slow path where we put our thread to sleep until we're signaled.) */ we'll enter the slow path where we put our thread to sleep until we're signaled.) */
for (size_t i = 0, idx = idx_start; i < k_attempt_multiplier*nops; i++, idx = next_idx(nops, idx_delta, idx)) { size_t i, idx;
for (i = 0, idx = idx_start; i < k_attempt_multiplier*nops; i++, idx = next_idx(nops, idx_delta, idx)) {
eb_chan_op *op = ops[idx]; eb_chan_op *op = ops[idx];
op_result r = try_op(&state, op, idx); op_result r = try_op(&state, op, idx);
/* If the op completed, we need to exit! */ /* If the op completed, we need to exit! */
@ -1356,7 +1362,8 @@ eb_chan_op *eb_chan_select_list(eb_nsec timeout, eb_chan_op *const ops[], size_t
/* Register our port for the appropriate notifications on every channel. */ /* Register our port for the appropriate notifications on every channel. */
/* This adds 'port' to the channel's sends/recvs (depending on the op), which we clean up at the /* This adds 'port' to the channel's sends/recvs (depending on the op), which we clean up at the
end of this function. */ end of this function. */
for (size_t i = 0; i < nops; i++) { size_t i;
for (i = 0; i < nops; i++) {
eb_chan_op *op = ops[i]; eb_chan_op *op = ops[i];
eb_chan c = op->chan; eb_chan c = op->chan;
if (c) { if (c) {
@ -1368,7 +1375,8 @@ eb_chan_op *eb_chan_select_list(eb_nsec timeout, eb_chan_op *const ops[], size_t
/* Before we go to sleep, call try_op() for every op until we get a non-busy return value. This way we'll ensure /* Before we go to sleep, call try_op() for every op until we get a non-busy return value. This way we'll ensure
that no op is actually able to be performed, and we'll also ensure that 'port' is registered as the 'unbuf_port' that no op is actually able to be performed, and we'll also ensure that 'port' is registered as the 'unbuf_port'
for the necessary channels. */ for the necessary channels. */
for (size_t i = 0, idx = idx_start; i < nops; i++, idx = next_idx(nops, idx_delta, idx)) { // size_t i, idx;
for (i = 0, idx = idx_start; i < nops; i++, idx = next_idx(nops, idx_delta, idx)) {
eb_chan_op *op = ops[idx]; eb_chan_op *op = ops[idx];
op_result r; op_result r;
while ((r = try_op(&state, op, idx)) == op_result_retry) { while ((r = try_op(&state, op, idx)) == op_result_retry) {
@ -1406,7 +1414,8 @@ eb_chan_op *eb_chan_select_list(eb_nsec timeout, eb_chan_op *const ops[], size_t
/* Cleanup! */ /* Cleanup! */
cleanup: { cleanup: {
if (state.port) { if (state.port) {
for (size_t i = 0; i < nops; i++) { size_t i;
for (i = 0; i < nops; i++) {
eb_chan_op *op = ops[i]; eb_chan_op *op = ops[i];
eb_chan c = op->chan; eb_chan c = op->chan;
if (c) { if (c) {

View File

@ -52,7 +52,7 @@ void endPoll(){
void dispatch_proc(iohook_event * const event) { void dispatch_proc(iohook_event * const event) {
if(!sending) return; if(!sending) return;
// leaking memory? hope not // leaking memory? hope not
char* buffer = calloc(200,sizeof(char)); char* buffer = calloc(200, sizeof(char));
switch (event->type) { switch (event->type) {
case EVENT_HOOK_ENABLED: case EVENT_HOOK_ENABLED:
@ -99,17 +99,19 @@ void dispatch_proc(iohook_event * const event) {
fprintf(stderr,"\nError on file: %s, unusual event->type: %i\n",__FILE__,event->type); fprintf(stderr,"\nError on file: %s, unusual event->type: %i\n",__FILE__,event->type);
return; return;
} }
// to-do remove this for // to-do remove this for
for(int i = 0; i < 5; i++){ int i;
switch(eb_chan_try_send(events,buffer)){ // never block the hook callback for (i = 0; i < 5; i++) {
switch (eb_chan_try_send(events,buffer)) { // never block the hook callback
case eb_chan_res_ok: case eb_chan_res_ok:
i=5; i=5;
break; break;
default: default:
if (i == 4) { // let's not leak memory if (i == 4) { // let's not leak memory
free(buffer); free(buffer);
} }
continue; continue;
} }
} }

View File

@ -37,7 +37,7 @@
int vccode[100]; int vccode[100];
int codesz; int codesz;
char *cevent; char *cevent;
int rrevent; int rrevent;

View File

@ -31,6 +31,7 @@ import (
) )
const ( const (
// HookEnabled honk enable status
HookEnabled = 1 // iota HookEnabled = 1 // iota
HookDisabled = 2 HookDisabled = 2
@ -46,7 +47,7 @@ const (
MouseWheel = 11 MouseWheel = 11
FakeEvent = 12 FakeEvent = 12
//Keychar could be v // Keychar could be v
CharUndefined = 0xFFFF CharUndefined = 0xFFFF
WheelUp = -1 WheelUp = -1
WheelDown = 1 WheelDown = 1
@ -121,7 +122,7 @@ func RawcodetoKeychar(r uint16) string {
return raw2key[r] return raw2key[r]
} }
// KeychartoiRawcode key char to rawcode // KeychartoRawcode key char to rawcode
func KeychartoRawcode(kc string) uint16 { func KeychartoRawcode(kc string) uint16 {
return keytoraw[kc] return keytoraw[kc]
} }