sr-dev

sr-dev@lists.kamailio.org

16 participants
44264 discussions

git:kamailio_3.0: core: extra flag when forcing a socket

by Daniel-Constantin Mierla

Module: sip-router Branch: kamailio_3.0 Commit: d2669142fa6ab65adebdb5f01aa71d7703ec2567 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=d266914… Author: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: Thu Nov 5 14:43:38 2009 +0100 core: extra flag when forcing a socket - when forcing a socket set an extra send flag (SND_F_FORCE_SOCKET), so that later we can tell if the socket in the dst structure was forced or not (useful for forcing a specific source ip on tcp or for keeping the forced socket during dns failover in tm). - added set_force_socket(msg, sock) and reset_force_socket(msg) macros that should be used instead of directly setting msg->force_send_socket (they take care of any extra work, like setting/resetting flags). (cherry picked from commit 8fb1a2121ebe5c17681e7921cd96d3fe9a5dab80) --- action.c | 2 +- ip_addr.h | 1 + parser/msg_parser.h | 19 +++++++++++++++++++ 3 files changed, 21 insertions(+), 1 deletions(-) diff --git a/action.c b/action.c index b8256a7..ddbf445 100644 --- a/action.c +++ b/action.c @@ -1201,7 +1201,7 @@ match_cleanup: ret=E_BUG; goto error; } - msg->force_send_socket=(struct socket_info*)a->val[0].u.data; + set_force_socket(msg, (struct socket_info*)a->val[0].u.data); ret=1; /* continue processing */ break; diff --git a/ip_addr.h b/ip_addr.h index 355fc77..2983e46 100644 --- a/ip_addr.h +++ b/ip_addr.h @@ -140,6 +140,7 @@ struct receive_info{ /* send flags */ #define SND_F_FORCE_CON_REUSE 1 /* reuse an existing connection or fail */ #define SND_F_CON_CLOSE 2 /* close the connection after sending */ +#define SND_F_FORCE_SOCKET 4 /* send socket in dst is forced */ typedef unsigned char snd_flags_t; diff --git a/parser/msg_parser.h b/parser/msg_parser.h index ce4c81d..adedddb 100644 --- a/parser/msg_parser.h +++ b/parser/msg_parser.h @@ -467,4 +467,23 @@ int set_path_vector(struct sip_msg* msg, str* path); void reset_path_vector(struct sip_msg* msg); + +/** force a specific send socket for forwarding a request. + * @param msg - sip msg. + * @param fsocket - forced socket, pointer to struct socket_info, can be 0 (in + * which case it's equivalent to reset_force_socket()). + */ +#define set_force_socket(msg, fsocket) \ + do { \ + (msg)->force_send_socket=(fsocket); \ + if ((msg)->force_send_socket) \ + (msg)->fwd_send_flags |= SND_F_FORCE_SOCKET; \ + else \ + (msg)->fwd_send_flags &= ~SND_F_FORCE_SOCKET; \ + } while (0) + +/** reset a previously forced send socket. */ +#define reset_force_socket(msg) set_force_socket(msg, 0) + + #endif

15 years, 2 months

git:kamailio_3.0: rr(s): use set_force_socket()

by Daniel-Constantin Mierla

Module: sip-router Branch: kamailio_3.0 Commit: 5107ad3a9df7a644f4ec1f79cbc363208b0519d8 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=5107ad3… Author: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: Thu Nov 5 15:12:52 2009 +0100 rr(s): use set_force_socket() - use set_force_socket() instead of msg->force_send_socket --- modules_s/rr/loose.c | 6 +++--- 1 files changed, 3 insertions(+), 3 deletions(-) diff --git a/modules_s/rr/loose.c b/modules_s/rr/loose.c index 33803fe..0ba9337 100644 --- a/modules_s/rr/loose.c +++ b/modules_s/rr/loose.c @@ -901,9 +901,9 @@ static inline int after_loose(struct sip_msg* _m, struct sip_uri* _pru, int _rou LOG(L_ERR, "after_loose: Error while parsing the second route header\n"); return RR_ERROR; } - _m->force_send_socket = grep_sock_info(&parsed_uri.host, - parsed_uri.port_no, - parsed_uri.proto); + set_force_socket(_m, grep_sock_info(&parsed_uri.host, + parsed_uri.port_no, + parsed_uri.proto) ); if (_m->force_send_socket == 0) LOG(L_WARN, "after_loose: send socket cannot be set" " based on the second route header\n");

15 years, 2 months

git:kamailio_3.0: tm: preserve forced sockets and send flags during dns failover

by Daniel-Constantin Mierla

Module: sip-router Branch: kamailio_3.0 Commit: 43b0a4a3321ef8c14348b31300bd0aec15eff2be URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=43b0a4a… Author: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: Thu Nov 5 14:48:41 2009 +0100 tm: preserve forced sockets and send flags during dns failover - fix for branches introduced as a result of dns failover not preserving the forced send socket. - dns failover branches now preserve also the original branch send flags. (cherry picked from commit 35755149a5baa028e5b0e441cebebd0d25d6063b) --- modules/tm/t_fwd.c | 72 +++++++++++++++++++++++++++++++++++---------------- 1 files changed, 49 insertions(+), 23 deletions(-) diff --git a/modules/tm/t_fwd.c b/modules/tm/t_fwd.c index e4df337..1e9644d 100644 --- a/modules/tm/t_fwd.c +++ b/modules/tm/t_fwd.c @@ -159,7 +159,7 @@ unsigned int get_on_branch(void) the sending information: t->uac[branch].request.dst, branch buffer, uri path vector a.s.o.) and runs the on_branch route. * t->uac[branch].request.dst will be filled if next_hop !=0 with the result - * of the DNS resolution (next_hop and fproto). + * of the DNS resolution (next_hop, fproto and fsocket). * If next_hop is 0 all the dst members except the send_flags are read-only * (send_flags it's updated) and are supposed to be pre-filled. * @@ -174,6 +174,8 @@ unsigned int get_on_branch(void) * for DNS resolution and the branch request.dst structure will * be filled. If 0 the branch must already have * a pre-filled valid request.dst. + * @param fsocket - forced send socket for forwarding. + * @param send_flags - special flags for sending (see SND_F_* / snd_flags_t). * @param fproto - forced proto for forwarding. Used only if next_hop!=0. * @param flags - 0 or UAC_DNS_FAILOVER_F for now. * @@ -181,8 +183,10 @@ unsigned int get_on_branch(void) */ static int prepare_new_uac( struct cell *t, struct sip_msg *i_req, int branch, str *uri, str* path, - str* next_hop, int fproto, - int flags) + str* next_hop, + struct socket_info* fsocket, + snd_flags_t snd_flags, + int fproto, int flags) { char *shbuf; struct lump* add_rm_backup, *body_lumps_backup; @@ -198,6 +202,7 @@ static int prepare_new_uac( struct cell *t, struct sip_msg *i_req, int backup_route_type; snd_flags_t fwd_snd_flags_bak; snd_flags_t rpl_snd_flags_bak; + struct socket_info *force_send_socket_bak; struct dest_info *dst; shbuf=0; @@ -321,17 +326,22 @@ static int prepare_new_uac( struct cell *t, struct sip_msg *i_req, ( */ if (exec_pre_script_cb(i_req, BRANCH_CB_TYPE)>0) { - /* backup ireq msg send flags */ + /* backup ireq msg send flags and force_send_socket*/ fwd_snd_flags_bak=i_req->fwd_send_flags;; rpl_snd_flags_bak=i_req->rpl_send_flags; - i_req->fwd_send_flags=dst->send_flags /* intial value */; + force_send_socket_bak=i_req->force_send_socket; + /* set the new values */ + i_req->fwd_send_flags=snd_flags /* intial value */; + set_force_socket(i_req, fsocket); if (run_top_route(branch_rt.rlist[branch_route], i_req, 0) < 0) { LOG(L_ERR, "Error in run_top_route\n"); } - /* update dst send_flags */ - dst->send_flags=i_req->fwd_send_flags; - /* restore ireq_msg flags */ + /* update dst send_flags and send socket*/ + snd_flags=i_req->fwd_send_flags; + fsocket=i_req->force_send_socket; + /* restore ireq_msg force_send_socket & flags */ + set_force_socket(i_req, force_send_socket_bak); i_req->fwd_send_flags=fwd_snd_flags_bak; i_req->rpl_send_flags=rpl_snd_flags_bak; exec_post_script_cb(i_req, BRANCH_CB_TYPE); @@ -376,11 +386,12 @@ static int prepare_new_uac( struct cell *t, struct sip_msg *i_req, if (likely(next_hop!=0 || (flags & UAC_DNS_FAILOVER_F))){ /* next_hop present => use it for dns resolution */ #ifdef USE_DNS_FAILOVER - if (uri2dst(&t->uac[branch].dns_h, dst, i_req, + if (uri2dst2(&t->uac[branch].dns_h, dst, fsocket, snd_flags, next_hop?next_hop:uri, fproto) == 0) #else /* dst filled from the uri & request (send_socket) */ - if (uri2dst(dst, i_req, next_hop?next_hop:uri, fproto)==0) + if (uri2dst2(dst, fsocket, snd_flags, + next_hop?next_hop:uri, fproto)==0) #endif { ret=E_BAD_ADDRESS; @@ -452,6 +463,7 @@ error03: i_req->parsed_uri=parsed_uri_bak; i_req->parsed_uri_ok=parsed_uri_ok_bak; i_req->path_vec=path_bak; + /* Delete the duplicated lump lists, this will also delete * all lumps created here, such as lumps created in per-branch * routing sections, Via, and Content-Length headers created in @@ -603,6 +615,8 @@ int add_blind_uac( /*struct cell *t*/ ) * uri format, e.g.: "<sip:1.2.3.4;lr>, <sip:5.6.7.8;lr>"). * @param proxy - proxy structure. If non-null it takes precedence over * next_hop/uri and it will be used for forwarding. + * @param fsocket - forced forward send socket (can be 0). + * @param snd_flags - special send flags (see SND_F_* / snd_flags_t) * @param proto - forced protocol for forwarding (overrides the protocol * in next_hop/uri or proxy if != PROTO_NONE). * @param flags - special flags passed to prepare_new_uac(). @@ -611,6 +625,7 @@ int add_blind_uac( /*struct cell *t*/ ) */ static int add_uac( struct cell *t, struct sip_msg *request, str *uri, str* next_hop, str* path, struct proxy_l *proxy, + struct socket_info* fsocket, snd_flags_t snd_flags, int proto, int flags) { @@ -653,7 +668,8 @@ static int add_uac( struct cell *t, struct sip_msg *request, str *uri, /* now message printing starts ... */ if (unlikely( (ret=prepare_new_uac(t, request, branch, uri, path, - next_hop, proto, flags)) < 0)){ + next_hop, fsocket, snd_flags, + proto, flags)) < 0)){ ser_error=ret; goto error01; } @@ -689,7 +705,10 @@ error: the failed branch to construct the new message in case of DNS failover. */ static int add_uac_from_buf( struct cell *t, struct sip_msg *request, - str *uri, str* path, int proto, + str *uri, str* path, + struct socket_info* fsocket, + snd_flags_t send_flags, + int proto, char *buf, short buf_len) { @@ -713,8 +732,8 @@ static int add_uac_from_buf( struct cell *t, struct sip_msg *request, goto error; } - if (uri2dst(&t->uac[branch].dns_h, &t->uac[branch].request.dst, - request, uri, proto) == 0) + if (uri2dst2(&t->uac[branch].dns_h, &t->uac[branch].request.dst, + fsocket, send_flags, uri, proto) == 0) { ret=ser_error=E_BAD_ADDRESS; goto error; @@ -820,21 +839,29 @@ int add_uac_dns_fallback(struct cell *t, struct sip_msg* msg, dns_srv_handle_cpy(&t->uac[t->nr_of_outgoings].dns_h, &old_uac->dns_h); - if (cfg_get(tm, tm_cfg, reparse_on_dns_failover)) + if (cfg_get(tm, tm_cfg, reparse_on_dns_failover)){ /* Reuse the old buffer and only replace the via header. * The drawback is that the send_socket is not corrected * in the rest of the message, only in the VIA HF (Miklos) */ ret=add_uac_from_buf(t, msg, &old_uac->uri, &old_uac->path, + (old_uac->request.dst.send_flags & + SND_F_FORCE_SOCKET)? + old_uac->request.dst.send_sock:0, + old_uac->request.dst.send_flags, old_uac->request.dst.proto, old_uac->request.buffer, old_uac->request.buffer_len); - else + }else /* add_uac will use dns_h => next_hop will be ignored. * Unfortunately we can't reuse the old buffer, the branch id * must be changed and the send_socket might be different => * re-create the whole uac */ ret=add_uac(t, msg, &old_uac->uri, 0, &old_uac->path, 0, + (old_uac->request.dst.send_flags & + SND_F_FORCE_SOCKET)? + old_uac->request.dst.send_sock:0, + old_uac->request.dst.send_flags, old_uac->request.dst.proto, UAC_DNS_FAILOVER_F); if (ret<0){ @@ -906,7 +933,7 @@ int e2e_cancel_branch( struct sip_msg *cancel_msg, struct cell *t_cancel, if (unlikely((ret=prepare_new_uac( t_cancel, cancel_msg, branch, &t_invite->uac[branch].uri, &t_invite->uac[branch].path, - 0, PROTO_NONE, 0)) <0)){ + 0, 0, 0, PROTO_NONE, 0)) <0)){ ser_error=ret; goto error; } @@ -1242,7 +1269,7 @@ int t_forward_nonack( struct cell *t, struct sip_msg* p_msg , int try_new; int lock_replies; str dst_uri, path; - struct socket_info* si, *backup_si; + struct socket_info* si; flag_t backup_bflags = 0; flag_t bflags = 0; @@ -1267,7 +1294,6 @@ int t_forward_nonack( struct cell *t, struct sip_msg* p_msg , } } - backup_si = p_msg->force_send_socket; getbflagsval(0, &backup_bflags); /* if no more specific error code is known, use this */ @@ -1303,7 +1329,8 @@ int t_forward_nonack( struct cell *t, struct sip_msg* p_msg , #endif try_new=1; branch_ret=add_uac( t, p_msg, GET_RURI(p_msg), GET_NEXT_HOP(p_msg), - &p_msg->path_vec, proxy, proto, 0); + &p_msg->path_vec, proxy, p_msg->force_send_socket, + p_msg->fwd_send_flags, proto, 0); if (branch_ret>=0) added_branches |= 1<<branch_ret; else @@ -1314,12 +1341,12 @@ int t_forward_nonack( struct cell *t, struct sip_msg* p_msg , while((current_uri.s=next_branch( &current_uri.len, &q, &dst_uri, &path, &bflags, &si))) { try_new++; - p_msg->force_send_socket = si; setbflagsval(0, bflags); branch_ret=add_uac( t, p_msg, &current_uri, (dst_uri.len) ? (&dst_uri) : &current_uri, - &path, proxy, proto, 0); + &path, proxy, si, p_msg->fwd_send_flags, + proto, 0); /* pick some of the errors in case things go wrong; note that picking lowest error is just as good as any other algorithm which picks any other negative @@ -1332,7 +1359,6 @@ int t_forward_nonack( struct cell *t, struct sip_msg* p_msg , /* consume processed branches */ clear_branches(); - p_msg->force_send_socket = backup_si; setbflagsval(0, backup_bflags); /* don't forget to clear all branches processed so far */

15 years, 2 months

git:kamailio_3.0: pv: use set_force_socket()

by Daniel-Constantin Mierla

Module: sip-router Branch: kamailio_3.0 Commit: 7f416129580ded586b8d1f5ec0be2c1df7175a21 URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=7f41612… Author: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: Thu Nov 5 15:15:33 2009 +0100 pv: use set_force_socket() - use set_force_socket() instead of msg->force_send_socket (cherry picked from commit d41be35145a2f049c574d183771ea7102563e8af) --- modules_k/pv/pv_core.c | 4 ++-- 1 files changed, 2 insertions(+), 2 deletions(-) diff --git a/modules_k/pv/pv_core.c b/modules_k/pv/pv_core.c index 71186dd..16c1f70 100644 --- a/modules_k/pv/pv_core.c +++ b/modules_k/pv/pv_core.c @@ -1882,7 +1882,7 @@ int pv_set_force_sock(struct sip_msg* msg, pv_param_t *param, if(val==NULL || (val->flags&PV_VAL_NULL)) { - msg->force_send_socket = NULL; + reset_force_socket(msg); return 0; } @@ -1904,7 +1904,7 @@ int pv_set_force_sock(struct sip_msg* msg, pv_param_t *param, si = grep_sock_info(&host, (unsigned short)port, (unsigned short)proto); if (si!=NULL) { - msg->force_send_socket = si; + set_force_socket(msg, si); } else { LM_WARN("no socket found to match [%.*s]\n", val->rs.len, val->rs.s);

15 years, 2 months

git:master: Merge remote branch 'origin/sr_3.0'

by Andrei Pelinescu-Onciul

Module: sip-router Branch: master Commit: 470d30ac7dbe70a1e7b348f4dc68ce4e98cd2d8c URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=470d30a… Author: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Committer: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Date: Fri Nov 6 08:56:40 2009 +0100 Merge remote branch 'origin/sr_3.0' latest sr_3.0 fixes. * origin/sr_3.0: (36 commits) core: added id to every field of gw table schema tcp: use the forced socket ip as source tmx: pv_t_copy_msg: copy also the send flags textops(k): msg_apply_changes: preserve the send flags seas: use set_force_socket() rr(k): use set_force_socket() registrar(k): use set_force_socket() pv: use set_force_socket() kex: use set_force_socket() domainpolicy: use set_force_socket() rr(s): use set_force_socket() registrar(s): use set_force_socket() tm: use set_force_socket() instead of msg->force_send_socket tm: preserve forced sockets and send flags during dns failover core: extra flag when forcing a socket core: kamailio mode config parser fix core: PAI and PPI parsing support fixed core: dset minor cleanups core: append_branch() sets also the send_socket, path & flags remove extra backslash in make modules-doc action ... ---

15 years, 2 months

tcp problem

by jh＠tutpro.com

i have twinkle registered from behind nat over tcp and another sip phone registered over udp using the same aor and q value. this aor is then called by another sip phone and sr forks the invite: Oct 28 17:58:37 localhost /usr/sbin/sip-proxy[28989]: INFO: Routing first INVITE to <sip:foo@192.168.0.169:5074;transport=tcp> and <<sip:JzlUogbN0_q5BaWAN1Zv@xx.xx.xx.xx>;q=0> ... twinkle answers and sends 200 ok. 200 ok is received by the calling phone, which then sends ack to twinkle via sr, the problem is that twinkle never receives the ack. instead sr reports a tcp error: Oct 28 17:58:46 localhost /usr/sbin/sip-proxy[28994]: INFO: Routing in-dialog ACK from <sip:foo.bar@foo.bar> to <sip:foo@192.168.0.169:5074;transport=TCP> Oct 28 17:58:46 lohi /usr/sbin/sip-proxy[28994]: WARNING: <core> [tcp_main.c:1200]: WARNING: tcp_do_connect 192.168.0.169:5074: could not find corresponding listening socket for 192.X.Y.2, using default... ... Oct 28 17:58:51 localhost /usr/sbin/sip-proxy[29140]: ERROR: <core> [tcp_main.c:3747]: connect 192.168.0.169:5074 failed (timeout) weird thing about the warning is that it mentions ip address 192.X.Y.2, which is not any of the ip addresses sr has configured to listen at. 192.X.Y.2 is the ip address of eth0 of sr host, but sr is listening at 192.X.Y.10, which is address of interface eth0:1. am i missing some magic from sr tcp config or what could be the reason that sr is trying to find non-existing listening socket? i do have wireshark capture of this if it helps. -- juha

15 years, 2 months

git:sr_3.0: core: added id to every field of gw table schema

by Juha Heinanen

Module: sip-router Branch: sr_3.0 Commit: a3a3ce31042a025fe93520350e53b049d5ef850d URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=a3a3ce3… Author: Juha Heinanen <jh(a)tutpro.com> Committer: Juha Heinanen <jh(a)tutpro.com> Date: Fri Nov 6 05:58:59 2009 +0200 core: added id to every field of gw table schema --- lib/srdb1/schema/gw.xml | 20 ++++++++++---------- 1 files changed, 10 insertions(+), 10 deletions(-) diff --git a/lib/srdb1/schema/gw.xml b/lib/srdb1/schema/gw.xml index bb2c354..a457719 100644 --- a/lib/srdb1/schema/gw.xml +++ b/lib/srdb1/schema/gw.xml @@ -47,14 +47,14 @@ <description>ID of gateway's group</description> </column> - <column> + <column id="ip_addr"> <name>ip_addr</name> <type>string</type> <size>15</size> <description>IP Address of the gateway</description> </column> - <column> + <column id="hostname"> <name>hostname</name> <type>string</type> <size>64</size> @@ -62,35 +62,35 @@ <description>Hostname of the gateway</description> </column> - <column> + <column id="port"> <name>port</name> <type>unsigned short</type> <null/> <description>Port of the gateway</description> </column> - <column> + <column id="uri_scheme"> <name>uri_scheme</name> <type>unsigned char</type> <null/> <description>URI scheme of gateway</description> </column> - <column> + <column id="transport"> <name>transport</name> <type>unsigned char</type> <null/> <description>Transport type to be used for the gateway</description> </column> - <column> + <column id="strip"> <name>strip</name> <type>unsigned char</type> <null/> <description>The number of digits to strip from Request URI user part before inserting tag</description> </column> - <column> + <column id="tag"> <name>tag</name> <type>string</type> <size>16</size> @@ -99,21 +99,21 @@ <description>Request URI user part tag</description> </column> - <column> + <column id="weight"> <name>weight</name> <type>unsigned int</type> <null/> <description>Weight of gateway within gw_grp. Valid values are 1-254.</description> </column> - <column> + <column id="flags"> <name>flags</name> <type>unsigned int</type> <default>&DEFAULT_FLAGS;</default> <description>Gateway specific flags</description> </column> - <column> + <column id="defunct"> <name>defunct</name> <type>unsigned int</type> <null/>

15 years, 2 months

default memdbg and memlog

by Klaus Darilion

Hi! IMO it would be better to increase the default value of memdbg and memlog to 4 (L_DBG+1) to avoid the memory log messages in debug=3 mode. I often use debug=3 to hunt down script or sip-router errors and I am not interested in memory debugging. I think this confuses many new sip-router users too. regards klaus

15 years, 2 months

git:sr_3.0: tcp: use the forced socket ip as source

by Andrei Pelinescu-Onciul

Module: sip-router Branch: sr_3.0 Commit: 6fcba958595c5189c1b9d97c8fc4c9f434a3c7ad URL: http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=6fcba95… Author: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Committer: Andrei Pelinescu-Onciul <andrei(a)iptel.org> Date: Thu Nov 5 16:21:35 2009 +0100 tcp: use the forced socket ip as source - if a socket is forced always use the forced socket ip as source (if a connection exists with different ip as source, open a new one with the forced ip). --- forward.h | 23 +++++++++++++++++++++-- 1 files changed, 21 insertions(+), 2 deletions(-) diff --git a/forward.h b/forward.h index 2a6e91e..b365753 100644 --- a/forward.h +++ b/forward.h @@ -123,6 +123,11 @@ static inline int msg_send(struct dest_info* dst, char* buf, int len) { struct dest_info new_dst; str outb; +#ifdef USE_TCP + union sockaddr_union* from; + union sockaddr_union local_addr; +#endif + outb.s = buf; outb.len = len; sr_event_exec(SREV_NET_DATA_OUT, (void*)&outb); @@ -152,7 +157,14 @@ static inline int msg_send(struct dest_info* dst, char* buf, int len) " support is disabled\n"); goto error; }else{ - if (unlikely(tcp_send(dst, 0, outb.s, outb.len)<0)){ + from=0; + if (unlikely((dst->send_flags & SND_F_FORCE_SOCKET) && + dst->send_sock)) { + local_addr=dst->send_sock->su; + su_setport(&local_addr, 0); /* any local port will do */ + from=&local_addr; + } + if (unlikely(tcp_send(dst, from, outb.s, outb.len)<0)){ STATS_TX_DROPS; LOG(L_ERR, "msg_send: ERROR: tcp_send failed\n"); goto error; @@ -167,7 +179,14 @@ static inline int msg_send(struct dest_info* dst, char* buf, int len) " support is disabled\n"); goto error; }else{ - if (unlikely(tcp_send(dst, 0, outb.s, outb.len)<0)){ + from=0; + if (unlikely((dst->send_flags & SND_F_FORCE_SOCKET) && + dst->send_sock)) { + local_addr=dst->send_sock->su; + su_setport(&local_addr, 0); /* any local port will do */ + from=&local_addr; + } + if (unlikely(tcp_send(dst, from, outb.s, outb.len)<0)){ STATS_TX_DROPS; LOG(L_ERR, "msg_send: ERROR: tcp_send failed\n"); goto error;

15 years, 2 months

db_flatstore debian packages overlap

by Klaus Darilion

Hi! Bug: db_flatstore is in db_modules package and ser standard package I think it should be removed from db_modules packages as it does not have any dependencies on db-libraries. regards klaus

15 years, 2 months

Jump to page:

2025

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

sr-dev