All,
I had some great advice about this a bit ago, but I'm just not good enough
with this code to put together all the pieces. The way the code below works
is as a service. When it is started, it watches a folder that is set in a
registry key, and if there is a file created in that folder, it copies it to
a destination folder, also defined in a registry key. This works fine, for
individual files, and small files, but as mentioned before, if I were to
create a bunch of multiple files almost simulteneously, it only copies the
first one.
I was given some great advice that I should separate the program into
threads, one that listens to the source-dir, and any file that gets created
gets added to a queue. The second thread should basically dequeue anything
in the queue. Well I THINK I was able to separate those two procedures into
their own threads, but I must have done something incorrectly, because it
still can't cope with it when I drop several files in the directory.
Can someone help me get over this one? I was thinking that if I could
somehow put the stuff in the "logchange" sub into the "StartMonitor" sub,
that I might be able to gain something, but at this point I don't see how
that would make any difference.
Imports System.ServiceProcess
Imports System.Threading
Public Class Service1
Inherits System.ServiceProcess.ServiceBase
Dim DestDirectory As String
Dim WatchDirectory As String
Dim SourceFilePath As String
Dim SourceFileName As String
Dim MyQueue As New Queue
Private CopyF As New Thread(New System.Threading.ThreadStart(AddressOf
CopyFile))
Private Watchservice As New Thread(New
System.Threading.ThreadStart(AddressOf StartMonitor))
#Region " Component Designer generated code "
Public Sub New()
MyBase.New()
' This call is required by the Component Designer.
InitializeComponent()
' Add any initialization after the InitializeComponent() call
End Sub
'UserService overrides dispose to clean up the component list.
Protected Overloads Overrides Sub Dispose(ByVal disposing As Boolean)
If disposing Then
If Not (components Is Nothing) Then
components.Dispose()
End If
End If
MyBase.Dispose(disposing)
End Sub
' The main entry point for the process
<MTAThread()_
Shared Sub Main()
Dim ServicesToRun() As System.ServiceProcess.ServiceBase
' More than one NT Service may run within the same process. To add
' another service to this process, change the following line to
' create a second service object. For example,
'
' ServicesToRun = New System.ServiceProcess.ServiceBase () {New Service1,
New MySecondUserService}
'
ServicesToRun = New System.ServiceProcess.ServiceBase() {New Service1}
System.ServiceProcess.ServiceBase.Run(ServicesToRu n)
End Sub
'Required by the Component Designer
Private components As System.ComponentModel.IContainer
' NOTE: The following procedure is required by the Component Designer
' It can be modified using the Component Designer.
' Do not modify it using the code editor.
<System.Diagnostics.DebuggerStepThrough()Private Sub InitializeComponent()
components = New System.ComponentModel.Container()
Me.ServiceName = "Service1"
End Sub
#End Region
Protected Overrides Sub OnStart(ByVal args() As String)
' Start the thread.
Watchservice.Start()
CopyF.Start()
End Sub
Protected Overrides Sub OnStop()
' Add code here to perform any tear-down necessary to stop your service.
Watchservice.Abort()
CopyF.Abort()
End Sub
Private Sub StartMonitor()
WatchDirectory =
My.Computer.Registry.GetValue("HKEY_LOCAL_MACHINE\ Software\CopyMon",
"Source", Nothing)
DestDirectory =
My.Computer.Registry.GetValue("HKEY_LOCAL_MACHINE\ Software\CopyMon",
"Destination", Nothing)
Do
Dim watcher As New System.IO.FileSystemWatcher(WatchDirectory)
Dim result
AddHandler watcher.Created, AddressOf logchange
'Dim SourceFileNameObject As IO.WaitForChangedResult
'Dim SourceFileName As String
'SourceFileName = SourceFileNameObject.Name
'MsgBox(SourceFileName)
result = watcher.WaitForChanged(System.IO.WatcherChangeType s.Created)
Loop
End Sub
Private Sub logchange(ByVal source As Object, ByVal e As
System.IO.FileSystemEventArgs)
If e.ChangeType = IO.WatcherChangeTypes.Created Then
SourceFilePath = e.FullPath
SourceFileName = e.Name
'MsgBox(SourceFilePath)
'MsgBox(DestDirectory & "\" & SourceFileName)
'Add files to queue to be picked off in a new sub below
MyQueue.Enqueue(SourceFilePath)
'MsgBox(MyQueue.Count)
End If
End Sub
Private Sub CopyFile()
Do
System.Threading.Thread.Sleep(60000)
If MyQueue.Count 0 Then
'MsgBox("Starting to copy files hopefully")
'get files from the queue, and copy them to destination path
Dim DestPath As String
Dim DQedSrceFilePath As String
DQedSrceFilePath = MyQueue.Dequeue()
DestPath = DestDirectory & "\" & SourceFileName
My.Computer.FileSystem.CopyFile(DQedSrceFilePath, DestPath)
End If
Loop
End Sub
End Class
