12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040 |
- /***************************************************************************
- * _ _ ____ _
- * Project ___| | | | _ \| |
- * / __| | | | |_) | |
- * | (__| |_| | _ <| |___
- * \___|\___/|_| \_\_____|
- *
- * Copyright (C) Daniel Stenberg, <daniel@haxx.se>, et al.
- *
- * This software is licensed as described in the file COPYING, which
- * you should have received as part of this distribution. The terms
- * are also available at https://curl.se/docs/copyright.html.
- *
- * You may opt to use, copy, modify, merge, publish, distribute and/or sell
- * copies of the Software, and permit persons to whom the Software is
- * furnished to do so, under the terms of the COPYING file.
- *
- * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
- * KIND, either express or implied.
- *
- * SPDX-License-Identifier: curl
- *
- *
- ***************************************************************************/
- /* OS/400 additional support. */
- #include <curl/curl.h>
- #include "config-os400.h" /* Not curl_setup.h: we only need some defines. */
- #include <sys/types.h>
- #include <sys/socket.h>
- #include <sys/un.h>
- #include <stdlib.h>
- #include <stddef.h>
- #include <string.h>
- #include <pthread.h>
- #include <netdb.h>
- #include <qadrt.h>
- #include <errno.h>
- #ifdef HAVE_LIBZ
- #include <zlib.h>
- #endif
- #ifdef HAVE_GSSAPI
- #include <gssapi.h>
- #endif
- #ifndef CURL_DISABLE_LDAP
- #include <ldap.h>
- #endif
- #include <netinet/in.h>
- #include <arpa/inet.h>
- #include "os400sys.h"
- /**
- *** QADRT OS/400 ASCII runtime defines only the most used procedures, but a
- *** lot of them are not supported. This module implements ASCII wrappers for
- *** those that are used by libcurl, but not defined by QADRT.
- **/
- #pragma convert(0) /* Restore EBCDIC. */
- #define MIN_BYTE_GAIN 1024 /* Minimum gain when shortening a buffer. */
- struct buffer_t {
- unsigned long size; /* Buffer size. */
- char *buf; /* Buffer address. */
- };
- static char *buffer_undef(localkey_t key, long size);
- static char *buffer_threaded(localkey_t key, long size);
- static char *buffer_unthreaded(localkey_t key, long size);
- static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
- static pthread_key_t thdkey;
- static struct buffer_t *locbufs;
- char *(*Curl_thread_buffer)(localkey_t key, long size) = buffer_undef;
- static void thdbufdestroy(void *private)
- {
- if(private) {
- struct buffer_t *p = (struct buffer_t *) private;
- localkey_t i;
- for(i = (localkey_t) 0; i < LK_LAST; i++) {
- free(p->buf);
- p++;
- }
- free(private);
- }
- }
- static void
- terminate(void)
- {
- if(Curl_thread_buffer == buffer_threaded) {
- locbufs = pthread_getspecific(thdkey);
- pthread_setspecific(thdkey, (void *) NULL);
- pthread_key_delete(thdkey);
- }
- if(Curl_thread_buffer != buffer_undef) {
- thdbufdestroy((void *) locbufs);
- locbufs = (struct buffer_t *) NULL;
- }
- Curl_thread_buffer = buffer_undef;
- }
- static char *
- get_buffer(struct buffer_t *buf, long size)
- {
- char *cp;
- /* If `size' >= 0, make sure buffer at `buf' is at least `size'-byte long.
- Return the buffer address. */
- if(size < 0)
- return buf->buf;
- if(!buf->buf) {
- buf->buf = malloc(size);
- if(buf->buf)
- buf->size = size;
- return buf->buf;
- }
- if((unsigned long) size <= buf->size) {
- /* Shorten the buffer only if it frees a significant byte count. This
- avoids some realloc() overhead. */
- if(buf->size - size < MIN_BYTE_GAIN)
- return buf->buf;
- }
- /* Resize the buffer. */
- cp = realloc(buf->buf, size);
- if(cp) {
- buf->buf = cp;
- buf->size = size;
- }
- else if(size <= buf->size)
- cp = buf->buf;
- return cp;
- }
- static char *
- buffer_unthreaded(localkey_t key, long size)
- {
- return get_buffer(locbufs + key, size);
- }
- static char *
- buffer_threaded(localkey_t key, long size)
- {
- struct buffer_t *bufs;
- /* Get the buffer for the given local key in the current thread, and
- make sure it is at least `size'-byte long. Set `size' to < 0 to get
- its address only. */
- bufs = (struct buffer_t *) pthread_getspecific(thdkey);
- if(!bufs) {
- if(size < 0)
- return (char *) NULL; /* No buffer yet. */
- /* Allocate buffer descriptors for the current thread. */
- bufs = calloc((size_t) LK_LAST, sizeof(*bufs));
- if(!bufs)
- return (char *) NULL;
- if(pthread_setspecific(thdkey, (void *) bufs)) {
- free(bufs);
- return (char *) NULL;
- }
- }
- return get_buffer(bufs + key, size);
- }
- static char *
- buffer_undef(localkey_t key, long size)
- {
- /* Define the buffer system, get the buffer for the given local key in
- the current thread, and make sure it is at least `size'-byte long.
- Set `size' to < 0 to get its address only. */
- pthread_mutex_lock(&mutex);
- /* Determine if we can use pthread-specific data. */
- if(Curl_thread_buffer == buffer_undef) { /* If unchanged during lock. */
- if(!pthread_key_create(&thdkey, thdbufdestroy))
- Curl_thread_buffer = buffer_threaded;
- else {
- locbufs = calloc((size_t) LK_LAST, sizeof(*locbufs));
- if(!locbufs) {
- pthread_mutex_unlock(&mutex);
- return (char *) NULL;
- }
- else
- Curl_thread_buffer = buffer_unthreaded;
- }
- atexit(terminate);
- }
- pthread_mutex_unlock(&mutex);
- return Curl_thread_buffer(key, size);
- }
- static char *
- set_thread_string(localkey_t key, const char *s)
- {
- int i;
- char *cp;
- if(!s)
- return (char *) NULL;
- i = strlen(s) + 1;
- cp = Curl_thread_buffer(key, MAX_CONV_EXPANSION * i + 1);
- if(cp) {
- i = QadrtConvertE2A(cp, s, MAX_CONV_EXPANSION * i, i);
- cp[i] = '\0';
- }
- return cp;
- }
- int
- Curl_getnameinfo_a(const struct sockaddr *sa, socklen_t salen,
- char *nodename, socklen_t nodenamelen,
- char *servname, socklen_t servnamelen,
- int flags)
- {
- char *enodename = NULL;
- char *eservname = NULL;
- int status;
- if(nodename && nodenamelen) {
- enodename = malloc(nodenamelen);
- if(!enodename)
- return EAI_MEMORY;
- }
- if(servname && servnamelen) {
- eservname = malloc(servnamelen);
- if(!eservname) {
- free(enodename);
- return EAI_MEMORY;
- }
- }
- status = getnameinfo(sa, salen, enodename, nodenamelen,
- eservname, servnamelen, flags);
- if(!status) {
- int i;
- if(enodename) {
- i = QadrtConvertE2A(nodename, enodename,
- nodenamelen - 1, strlen(enodename));
- nodename[i] = '\0';
- }
- if(eservname) {
- i = QadrtConvertE2A(servname, eservname,
- servnamelen - 1, strlen(eservname));
- servname[i] = '\0';
- }
- }
- free(enodename);
- free(eservname);
- return status;
- }
- int
- Curl_getaddrinfo_a(const char *nodename, const char *servname,
- const struct addrinfo *hints,
- struct addrinfo **res)
- {
- char *enodename;
- char *eservname;
- int status;
- int i;
- enodename = (char *) NULL;
- eservname = (char *) NULL;
- if(nodename) {
- i = strlen(nodename);
- enodename = malloc(i + 1);
- if(!enodename)
- return EAI_MEMORY;
- i = QadrtConvertA2E(enodename, nodename, i, i);
- enodename[i] = '\0';
- }
- if(servname) {
- i = strlen(servname);
- eservname = malloc(i + 1);
- if(!eservname) {
- free(enodename);
- return EAI_MEMORY;
- }
- QadrtConvertA2E(eservname, servname, i, i);
- eservname[i] = '\0';
- }
- status = getaddrinfo(enodename, eservname, hints, res);
- free(enodename);
- free(eservname);
- return status;
- }
- #ifdef HAVE_GSSAPI
- /* ASCII wrappers for the GSSAPI procedures. */
- static int
- Curl_gss_convert_in_place(OM_uint32 *minor_status, gss_buffer_t buf)
- {
- unsigned int i = buf->length;
- /* Convert `buf' in place, from EBCDIC to ASCII.
- If error, release the buffer and return -1. Else return 0. */
- if(i) {
- char *t = malloc(i);
- if(!t) {
- gss_release_buffer(minor_status, buf);
- if(minor_status)
- *minor_status = ENOMEM;
- return -1;
- }
- QadrtConvertE2A(t, buf->value, i, i);
- memcpy(buf->value, t, i);
- free(t);
- }
- return 0;
- }
- OM_uint32
- Curl_gss_import_name_a(OM_uint32 *minor_status, gss_buffer_t in_name,
- gss_OID in_name_type, gss_name_t *out_name)
- {
- OM_uint32 rc;
- unsigned int i;
- gss_buffer_desc in;
- if(!in_name || !in_name->value || !in_name->length)
- return gss_import_name(minor_status, in_name, in_name_type, out_name);
- memcpy((char *) &in, (char *) in_name, sizeof(in));
- i = in.length;
- in.value = malloc(i + 1);
- if(!in.value) {
- if(minor_status)
- *minor_status = ENOMEM;
- return GSS_S_FAILURE;
- }
- QadrtConvertA2E(in.value, in_name->value, i, i);
- ((char *) in.value)[i] = '\0';
- rc = gss_import_name(minor_status, &in, in_name_type, out_name);
- free(in.value);
- return rc;
- }
- OM_uint32
- Curl_gss_display_status_a(OM_uint32 *minor_status, OM_uint32 status_value,
- int status_type, gss_OID mech_type,
- gss_msg_ctx_t *message_context,
- gss_buffer_t status_string)
- {
- int rc;
- rc = gss_display_status(minor_status, status_value, status_type,
- mech_type, message_context, status_string);
- if(rc != GSS_S_COMPLETE || !status_string ||
- !status_string->length || !status_string->value)
- return rc;
- /* No way to allocate a buffer here, because it will be released by
- gss_release_buffer(). The solution is to overwrite the EBCDIC buffer
- with ASCII to return it. */
- if(Curl_gss_convert_in_place(minor_status, status_string))
- return GSS_S_FAILURE;
- return rc;
- }
- OM_uint32
- Curl_gss_init_sec_context_a(OM_uint32 *minor_status,
- gss_cred_id_t cred_handle,
- gss_ctx_id_t *context_handle,
- gss_name_t target_name, gss_OID mech_type,
- gss_flags_t req_flags, OM_uint32 time_req,
- gss_channel_bindings_t input_chan_bindings,
- gss_buffer_t input_token,
- gss_OID *actual_mech_type,
- gss_buffer_t output_token, gss_flags_t *ret_flags,
- OM_uint32 *time_rec)
- {
- int rc;
- gss_buffer_desc in;
- gss_buffer_t inp;
- in.value = NULL;
- inp = input_token;
- if(inp) {
- if(inp->length && inp->value) {
- unsigned int i = inp->length;
- in.value = malloc(i + 1);
- if(!in.value) {
- if(minor_status)
- *minor_status = ENOMEM;
- return GSS_S_FAILURE;
- }
- QadrtConvertA2E(in.value, input_token->value, i, i);
- ((char *) in.value)[i] = '\0';
- in.length = i;
- inp = ∈
- }
- }
- rc = gss_init_sec_context(minor_status, cred_handle, context_handle,
- target_name, mech_type, req_flags, time_req,
- input_chan_bindings, inp, actual_mech_type,
- output_token, ret_flags, time_rec);
- free(in.value);
- if(rc != GSS_S_COMPLETE || !output_token ||
- !output_token->length || !output_token->value)
- return rc;
- /* No way to allocate a buffer here, because it will be released by
- gss_release_buffer(). The solution is to overwrite the EBCDIC buffer
- with ASCII to return it. */
- if(Curl_gss_convert_in_place(minor_status, output_token))
- return GSS_S_FAILURE;
- return rc;
- }
- OM_uint32
- Curl_gss_delete_sec_context_a(OM_uint32 *minor_status,
- gss_ctx_id_t *context_handle,
- gss_buffer_t output_token)
- {
- OM_uint32 rc;
- rc = gss_delete_sec_context(minor_status, context_handle, output_token);
- if(rc != GSS_S_COMPLETE || !output_token ||
- !output_token->length || !output_token->value)
- return rc;
- /* No way to allocate a buffer here, because it will be released by
- gss_release_buffer(). The solution is to overwrite the EBCDIC buffer
- with ASCII to return it. */
- if(Curl_gss_convert_in_place(minor_status, output_token))
- return GSS_S_FAILURE;
- return rc;
- }
- #endif /* HAVE_GSSAPI */
- #ifndef CURL_DISABLE_LDAP
- /* ASCII wrappers for the LDAP procedures. */
- void *
- Curl_ldap_init_a(char *host, int port)
- {
- size_t i;
- char *ehost;
- void *result;
- if(!host)
- return (void *) ldap_init(host, port);
- i = strlen(host);
- ehost = malloc(i + 1);
- if(!ehost)
- return (void *) NULL;
- QadrtConvertA2E(ehost, host, i, i);
- ehost[i] = '\0';
- result = (void *) ldap_init(ehost, port);
- free(ehost);
- return result;
- }
- int
- Curl_ldap_simple_bind_s_a(void *ld, char *dn, char *passwd)
- {
- int i;
- char *edn;
- char *epasswd;
- edn = (char *) NULL;
- epasswd = (char *) NULL;
- if(dn) {
- i = strlen(dn);
- edn = malloc(i + 1);
- if(!edn)
- return LDAP_NO_MEMORY;
- QadrtConvertA2E(edn, dn, i, i);
- edn[i] = '\0';
- }
- if(passwd) {
- i = strlen(passwd);
- epasswd = malloc(i + 1);
- if(!epasswd) {
- free(edn);
- return LDAP_NO_MEMORY;
- }
- QadrtConvertA2E(epasswd, passwd, i, i);
- epasswd[i] = '\0';
- }
- i = ldap_simple_bind_s(ld, edn, epasswd);
- free(epasswd);
- free(edn);
- return i;
- }
- int
- Curl_ldap_search_s_a(void *ld, char *base, int scope, char *filter,
- char **attrs, int attrsonly, LDAPMessage **res)
- {
- int i;
- int j;
- char *ebase;
- char *efilter;
- char **eattrs;
- int status;
- ebase = (char *) NULL;
- efilter = (char *) NULL;
- eattrs = (char **) NULL;
- status = LDAP_SUCCESS;
- if(base) {
- i = strlen(base);
- ebase = malloc(i + 1);
- if(!ebase)
- status = LDAP_NO_MEMORY;
- else {
- QadrtConvertA2E(ebase, base, i, i);
- ebase[i] = '\0';
- }
- }
- if(filter && status == LDAP_SUCCESS) {
- i = strlen(filter);
- efilter = malloc(i + 1);
- if(!efilter)
- status = LDAP_NO_MEMORY;
- else {
- QadrtConvertA2E(efilter, filter, i, i);
- efilter[i] = '\0';
- }
- }
- if(attrs && status == LDAP_SUCCESS) {
- for(i = 0; attrs[i++];)
- ;
- eattrs = calloc(i, sizeof(*eattrs));
- if(!eattrs)
- status = LDAP_NO_MEMORY;
- else {
- for(j = 0; attrs[j]; j++) {
- i = strlen(attrs[j]);
- eattrs[j] = malloc(i + 1);
- if(!eattrs[j]) {
- status = LDAP_NO_MEMORY;
- break;
- }
- QadrtConvertA2E(eattrs[j], attrs[j], i, i);
- eattrs[j][i] = '\0';
- }
- }
- }
- if(status == LDAP_SUCCESS)
- status = ldap_search_s(ld, ebase? ebase: "", scope,
- efilter? efilter: "(objectclass=*)",
- eattrs, attrsonly, res);
- if(eattrs) {
- for(j = 0; eattrs[j]; j++)
- free(eattrs[j]);
- free(eattrs);
- }
- free(efilter);
- free(ebase);
- return status;
- }
- struct berval **
- Curl_ldap_get_values_len_a(void *ld, LDAPMessage *entry, const char *attr)
- {
- char *cp;
- struct berval **result;
- cp = (char *) NULL;
- if(attr) {
- int i = strlen(attr);
- cp = malloc(i + 1);
- if(!cp) {
- ldap_set_lderrno(ld, LDAP_NO_MEMORY, NULL,
- ldap_err2string(LDAP_NO_MEMORY));
- return (struct berval **) NULL;
- }
- QadrtConvertA2E(cp, attr, i, i);
- cp[i] = '\0';
- }
- result = ldap_get_values_len(ld, entry, cp);
- free(cp);
- /* Result data are binary in nature, so they haven't been
- converted to EBCDIC. Therefore do not convert. */
- return result;
- }
- char *
- Curl_ldap_err2string_a(int error)
- {
- return set_thread_string(LK_LDAP_ERROR, ldap_err2string(error));
- }
- char *
- Curl_ldap_get_dn_a(void *ld, LDAPMessage *entry)
- {
- int i;
- char *cp;
- char *cp2;
- cp = ldap_get_dn(ld, entry);
- if(!cp)
- return cp;
- i = strlen(cp);
- cp2 = malloc(i + 1);
- if(!cp2)
- return cp2;
- QadrtConvertE2A(cp2, cp, i, i);
- cp2[i] = '\0';
- /* No way to allocate a buffer here, because it will be released by
- ldap_memfree() and ldap_memalloc() does not exist. The solution is to
- overwrite the EBCDIC buffer with ASCII to return it. */
- strcpy(cp, cp2);
- free(cp2);
- return cp;
- }
- char *
- Curl_ldap_first_attribute_a(void *ld,
- LDAPMessage *entry, BerElement **berptr)
- {
- int i;
- char *cp;
- char *cp2;
- cp = ldap_first_attribute(ld, entry, berptr);
- if(!cp)
- return cp;
- i = strlen(cp);
- cp2 = malloc(i + 1);
- if(!cp2)
- return cp2;
- QadrtConvertE2A(cp2, cp, i, i);
- cp2[i] = '\0';
- /* No way to allocate a buffer here, because it will be released by
- ldap_memfree() and ldap_memalloc() does not exist. The solution is to
- overwrite the EBCDIC buffer with ASCII to return it. */
- strcpy(cp, cp2);
- free(cp2);
- return cp;
- }
- char *
- Curl_ldap_next_attribute_a(void *ld,
- LDAPMessage *entry, BerElement *berptr)
- {
- int i;
- char *cp;
- char *cp2;
- cp = ldap_next_attribute(ld, entry, berptr);
- if(!cp)
- return cp;
- i = strlen(cp);
- cp2 = malloc(i + 1);
- if(!cp2)
- return cp2;
- QadrtConvertE2A(cp2, cp, i, i);
- cp2[i] = '\0';
- /* No way to allocate a buffer here, because it will be released by
- ldap_memfree() and ldap_memalloc() does not exist. The solution is to
- overwrite the EBCDIC buffer with ASCII to return it. */
- strcpy(cp, cp2);
- free(cp2);
- return cp;
- }
- #endif /* CURL_DISABLE_LDAP */
- static int
- sockaddr2ebcdic(struct sockaddr_storage *dstaddr,
- const struct sockaddr *srcaddr, int srclen)
- {
- const struct sockaddr_un *srcu;
- struct sockaddr_un *dstu;
- unsigned int i;
- unsigned int dstsize;
- /* Convert a socket address to job CCSID, if needed. */
- if(!srcaddr || srclen < offsetof(struct sockaddr, sa_family) +
- sizeof(srcaddr->sa_family) || srclen > sizeof(*dstaddr)) {
- errno = EINVAL;
- return -1;
- }
- memcpy((char *) dstaddr, (char *) srcaddr, srclen);
- switch(srcaddr->sa_family) {
- case AF_UNIX:
- srcu = (const struct sockaddr_un *) srcaddr;
- dstu = (struct sockaddr_un *) dstaddr;
- dstsize = sizeof(*dstaddr) - offsetof(struct sockaddr_un, sun_path);
- srclen -= offsetof(struct sockaddr_un, sun_path);
- i = QadrtConvertA2E(dstu->sun_path, srcu->sun_path, dstsize - 1, srclen);
- dstu->sun_path[i] = '\0';
- srclen = i + offsetof(struct sockaddr_un, sun_path);
- }
- return srclen;
- }
- static int
- sockaddr2ascii(struct sockaddr *dstaddr, int dstlen,
- const struct sockaddr_storage *srcaddr, int srclen)
- {
- const struct sockaddr_un *srcu;
- struct sockaddr_un *dstu;
- unsigned int dstsize;
- /* Convert a socket address to ASCII, if needed. */
- if(!srclen)
- return 0;
- if(srclen > dstlen)
- srclen = dstlen;
- if(!srcaddr || srclen < 0) {
- errno = EINVAL;
- return -1;
- }
- memcpy((char *) dstaddr, (char *) srcaddr, srclen);
- if(srclen >= offsetof(struct sockaddr_storage, ss_family) +
- sizeof(srcaddr->ss_family)) {
- switch(srcaddr->ss_family) {
- case AF_UNIX:
- srcu = (const struct sockaddr_un *) srcaddr;
- dstu = (struct sockaddr_un *) dstaddr;
- dstsize = dstlen - offsetof(struct sockaddr_un, sun_path);
- srclen -= offsetof(struct sockaddr_un, sun_path);
- if(dstsize > 0 && srclen > 0) {
- srclen = QadrtConvertE2A(dstu->sun_path, srcu->sun_path,
- dstsize - 1, srclen);
- dstu->sun_path[srclen] = '\0';
- }
- srclen += offsetof(struct sockaddr_un, sun_path);
- }
- }
- return srclen;
- }
- int
- Curl_os400_connect(int sd, struct sockaddr *destaddr, int addrlen)
- {
- int i;
- struct sockaddr_storage laddr;
- i = sockaddr2ebcdic(&laddr, destaddr, addrlen);
- if(i < 0)
- return -1;
- return connect(sd, (struct sockaddr *) &laddr, i);
- }
- int
- Curl_os400_bind(int sd, struct sockaddr *localaddr, int addrlen)
- {
- int i;
- struct sockaddr_storage laddr;
- i = sockaddr2ebcdic(&laddr, localaddr, addrlen);
- if(i < 0)
- return -1;
- return bind(sd, (struct sockaddr *) &laddr, i);
- }
- int
- Curl_os400_sendto(int sd, char *buffer, int buflen, int flags,
- const struct sockaddr *dstaddr, int addrlen)
- {
- int i;
- struct sockaddr_storage laddr;
- i = sockaddr2ebcdic(&laddr, dstaddr, addrlen);
- if(i < 0)
- return -1;
- return sendto(sd, buffer, buflen, flags, (struct sockaddr *) &laddr, i);
- }
- int
- Curl_os400_recvfrom(int sd, char *buffer, int buflen, int flags,
- struct sockaddr *fromaddr, int *addrlen)
- {
- int rcvlen;
- struct sockaddr_storage laddr;
- int laddrlen = sizeof(laddr);
- if(!fromaddr || !addrlen || *addrlen <= 0)
- return recvfrom(sd, buffer, buflen, flags, fromaddr, addrlen);
- laddr.ss_family = AF_UNSPEC; /* To detect if unused. */
- rcvlen = recvfrom(sd, buffer, buflen, flags,
- (struct sockaddr *) &laddr, &laddrlen);
- if(rcvlen < 0)
- return rcvlen;
- if(laddr.ss_family == AF_UNSPEC)
- laddrlen = 0;
- else {
- laddrlen = sockaddr2ascii(fromaddr, *addrlen, &laddr, laddrlen);
- if(laddrlen < 0)
- return laddrlen;
- }
- *addrlen = laddrlen;
- return rcvlen;
- }
- int
- Curl_os400_getpeername(int sd, struct sockaddr *addr, int *addrlen)
- {
- struct sockaddr_storage laddr;
- int laddrlen = sizeof(laddr);
- int retcode = getpeername(sd, (struct sockaddr *) &laddr, &laddrlen);
- if(!retcode) {
- laddrlen = sockaddr2ascii(addr, *addrlen, &laddr, laddrlen);
- if(laddrlen < 0)
- return laddrlen;
- *addrlen = laddrlen;
- }
- return retcode;
- }
- int
- Curl_os400_getsockname(int sd, struct sockaddr *addr, int *addrlen)
- {
- struct sockaddr_storage laddr;
- int laddrlen = sizeof(laddr);
- int retcode = getsockname(sd, (struct sockaddr *) &laddr, &laddrlen);
- if(!retcode) {
- laddrlen = sockaddr2ascii(addr, *addrlen, &laddr, laddrlen);
- if(laddrlen < 0)
- return laddrlen;
- *addrlen = laddrlen;
- }
- return retcode;
- }
- #ifdef HAVE_LIBZ
- const char *
- Curl_os400_zlibVersion(void)
- {
- return set_thread_string(LK_ZLIB_VERSION, zlibVersion());
- }
- int
- Curl_os400_inflateInit_(z_streamp strm, const char *version, int stream_size)
- {
- z_const char *msgb4 = strm->msg;
- int ret;
- ret = inflateInit(strm);
- if(strm->msg != msgb4)
- strm->msg = set_thread_string(LK_ZLIB_MSG, strm->msg);
- return ret;
- }
- int
- Curl_os400_inflateInit2_(z_streamp strm, int windowBits,
- const char *version, int stream_size)
- {
- z_const char *msgb4 = strm->msg;
- int ret;
- ret = inflateInit2(strm, windowBits);
- if(strm->msg != msgb4)
- strm->msg = set_thread_string(LK_ZLIB_MSG, strm->msg);
- return ret;
- }
- int
- Curl_os400_inflate(z_streamp strm, int flush)
- {
- z_const char *msgb4 = strm->msg;
- int ret;
- ret = inflate(strm, flush);
- if(strm->msg != msgb4)
- strm->msg = set_thread_string(LK_ZLIB_MSG, strm->msg);
- return ret;
- }
- int
- Curl_os400_inflateEnd(z_streamp strm)
- {
- z_const char *msgb4 = strm->msg;
- int ret;
- ret = inflateEnd(strm);
- if(strm->msg != msgb4)
- strm->msg = set_thread_string(LK_ZLIB_MSG, strm->msg);
- return ret;
- }
- #endif
|