Home
last modified time | relevance | path

Searched refs:rsrv (Results 1 – 25 of 358) sorted by relevance

12345678910>>...15

/dports/net/kamailio/kamailio-5.4.5/src/modules/ndb_redis/
H A Dredis_client.c93 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 Dredis_client.h91 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 Dmongodb_client.c57 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 Drswrite.c57 { 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 Drsmerge.c64 { 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 Drswrite.c57 { 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 Drsmerge.c64 { 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 Drswrite.c57 { 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 Drsmerge.c64 { 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 Dsfgetr.c41 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 Dsfreserve.c36 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 Dsfstack.c37 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 Dsfgetr.c33 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 Dsfreserve.c29 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 Dsfstack.c40 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 Dsfgetr.c42 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 Dsfreserve.c39 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 Dsfstack.c50 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 Dsfgetr.c42 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 Dsfreserve.c39 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 Dsfstack.c50 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 Dsfgetr.c42 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 Dsfreserve.c39 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 Dsfstack.c50 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 Dtopos_redis_storage.c168 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 …]

12345678910>>...15