public
Fork of riham/eventmachine
Description: A fast network I/O and event-management framework for Ruby, Java, and C++ programmers.
Homepage: http://rubyeventmachine.com
Clone URL: git://github.com/espace/eventmachine.git
eventmachine / ext / files.cpp
100644 95 lines (65 sloc) 2.012 kb
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
/*****************************************************************************
 
$Id$
 
File: files.cpp
Date: 26Aug06
 
Copyright (C) 2006-07 by Francis Cianfrocca. All Rights Reserved.
Gmail: blackhedd
 
This program is free software; you can redistribute it and/or modify
it under the terms of either: 1) the GNU General Public License
as published by the Free Software Foundation; either version 2 of the
License, or (at your option) any later version; or 2) Ruby's License.
 
See the file COPYING for complete licensing information.
 
*****************************************************************************/
 
#include "project.h"
 
 
/******************************************
FileStreamDescriptor::FileStreamDescriptor
******************************************/
 
FileStreamDescriptor::FileStreamDescriptor (int fd, EventMachine_t *em):
EventableDescriptor (fd, em),
OutboundDataSize (0)
{
cerr << "#####";
}
 
 
/*******************************************
FileStreamDescriptor::~FileStreamDescriptor
*******************************************/
 
FileStreamDescriptor::~FileStreamDescriptor()
{
// Run down any stranded outbound data.
for (size_t i=0; i < OutboundPages.size(); i++)
OutboundPages[i].Free();
}
 
 
/**************************
FileStreamDescriptor::Read
**************************/
 
void FileStreamDescriptor::Read()
{
}
 
/***************************
FileStreamDescriptor::Write
***************************/
 
void FileStreamDescriptor::Write()
{
}
 
 
/*******************************
FileStreamDescriptor::Heartbeat
*******************************/
 
void FileStreamDescriptor::Heartbeat()
{
}
 
 
/***********************************
FileStreamDescriptor::SelectForRead
***********************************/
 
bool FileStreamDescriptor::SelectForRead()
{
  cerr << "R?";
  return false;
}
 
 
/************************************
FileStreamDescriptor::SelectForWrite
************************************/
 
bool FileStreamDescriptor::SelectForWrite()
{
  cerr << "W?";
  return false;
}