Skip to content

Commit 4e63372

Browse files
committed
rename struct
1 parent fffc2b9 commit 4e63372

File tree

5 files changed

+9
-9
lines changed

5 files changed

+9
-9
lines changed

DESCRIPTION

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
Package: nanonext
22
Type: Package
33
Title: NNG (Nanomsg Next Gen) Lightweight Messaging Library
4-
Version: 1.2.1.9011
4+
Version: 1.2.1.9012
55
Description: R binding for NNG (Nanomsg Next Gen), a successor to ZeroMQ. NNG is
66
a socket library implementing 'Scalability Protocols', a reliable,
77
high-performance standard for common communications patterns including

NEWS.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
# nanonext 1.2.1.9011 (development)
1+
# nanonext 1.2.1.9012 (development)
22

33
#### New Features
44

src/aio.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -209,7 +209,7 @@ SEXP rnng_aio_get_msg(SEXP env) {
209209
case RECVAIOS:
210210
case REQAIOS:
211211
case IOV_RECVAIOS: ;
212-
nano_cv *ncv = (nano_cv *) (raio->type == REQAIOS ? ((nano_sendaio *) raio->next)->next : raio->next);
212+
nano_cv *ncv = (nano_cv *) (raio->type == REQAIOS ? ((nano_rsaio *) raio->next)->next : raio->next);
213213
nng_mtx *mtx = ncv->mtx;
214214
nng_mtx_lock(mtx);
215215
res = raio->result;

src/nanonext.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -184,10 +184,10 @@ typedef struct nano_aio_s {
184184
nano_aio_typ type;
185185
} nano_aio;
186186

187-
typedef struct nano_sendaio_s {
187+
typedef struct nano_rsaio_s {
188188
nng_aio *aio;
189189
void *next;
190-
} nano_sendaio;
190+
} nano_rsaio;
191191

192192
typedef struct nano_cv_s {
193193
int condition;

src/sync.c

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ static void request_complete_dropcon(void *arg) {
5454
static void request_complete_signal(void *arg) {
5555

5656
nano_aio *raio = (nano_aio *) arg;
57-
nano_cv *ncv = (nano_cv *) ((nano_sendaio *) raio->next)->next;
57+
nano_cv *ncv = (nano_cv *) ((nano_rsaio *) raio->next)->next;
5858
nng_cv *cv = ncv->cv;
5959
nng_mtx *mtx = ncv->mtx;
6060

@@ -180,7 +180,7 @@ static void request_finalizer(SEXP xptr) {
180180

181181
if (NANO_PTR(xptr) == NULL) return;
182182
nano_aio *xp = (nano_aio *) NANO_PTR(xptr);
183-
nano_sendaio *saio = (nano_sendaio *) xp->next;
183+
nano_rsaio *saio = (nano_rsaio *) xp->next;
184184
nng_aio_free(saio->aio);
185185
nng_aio_free(xp->aio);
186186
if (xp->data != NULL)
@@ -438,13 +438,13 @@ SEXP rnng_request(SEXP con, SEXP data, SEXP sendmode, SEXP recvmode, SEXP timeou
438438

439439
SEXP aio, env, fun;
440440
nano_buf buf;
441-
nano_sendaio *saio;
441+
nano_rsaio *saio;
442442
nano_aio *raio;
443443
nng_msg *msg;
444444
int xc;
445445

446446
nano_encodes(sendmode) == 2 ? nano_encode(&buf, data) : nano_serialize(&buf, data, NANO_PROT(con));
447-
saio = R_Calloc(1, nano_sendaio);
447+
saio = R_Calloc(1, nano_rsaio);
448448
saio->next = ncv;
449449

450450
if ((xc = nng_msg_alloc(&msg, 0)))

0 commit comments

Comments
 (0)