Packages December 2009

packages@lists.squeakfoundation.org

1 participants
1032 discussions

The Trunk: Monticello-ar.346.mcz
by commits＠source.squeak.org 30 Dec '09

30 Dec '09

Andreas Raab uploaded a new version of Monticello to project The Trunk: http://source.squeak.org/trunk/Monticello-ar.346.mcz ==================== Summary ==================== Name: Monticello-ar.346 Author: ar Time: 30 December 2009, 5:04:52 am UUID: 305a6619-474d-314a-9331-9a03c6d97588 Ancestors: Monticello-ar.345 Include names of repository and package in up and download progress. =============== Diff against Monticello-ar.345 =============== Item was changed: ----- Method: MCHttpRepository>>readStreamForFileNamed:do: (in category 'required') ----- readStreamForFileNamed: aString do: aBlock | contents | + self displayProgress: 'Downloading ', aString during:[ + contents := HTTPSocket httpGet: (self urlForFileNamed: aString) args: nil user: self user passwd: self password. + ]. - contents := HTTPSocket httpGet: (self urlForFileNamed: aString) args: nil user: self user passwd: self password. ^ contents isString ifFalse: [aBlock value: contents]! Item was changed: ----- Method: MCHttpRepository>>writeStreamForFileNamed:replace:do: (in category 'required') ----- writeStreamForFileNamed: aString replace: ignoreBoolean do: aBlock | stream response | stream := RWBinaryOrTextStream on: String new. aBlock value: stream. + self displayProgress: 'Uploading ', aString during:[ - self displayProgress: 'Uploading package' during:[ response := HTTPSocket httpPut: stream contents to: (self urlForFileNamed: aString) user: self user passwd: self password. ]. (#( 'HTTP/1.1 201 ' 'HTTP/1.1 200 ' 'HTTP/1.0 201 ' 'HTTP/1.0 200 ') anySatisfy: [:code | response beginsWith: code ]) ifFalse: [self error: response].! Item was changed: ----- Method: MCHttpRepository>>allFileNames (in category 'required') ----- allFileNames | index | + self displayProgress: 'Updating ', self description during:[ - self displayProgress: 'Updating repository' during:[ index := HTTPSocket httpGet: self locationWithTrailingSlash, '?C=M;O=D' args: nil user: self user passwd: self password. ]. index isString ifTrue: [self error: 'Could not access ', location]. ^ self parseFileNamesFromStream: index !

1 0

The Trunk: Monticello-ar.346.mcz
by commits＠source.squeak.org 30 Dec '09

30 Dec '09

1 0

The Trunk: Monticello-ar.346.mcz
by commits＠source.squeak.org 30 Dec '09

30 Dec '09

1 0

The Trunk: Network-ar.47.mcz
by commits＠source.squeak.org 30 Dec '09

30 Dec '09

Andreas Raab uploaded a new version of Network to project The Trunk: http://source.squeak.org/trunk/Network-ar.47.mcz ==================== Summary ==================== Name: Network-ar.47 Author: ar Time: 30 December 2009, 4:40:24 am UUID: 429af7d7-a121-3342-a5c5-2f6c27f10bbe Ancestors: Network-ar.46 Add HTTPProgress for put operations (uploads). =============== Diff against Network-ar.46 =============== Item was added: + ----- Method: HTTPSocket>>sendCommandWithProgress: (in category 'as yet unclassified') ----- + sendCommandWithProgress: commandString + "Send the given command as a single line followed by a <CR><LF> terminator." + + self sendDataWithProgress: commandString, CrLf. + ! Item was changed: ----- Method: HTTPSocket class>>httpPut:to:user:passwd: (in category 'get the page') ----- httpPut: contents to: url user: user passwd: passwd "Upload the contents of the stream to a file on the server" | bare serverName specifiedServer port page serverAddr authorization s list header firstData length aStream command digest | Socket initializeNetwork. "parse url" bare := (url asLowercase beginsWith: 'http://') ifTrue: [url copyFrom: 8 to: url size] ifFalse: [url]. serverName := bare copyUpTo: $/. specifiedServer := serverName. (serverName includes: $:) ifFalse: [ port := self defaultPort ] ifTrue: [ port := (serverName copyFrom: (serverName indexOf: $:) + 1 to: serverName size) asNumber. serverName := serverName copyUpTo: $:. ]. page := bare copyFrom: (bare indexOf: $/) to: bare size. page size = 0 ifTrue: [page := '/']. (self shouldUseProxy: serverName) ifTrue: [ page := 'http://', serverName, ':', port printString, page. "put back together" serverName := self httpProxyServer. port := self httpProxyPort]. "make the request" serverAddr := NetNameResolver addressForName: serverName timeout: 20. serverAddr ifNil: [ ^ 'Could not resolve the server named: ', serverName]. authorization := ' Basic ', (user , ':' , passwd) base64Encoded. [ s := HTTPSocket new. s connectTo: serverAddr port: port. s waitForConnectionUntil: self standardDeadline. Transcript cr; show: url; cr. command := 'PUT ', page, ' HTTP/1.0', CrLf, self userAgentString, CrLf, 'Host: ', specifiedServer, CrLf, 'ACCEPT: */*', CrLf, HTTPProxyCredentials, 'Authorization: ' , authorization , CrLf , 'Content-length: ', contents size printString, CrLf , CrLf , contents. + s sendCommandWithProgress: command. - s sendCommand: command. "get the header of the reply" list := s getResponseUpTo: CrLf, CrLf ignoring: String cr. "list = header, CrLf, CrLf, beginningOfData" header := list at: 1. "Transcript show: page; cr; show: argsStream contents; cr; show: header; cr." firstData := list at: 3. "dig out some headers" s header: header. (authorization beginsWith: 'Digest ') not and: [(digest := self digestFrom: s method: 'PUT' url: url user: user password: passwd) notNil]] whileTrue: [authorization := 'Digest ', digest]. length := s getHeader: 'content-length'. length ifNotNil: [ length := length asNumber ]. + "Suppress progress during response handling" + [aStream := s getRestOfBuffer: firstData totalLength: length] + on: HTTPProgress do:[:ex| ex resume]. - aStream := s getRestOfBuffer: firstData totalLength: length. s destroy. "Always OK to destroy!!" ^ header, aStream contents! Item was added: + ----- Method: HTTPSocket>>sendDataWithProgress: (in category 'as yet unclassified') ----- + sendDataWithProgress: aStringOrByteArray + "Send all of the data in the given array, even if it requires multiple calls to send it all. Return the number of bytes sent." + + "An experimental version use on slow lines: Longer timeout and smaller writes to try to avoid spurious timeouts." + + | bytesSent bytesToSend count | + bytesToSend := aStringOrByteArray size. + bytesSent := 0. + [bytesSent < bytesToSend] whileTrue: [ + (HTTPProgress new) + total: bytesToSend; + amount: bytesSent; + signal: 'Uploading...'. + (self waitForSendDoneUntil: (Socket deadlineSecs: 60)) + ifFalse: [ConnectionTimedOut signal: 'send data timeout; data not sent']. + count := self primSocket: socketHandle + sendData: aStringOrByteArray + startIndex: bytesSent + 1 + count: (bytesToSend - bytesSent min: 5000). + bytesSent := bytesSent + count]. + + ^ bytesSent + !

1 0

The Trunk: Network-ar.47.mcz
by commits＠source.squeak.org 30 Dec '09

30 Dec '09

1 0

The Trunk: Network-ar.47.mcz
by commits＠source.squeak.org 30 Dec '09

30 Dec '09

1 0

The Trunk: Monticello-ar.345.mcz
by commits＠source.squeak.org 30 Dec '09

30 Dec '09

Andreas Raab uploaded a new version of Monticello to project The Trunk: http://source.squeak.org/trunk/Monticello-ar.345.mcz ==================== Summary ==================== Name: Monticello-ar.345 Author: ar Time: 30 December 2009, 4:43:26 am UUID: 41d6d7f1-8398-464f-afa8-9d67fa71271f Ancestors: Monticello-ar.344 Display progress during common MC operations on HTTP repositories. =============== Diff against Monticello-ar.344 =============== Item was added: + ----- Method: MCHttpRepository>>displayProgress:during: (in category 'required') ----- + displayProgress: label during: workBlock + | nextUpdateTime | + nextUpdateTime := 0. + ^UIManager default displayProgress: label at: Display center + from: 0.0 to: 1.0 during:[:bar| + [workBlock value] on: HTTPProgress do:[:ex| + (ex total == nil or:[ex amount == nil]) ifFalse:[ + (nextUpdateTime < Time millisecondClockValue + or:[ex total = ex amount]) ifTrue:[ + bar value: ex amount asFloat / ex total asFloat. + nextUpdateTime := Time millisecondClockValue + 100. + ]. + ]. + ex resume. + ] + ]. + ! Item was changed: ----- Method: MCHttpRepository>>writeStreamForFileNamed:replace:do: (in category 'required') ----- writeStreamForFileNamed: aString replace: ignoreBoolean do: aBlock | stream response | stream := RWBinaryOrTextStream on: String new. aBlock value: stream. + self displayProgress: 'Uploading package' during:[ + response := HTTPSocket - response := HTTPSocket httpPut: stream contents to: (self urlForFileNamed: aString) user: self user passwd: self password. + ]. - (#( 'HTTP/1.1 201 ' 'HTTP/1.1 200 ' 'HTTP/1.0 201 ' 'HTTP/1.0 200 ') anySatisfy: [:code | response beginsWith: code ]) ifFalse: [self error: response].! Item was changed: ----- Method: MCHttpRepository>>allFileNames (in category 'required') ----- allFileNames | index | + self displayProgress: 'Updating repository' during:[ + index := HTTPSocket httpGet: self locationWithTrailingSlash, '?C=M;O=D' args: nil user: self user passwd: self password. + ]. - index := HTTPSocket httpGet: self locationWithTrailingSlash, '?C=M;O=D' args: nil user: self user passwd: self password. index isString ifTrue: [self error: 'Could not access ', location]. ^ self parseFileNamesFromStream: index !

1 0

The Trunk: Monticello-ar.345.mcz
by commits＠source.squeak.org 30 Dec '09

30 Dec '09

1 0

The Trunk: Monticello-ar.345.mcz
by commits＠source.squeak.org 30 Dec '09

30 Dec '09

1 0

The Trunk: Network-ar.46.mcz
by commits＠source.squeak.org 30 Dec '09

30 Dec '09

Andreas Raab uploaded a new version of Network to project The Trunk: http://source.squeak.org/trunk/Network-ar.46.mcz ==================== Summary ==================== Name: Network-ar.46 Author: ar Time: 30 December 2009, 4:23:24 am UUID: 62689cdd-d137-f546-acfb-840508ca3502 Ancestors: Network-ar.45 Add an HTTPProgress notification that can be used to display progress during HTTPSocket httpGet: operations. =============== Diff against Network-ar.45 =============== Item was changed: ----- Method: HTTPSocket class>>httpGetDocument:args:accept:request: (in category 'get the page') ----- httpGetDocument: url args: args accept: mimeType request: requestString "Return the exact contents of a web object. Asks for the given MIME type. If mimeType is nil, use 'text/html'. An extra requestString may be submitted and must end with crlf. The parsed header is saved. Use a proxy server if one has been registered. tk 7/23/97 17:12" "Note: To fetch raw data, you can use the MIME type 'application/octet-stream'." | serverName serverAddr port bare page index connectToHost connectToPort aStream portSuffix | Socket initializeNetwork. bare := (url asLowercase beginsWith: 'http://') ifTrue: [url copyFrom: 8 to: url size] ifFalse: [url]. bare := bare copyUpTo: $#. "remove fragment, if specified" serverName := bare copyUpTo: $/. page := bare copyFrom: serverName size + 1 to: bare size. (serverName includes: $:) ifTrue: [ index := serverName indexOf: $:. port := (serverName copyFrom: index+1 to: serverName size) asNumber. portSuffix := ':', port printString. serverName := serverName copyFrom: 1 to: index-1. ] ifFalse: [ port := self defaultPort. portSuffix := ''. ]. page size = 0 ifTrue: [page := '/']. "add arguments" args ifNotNil: [page := page, (self argString: args) ]. (self shouldUseProxy: serverName) ifFalse: [ connectToHost := serverName. connectToPort := port ] ifTrue: [ page := 'http://', serverName, portSuffix, page. "put back together" connectToHost := self httpProxyServer. connectToPort := self httpProxyPort]. + HTTPProgress signal: 'Looking up ', connectToHost. serverAddr := NetNameResolver addressForName: connectToHost timeout: 20. + serverAddr ifNil: [^ 'Could not resolve the server named: ', connectToHost]. - serverAddr ifNil: [ - ^ 'Could not resolve the server named: ', connectToHost]. 3 timesRepeat: [ | sock length firstData list type header newUrl | sock := HTTPSocket new. sock connectTo: serverAddr port: connectToPort. (sock waitForConnectionUntil: (self deadlineSecs: 30)) ifFalse: [ Socket deadServer: connectToHost. sock destroy. ^ 'Server ',connectToHost,' is not responding']. "Transcript cr;show: url; cr. Transcript show: page; cr." sock sendCommand: 'GET ', page, ' HTTP/1.0', CrLf, (mimeType ifNotNil: ['ACCEPT: ', mimeType, CrLf] ifNil: ['']), 'ACCEPT: text/html', CrLf, "Always accept plain text" HTTPBlabEmail, "may be empty" requestString, "extra user request. Authorization" self userAgentString, CrLf, 'Host: ', serverName, portSuffix, CrLf. "blank line automatically added" list := sock getResponseUpTo: CrLf, CrLf ignoring: (String with: CR). "list = header, CrLf, CrLf, beginningOfData" header := list at: 1. "Transcript show: page; cr; show: header; cr." firstData := list at: 3. header isEmpty ifTrue: [aStream := 'server aborted early'] ifFalse: [ "dig out some headers" sock header: header. length := sock getHeader: 'content-length'. length ifNotNil: [ length := length asNumber ]. type := sock getHeader: 'content-type'. sock responseCode first = $3 ifTrue: [ newUrl := sock getHeader: 'location'. newUrl ifNotNil: [ Transcript show: 'redirecting to ', newUrl; cr. sock destroy. newUrl := self expandUrl: newUrl ip: serverAddr port: connectToPort. ^self httpGetDocument: newUrl args: args accept: mimeType request: requestString] ]. aStream := sock getRestOfBuffer: firstData totalLength: length. "a 400-series error" sock responseCode first = $4 ifTrue: [^ header, aStream contents]. ]. sock destroy. "Always OK to destroy!!" aStream class ~~ String ifTrue: [ ^ MIMEDocument contentType: type content: aStream contents url: url]. aStream = 'server aborted early' ifTrue: [ ^aStream ]. ]. {'HTTPSocket class>>httpGetDocument:args:accept:request:'. aStream. url} inspect. ^'some other bad thing happened!!'! Item was added: + Notification subclass: #HTTPProgress + instanceVariableNames: 'total amount' + classVariableNames: '' + poolDictionaries: '' + category: 'Network-Protocols'! + + !HTTPProgress commentStamp: 'ar 12/30/2009 16:16' prior: 0! + HTTP progress notification. Includes: + - total: The total size of the download (if known) + - amount: The completed amount of the download (if known) + ! Item was changed: ----- Method: HTTPSocket>>getRestOfBuffer:totalLength: (in category 'as yet unclassified') ----- getRestOfBuffer: beginning totalLength: length "Reel in a string of a fixed length. Part of it has already been received. Close the connection after all chars are received. We do not strip out linefeed chars. tk 6/16/97 22:32" "if length is nil, read until connection close. Response is of type text, not binary." | buf response bytesRead | length ifNil: [^ self getRestOfBuffer: beginning]. buf := String new: length. response := RWBinaryOrTextStream on: buf. response nextPutAll: beginning. buf := String new: length. [(response position < length) & (self isConnected | self dataAvailable)] whileTrue: [ + (HTTPProgress new) + total: length; + amount: response position; + signal: 'Downloading...'. (self waitForDataUntil: (Socket deadlineSecs: 5)) ifFalse: [ Transcript show: 'data was slow'; cr]. bytesRead := self primSocket: socketHandle receiveDataInto: buf startingAt: 1 count: (length - response position). bytesRead > 0 ifTrue: [ response nextPutAll: (buf copyFrom: 1 to: bytesRead)] ]. "Transcript cr; show: 'data byte count: ', response position printString." "Transcript cr; show: ((self isConnected) ifTrue: ['Over length by: ', bytesRead printString] ifFalse: ['Socket closed'])." response position < length ifTrue: [^ 'server aborted early']. response reset. "position: 0." ^ response! Item was added: + ----- Method: HTTPProgress>>total (in category 'accessing') ----- + total + "Answer the total size of the download, if known" + ^total! Item was added: + ----- Method: HTTPProgress>>amount: (in category 'accessing') ----- + amount: bytes + "Set the completed amount of the download (if known)" + amount := bytes! Item was added: + ----- Method: HTTPProgress>>total: (in category 'accessing') ----- + total: bytes + "Answer the total size of the download, if known" + total := bytes! Item was added: + ----- Method: HTTPProgress>>amount (in category 'accessing') ----- + amount + "Answer the completed amount of the download (if known)" + ^amount!

1 0

← Newer
1
...
7
8
9
10
11
12
13
...
104
Older →

Jump to page:

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

2007

2006

2005

Packages December 2009