summaryrefslogtreecommitdiff
path: root/support/dktools/dk4sock25.c
diff options
context:
space:
mode:
authorNorbert Preining <norbert@preining.info>2019-09-02 13:46:59 +0900
committerNorbert Preining <norbert@preining.info>2019-09-02 13:46:59 +0900
commite0c6872cf40896c7be36b11dcc744620f10adf1d (patch)
tree60335e10d2f4354b0674ec22d7b53f0f8abee672 /support/dktools/dk4sock25.c
Initial commit
Diffstat (limited to 'support/dktools/dk4sock25.c')
-rw-r--r--support/dktools/dk4sock25.c341
1 files changed, 341 insertions, 0 deletions
diff --git a/support/dktools/dk4sock25.c b/support/dktools/dk4sock25.c
new file mode 100644
index 0000000000..e844e4920f
--- /dev/null
+++ b/support/dktools/dk4sock25.c
@@ -0,0 +1,341 @@
+/*
+ WARNING: This file was generated by dkct.
+ Changes you make here will be lost if dkct is run again!
+ You should modify the original source and run dkct on it.
+ Original source: dk4sock25.ctr
+*/
+
+/*
+Copyright (C) 2015-2017, Dirk Krause
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice,
+ this list of conditions and the following disclaimer.
+* Redistributions in binary form must reproduce the above opyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+* Neither the name of the author nor the names of contributors may be used
+ to endorse or promote products derived from this software without specific
+ prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS ``AS IS''
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ARE DISCLAIMED.
+IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY
+DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+(INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
+THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+*/
+
+/** @file dk4sock25.c The dk4sock25 module.
+*/
+
+
+#line 10 "dk4sock25.ctr"
+
+
+
+#include "dk4sock.h"
+#include "dk4mem.h"
+
+#if DK4_HAVE_GETADDRINFO
+#include "dk4maowd.h"
+#else
+#include "dk4maiwdus.h"
+#endif
+
+#include "dk4rec24.h"
+
+
+
+
+
+#line 27 "dk4sock25.ctr"
+
+
+
+#if DK4_CHAR_SIZE > 1
+#if DK4_ON_WINDOWS
+
+/* +++++ +wchar_t +Windows */
+
+/** Create listener socket set for a local port number.
+ @param servicename Local service name.
+ @param backlog Number of connection requests to queue.
+ @param local Flag: Allow local connections only.
+ @param numeric Flag: Service name is numeric.
+ @param erp Error report, may be NULL.
+ @return Socket set on success, NULL on error.
+*/
+static
+dk4_socket_set_t *
+dk4socket_wc_set_service_num_flag(
+ const wchar_t *servicename,
+ int backlog,
+ int local,
+ int numeric,
+ dk4_er_t *erp
+)
+{
+#if DK4_HAVE_GETADDRINFO
+ /* +++++ +getaddrinfo */
+ ADDRINFOW hints;
+ ADDRINFOW *addri = NULL;
+ ADDRINFOW *paddr = NULL;
+ dk4_socket_set_t *back = NULL;
+ size_t numad = 0;
+ int res = 0;
+#if DK4_HAVE_SETSOCKOPT && (defined(SO_REUSEPORT) || defined(SO_REUSEADDR))
+ int opt = 0;
+#endif
+
+ if (NULL != servicename) {
+ DK4_MEMRES(&hints, sizeof(hints));
+ hints.ai_family = AF_UNSPEC;
+ hints.ai_socktype = SOCK_STREAM;
+ hints.ai_flags = 0;
+ hints.ai_protocol = 0;
+ hints.ai_addrlen = 0;
+ hints.ai_canonname = NULL;
+ hints.ai_addr = NULL;
+ hints.ai_next = NULL;
+ if (0 == local) { hints.ai_flags |= AI_PASSIVE; }
+ if (0 != numeric) { hints.ai_flags |= AI_NUMERICSERV; }
+ res = GetAddrInfoW(NULL, servicename, &hints, &addri);
+ if ((0 == res) && (NULL != addri)) {
+ paddr = addri;
+ while (NULL != paddr) { numad++; paddr = paddr->ai_next; }
+ if (0 < numad) {
+ paddr = addri;
+ back = dk4socket_set_new(numad, erp);
+ if (NULL != back) {
+ while (NULL != paddr) {
+ (back->pSockets)[back->szUsed] = dk4socket_open(
+ paddr->ai_family, SOCK_STREAM, 0, erp
+ );
+ if (INVALID_SOCKET != (back->pSockets)[back->szUsed]) {
+#if DK4_HAVE_SETSOCKOPT && defined(SO_REUSEPORT)
+
+
+#line 92 "dk4sock25.ctr"
+ dk4socket_set_one_bytes(&opt, sizeof(opt));
+ res = setsockopt(
+ (back->pSockets)[back->szUsed], SOL_SOCKET,
+ SO_REUSEPORT, (void *)(&opt), sizeof(opt)
+ );
+ if (0 != res) {
+
+#line 98 "dk4sock25.ctr"
+ }
+#else
+#if DK4_HAVE_SETSOCKOPT && defined(SO_REUSEADDR)
+
+
+#line 102 "dk4sock25.ctr"
+ dk4socket_set_one_bytes(&opt, sizeof(opt));
+ res = setsockopt(
+ (back->pSockets)[back->szUsed], SOL_SOCKET,
+ SO_REUSEADDR, (void *)(&opt), sizeof(opt)
+ );
+ if (0 != res) {
+
+#line 108 "dk4sock25.ctr"
+ }
+#else
+
+
+#line 111 "dk4sock25.ctr"
+#endif
+#endif
+ res = dk4socket_bind(
+ (back->pSockets)[back->szUsed], paddr->ai_addr,
+ paddr->ai_addrlen, erp
+ );
+ if (DK4_SOCKET_RESULT_SUCCESS == res) {
+#if 0
+ /* Setting SO_REUSEADDR or SO_REUSEPORT must follow
+ immediately on socket().
+ */
+ (void)dk4socket_option_set_reuse(back, 1, NULL);
+#endif
+ res = dk4socket_listen(
+ (back->pSockets)[back->szUsed], backlog, erp
+ );
+ if (DK4_SOCKET_RESULT_SUCCESS == res) {
+ back->szUsed += 1;
+ } else {
+ (void)dk4socket_close((back->pSockets)[back->szUsed], NULL);
+ (back->pSockets)[back->szUsed] = INVALID_SOCKET;
+ }
+ } else {
+ (void)dk4socket_close((back->pSockets)[back->szUsed], NULL);
+ (back->pSockets)[back->szUsed] = INVALID_SOCKET;
+ }
+ }
+ paddr = paddr->ai_next;
+ }
+ if (0 == back->szUsed) {
+ dk4socket_set_delete(back, NULL);
+ back = NULL;
+ }
+ }
+ }
+ FreeAddrInfo(addri);
+ } else {
+ dk4error_set_idetails(erp, DK4_E_SOCKET_GETADDRLOC, res);
+ }
+ } else {
+ dk4error_set_simple_error_code(erp, DK4_E_INVALID_ARGUMENTS);
+ }
+ return back;
+ /* ----- +getaddrinfo */
+#else
+ /* +++++ -getaddrinfo */
+ char asvcn[128];
+ const wchar_t *endptr = NULL;
+ dk4_socket_set_t *back = NULL;
+ struct servent *serv = NULL;
+ int iport = 0;
+ int res = 0;
+ unsigned short portno = 0;
+ if (NULL != servicename) {
+ res = dk4ma_input_wc_dec_ushort(
+ &portno, servicename, &endptr, 1, erp
+ );
+ if (0 != res) {
+ back = dk4socket_set_server_directly(portno, backlog, local, erp);
+ } else {
+ res = dk4recode_wchar_t_to_char(asvcn, sizeof(asvcn), servicename, erp);
+ if (0 != res) {
+ serv = getservbyname(asvcn, NULL);
+ if (NULL != serv) {
+ iport = serv->s_port;
+ dk4socket_swap_bytes_if_not_bigendian((void *)(&iport),sizeof(iport));
+ portno = (unsigned short)iport;
+ back = dk4socket_set_server_directly(portno, backlog, local, erp);
+ } else {
+ dk4socket_error_report(erp, DK4_E_SOCKET_GETSERVBYNAME);
+ }
+ }
+ }
+ } else {
+ dk4error_set_simple_error_code(erp, DK4_E_INVALID_ARGUMENTS);
+ }
+ return back;
+ /* ----- -getaddrinfo */
+#endif
+}
+
+
+
+static
+dk4_socket_set_t *
+dk4socket_wc_set_server(
+ unsigned short portno,
+ int backlog,
+ int local,
+ dk4_er_t *erp
+)
+{
+#if DK4_HAVE_GETADDRINFO
+ /* +++++ +getaddrinfo */
+ wchar_t pnb[16*sizeof(dk4_um_t)];
+ dk4_socket_set_t *back = NULL;
+ int res;
+ if (0 < portno) {
+ res = dk4ma_write_wc_decimal_unsigned(
+ pnb, DK4_SIZEOF(pnb,wchar_t), (dk4_um_t)portno, 0, erp
+ );
+ if (0 != res) {
+ back = dk4socket_wc_set_service_num_flag(
+ pnb, backlog, local, 1, erp
+ );
+ }
+ } else {
+ dk4error_set_simple_error_code(erp, DK4_E_INVALID_ARGUMENTS);
+ }
+ return back;
+ /* ----- +getaddrinfo */
+#else
+ /* +++++ -getaddrinfo */
+ return (
+ dk4socket_set_server_directly(portno, backlog, local, erp)
+ );
+ /* ----- -getaddrinfo */
+#endif
+}
+
+
+
+static
+dk4_socket_set_t *
+dk4socket_wc_set_service(
+ const wchar_t *servicename,
+ int backlog,
+ int local,
+ dk4_er_t *erp
+)
+{
+ return (
+ dk4socket_wc_set_service_num_flag(servicename, backlog, local, 0, erp)
+ );
+}
+
+/* ----- +wchar_t +Windows */
+
+#else
+#error No networking functions using wchar_t host and service names available!
+#endif
+#endif
+
+
+
+
+dk4_socket_set_t *
+dk4socket_set_server(
+ unsigned short portno,
+ int backlog,
+ int local,
+ dk4_er_t *erp
+)
+{
+#if DK4_CHAR_SIZE > 1
+ return (
+ dk4socket_wc_set_server(portno, backlog, local, erp)
+ );
+#else
+ return (
+ dk4socket_c8_set_server(portno, backlog, local, erp)
+ );
+#endif
+}
+
+
+
+dk4_socket_set_t *
+dk4socket_set_service(
+ const dkChar *servicename,
+ int backlog,
+ int local,
+ dk4_er_t *erp
+)
+{
+#if DK4_CHAR_SIZE > 1
+ return (
+ dk4socket_wc_set_service(servicename, backlog, local, erp)
+ );
+#else
+ return (
+ dk4socket_c8_set_service(servicename, backlog, local, erp)
+ );
+#endif
+}
+
+
+