Annotation of ircnowd/src/ngircd/conn-func.c, Revision 1.1
1.1 ! tomglok 1: /*
! 2: * ngIRCd -- The Next Generation IRC Daemon
! 3: * Copyright (c)2001-2018 Alexander Barton (alex@barton.de) and Contributors.
! 4: *
! 5: * This program is free software; you can redistribute it and/or modify
! 6: * it under the terms of the GNU General Public License as published by
! 7: * the Free Software Foundation; either version 2 of the License, or
! 8: * (at your option) any later version.
! 9: * Please read the file COPYING, README and AUTHORS for more information.
! 10: */
! 11:
! 12: #define CONN_MODULE
! 13:
! 14: #include "portab.h"
! 15:
! 16: /**
! 17: * @file
! 18: * Connection management: Global functions
! 19: */
! 20:
! 21: #include <assert.h>
! 22: #include <time.h>
! 23:
! 24: #ifdef DEBUG
! 25: # include "log.h"
! 26: #endif
! 27: #include "conn.h"
! 28:
! 29: #include "conf.h"
! 30: #include "conn-func.h"
! 31:
! 32: /**
! 33: * Update "idle timestamp", the time of the last visible user action
! 34: * (e. g. like sending messages, joining or leaving channels).
! 35: *
! 36: * @param Idx Connection index.
! 37: */
! 38: GLOBAL void
! 39: Conn_UpdateIdle(CONN_ID Idx)
! 40: {
! 41: assert(Idx > NONE);
! 42: My_Connections[Idx].lastprivmsg = time(NULL);
! 43: }
! 44:
! 45: /**
! 46: * Update "ping timestamp", the time of the last outgoing PING request.
! 47: *
! 48: * the value 0 signals a newly connected client including servers during the
! 49: * initial "server burst"; and 1 means that no PONG is pending for a PING.
! 50: *
! 51: * @param Idx Connection index.
! 52: * @param TimeStamp 0, 1, or time stamp.
! 53: */
! 54: GLOBAL void
! 55: Conn_UpdatePing(CONN_ID Idx, time_t TimeStamp)
! 56: {
! 57: assert(Idx > NONE);
! 58: My_Connections[Idx].lastping = TimeStamp;
! 59: }
! 60:
! 61: /*
! 62: * Get signon time of a connection.
! 63: */
! 64: GLOBAL time_t
! 65: Conn_GetSignon(CONN_ID Idx)
! 66: {
! 67: assert(Idx > NONE);
! 68: return My_Connections[Idx].signon;
! 69: }
! 70:
! 71: GLOBAL time_t
! 72: Conn_GetIdle( CONN_ID Idx )
! 73: {
! 74: /* Return Idle-Timer of a connetion */
! 75: assert( Idx > NONE );
! 76: return time( NULL ) - My_Connections[Idx].lastprivmsg;
! 77: } /* Conn_GetIdle */
! 78:
! 79: GLOBAL time_t
! 80: Conn_LastPing( CONN_ID Idx )
! 81: {
! 82: assert( Idx > NONE );
! 83: return My_Connections[Idx].lastping;
! 84: } /* Conn_LastPing */
! 85:
! 86: /**
! 87: * Add "penalty time" for a connection.
! 88: *
! 89: * During the "penalty time" the socket is ignored completely, no new data
! 90: * is read. This function only increases the penalty, it is not possible to
! 91: * decrease the penalty time.
! 92: *
! 93: * @param Idx Connection index.
! 94: * @param Seconds Seconds to add.
! 95: * @see Conn_ResetPenalty
! 96: */
! 97: GLOBAL void
! 98: Conn_SetPenalty(CONN_ID Idx, time_t Seconds)
! 99: {
! 100: time_t t;
! 101:
! 102: assert(Idx > NONE);
! 103: assert(Seconds >= 0);
! 104:
! 105: /* Limit new penalty to maximum configured, when less than 10 seconds. *
! 106: The latter is used to limit brute force attacks, therefore we don't *
! 107: want to limit that! */
! 108: if (Conf_MaxPenaltyTime >= 0
! 109: && Seconds > Conf_MaxPenaltyTime
! 110: && Seconds < 10)
! 111: Seconds = Conf_MaxPenaltyTime;
! 112:
! 113: t = time(NULL);
! 114: if (My_Connections[Idx].delaytime < t)
! 115: My_Connections[Idx].delaytime = t;
! 116:
! 117: My_Connections[Idx].delaytime += Seconds;
! 118:
! 119: #ifdef DEBUG
! 120: Log(LOG_DEBUG,
! 121: "Add penalty time on connection %d: %ld second%s, total %ld second%s.",
! 122: Idx, (long)Seconds, Seconds != 1 ? "s" : "",
! 123: My_Connections[Idx].delaytime - t,
! 124: My_Connections[Idx].delaytime - t != 1 ? "s" : "");
! 125: #endif
! 126: } /* Conn_SetPenalty */
! 127:
! 128: GLOBAL void
! 129: Conn_ClearFlags( void )
! 130: {
! 131: CONN_ID i;
! 132:
! 133: for( i = 0; i < Pool_Size; i++ ) My_Connections[i].flag = 0;
! 134: } /* Conn_ClearFlags */
! 135:
! 136: GLOBAL int
! 137: Conn_Flag( CONN_ID Idx )
! 138: {
! 139: assert( Idx > NONE );
! 140: return My_Connections[Idx].flag;
! 141: } /* Conn_Flag */
! 142:
! 143: GLOBAL void
! 144: Conn_SetFlag( CONN_ID Idx, int Flag )
! 145: {
! 146: assert( Idx > NONE );
! 147: My_Connections[Idx].flag = Flag;
! 148: } /* Conn_SetFlag */
! 149:
! 150: GLOBAL CONN_ID
! 151: Conn_First( void )
! 152: {
! 153: CONN_ID i;
! 154:
! 155: for( i = 0; i < Pool_Size; i++ )
! 156: {
! 157: if( My_Connections[i].sock != NONE ) return i;
! 158: }
! 159: return NONE;
! 160: } /* Conn_First */
! 161:
! 162: GLOBAL CONN_ID
! 163: Conn_Next( CONN_ID Idx )
! 164: {
! 165: CONN_ID i = NONE;
! 166:
! 167: assert( Idx > NONE );
! 168:
! 169: for( i = Idx + 1; i < Pool_Size; i++ )
! 170: {
! 171: if( My_Connections[i].sock != NONE ) return i;
! 172: }
! 173: return NONE;
! 174: } /* Conn_Next */
! 175:
! 176: GLOBAL UINT16
! 177: Conn_Options( CONN_ID Idx )
! 178: {
! 179: assert( Idx > NONE );
! 180: return My_Connections[Idx].options;
! 181: } /* Conn_Options */
! 182:
! 183: /**
! 184: * Set connection option.
! 185: */
! 186: GLOBAL void
! 187: Conn_SetOption(CONN_ID Idx, int Option)
! 188: {
! 189: assert(Idx > NONE);
! 190: Conn_OPTION_ADD(&My_Connections[Idx], Option);
! 191: } /* Conn_SetOption */
! 192:
! 193: /**
! 194: * Get the start time of the connection.
! 195: * The result is the start time in seconds since 1970-01-01, as reported
! 196: * by the C function time(NULL).
! 197: */
! 198: GLOBAL time_t
! 199: Conn_StartTime( CONN_ID Idx )
! 200: {
! 201: CLIENT *c;
! 202:
! 203: assert(Idx > NONE);
! 204:
! 205: /* Search client structure for this link ... */
! 206: c = Conn_GetClient(Idx);
! 207: if(c != NULL)
! 208: return Client_StartTime(c);
! 209:
! 210: return 0;
! 211: } /* Conn_StartTime */
! 212:
! 213: /**
! 214: * return number of bytes queued for writing
! 215: */
! 216: GLOBAL size_t
! 217: Conn_SendQ( CONN_ID Idx )
! 218: {
! 219: assert( Idx > NONE );
! 220: #ifdef ZLIB
! 221: if( My_Connections[Idx].options & CONN_ZIP )
! 222: return array_bytes(&My_Connections[Idx].zip.wbuf);
! 223: else
! 224: #endif
! 225: return array_bytes(&My_Connections[Idx].wbuf);
! 226: } /* Conn_SendQ */
! 227:
! 228: /**
! 229: * return number of messages sent on this connection so far
! 230: */
! 231: GLOBAL long
! 232: Conn_SendMsg( CONN_ID Idx )
! 233: {
! 234:
! 235: assert( Idx > NONE );
! 236: return My_Connections[Idx].msg_out;
! 237: } /* Conn_SendMsg */
! 238:
! 239: /**
! 240: * return number of (uncompressed) bytes sent
! 241: * on this connection so far
! 242: */
! 243: GLOBAL long
! 244: Conn_SendBytes( CONN_ID Idx )
! 245: {
! 246: assert( Idx > NONE );
! 247: return My_Connections[Idx].bytes_out;
! 248: } /* Conn_SendBytes */
! 249:
! 250: /**
! 251: * return number of bytes pending in read buffer
! 252: */
! 253: GLOBAL size_t
! 254: Conn_RecvQ( CONN_ID Idx )
! 255: {
! 256: assert( Idx > NONE );
! 257: #ifdef ZLIB
! 258: if( My_Connections[Idx].options & CONN_ZIP )
! 259: return array_bytes(&My_Connections[Idx].zip.rbuf);
! 260: else
! 261: #endif
! 262: return array_bytes(&My_Connections[Idx].rbuf);
! 263: } /* Conn_RecvQ */
! 264:
! 265: /**
! 266: * return number of messages received on this connection so far
! 267: */
! 268: GLOBAL long
! 269: Conn_RecvMsg( CONN_ID Idx )
! 270: {
! 271: assert( Idx > NONE );
! 272: return My_Connections[Idx].msg_in;
! 273: } /* Conn_RecvMsg */
! 274:
! 275: /**
! 276: * return number of (uncompressed) bytes received on this
! 277: * connection so far
! 278: */
! 279: GLOBAL long
! 280: Conn_RecvBytes( CONN_ID Idx )
! 281: {
! 282: assert( Idx > NONE );
! 283: return My_Connections[Idx].bytes_in;
! 284: } /* Conn_RecvBytes */
! 285:
! 286: /**
! 287: * Return the remote IP address of this connection as string.
! 288: */
! 289: GLOBAL const char *
! 290: Conn_IPA(CONN_ID Idx)
! 291: {
! 292: assert (Idx > NONE);
! 293: return ng_ipaddr_tostr(&My_Connections[Idx].addr);
! 294: }
! 295:
! 296: GLOBAL void
! 297: Conn_ResetWCounter( void )
! 298: {
! 299: WCounter = 0;
! 300: } /* Conn_ResetWCounter */
! 301:
! 302: GLOBAL long
! 303: Conn_WCounter( void )
! 304: {
! 305: return WCounter;
! 306: } /* Conn_WCounter */
! 307:
! 308: /* -eof- */
CVSweb
![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to conn-func.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [local] / ircnowd / src / ngircd