/dports/net/kamailio/kamailio-5.4.5/src/modules/ndb_redis/ |
H A D | redis_client.c | 93 for(rsrv=_redisc_srv_list; rsrv; rsrv=rsrv->next) in redisc_init() 318 rsrv=rsrv->next; in redisc_destroy() 361 rsrv->hname = get_hash1_raw(rsrv->sname->s, rsrv->sname->len); in redisc_add_server() 396 rsrv->sname->len, rsrv->sname->s); in redisc_get_server() 400 rsrv=rsrv->next; in redisc_get_server() 695 rsrv->sname->len,rsrv->sname->s); in redisc_create_pipelined_message() 751 rsrv->sname->len,rsrv->sname->s); in redisc_exec_pipelined() 1130 (rsrv)?rsrv->sname->len:0, in redisc_exec_argv() 1131 (rsrv)?rsrv->sname->s:""); in redisc_exec_argv() 1139 (rsrv)?rsrv->sname->len:0, in redisc_exec_argv() [all …]
|
H A D | redis_client.h | 91 int redisc_reconnect_server(redisc_server_t *rsrv); 97 int redisc_exec_pipelined(redisc_server_t *rsrv); 98 int redisc_create_pipelined_message(redisc_server_t *rsrv); 99 void redisc_free_pipelined_cmds(redisc_server_t *rsrv); 100 redisReply* redisc_exec_argv(redisc_server_t *rsrv, int argc, const char **argv, 104 int redisc_check_auth(redisc_server_t *rsrv, char *pass); 105 int redis_check_server(redisc_server_t *rsrv); 106 int redis_count_err_and_disable(redisc_server_t *rsrv);
|
/dports/net/kamailio/kamailio-5.4.5/src/modules/ndb_mongodb/ |
H A D | mongodb_client.c | 57 for(rsrv=_mongodbc_srv_list; rsrv; rsrv=rsrv->next) in mongodbc_init() 61 rsrv->sname->len, rsrv->sname->s); in mongodbc_init() 67 rsrv->sname->len, rsrv->sname->s, in mongodbc_init() 68 rsrv->uri->len, rsrv->uri->s); in mongodbc_init() 101 rsrv=rsrv->next; in mongodbc_destroy() 143 rsrv->hname = get_hash1_raw(rsrv->sname->s, rsrv->sname->len); in mongodbc_add_server() 146 if(rsrv->uri->s[rsrv->uri->len]!='\0') rsrv->uri->s[rsrv->uri->len]='\0'; in mongodbc_add_server() 155 rsrv->sname->len, rsrv->sname->s, in mongodbc_add_server() 156 rsrv->uri->len, rsrv->uri->s); in mongodbc_add_server() 184 rsrv=rsrv->next; in mongodbc_get_server() [all …]
|
/dports/shells/ksh93-devel/ast-cc1bca27/src/lib/librecsort/ |
H A D | rswrite.c | 57 { if(rsrv && sfwrite(f,rsrv,cur-rsrv) != cur-rsrv) return -1; \ 63 endrsrv = (cur = rsrv) + rw; \ 82 reg uchar *d, *cur, *endrsrv, *rsrv; local 100 { rsrv = rs->rsrv; endrsrv = rs->endrsrv; cur = rs->cur; 104 { rsrv = cur = endrsrv = NIL(uchar*); 140 RESERVE(rs,f,rsrv,endrsrv,cur,w); 242 RESERVE(rs,f,rsrv,endrsrv,cur,w); 279 RESERVE(rs,f,rsrv,endrsrv,cur,w); 311 { rs->rsrv = rsrv; rs->endrsrv = endrsrv; rs->cur = cur; 314 { if(rsrv) [all …]
|
H A D | rsmerge.c | 64 { if(rsrv && sfread(mg->f,rsrv,cur-rsrv) != cur-rsrv) { MGSETEOF(mg); action;} \ 79 { if(rsrv && sfwrite(rs->f,rsrv,cur-rsrv) != cur-rsrv) { action;} \ 92 { sfwrite(rs->f,rs->rsrv,rs->cur-rs->rsrv); \ 159 cur = mg->cur; rsrv = mg->rsrv; endrsrv = mg->endrsrv; 359 mg->rsrv = rsrv; mg->endrsrv = endrsrv; mg->cur = cur; 376 if(mg->rsrv) 377 sfread(mg->f,mg->rsrv,mg->cur-mg->rsrv); 580 rsrv = rs->rsrv; endrsrv = rs->endrsrv; cur = rs->cur; 587 { if(rsrv) 588 { sfwrite(rs->f, rsrv, cur-rsrv); [all …]
|
/dports/shells/ksh93/ast-93u/src/lib/librecsort/ |
H A D | rswrite.c | 57 { if(rsrv && sfwrite(f,rsrv,cur-rsrv) != cur-rsrv) return -1; \ 63 endrsrv = (cur = rsrv) + rw; \ 82 reg uchar *d, *cur, *endrsrv, *rsrv; local 100 { rsrv = rs->rsrv; endrsrv = rs->endrsrv; cur = rs->cur; 104 { rsrv = cur = endrsrv = NIL(uchar*); 140 RESERVE(rs,f,rsrv,endrsrv,cur,w); 242 RESERVE(rs,f,rsrv,endrsrv,cur,w); 279 RESERVE(rs,f,rsrv,endrsrv,cur,w); 311 { rs->rsrv = rsrv; rs->endrsrv = endrsrv; rs->cur = cur; 314 { if(rsrv) [all …]
|
H A D | rsmerge.c | 64 { if(rsrv && sfread(mg->f,rsrv,cur-rsrv) != cur-rsrv) { MGSETEOF(mg); action;} \ 79 { if(rsrv && sfwrite(rs->f,rsrv,cur-rsrv) != cur-rsrv) { action;} \ 92 { sfwrite(rs->f,rs->rsrv,rs->cur-rs->rsrv); \ 159 cur = mg->cur; rsrv = mg->rsrv; endrsrv = mg->endrsrv; 359 mg->rsrv = rsrv; mg->endrsrv = endrsrv; mg->cur = cur; 376 if(mg->rsrv) 377 sfread(mg->f,mg->rsrv,mg->cur-mg->rsrv); 580 rsrv = rs->rsrv; endrsrv = rs->endrsrv; cur = rs->cur; 587 { if(rsrv) 588 { sfwrite(rs->f, rsrv, cur-rsrv); [all …]
|
/dports/shells/ast-ksh/ast-ksh93v/src/lib/librecsort/ |
H A D | rswrite.c | 57 { if(rsrv && sfwrite(f,rsrv,cur-rsrv) != cur-rsrv) return -1; \ 63 endrsrv = (cur = rsrv) + rw; \ 82 reg uchar *d, *cur, *endrsrv, *rsrv; local 100 { rsrv = rs->rsrv; endrsrv = rs->endrsrv; cur = rs->cur; 104 { rsrv = cur = endrsrv = NIL(uchar*); 140 RESERVE(rs,f,rsrv,endrsrv,cur,w); 242 RESERVE(rs,f,rsrv,endrsrv,cur,w); 279 RESERVE(rs,f,rsrv,endrsrv,cur,w); 311 { rs->rsrv = rsrv; rs->endrsrv = endrsrv; rs->cur = cur; 314 { if(rsrv) [all …]
|
H A D | rsmerge.c | 64 { if(rsrv && sfread(mg->f,rsrv,cur-rsrv) != cur-rsrv) { MGSETEOF(mg); action;} \ 79 { if(rsrv && sfwrite(rs->f,rsrv,cur-rsrv) != cur-rsrv) { action;} \ 92 { sfwrite(rs->f,rs->rsrv,rs->cur-rs->rsrv); \ 159 cur = mg->cur; rsrv = mg->rsrv; endrsrv = mg->endrsrv; 359 mg->rsrv = rsrv; mg->endrsrv = endrsrv; mg->cur = cur; 376 if(mg->rsrv) 377 sfread(mg->f,mg->rsrv,mg->cur-mg->rsrv); 574 rsrv = rs->rsrv; endrsrv = rs->endrsrv; cur = rs->cur; 581 { if(rsrv) 582 { sfwrite(rs->f, rsrv, cur-rsrv); [all …]
|
/dports/shells/ksh2020/ast-ksh2020/src/lib/libast/sfio/ |
H A D | sfgetr.c | 41 Sfrsrv_t *rsrv; in sfgetr() local 50 rsrv = NULL; in sfgetr() 64 } else if ((rsrv = f->rsrv) && (un = -rsrv->slen) > 0) { in sfgetr() 65 us = rsrv->data; in sfgetr() 120 if (!rsrv || rsrv->size < un + n + 1) { in sfgetr() 121 if (rsrv) rsrv->slen = un; in sfgetr() 122 rsrv = _sfrsrv(f, un + n + 1); in sfgetr() 123 if (rsrv) { in sfgetr() 124 us = rsrv->data; in sfgetr() 157 if (rsrv) rsrv->slen = found ? 0 : -un; in sfgetr()
|
H A D | sfreserve.c | 36 Sfrsrv_t *rsrv; in sfreserve() local 57 } else if ((rsrv = f->rsrv) && (n = -rsrv->slen) > 0) { in sfreserve() 58 rsrv->slen = 0; in sfreserve() 60 data = (void *)rsrv->data; in sfreserve() 159 } else if (type == SF_LOCKR && size == 0 && (rsrv = _sfrsrv(f, 0))) { in sfreserve() 160 data = (void *)rsrv->data; in sfreserve() 172 if (type == SF_LOCKR && (rsrv = _sfrsrv(f, sz))) data = (void *)rsrv->data; in sfreserve() 173 } else if (type != SF_LOCKR && sz > f->size && (rsrv = _sfrsrv(f, sz))) { in sfreserve() 174 if ((n = SFREAD(f, (void *)rsrv->data, sz)) >= sz) { /* read side buffer */ in sfreserve() 175 data = (void *)rsrv->data; in sfreserve() [all …]
|
H A D | sfstack.c | 37 Sfrsrv_t *rsrv; in sfstack() local 91 rsrv = f1->rsrv; in sfstack() 92 f1->rsrv = f2->rsrv; in sfstack() 93 f2->rsrv = rsrv; in sfstack()
|
/dports/graphics/graphviz/graphviz-2.44.1/lib/sfio/ |
H A D | sfgetr.c | 33 reg Sfrsrv_t *rsrv; in sfgetr() local 42 rsrv = NIL(Sfrsrv_t *); in sfgetr() 51 if ((rsrv = f->rsrv) && (un = -rsrv->slen) > 0) { in sfgetr() 52 us = rsrv->data; in sfgetr() 94 if (!rsrv || rsrv->size < un + n + 1) { in sfgetr() 95 if (rsrv) in sfgetr() 96 rsrv->slen = un; in sfgetr() 97 if ((rsrv = _sfrsrv(f, un + n + 1)) != NIL(Sfrsrv_t *)) in sfgetr() 98 us = rsrv->data; in sfgetr() 125 if (rsrv) in sfgetr() [all …]
|
H A D | sfreserve.c | 29 reg Sfrsrv_t *rsrv; in sfreserve() local 36 rsrv = NIL(Sfrsrv_t *); in sfreserve() 41 if ((rsrv = f->rsrv) && (n = -rsrv->slen) > 0) { in sfreserve() 42 rsrv->slen = 0; in sfreserve() 44 SFMTXRETURN(f, (void *) rsrv->data); in sfreserve() 61 rsrv = _sfrsrv(f, 0); in sfreserve() 121 if (type > 0 && (rsrv = _sfrsrv(f, sz))) in sfreserve() 124 if (type <= 0 && (rsrv = _sfrsrv(f, sz)) && in sfreserve() 125 (n = SFREAD(f, (void *) rsrv->data, sz)) < sz) in sfreserve() 126 rsrv->slen = -n; in sfreserve() [all …]
|
H A D | sfstack.c | 40 reg Sfrsrv_t *rsrv; in sfstack() local 79 rsrv = f1->rsrv; in sfstack() 80 f1->rsrv = f2->rsrv; in sfstack() 81 f2->rsrv = rsrv; in sfstack()
|
/dports/shells/ksh93-devel/ast-cc1bca27/src/lib/libast/sfio/ |
H A D | sfgetr.c | 42 Sfrsrv_t* rsrv; local 52 rsrv = NIL(Sfrsrv_t*); 66 else if((rsrv = f->rsrv) && (un = -rsrv->slen) > 0) 67 { us = rsrv->data; 127 if(!rsrv || rsrv->size < un+n+1) 128 { if(rsrv) 129 rsrv->slen = un; 130 if((rsrv = _sfrsrv(f,un+n+1)) != NIL(Sfrsrv_t*)) 131 us = rsrv->data; 158 if(rsrv) [all …]
|
H A D | sfreserve.c | 39 reg Sfrsrv_t* rsrv; local 60 else if((rsrv = f->rsrv) && (n = -rsrv->slen) > 0) 61 { rsrv->slen = 0; 63 data = (Void_t*)rsrv->data; 170 else if(type == SF_LOCKR && size == 0 && (rsrv = _sfrsrv(f,0)) ) 171 data = (Void_t*)rsrv->data; 183 { if(type == SF_LOCKR && (rsrv = _sfrsrv(f, sz)) ) 184 data = (Void_t*)rsrv->data; 186 else if(type != SF_LOCKR && sz > f->size && (rsrv = _sfrsrv(f,sz)) ) 188 data = (Void_t*)rsrv->data; [all …]
|
H A D | sfstack.c | 50 reg Sfrsrv_t* rsrv; local 92 rsrv = f1->rsrv; f1->rsrv = f2->rsrv; f2->rsrv = rsrv;
|
/dports/shells/ksh93/ast-93u/src/lib/libast/sfio/ |
H A D | sfgetr.c | 42 Sfrsrv_t* rsrv; local 52 rsrv = NIL(Sfrsrv_t*); 66 else if((rsrv = f->rsrv) && (un = -rsrv->slen) > 0) 67 { us = rsrv->data; 127 if(!rsrv || rsrv->size < un+n+1) 128 { if(rsrv) 129 rsrv->slen = un; 130 if((rsrv = _sfrsrv(f,un+n+1)) != NIL(Sfrsrv_t*)) 131 us = rsrv->data; 158 if(rsrv) [all …]
|
H A D | sfreserve.c | 39 reg Sfrsrv_t* rsrv; local 60 else if((rsrv = f->rsrv) && (n = -rsrv->slen) > 0) 61 { rsrv->slen = 0; 63 data = (Void_t*)rsrv->data; 170 else if(type == SF_LOCKR && size == 0 && (rsrv = _sfrsrv(f,0)) ) 171 data = (Void_t*)rsrv->data; 183 { if(type == SF_LOCKR && (rsrv = _sfrsrv(f, sz)) ) 184 data = (Void_t*)rsrv->data; 186 else if(type != SF_LOCKR && sz > f->size && (rsrv = _sfrsrv(f,sz)) ) 188 data = (Void_t*)rsrv->data; [all …]
|
H A D | sfstack.c | 50 reg Sfrsrv_t* rsrv; local 92 rsrv = f1->rsrv; f1->rsrv = f2->rsrv; f2->rsrv = rsrv;
|
/dports/shells/ast-ksh/ast-ksh93v/src/lib/libast/sfio/ |
H A D | sfgetr.c | 42 Sfrsrv_t* rsrv; local 52 rsrv = NIL(Sfrsrv_t*); 66 else if((rsrv = f->rsrv) && (un = -rsrv->slen) > 0) 67 { us = rsrv->data; 127 if(!rsrv || rsrv->size < un+n+1) 128 { if(rsrv) 129 rsrv->slen = un; 130 if((rsrv = _sfrsrv(f,un+n+1)) != NIL(Sfrsrv_t*)) 131 us = rsrv->data; 158 if(rsrv) [all …]
|
H A D | sfreserve.c | 39 reg Sfrsrv_t* rsrv; local 60 else if((rsrv = f->rsrv) && (n = -rsrv->slen) > 0) 61 { rsrv->slen = 0; 63 data = (Void_t*)rsrv->data; 170 else if(type == SF_LOCKR && size == 0 && (rsrv = _sfrsrv(f,0)) ) 171 data = (Void_t*)rsrv->data; 183 { if(type == SF_LOCKR && (rsrv = _sfrsrv(f, sz)) ) 184 data = (Void_t*)rsrv->data; 186 else if(type != SF_LOCKR && sz > f->size && (rsrv = _sfrsrv(f,sz)) ) 188 data = (Void_t*)rsrv->data; [all …]
|
H A D | sfstack.c | 50 reg Sfrsrv_t* rsrv; local 92 rsrv = f1->rsrv; f1->rsrv = f2->rsrv; f2->rsrv = rsrv;
|
/dports/net/kamailio/kamailio-5.4.5/src/modules/topos_redis/ |
H A D | topos_redis_storage.c | 168 if(rsrv==NULL) { in tps_redis_insert_dialog() 248 if(rsrv->ctxRedis->err) { in tps_redis_insert_dialog() 277 if(rsrv->ctxRedis->err) { in tps_redis_insert_dialog() 319 if(rsrv==NULL) { in tps_redis_insert_invite_branch() 423 if(rsrv==NULL) { in tps_redis_insert_branch() 578 if(rsrv==NULL) { in tps_redis_load_invite_branch() 721 if(rsrv==NULL) { in tps_redis_load_branch() 924 if(rsrv==NULL) { in tps_redis_load_dialog() 1131 if(rsrv==NULL) { in tps_redis_update_branch() 1219 if(rsrv==NULL) { in tps_redis_update_dialog() [all …]
|