postal/smtpserver.cpp at main · simta/postal · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
#include "smtpserver.h"

int smtp_server::m_processes = 0;
int smtp_server::m_max_conn = 0;
int smtp_server::m_nextThread = 0;


smtp_server::smtp_server( short port, UserList &ul, int maxMsgSize
                          , int processes, Logit *log, Logit *debug
#ifdef USE_SSL
                          , bool use_ssl
#endif
                          )
    : tcp( NULL, port, log
#ifdef USE_SSL
           , use_ssl
#endif
           , debug )
    , m_ul( ul )
    , m_res( new results )
    , m_maxMsgSize( maxMsgSize )
{
    m_max_conn = processes;
}

smtp_server::smtp_server( int threadNum, const smtp_server *parent )
    : tcp( threadNum, parent )
    , m_ul( parent->m_ul )
    , m_res( parent->m_res )
    , m_maxMsgSize( parent->m_maxMsgSize )
{
}


Thread *
smtp_server::newThread( int threadNum )
{
    return( new smtp_server( threadNum, this ));
}

smtp_server::~smtp_server( )
{
}

int
smtp_server::action( PVOID )
{
    while ( 1 ) {

    }
}

int
smtp_server::pollRead( )
{
    m_res->pollPrint( );
    if ( m_max_conn && m_processes < m_max_conn ) {
        int rc = pollForAccept( );
        if ( rc == -1 ) {
            return( -1 );
        }
        if ( rc == 1 ) {
            smtp_server *n = (smtp_server*)newThread( m_nextThread );
            if ( n->isOpen( )) {
                m_nextThread++;
                m_processes++;
            }else  {
                delete n;
            }
        }
    }
    return( 0 );
}

void
smtp_server::error( )
{
    m_res->error( );
    tcp::disconnect( );
}

int
smtp_server::WriteWork( PVOID buf, int size, int timeout )
{
    return( Write( buf, size, timeout ));
}

void
smtp_server::sentData( int bytes )
{
    m_res->dataBytes( bytes );
}

ERROR_TYPE
smtp_server::readCommandResp( )
{
    char recvBuf[ 1024 ];

}

int
smtp_server::doAllWork( )
{

}

int
smtp_server::disconnect( )
{
    const char * str = "550 disconnect\r\n";
    const len = strlen( str );

    rc = sendData( str, len );
    if ( rc != len ) {
        return( -1 );
    }
    rc =
}