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
|
#ifndef NULLSOFT_JNETCOMH
#define NULLSOFT_JNETCOMH
#include <process.h>
#include <ocidl.h>
#include "../../..\Components\wac_network\wac_network_http_receiver_api.h"
#include <objbase.h>
#include "BufferCache.h"
#include <map>
#include <string>
typedef std::map<std::wstring, Buffer_GrowBuf *> BufferMap;
extern BufferMap buffer_map;
#define WORKSIZE 32768
class JnetCOM : public IDispatch
{
public:
JnetCOM() :
refCount(1),
threadexit(0),
active(0),
jnetThread(0),
jnetbuf(NULL),
isBlocking(0),
finalSize(0),
getter(NULL),
callback(NULL),
postData(0),
url(0),
callingThreadId(0),
callingThreadHandle(0)
{
memset(errorstr, 0, sizeof(errorstr));
}
STDMETHOD(QueryInterface)(REFIID riid, PVOID *ppvObject);
STDMETHOD_(ULONG, AddRef)(void);
STDMETHOD_(ULONG, Release)(void);
int refCount;
// *** IDispatch Methods ***
STDMETHOD (GetIDsOfNames)(REFIID riid, OLECHAR FAR* FAR* rgszNames, unsigned int cNames, LCID lcid, DISPID FAR* rgdispid);
STDMETHOD (GetTypeInfo)(unsigned int itinfo, LCID lcid, ITypeInfo FAR* FAR* pptinfo);
STDMETHOD (GetTypeInfoCount)(unsigned int FAR * pctinfo);
STDMETHOD (Invoke)(DISPID dispid, REFIID riid, LCID lcid, WORD wFlags, DISPPARAMS FAR *pdispparams, VARIANT FAR *pvarResult, EXCEPINFO FAR * pexecinfo, unsigned int FAR *puArgErr);
void DownloadURL(DISPPARAMS FAR *pdispparams );
void PostURL(DISPPARAMS FAR *pdispparams);
void callBack();
int threadexit;
int isBlocking;
api_httpreceiver *getter;
Buffer_GrowBuf *jnetbuf;
IDispatch *callback;
BSTR htmldiv;
DWORD callingThreadId;
HANDLE callingThreadHandle;
static DWORD WINAPI JThreadProc(void *param)
{
CoInitialize(NULL);
JnetCOM *th = static_cast<JnetCOM*>(param);
int ret = th->JthreadProc();
_endthread();
return ret;
}
static DWORD WINAPI jnetPostProcedure(void *param)
{
CoInitialize(NULL);
JnetCOM *th = static_cast<JnetCOM*>(param);
int ret = th->PostProcedure();
_endthread();
return ret;
}
size_t finalSize;
wchar_t *url;
char *postData;
int active;
char errorstr[2048];
HANDLE jnetThread;
private:
int JthreadProc();
int PostProcedure();
};
#endif
|
